TCP 检测与客户端断开连接的服务器

Question

我正在用 Java 编写一个简单的 TCP 客户端/服务器程序对，如果客户端在 10 秒内没有发送任何内容，则服务器必须断开连接。 socket.setSoTimeout() 让我明白了，服务器断开连接就好了。问题是 - 我怎样才能让客户端确定服务器是否关闭？目前我正在使用 DataOutputStream 写入服务器，这里的一些答案表明写入关闭的套接字会抛出 IOException，但这不会发生。

我应该使用哪种写入器对象来向服务器发送任意字节块，这会引发异常或以其他方式指示连接已远程关闭？

编辑：这是客户端代码。这是一个测试函数，它从文件系统中读取一个文件并将其发送到服务器。它以块的形式发送它，并在每个块之间暂停一段时间。

public static void sendFileWithTimeout(String file, String address, int dataPacketSize, int timeout) {
    Socket connectionToServer = null;
    DataOutputStream outStream = null;
    FileInputStream inStream = null;
    try {
        connectionToServer = new Socket(address, 2233);

        outStream = new DataOutputStream(connectionToServer.getOutputStream());

        Path fileObject = Paths.get(file);

        outStream.writeUTF(fileObject.getFileName().toString());

        byte[] data = new byte[dataPacketSize];

        inStream = new FileInputStream(fileObject.toFile());
        boolean fileFinished = false;
        while (!fileFinished) {
            int bytesRead = inStream.read(data);
            if (bytesRead == -1) {
                fileFinished = true;
            } else {
                outStream.write(data, 0, bytesRead);
                System.out.println("Thread " + Thread.currentThread().getName() + " wrote " + bytesRead + " bytes.");
                Thread.sleep(timeout);
            }
        }

    } catch (IOException | InterruptedException e) {
        System.out.println("Something something.");
        throw new RuntimeException("Problem sending data to server.", e);
    } finally {
        TCPUtil.silentCloseObject(inStream);
        TCPUtil.silentCloseObject(outStream);
        TCPUtil.silentCloseObject(connectionToServer);
    }
}

我希望 outStream.write 在尝试写入已关闭的服务器时抛出 IOException，但什么也没有。

Answer 1

我希望 outStream.write 在尝试写入已关闭的服务器时抛出 IOException，但什么也没有。

第一次不会这样做，因为套接字发送缓冲区。如果你继续写，它最终会抛出一个 IOException: 'connection reset'。如果您没有数据可以到达该点，您将永远不会发现对等点已关闭。

Answer 2

我认为你需要在像 outStream.flush(); 这样写之后flush和close outStream.close(); inStream.close();

Answer 3

记住ServerSocket.setSoTimeout() 不同于客户端的同名函数。

对于服务器，这个函数只抛出SocketTimeoutException，如果超时过期，你可以捕捉它，但服务器套接字仍然存在。

对于客户端，setSoTimeout() 与流读取的“读取超时”相关。

在您的情况下，您必须在捕获SocketTimeoutException => 后显示关闭连接的套接字的服务器代码 => 确保服务器关闭与指定客户端的关联套接字。 如果完成，在客户端，您的代码行：

throw new RuntimeException("Problem sending data to server.", e);

将被调用。

[更新]

我注意到您声明将服务器端接受套接字的超时设置为 10 秒（=10,000 毫秒）；在此期间，您的客户是否完成了所有文件发送？如果确实如此，则永远不会发生异常。

[建议]

为了探测，只需注释掉你的读取文件内容的代码发送到服务器，并尝试用几行写入输出流替换：

outStream.writeUTF("ONE");
outStream.writeUTF("TWO");
outStream.writeUTF("TREE");

那么你就可以得出结论了。