Socket与ThreadPoolExecutor结合异常：第46次请求卡顿排查

核心原因 #

1. ObjectInputStream构造的天然阻塞特性 #

客户端创建ObjectInputStream时，该方法会阻塞等待从Socket输入流读取序列化协议头部（由服务端的ObjectOutputStream发送）。如果服务端未及时处理该Socket连接（即未初始化对应的输出流），客户端会一直卡在这个步骤。

2. 线程池资源泄漏与任务调度延迟 #

你的线程池为固定大小8，前45次正常后第46次卡顿，结合线程池状态（活跃数0、已完成41、总任务42、队列大小1），大概率是前序任务存在Socket/流未正确关闭的资源泄漏：

• 服务端的Transaction任务在处理完请求后，未正确关闭ObjectInputStream、ObjectOutputStream和Socket，导致线程池中的线程被阻塞在IO操作（比如readObject()等待已断开的客户端发送数据），表面上线程池活跃数显示为0，但实际线程无法被复用调度新任务。
• 新提交的第46次任务被滞留在线程池队列中，无法及时执行run方法初始化流并响应客户端，最终引发客户端阻塞。

解决方案 #

1. 强制确保资源关闭（使用try-with-resources） #

无论任务执行成功还是失败，都必须关闭Socket及相关流，避免线程阻塞。修改Transaction的run方法：

@Override
public void run() {
    Socket socket = this.socket; // 假设构造时传入Socket
    try (ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
         ObjectInputStream ois = new ObjectInputStream(socket.getInputStream())) {
        // 读取请求、处理逻辑、返回结果
        Object request = ois.readObject();
        Object result = handleRequest(request);
        oos.writeObject(result);
        oos.flush(); // 确保数据发送完成
    } catch (Exception e) {
        // 捕获并处理异常，避免线程因未捕获异常终止
        e.printStackTrace();
    } finally {
        try {
            socket.close();
        } catch (IOException e) {
            e.printStackTrace();
        }
    }
}

注：使用try-with-resources可以自动关闭实现了AutoCloseable接口的流，Socket也应在finally中强制关闭。

2. 调整线程池配置与监控 #

• 避免使用无界队列（如LinkedBlockingQueue），改用有界队列并设置饱和策略，防止任务无限堆积：

ThreadPoolExecutor executor = new ThreadPoolExecutor(
        8, // 核心线程数
        8, // 最大线程数
        60L, TimeUnit.SECONDS,
        new ArrayBlockingQueue<>(100), // 有界队列，限制任务堆积
        new ThreadPoolExecutor.CallerRunsPolicy() // 队列满时由主线程执行，避免任务丢失
);

• 添加线程池监控，定期打印线程池状态，便于定位任务堆积或线程阻塞问题：

// 定时打印线程池状态
ScheduledExecutorService monitor = Executors.newSingleThreadScheduledExecutor();
monitor.scheduleAtFixedRate(() -> {
    System.out.println("活跃线程数: " + executor.getActiveCount());
    System.out.println("队列任务数: " + executor.getQueue().size());
    System.out.println("已完成任务数: " + executor.getCompletedTaskCount());
    System.out.println("总提交任务数: " + executor.getTaskCount());
}, 0, 5, TimeUnit.SECONDS);

3. 优化客户端流初始化逻辑 #

客户端在创建ObjectOutputStream后先发送握手信号，再初始化ObjectInputStream，确保服务端已完成流初始化：

Socket socket = new Socket(host, port);
ObjectOutputStream oos = new ObjectOutputStream(socket.getOutputStream());
oos.writeObject("CONNECT"); // 发送握手信号
oos.flush();
ObjectInputStream ois = new ObjectInputStream(socket.getInputStream());

服务端在读取到握手信号后再处理业务请求，确保两端流初始化完成。

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