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

Question

我正在尝试使用具有可选通道的NIO制作简单的服务器，并将所有“繁重的”逻辑移至主NIO循环之外，并移至单独的线程中。但是我无法从其他线程注册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-如果集合中的某位与此键的通道支持的操作，即，如果（ops＆〜channel（）。validOps（））！= 0

并且添加了一些技巧，看看是否是我的情况。第二个线程中的检查是：

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

sChann.register(selector, SelectionKey.OP_READ);