java - NIO:写入的字节永远不会到达接收者

Question

我正在开发一个 Java 库来使用 NIO 交换数据。我的客户端是否有可能向套接字写入一些内容并关闭它，并且服务器接受连接但从不读取这些字节，因为 read 方法返回 -1？

在我的例子中，客户端在套接字上写入后关闭连接。我将遇到的问题的日志留在这里。正如您所看到的，379 字节被写入套接字的客户端，但从未在服务器上接收。

客户端日志

43:32.335- OPENING SOCKET 1480207683
43:32.976- FINISH CONNECTION for socket@1480207683 -> Socket[addr=/10.20.0.10,port=43000,localport=45002]
43:32.976- Socket 1480207683 has written 379 bytes
43:33.445- Closing socket 1480207683

服务器日志

43:32.766: ACCEPT for socket@816266612 -> Socket[address=/172.16.8.251,port=45002,localPort=43000]
43:33.641 D/Comm: Socket 816266612 has read -1 bytes
43:33.644 D/Comm: Closing socket 816266612...

我必须采取哪些选项来确保这种沟通有效？我应该等到服务器关闭它的一端再关闭客户端吗？或者是否有任何其他方法可以确保一旦写入套接字，无论网络使用它做什么，消息都应该到达？

这是写入和读取方法的代码(我对其进行了简化，因为它在接收到根本不感兴趣的字节后进行了一些处理)。它适用于我正在进行的 99% 的通信和简单案例。当处理许多并发通信时就会出现这个问题。

private void read(SelectionKey key) {
    SocketChannel sc = (SocketChannel) key.channel();
    // Read data from the socket
    ByteBuffer readBuffer = ByteBuffer.allocate(NIOProperties.PACKET_SIZE);
    int size = sc.read(readBuffer);
    LOGGER.info("Socket " + sc.hashCode() + " has read " + size + " bytes");
    if (size == -1) {
        closeChannel(key, sc);
        return;
    }
    readBuffer.flip();
    process(readBuffer);
}

private void write(SelectionKey key) {
    if (writeBuffer != null) {
        if (writeBuffer.remaining() > 0) {
            int written = sc.write(writeBuffer);
            LOGGER.info("Socket " + sc.hashCode() + " has written " + written + " bytes");
        }
        changeInterest(sc, SelectionKey.OP_READ);          
    }
}

Answer 1

Is it possible that my client writes something into a socket and close it and the server accepts the connection but never reads those bytes because the read method returns -1?

没有。所有数据将在 read() 返回 -1 之前读取。 TCP 保证了这一点。

如果这是一个高并发问题，我怀疑某些东西是static但不应该是static，或者是一个应该是局部变量的成员变量。例如套接字 channel 、选择键或缓冲区。

注意，您不需要将 key 传递给 closeChannel()。您甚至不需要该方法，除非它记录了某些内容。 channel.close() 就足够了。