Java并发Socket编程：多客户端连接仅接收首个输入问题求助

我来帮你排查下这个问题～你贴的main方法逻辑是没问题的：循环监听端口，每收到一个客户端连接就启动新线程处理，问题几乎肯定出在你没贴全的ConcurrentServer线程类实现上。

先把你给出的main代码格式化出来：

public static void main(String[] args) { 
    try { 
        ServerSocket serverSocket = new ServerSocket(8001); 
        while (true){ 
            Socket clientSocket = serverSocket.accept(); 
            System.out.println(clientSocket); 
            ConcurrentServer client = new ConcurrentServer(clientSocket); 
            client.start(); 
        } 
    } catch (IOException ioe) {
        // 建议补充异常处理，避免程序直接崩溃
        ioe.printStackTrace();
    }
}

下面是几个最可能导致“仅处理首个客户端输入”的原因，以及对应的修复方案：

1. 共享了全局IO流（最常见） #

如果你的ConcurrentServer类里用了静态的BufferedReader/InputStream，那所有线程都会抢占同一个流资源，只有第一个线程能拿到输入。

✅ 正确做法：每个ConcurrentServer实例持有自己的、和当前clientSocket绑定的IO流，不要用静态变量。

2. 读取逻辑没有循环，只读取一次就结束线程 #

如果你的run()方法里只读取了一次输入就退出了，线程会直接终止，后续客户端的输入自然不会被处理。

✅ 正确做法：在run()方法里写一个循环，持续读取客户端发送的数据，直到连接关闭（比如readLine()返回null）。

3. 未捕获IO异常导致线程意外终止 #

如果读取输入时抛出异常但没捕获，线程会直接崩溃，也会表现为只处理第一个客户端。

✅ 正确做法：在run()里用try-catch包裹IO操作，捕获并处理异常，同时确保socket资源被正确关闭。

给你一个正确的ConcurrentServer实现示例 #

class ConcurrentServer extends Thread {
    private final Socket clientSocket;

    // 构造方法传入当前客户端的socket
    public ConcurrentServer(Socket socket) {
        this.clientSocket = socket;
    }

    @Override
    public void run() {
        // 使用try-with-resources自动关闭流和socket
        try (BufferedReader in = new BufferedReader(
                new InputStreamReader(clientSocket.getInputStream()));
             PrintWriter out = new PrintWriter(clientSocket.getOutputStream(), true)) {

            String inputLine;
            // 循环读取客户端输入，直到连接断开
            while ((inputLine = in.readLine()) != null) {
                // 打印客户端的IP、端口和输入内容，方便区分不同客户端
                System.out.printf("来自客户端[%s:%d]的输入：%s%n",
                        clientSocket.getInetAddress(),
                        clientSocket.getPort(),
                        inputLine);
                // 可选：给客户端返回响应
                out.println("服务器已收到：" + inputLine);
            }
        } catch (IOException e) {
            // 打印异常信息，方便排查问题
            System.err.printf("处理客户端[%s:%d]时出错：%s%n",
                    clientSocket.getInetAddress(),
                    clientSocket.getPort(),
                    e.getMessage());
        }
    }
}

最后再检查这几个点： #

• 确认ConcurrentServer没有使用静态的IO流变量
• 确认run()方法里有持续读取输入的循环
• 确认IO操作都被正确的异常处理包裹

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