Java多客户端聊天服务器线程异常终止问题求助

问题根源 #

你的代码存在两个核心问题：

• clientHandler中的socket、in、out全被声明为static变量，且两个线程共用同一个clientHandler实例。static变量属于类级别，所有实例共享，第二个线程执行accept()后会直接覆盖第一个线程的socket和流对象，导致第一个线程后续操作的是第二个客户端的连接，最终表现为一个客户端连接被终止。
• clientHandler中新建server实例完全多余，server的serverSocket是static的，直接引用即可，新建实例不会复用原有服务端套接字。

修复后的代码 #

Server类

import java.io.IOException;
import java.net.ServerSocket;

public class Server {
    public static ServerSocket serverSocket;

    public static void main(String[] args) throws IOException {
        serverSocket = new ServerSocket(1234);
        // 每个线程对应独立的ClientHandler实例
        Thread clientThread1 = new Thread(new ClientHandler());
        Thread clientThread2 = new Thread(new ClientHandler());
        clientThread1.start();
        clientThread2.start();
    }
}

ClientHandler类

import java.io.BufferedReader;
import java.io.IOException;
import java.io.InputStreamReader;
import java.io.PrintWriter;
import java.net.Socket;

public class ClientHandler implements Runnable {
    // 移除static，让每个实例持有独立的连接资源
    private Socket socket;
    private BufferedReader in;
    private PrintWriter out;

    @Override
    public void run() {
        try {
            // 直接复用Server类的static服务端套接字
            socket = Server.serverSocket.accept();
            in = new BufferedReader(new InputStreamReader(socket.getInputStream()));
            out = new PrintWriter(socket.getOutputStream(), true);
            
            String msg;
            // 客户端断开时readLine()返回null，正常退出循环
            while ((msg = in.readLine()) != null) {
                System.out.println(msg);
            }
        } catch (IOException ex) {
            ex.printStackTrace();
        } finally {
            // 确保资源关闭，避免泄漏
            try {
                if (in != null) in.close();
                if (out != null) out.close();
                if (socket != null) socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

关键修改点 #

1. 移除static修饰符：每个ClientHandler实例持有独立的连接和流，线程间资源完全隔离，不会互相覆盖。
2. 每个线程对应独立的ClientHandler实例：不再共用同一个实例，保证每个线程处理专属的客户端连接。
3. 删除多余的Server实例创建：直接通过Server.serverSocket获取服务端套接字，避免无意义的实例初始化。
4. 完善循环退出条件：替换while(true)，客户端断开时能正常终止循环，避免无效执行。
5. 增加资源关闭逻辑：在finally块中关闭所有IO资源，防止连接和流泄漏。

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