如何解决多线程Socket通信中的java.net.SocketException: 已建立的连接被主机软件中止问题

1. 异常产生的根本原因 #

这个异常的核心是时序差异加上客户端过早关闭连接：

• 你的客户端用try-with-resources管理Socket，这意味着客户端main方法执行完毕（仅创建ObjectOutputStream并flush后），Socket会被立刻关闭，客户端主动终止了连接。
• 线程版服务器中，主线程拿到连接后启动WorkerThread就直接结束了。而线程启动需要短暂的调度时间，当WorkerThread真正开始执行、尝试创建ObjectInputStream时，客户端的连接已经关闭了。
• ObjectInputStream的构造方法会尝试从输入流读取序列化协议的流头，此时连接已被客户端中止，服务器的读取操作失败，就抛出了SocketException。

至于非线程版不会触发异常，是因为所有操作在主线程连续执行：从accept到创建输出流、刷新再到创建输入流，整个过程几乎没有延迟，在客户端关闭Socket之前，服务器已经完成了ObjectInputStream的初始化（成功读取了客户端发送的流头），所以不会抛出异常。

2. 更合理的修复方式 #

除了把逻辑移到主线程，还有几个符合网络编程规范的修复方案：

方案一：修正客户端通信流程，避免过早关闭连接 #

客户端不要在发送完流头后立刻断开，应该遵循完整的通信协议。比如保持连接直到确认服务器完成初始化，或者添加业务逻辑的交互：

import java.net.Socket;
import java.io.ObjectInputStream;
import java.io.ObjectOutputStream;
public class Client {
    public static void main(String[] args) throws Exception {
        try (Socket socket = new Socket("192.168.1.3", 12345)) {
            ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
            oos.flush();
            // 保持连接，等待服务器响应或完成初始化
            ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());
            // 可根据业务需求读取服务器数据，或短暂等待
        }
    }
}

方案二：服务器端增加连接校验，优雅处理异常 #

在WorkerThread中，初始化输入流前先检查Socket状态，并且在异常发生时正确释放资源：

class WorkerThread extends Thread {
    private Socket socket;
    public WorkerThread(Socket socket) {
        this.socket = socket;
    }
    @Override
    public void run() {
        ObjectOutputStream oos = null;
        ObjectInputStream ois = null;
        try {
            // 先检查Socket是否仍处于连接状态
            if (socket.isClosed() || !socket.isConnected()) {
                return;
            }
            oos = new ObjectOutputStream(socket.getOutputStream());
            oos.flush();
            ois = new ObjectInputStream(socket.getInputStream());
            // 执行业务处理逻辑
        } catch (IOException e) {
            System.err.println("连接处理失败: " + e.getMessage());
        } finally {
            // 确保所有资源被正确关闭
            try {
                if (ois != null) ois.close();
                if (oos != null) oos.close();
                if (socket != null && !socket.isClosed()) socket.close();
            } catch (IOException e) {
                e.printStackTrace();
            }
        }
    }
}

方案三：让服务器主线程保持运行，避免极端调度延迟 #

虽然主线程退出不会影响用户线程，但可以让主线程进入等待状态，避免系统资源紧张时WorkerThread启动被大幅推迟：

public class Server {
    public static void main(String[] args) throws IOException {
        ServerSocket serverSocket = new ServerSocket(12345, 3);
        Socket socket = serverSocket.accept();
        WorkerThread worker = new WorkerThread(socket);
        worker.start();
        
        // 让主线程等待WorkerThread执行完毕
        try {
            worker.join();
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        }
    }
}

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