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,但没有抛出IOException。

Answer 1

我希望OutStream.write在尝试写入关闭的服务器时抛出IOException,但没有抛出IOException。

由于套接字发送缓冲区的原因，它第一次不会这样做。如果你继续写，它最终会抛出一个IOException:'Connection Reset'。如果您没有数据来到达那个点，您将永远不会发现对等体已经关闭。