3

我有一个带有主循环的简单非阻塞服务器：

try {
    while (selector.select() > -1) {

        // Wait for an event one of the registered channels

        // Iterate over the set of keys for which events are available
        Iterator selectedKeys = selector.selectedKeys().iterator();
        while (selectedKeys.hasNext()) {
            SelectionKey key = (SelectionKey) selectedKeys.next();
            selectedKeys.remove();
            try {
                if (!key.isValid()) {
                    continue;
                }

                if (key.isConnectable()) {
                    connect(key);
                }

                // Check what event is available and deal with it
                if (key.isAcceptable()) {
                    accept(key);
                }

                if (key.isReadable()) {
                    read(key);
                }

                if (key.isWritable()) {
                    write(key);
                }
            } catch (Exception e) {
                e.printStackTrace();
                close(key);
            }
        }
    }
} catch (Exception e) {
    e.printStackTrace();
}

在读/写部分，我检查是否有要读/写的东西，如果没有 - 然后我尝试关闭频道：

if (channel.read(attachment.buffer) < 1) 
    close(key);

关闭方法：

private void close(SelectionKey key) throws IOException {
    key.cancel();
    key.channel().close();
}

但是在处理此代码期间，我在主循环中遇到异常（它被捕获但我认为有问题）我得到了这个堆栈跟踪：

java.nio.channels.CancelledKeyException
    at sun.nio.ch.SelectionKeyImpl.ensureValid(Unknown Source)
    at sun.nio.ch.SelectionKeyImpl.readyOps(Unknown Source)
    at java.nio.channels.SelectionKey.isWritable(Unknown Source)

因此，当进入写入部分时，它在主循环上失败，关闭通道并在“可写”部分返回主循环，并因此类异常而失败。有什么建议么？

4

1 回答 1

9

错误非常简单。

if (!key.isValid()) {
    continue;
}

if (key.isConnectable()) {
    connect(key);
}

// Check what event is available and deal with it
if (key.isAcceptable()) {
    accept(key);
}

if (key.isReadable()) {
    read(key);
}

if (key.isWritable()) {
    write(key);
}

您的read方法是取消SelectionKey. 但是，在从 中返回后read，您再次测试该通道是否可写的密钥 - 可能只是在取消相同的密钥之后！您的初始检查在这里无济于事。

一种解决方案是检查密钥在刚刚被取消的地方是否有效：

...
if (key.isValid() && key.isWritable()) {
  write(key);
}
...

或者，您也可以尝试在任何特定频道上一次只注册一个兴趣，因此所有就绪事件都是互斥的：

if (!key.isValid()) {
  continue;
}

if (key.isConnectable()) {
  connect(key);
} else if (key.isAcceptable()) {
  accept(key);
} else if (key.isReadable()) {
  read(key);
} else if (key.isWritable()) {
  write(key);
}

这在某些情况下可能是有益的；一般来说，一个通道几乎总是可以写的，保持对写准备的兴趣和边读准备可能会保持Selector循环旋转，这很可能是不可取的。在大多数情况下，通常只有在底层套接字输出缓冲区已满时才对写就绪感兴趣。

附带说明一下，知道它SocketChannel.read可以返回一个值< 1而不会出错。

读取操作可能不会填满缓冲区，实际上它可能根本不会读取任何字节。是否这样做取决于通道的性质和状态。例如，处于非阻塞模式的套接字通道不能读取比从套接字输入缓冲区立即可用的字节数更多的字节；

此外，Selector.select没有说明任何有关返回< -1以表明它已关闭的信息。

返回：键的数量，可能为零，其就绪操作集已更新

于 2012-08-07T22:03:30.797 回答