Java 中 Socket is closed 异常的成因与安全复用实践

本文详解 java.net.SocketException: Socket is closed 的根本原因(非网络丢包,而是套接字生命周期误用),重点剖析 IO 流关闭导致 Socket 自动关闭的隐式行为,并提供可复用、线程安全的 Socket 通信最佳实践。

本文详解 `java.net.SocketException: Socket is closed` 的根本原因(非网络丢包,而是套接字生命周期误用),重点剖析 IO 流关闭导致 Socket 自动关闭的隐式行为,并提供可复用、线程安全的 Socket 通信最佳实践。

在 Java 网络编程中,java.net.SocketException: Socket is closed 是一个高频但极易被误解的异常。它与网络丢包、防火墙或超时完全无关,其本质是程序违反了 Socket 的生命周期契约:对一个已关闭的套接字执行读/写操作。而最常见的“隐式关闭”场景,正出自你代码中看似无害的一行:

out.close(); // ⚠️ 危险!这会连带关闭整个 Socket

根据 [Java 官方文档](https://docs.oracle.com/javase/17/docs/api/java.base/java/net/Socket.html#getOutputStream()) 明确说明:

Closing the returned OutputStream will close the associated socket.
(关闭 getOutputStream() 返回的流,将一并关闭关联的 Socket)

你的 sendRequest 方法中,在每次请求后调用了 out.close(),这直接触发了 Socket 的底层关闭逻辑。当第二次调用 sendRequest(socket, "youtube.com") 时,socket.getOutputStream() 尝试获取已失效的输出流,JVM 立即抛出 Socket is closed。

✅ 正确复用 Socket 的核心原则

  1. 流不单独关闭:InputStream 和 OutputStream 绝不主动调用 .close();它们的生命周期应严格绑定于 Socket 本身。
  2. 资源统一管理:仅在所有通信完成且确认不再使用时,调用 socket.close()。
  3. 协议适配性判断:并非所有服务都支持长连接复用。WHOIS 协议(如 whois.verisign-grs.com:43)属于典型的“请求-响应-断连”模式——服务端在返回完整响应后会主动关闭 TCP 连接。即使客户端不关流,服务端挥手(FIN)后再次写入仍会触发 Socket is closed 或 Connection reset。

✅ 修复后的可复用示例(适用于支持长连接的协议)

@Test
void reusableSocketExample() {
    try (Socket socket = new Socket(WHOIS_HOST, WHOIS_PORT)) { // 使用 try-with-resources 统一管理
        socket.setSoTimeout(5000);

        sendRequestSafe(socket, "cnn.com");
        Thread.sleep(2000);
        sendRequestSafe(socket, "youtube.com");
        Thread.sleep(2000);
        sendRequestSafe(socket, "toyota.com");

        // ✅ Socket 在 try 块结束时自动关闭,流无需手动关闭
    } catch (Exception e) {
        e.printStackTrace();
    }
}

private void sendRequestSafe(Socket socket, String domain) throws IOException {
    // ✅ 不关闭流!复用同一 Socket 的输入/输出流
    OutputStream out = socket.getOutputStream();
    out.write((domain + "\r\n").getBytes(StandardCharsets.UTF_8));
    out.flush(); // 必须 flush,否则数据可能滞留在缓冲区

    // ✅ 使用 try-with-resources 仅关闭 BufferedReader,不影响底层流
    try (BufferedReader input = new BufferedReader(
            new InputStreamReader(socket.getInputStream(), StandardCharsets.UTF_8))) {
        String line;
        while ((line = input.readLine()) != null) {
            if (line.contains("Registry Expiry Date")) {
                String dateStr = line.substring(line.indexOf(':') + 1).trim();
                System.out.println("---> " + dateStr);
                break;
            }
        }

        // 解析逻辑(略,保持与原逻辑一致)
        if (line != null && line.matches("\\d{4}-\\d{2}-\\d{2}T\\d{2}:\\d{2}:\\d{2}Z")) {
            LocalDateTime dt = LocalDateTime.parse(line, DateTimeFormatter.ISO_LOCAL_DATE_TIME);
            System.out.println("---> " + dt);
            System.out.println("---> Not available " + domain);
        } else {
            System.out.println("---> Available " + domain);
        }
    }
}

⚠️ 关键注意事项

总结

Socket is closed 是典型的资源管理失误,根源在于混淆了流与套接字的关闭边界。牢记:关闭流 = 关闭 Socket。安全复用的前提是协议支持长连接,且全程避免任何流的 close() 调用。对于 WHOIS 等短连接协议,应放弃复用幻想,转而优化连接池(如 Apache Commons Net 的 WhoisClient)或异步批量请求策略。真正的健壮性,始于对网络协议语义的敬畏。

本文转载于:互联网 如有侵犯,请联系zhengruancom@outlook.com删除。
免责声明:正软商城发布此文仅为传递信息,不代表正软商城认同其观点或证实其描述。