Java Socket服务端发消息 客户端断连未触发IOException问题求解

无法捕获客户端断连触发的IOException，核心是四个代码缺陷：

• PrintWriter 默认吞掉所有写入时的IO异常，错误仅存在内部状态位，不主动抛出，必须手动调用方法检查错误。
• 服务端仅写不读客户端输入流，TCP层客户端发送的断连FIN报文无法被及时感知，操作系统会先把写入数据存入发送缓冲区，短时间内写入不会报错，直到缓冲区满才会触发连接重置。
• 内层空死循环属于无效忙等，会占满1个CPU核心，浪费算力。
• 断连后没有主动重置连接状态、释放资源，旧的Socket引用会一直残留。

1. 将ServerSocket初始化移到外层，只绑定一次端口，避免异常时反复绑定端口失败。
2. 新增独立的读线程阻塞监听客户端输入流，只要客户端主动断开，读阻塞方法会立刻返回，第一时间感知断连。
3. 开启Socket的SO_KEEPALIVE参数，辅助探测半开死连接。
4. 每次写入消息后主动检查PrintWriter的错误状态，一旦发现写入失败直接抛出IOException，触发异常处理逻辑。
5. 去掉空死循环，用线程阻塞等待代替忙等，降低CPU占用。
6. 新增连接清理逻辑，断连后主动关闭旧连接、重置状态，等待下一个客户端接入。

修正后的可运行代码：

public class SampleThread extends Thread {
    private static final int SAMPLE_PORT = 替换为你的实际端口;
    private static PrintWriter out;
    private static Socket currentSocket;
    // 多线程可见的连接状态标记
    private static volatile boolean clientConnected = false;

    @Override
    public void run() {
        // ServerSocket只初始化一次，常驻运行
        try (ServerSocket server = new ServerSocket(SAMPLE_PORT)) {
            while (true) {
                try {
                    // 阻塞等待客户端连接
                    currentSocket = server.accept();
                    // 开启TCP层心跳探测，检测异常断连
                    currentSocket.setKeepAlive(true);
                    // 构造PrintWriter时开启自动刷新
                    out = new PrintWriter(currentSocket.getOutputStream(), true);
                    clientConnected = true;

                    // 启动独立读线程感知客户端断连
                    Thread readThread = new Thread(() -> {
                        try (BufferedReader in = new BufferedReader(
                                new InputStreamReader(currentSocket.getInputStream()))) {
                            // 阻塞读，客户端不断开就会一直停在这里
                            while (in.readLine() != null) {
                                // 不需要处理客户端消息就留空
                            }
                        } catch (IOException ignored) {
                            // 读异常即为连接故障
                        } finally {
                            // 读线程退出 = 连接断开，重置状态
                            clientConnected = false;
                            releaseConnection();
                        }
                    });
                    readThread.setDaemon(true);
                    readThread.start();

                    // 阻塞等待读线程结束（连接断开），替代空死循环，不占CPU
                    readThread.join();
                } catch (IOException | InterruptedException e) {
                    // 此处放你原有的JDialog重试提示逻辑
                    clientConnected = false;
                    releaseConnection();
                    // 重试间隔1秒，避免空转
                    Thread.sleep(1000);
                }
            }
        } catch (IOException e) {
            // ServerSocket绑定失败的致命错误，单独处理
            e.printStackTrace();
        }
    }

    // 清理连接资源
    private static void releaseConnection() {
        try {
            if (out != null) {
                out.close();
                out = null;
            }
            if (currentSocket != null) {
                currentSocket.close();
                currentSocket = null;
            }
        } catch (IOException ignored) {}
    }

    // 改造后的发送方法，断连时会主动抛出IOException
    public static void sendToClient(String s1, String s2) throws IOException {
        if (!clientConnected || out == null) {
            throw new IOException("客户端未连接");
        }
        out.write(s1 + "\n");
        out.write(s2 + "\n");
        out.flush();
        // PrintWriter必须主动调用checkError才能拿到写入错误，不会自动抛异常
        if (out.checkError()) {
            clientConnected = false;
            releaseConnection();
            throw new IOException("连接已断开，写入失败");
        }
    }
}

• 客户端主动调用close()断开连接时，服务端读线程的readLine()会立刻返回null，直接触发连接清理，不需要等下次发消息才感知断连。
• 发送消息时的checkError()会触发PrintWriter内部的错误校验，只要网络连接异常、写入失败，就会返回true，此时手动抛出IOException即可被上层业务逻辑捕获。
• 用join()阻塞服务线程替代空死循环，CPU占用会从100%降到接近0。
• 所有连接资源在断连后都会主动释放，不会出现文件句柄泄漏。

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