Java多TCP客户端通信阻塞问题及解决方案咨询

这问题我太熟了——你的TCP服务器现在是单线程串行处理模式，主线程每次接收到一个客户端连接后，会全程卡在处理这个客户端的逻辑上（直到读取完客户端输入、返回结果），在这期间根本没法响应新的客户端连接。所以第二个客户端必须等第一个客户端完成输入并拿到服务器响应后，才能被服务器处理。

解决方案：用多线程并行处理客户端连接 #

给每个新接入的客户端分配独立的线程来处理它的请求，这样服务器主线程可以立刻回到监听状态，接收下一个客户端，多个客户端的请求就能同时处理了。

修改后的TCP服务器代码

public class TCPServer {
    public static void main(String[] args) throws Exception {
        ServerSocket welcomeSocket = new ServerSocket(6789);
        System.out.println("服务器已启动，等待客户端连接...");
        
        while (true) {
            // 主线程只负责接受新的客户端连接
            Socket connectionSocket = welcomeSocket.accept();
            System.out.println("新客户端已连接: " + connectionSocket.getInetAddress());
            
            // 为每个连接创建独立线程处理请求
            new Thread(() -> {
                // 用try-with-resources自动关闭流，避免资源泄漏
                try (
                    BufferedReader inFromClient = new BufferedReader(new InputStreamReader(connectionSocket.getInputStream()));
                    DataOutputStream outToClient = new DataOutputStream(connectionSocket.getOutputStream())
                ) {
                    String clientSentence = inFromClient.readLine();
                    int clientSentenceLength = clientSentence.length();
                    outToClient.writeBytes(clientSentenceLength + "\n");
                    System.out.println("已处理客户端请求，返回长度: " + clientSentenceLength);
                } catch (Exception e) {
                    e.printStackTrace();
                } finally {
                    // 确保客户端连接被关闭
                    try {
                        connectionSocket.close();
                    } catch (IOException e) {
                        e.printStackTrace();
                    }
                }
            }).start();
        }
    }
}

关键改动说明

• 主线程只做一件事：不断调用accept()接受新客户端，拿到连接后立刻丢给新线程处理，自己马上回到监听状态
• 使用try-with-resources语法自动管理输入输出流，不用手动关闭，避免资源泄漏
• 每个线程独立处理自己的客户端请求，互相不干扰，实现并行处理

客户端代码无需修改

你的客户端代码逻辑是正常的，保持原样即可：

public class TCPClient {
    public static void main(String[] args) throws Exception {
        String sentence;
        String sentenceLength;
        BufferedReader inFromUser = new BufferedReader(new InputStreamReader(System.in));
        Socket clientSocket = new Socket("mycomputer", 6789);
        DataOutputStream outToServer = new DataOutputStream(clientSocket.getOutputStream());
        BufferedReader inFromServer = new BufferedReader(new InputStreamReader(clientSocket.getInputStream()));
        
        sentence = inFromUser.readLine();
        outToServer.writeBytes(sentence + '\n');
        sentenceLength = inFromServer.readLine();
        System.out.println("服务器返回的字符串长度: " + sentenceLength);
        
        clientSocket.close();
    }
}

验证效果 #

现在启动服务器后，先打开第一个客户端输入字符串但不回车，再打开第二个客户端输入字符串并回车——第二个客户端会立刻收到服务器返回的长度，完全不需要等第一个客户端操作，完美解决阻塞问题。

内容的提问来源于stack exchange，提问作者Sean