java - Java NIO 中的异步 channel 关闭

Question

假设我有一个简单的基于 nio 的 java 服务器。例如(简化代码):

while (!self.isInterrupted()) {
  if (selector.select() <= 0) {
    continue;
  }

  Iterator<SelectionKey> iterator = selector.selectedKeys().iterator();
  while (iterator.hasNext()) {
    SelectionKey key = iterator.next();
    iterator.remove();
    SelectableChannel channel = key.channel();

    if (key.isValid() && key.isAcceptable()) {
      SocketChannel client = ((ServerSocketChannel) channel).accept();
      if (client != null) {
        client.configureBlocking(false);
        client.register(selector, SelectionKey.OP_READ);
      }
    } else if (key.isValid() && key.isReadable()) {
      channel.read(buffer);
      channel.close();
    }
  }
}

所以，这是一个简单的单线程非阻塞服务器。

问题出在下面的代码中。

channel.read(buffer);
channel.close();

当我在同一线程(接受连接和读取数据的线程)中关闭 channel 时，一切正常。但是当连接在另一个线程中关闭时我遇到了问题。例如

((SocketChannel) channel).read(buffer);
executor.execute(new Runnable() {
   public void run() {
     channel.close();
   }
});

在这种情况下，我最终在服务器上的套接字处于 TIME_WAIT 状态，在客户端上处于 ESTABLISHED 状态。所以连接没有正常关闭。任何想法出了什么问题？我错过了什么？

Answer 1

TIME_WAIT 表示操作系统已收到关闭套接字的请求，但等待来自客户端的可能延迟的通信。客户显然没有得到 RST，因为它仍然认为它是 ESTABLISHED。它不是 Java 的东西，它是操作系统。 RST 显然被操作系统延迟了——无论出于何种原因。

为什么只有当您在另一个线程中关闭它时它才会发生——谁知道呢？可能是操作系统认为在另一个线程中关闭应该等待原始线程退出或其他。正如我所说，这是操作系统内部机制。