java多线程与线程池实现socket多个客户端连接服务器同时通信代码 ———————

要实现多个客户端同时连接服务器进行通信，可以使用Java多线程和线程池的概念。以下是一个示例代码：

服务器端代码：

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

public class Server {

    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(12345);
        ExecutorService executorService = Executors.newFixedThreadPool(10);
        
        while (true) {
            System.out.println("服务器等待建立连接...");
            Socket socket = serverSocket.accept();
            
            // 每次有客户端建立连接就创建一个新的线程处理
            executorService.execute(new ClientHandler(socket));
            
            System.out.println("连接成功!");
        }
    }
}

class ClientHandler implements Runnable {
    private Socket socket;

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

    @Override
    public void run() {
        try {
            BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
            
            String line;
            while ((line = br.readLine()) != null) {
                System.out.println("接收到客户端消息：" + line);
                
                // 处理客户端发送的消息
                
                bw.write("服务器收到消息：" + line);
                bw.newLine();
                bw.flush();
            }
            
            br.close();
            bw.close();
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

客户端代码：

import java.io.*;
import java.net.*;

public class Client {

    public static void main(String[] args) throws IOException {
        Socket socket = new Socket("服务器IP地址", 12345);
        
        BufferedReader br = new BufferedReader(new InputStreamReader(socket.getInputStream()));
        BufferedWriter bw = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
        
        // 发送消息给服务器
        bw.write("Hello, Server!");
        bw.newLine();
        bw.flush();
        
        // 接收服务器的响应
        String response = br.readLine();
        System.out.println("服务器响应：" + response);
        
        br.close();
        bw.close();
        socket.close();
    }
}

在服务器端代码中，通过创建一个线程池（这里使用固定大小的线程池），每当有一个客户端连接时，就创建一个新线程去处理客户端的请求。该线程负责与客户端进行通信。

在客户端代码中，创建一个Socket对象与服务器建立连接，然后通过输入输出流进行通信。在示例中，客户端向服务器发送一条消息，服务器接收到后处理，然后返回响应给客户端。

这样，多个客户端可以同时连接服务器进行通信，服务器通过多线程来处理每个客户端的请求，并保证线程安全性。