Java里socket通信怎样实现多线程

在Java中，使用Socket通信实现多线程主要涉及到服务器端和客户端的处理。下面分别介绍服务器端和客户端如何实现多线程。

1. 服务器端多线程实现：

服务器端需要创建一个线程池来处理客户端的连接请求。当客户端连接到服务器时，服务器会创建一个新的线程来处理与该客户端的通信。这样可以确保服务器能够同时处理多个客户端的请求。

以下是一个简单的服务器端多线程实现示例：

import java.io.*; import java.net.*; import java.util.concurrent.*;  public class Server {     public static void main(String[] args) throws IOException, InterruptedException {         int port = 12345;         ExecutorService executorService = Executors.newFixedThreadPool(10); // 创建一个固定大小的线程池          try (ServerSocket serverSocket = new ServerSocket(port)) {             System.out.println("Server is listening on port " + port);              while (true) {                 try (Socket socket = serverSocket.accept()) {                     executorService.submit(() -> handleClient(socket)); // 将客户端连接请求提交给线程池处理                 } catch (IOException e) {                     System.out.println("Error accepting client connection: " + e.getMessage());                 }             }         } finally {             executorService.shutdown(); // 关闭线程池         }     }      private static void handleClient(Socket socket) {         try {             InputStream inputStream = socket.getInputStream();             BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream));             String message;              while ((message = reader.readLine()) != null) {                 System.out.println("Received from client: " + message);                 // 处理客户端发送的消息             }         } catch (IOException e) {             System.out.println("Error handling client communication: " + e.getMessage());         } finally {             try {                 socket.close();             } catch (IOException e) {                 System.out.println("Error closing client socket: " + e.getMessage());             }         }     } } 

2. 客户端多线程实现：

客户端也可以使用多线程来实现多个连接的并发处理。例如，可以创建一个线程池，并为每个需要连接的服务器端端口分配一个线程。

以下是一个简单的客户端多线程实现示例：

import java.io.*; import java.net.*; import java.util.concurrent.*;  public class Client {     public static void main(String[] args) throws IOException, InterruptedException {         String serverAddress = "localhost";         int serverPort = 12345;         int numberOfConnections = 5; // 需要连接的服务器端端口数量          ExecutorService executorService = Executors.newFixedThreadPool(numberOfConnections); // 创建一个固定大小的线程池          for (int i = 0; i < numberOfConnections; i++) {             executorService.submit(() -> connectToServer(serverAddress, serverPort)); // 将连接请求提交给线程池处理         }          executorService.shutdown(); // 关闭线程池     }      private static void connectToServer(String serverAddress, int serverPort) throws IOException {         try (Socket socket = new Socket(serverAddress, serverPort);              InputStream inputStream = socket.getInputStream();              BufferedReader reader = new BufferedReader(new InputStreamReader(inputStream))) {              String message;             while ((message = reader.readLine()) != null) {                 System.out.println("Received from server: " + message);                 // 处理服务器发送的消息             }         } catch (IOException e) {             System.out.println("Error connecting to server: " + e.getMessage());         }     } } 

这个示例中，客户端创建了5个线程，每个线程都尝试连接到服务器。服务器端使用线程池处理客户端的连接请求。这样，客户端和服务器端都可以实现多线程通信。