Socket关闭异常原因及安全复用方法

本文详解 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);
        }
    }
}

⚠️ 关键注意事项

• WHOIS 场景特殊性：上述修复无法解决 WHOIS 复用问题。因其协议设计为单请求单连接，服务端必断连。强行复用会导致 Connection reset by peer。真实场景中应为每次查询创建新 Socket：

  try (Socket socket = new Socket(WHOIS_HOST, WHOIS_PORT)) { ... } // 每次请求新建

• 异常防御性处理：始终用 try-catch 包裹 Socket 操作，并捕获 SocketException、IOException，避免因连接中断导致程序崩溃。
• 超时设置不可少：setSoTimeout() 防止线程永久阻塞；connect() 也建议使用带超时的重载方法。
• 线程安全提示：Socket 实例不是线程安全的。多线程并发访问同一 Socket 必须加锁，或为每个线程分配独立实例。

总结

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