Java 客户端 Socket 正常关闭的正确实践-java教程-PHP中文网

Java 客户端 Socket 正常关闭的正确实践

Java 网络编程中，客户端调用 BufferedReader.close() 会阻塞主线程，若读线程正阻塞在 readLine() 上，需避免在发送线程中主动关闭共享流；应统一通过关闭底层 Socket 实现资源释放与线程退出。

java 网络编程中，客户端调用 `bufferedreader.close()` 会阻塞主线程，若读线程正阻塞在 `readline()` 上，需避免在发送线程中主动关闭共享流；应统一通过关闭底层 socket 实现资源释放与线程退出。

在基于 Socket 的 Java 聊天程序中，一个常见但隐蔽的问题是：当用户输入 "exit" 时，客户端看似执行了 close() 操作却无法立即退出——程序卡住，直到收到服务器新消息才终止。根本原因在于 多线程竞争关闭共享 I/O 流，尤其是对 BufferedReader（包装自 Socket.getInputStream()）的误操作。

? 问题根源分析

在您的 Client.java 中，receiveThread 持有 serverReader 并持续调用 readLine()：

String message = serverReader.readLine(); // 阻塞调用，内部持有锁

而主发送线程在检测到 "exit" 后，错误地执行了：

serverReader.close(); // ❌ 危险！此调用会等待 readLine() 返回或抛出异常
clientSocket.close();

BufferedReader.close() 在 JDK 实现中会同步尝试关闭其底层 InputStream，而 SocketInputStream.read() 是阻塞式系统调用。若此时 readLine() 正在等待网络数据，close() 将被挂起，直至该阻塞调用因连接关闭、超时或接收到数据而返回——这正是您观察到“必须等一条消息才退出”的原因。

✅ 正确解决方案：只关闭 Socket，让读线程自然退出

无需手动关闭 serverReader 或 out（BufferedWriter），只需安全关闭底层 Socket。Socket.close() 是线程安全的，它会：

Java Maven Code Review

审查Java Maven项目（ZIP压缩包或GitLab仓库URL），检查代码规范、命名、模块边界、可维护性问题以及重复代码。

下载

立即中断所有阻塞在该 Socket I/O 上的线程（如 readLine() 抛出 IOException）；
自动触发关联的 InputStream/OutputStream 关闭；
使 readLine() 快速返回 null 或抛出异常，从而退出循环。

因此，修正后的 "exit" 处理逻辑应为：

if ("exit".equals(message)) {
    System.out.println("REACHED EXIT");
    // ✅ 正确：仅关闭 Socket，由 JVM 自动清理包装流
    clientSocket.close();
    in.close(); // Scanner 可安全关闭（不依赖 Socket）
    System.out.println("EXITED");
    System.exit(0);
    break;
}

同时，必须增强接收线程的健壮性，捕获 IOException 并优雅退出：

Thread receiveThread = new Thread(() -> {
    try {
        String message;
        while (!stopReceiving && (message = serverReader.readLine()) != null) {
            System.out.println("Zpráva od serveru: " + message);
            if ("Připojení odmítnuto - dosaženo maximálního počtu klientů. Zkuste se připojit později.".equals(message)) {
                stopReceiving = true;
                break;
            }
        }
    } catch (IOException e) {
        // Socket 关闭时 readLine() 抛出 IOException，正常退出
        System.out.println("Receiving thread interrupted: " + e.getMessage());
    } finally {
        closeClient(); // 统一清理（可选，Socket 已关，此处更侧重防御）
    }
});
receiveThread.start();

? 关键提示：serverReader.close() 和 out.close() 在 Socket.close() 后调用是冗余且潜在危险的，应移除。Scanner in 不依赖 Socket，可独立关闭。

?️ 补充最佳实践

使用 try-with-resources 替代手动关闭（推荐 Java 7+）：

try (Socket socket = new Socket("localhost", 8080);
     BufferedReader reader = new BufferedReader(new InputStreamReader(socket.getInputStream()));
     BufferedWriter writer = new BufferedWriter(new OutputStreamWriter(socket.getOutputStream()));
     Scanner scanner = new Scanner(System.in)) {
    // ... 业务逻辑
} // 自动关闭所有资源，包括 socket