如何确定客户端连接是否在 Java 服务器的 TCP 套接字连接中终止？

Question

我正在使用 TCP 套接字上的阻塞读/写实现多线程服务器，其中 InputStream 和 OutputStream 原语由适当的 Reader/Writer 封装。

如果客户端断开连接，InputStreamReader's read() 方法会返回-1，但如果客户端连接完好无损，它会无限期地等待。我该如何克服这个问题？

Answer 1

这里最重要的问题是“丢失”对于应用程序的真正含义是什么。套接字通信中有两个角色——写者和读者。我们的代码可能同时扮演这两个角色。因此，对于套接字通信：

1. 从作者的角度来看，连接“丢失”意味着作者在写入/发送到套接字时出错（OutputStream.write(...)）。对于 TCP，这仅由于接收到 FIN 或 RST，或由于重新传输超时（在 Java 中无法管理）或由于操作系统检测到 TCP keepalive 连接丢失（https://tldp.org/HOWTO/TCP-Keepalive-HOWTO/overview.html）而发生

2. 从读者的角度来看，连接“丢失”意味着读者在从套接字读取时出错（InputStream.read(...)）。对于 TCP，这仅由于接收到 FIN 或 RST，或者由于操作系统检测到与 TCP keepalive 的“丢失”连接，或者由于阻塞读取超时 (SO_TIMEOUT) 而发生。

TCP 重传超时 (RTO) 和 TCP keepalive 都不太好：

1. RTO：https://pracucci.com/linux-tcp-rto-min-max-and-tcp-retries2.html
2. Keepalive 更糟糕：https://docs.microsoft.com/en-us/windows/win32/winsock/so-keepalive。默认情况下，Windows 在 2 小时后发送第一个 TCP Keepalive 数据包（！）。 Linux 上的相同问题https://tldp.org/HOWTO/TCP-Keepalive-HOWTO/usingkeepalive.html

因此，如果您是服务器，我强烈建议您只使用强制设置 SO_TIMEOUT（或您自己的用于解除阻塞读取的等效项），或者在应用程序级别引入运行状况/可用性检查。有两种典型的模式：ping-pong（达到超时后，服务器向客户端发送一个 ping 数据包并等待接收到的 pong），一个心跳（客户端应该在指定的周期内发送一个心跳包）时间）。请注意，客户端通常会遇到相同的问题，您可能会决定支持双方的 ping-pong/heartbeat。

只是一个关于主题https://blog.cloudflare.com/when-tcp-sockets-refuse-to-die/的有趣帖子

Answer 2

您是否在套接字对象上创建输入流？

ServerSocket server = new ServerSocket(port);
Socket socket = server.accept();
DataInputStream in = new DataInputStream(new BufferedInputStream(socket.getInputStream()));

然后你可以检查套接字是否连接使用

socket.isClosed()

在你的循环之间？