java socket 多线程编程

在Java中，可以使用多线程编程来实现Java Socket的多线程通信。一种常见的方法是使用Java 5中引入的ExecutorService接口来创建线程池。

首先，在服务端的代码中，可以创建一个线程池，用于处理客户端的请求。通过使用ExecutorService的工厂方法创建一个固定大小的线程池，可以控制并发处理的请求数量。然后，可以使用Socket类来监听客户端连接，并将连接交给线程池中的线程来处理。

在每个线程中，可以使用Socket类的输入输出流来与客户端进行通信。可以使用BufferedReader类来读取客户端发送的请求，并使用PrintWriter类来向客户端发送响应。

以下是一个简化的示例代码，用于演示Java Socket的多线程编程：

import java.io.*;
import java.net.ServerSocket;
import java.net.Socket;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

public class Server {
    public static void main(String[] args) throws IOException {
        // 创建一个固定大小的线程池
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        
        // 创建ServerSocket并监听指定的端口
        ServerSocket serverSocket = new ServerSocket(8888);
        System.out.println("服务器启动，等待客户端连接...");

        while (true) {
            // 等待客户端连接
            Socket socket = serverSocket.accept();
            System.out.println("客户端连接成功，地址：" + socket.getInetAddress());

            // 将连接交给线程池中的线程来处理
            executorService.execute(new ClientHandler(socket));
        }
    }

    static class ClientHandler implements Runnable {
        private Socket socket;

        public ClientHandler(Socket socket) {
            this.socket = socket;
        }

        @Override
        public void run() {
            try {
                // 获取输入输出流
                BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
                PrintWriter writer = new PrintWriter(socket.getOutputStream(), true);

                // 读取客户端发送的请求
                String request = reader.readLine();
                System.out.println("收到客户端请求：" + request);

                // 处理请求并返回响应
                String response = "Hello, " + request + "!";
                writer.println(response);
                System.out.println("发送响应：" + response);

                // 关闭连接
                socket.close();
                System.out.println("客户端连接关闭");
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

以上代码中，通过创建一个固定大小的线程池，可以控制并发处理的请求数量。每个客户端连接都会被分配给线程池中的一个线程来处理。在每个线程中，读取客户端发送的请求并进行处理，然后将响应发送回客户端。最后，关闭连接。

需要注意的是，以上代码只是一个简化的示例，实际应用中可能需要更复杂的逻辑和异常处理。此外，为了保证线程安全，可能还需要使用同步机制来保护共享资源的访问。

希望以上信息能对你有所帮助。