无法在单独的线程中设置 SelectionKey 的 interestOps

Question

我正在尝试使用带有可选通道的 NIO 制作一个简单的服务器，并将主 NIO 循环之外的所有 "heavy" 逻辑移动到一个单独的线程中。但我无法从其他线程注册 SelectionKey。抱歉阅读时间过长。

服务器正常启动：

ServerSocketChannel serverChannel;
Selector selector;
try {
   serverChannel = ServerSocketChannel.open();
   ServerSocket ss = serverChannel.socket();
   InetSocketAddress address = new InetSocketAddress(port);
   ss.bind(address);
   serverChannel.configureBlocking(false);
   selector = Selector.open();
   serverChannel.register(selector, SelectionKey.OP_ACCEPT);
} catch (IOException ex) {
   ex.printStackTrace();
   return;
}

然后进入主循环，在接受阶段 (key.isAcceptable()) 我执行接受（我更愿意在单独的线程中接受连接，但似乎在主 NIO 循环中没有接受我不会得到 SocketChannel 对象):

ServerSocketChannel server = (ServerSocketChannel) key.channel();
SocketChannel sChann = server.accept();

然后我将当前的 SocketChannel 和 SelectionKey 传递给第二个线程，以便进行一些检查并决定是否应该关闭通道或者我可以从通道读取数据。如果所有检查都成功通过，我正在尝试为此密钥注册 OP_READ 标志并遇到以下问题：

在Java手册中写到，SelectionKey对于频道来说是常数。但是，当我在第二个线程中尝试执行

key.interestOps(SelectionKey.OP_READ);

我遇到以下异常：

Exception in thread "Thread-0" java.lang.IllegalArgumentException
    at java.base/sun.nio.ch.SelectionKeyImpl.interestOps(SelectionKeyImpl.java:98)
    at ConnectionAcceptor.run(ConnectionAcceptor.java:55)
    at java.base/java.lang.Thread.run(Thread.java:834)

我在手册中读到了这个异常

IllegalArgumentException - If a bit in the set does not correspond to an operation that is supported by this key's channel, that is, if (ops & ~channel().validOps()) != 0

并添加了一些 ckecks 以查看是否是我的情况。第二个线程中的检查是：

System.out.println("ConnectionAcceptor: valid options " + ci.sockChan.validOps());
System.out.println("ConnectionAcceptor: OP_ACCEPT " + SelectionKey.OP_ACCEPT);
System.out.println("ConnectionAcceptor: OP_READ " + SelectionKey.OP_READ);
System.out.println("ConnectionAcceptor: OP_WRITE " + SelectionKey.OP_WRITE);

结果是：

ConnectionAcceptor: valid options 13
ConnectionAcceptor: OP_ACCEPT 16
ConnectionAcceptor: OP_READ 1
ConnectionAcceptor: OP_WRITE 4

因此，没有违反手册中的规则，不应引发 IllegalArgumentException。

Here 我找到了另一种设置所需标志的方法：

sockChan.keyFor(selector).interestOps(SelectionKey.OP_READ);

但是在我的第二个线程中使用它我得到

Exception in thread "Thread-0" java.lang.NullPointerException
    at ConnectionAcceptor.run(ConnectionAcceptor.java:59)
    at java.base/java.lang.Thread.run(Thread.java:834)

因此，看起来当通道和键对象被转移到第二个线程时，主 NIO 循环进行了一些迭代，通道的 SelectionKey 变得无效。请帮我找到从第二个线程注册频道选择器标志的方法。

Answer 1

有

key.interestOps(SelectionKey.OP_READ);

您正在尝试更改注册的兴趣集来自

/* SelectionKey key = */ serverChannel.register(selector, SelectionKey.OP_ACCEPT);

那个ServerSocketChannel只支持OP_ACCEPT。

你要做的是在新接受的套接字通道

上注册一个新的OP_READ

SelectionKey aNewKey = sChann.register(selector, SelectionKey.OP_READ);

该新密钥将驱动该套接字上的操作。

您的第二次尝试失败，因为您的 SocketChannel 没有注册任何 Selector，因此 keyFor 返回 null。

无法在单独的线程中设置 SelectionKey 的 interestOps

Can't set SelectionKey 's interestOps in separate thread

java

multithreading

nio