Java NIO SelectionKey 迭代器和键处理，我做得对吗？

Question

我正在关注this tutorial关于 Java NIO。我找到了似乎正确的 java 文件 Here 。我已经调整了代码以在单个端口而不是多个端口上运行，并且只是将数据输出到屏幕而不是将其回显给客户端。

当我运行代码时，我的版本和上面超链接上的版本似乎都没有正确处理 channel 。我只是根据笔记本电脑风扇的声音得出了这个结论，在快速输入几条 System.out.println() 消息后，我设法将问题范围缩小了一些。起初我以为 selector.select() 方法由于某种原因没有阻塞， channel 似乎是空的，但 while(hasContent) 循环不断迭代。

经过一番搜索，我发现了 this post并意识到也许我没有正确处理 key 。从 channel 读取数据后，我调整了代码以取消 while(iterator.hasNext()) 循环底部的 if 语句中的 SelectionKey。

这似乎已经成功了，现在我收到一条消息，通知在 channel 关闭之前没有更多字节可供读取，并且总体上事情似乎运行得更顺利。

这是我迄今为止所做的代码，我对于如何实现它的想法是否正确？我是否在正确的时间点取消了 key ？

public class ServerRunnable implements Runnable {

    private int serverPort;
    private int queueLength;

    public ServerRunnable(int serverPort, int queueLength) {
        this.serverPort = serverPort;
        this.queueLength = queueLength;

    }

    private boolean running;
    private ServerSocketChannel serverSocketChannel;
    private ByteBuffer buffer = ByteBuffer.allocate(1024);

    @Override
    public void run() {
        try {
            Selector selector = Selector.open();

            serverSocketChannel = ServerSocketChannel.open();
            serverSocketChannel.configureBlocking(false);
            ServerSocket serverSocket = serverSocketChannel.socket();
            serverSocket.bind(new InetSocketAddress(serverPort));
            System.out
                    .println("DeviceServerV0.2 - Going to Listen for connections on port: "
                            + serverSocket.getLocalPort());
            running = true;

            SelectionKey serverAcceptKey = serverSocketChannel.register(
                    selector, SelectionKey.OP_ACCEPT);
            int count = 0;
            while (running) {
                int keyCount = selector.select();
                System.out.println("keyCount: " + keyCount);
                Set<SelectionKey> selectedKeys = selector.selectedKeys();
                Iterator keyIterator = selectedKeys.iterator();
                while (keyIterator.hasNext()) {
                    SelectionKey key = (SelectionKey) keyIterator.next();

                    if ((key.readyOps() & SelectionKey.OP_ACCEPT) == SelectionKey.OP_ACCEPT) {

                        ServerSocketChannel ssc = (ServerSocketChannel) key
                                .channel();
                        SocketChannel sc = ssc.accept();
                        sc.configureBlocking(false);

                        // Here we add the new connection to the selector
                        SelectionKey newKey = sc.register(selector,
                                SelectionKey.OP_READ);

                        keyIterator.remove();

                    } else if ((key.readyOps() & SelectionKey.OP_READ) == SelectionKey.OP_READ) {
                        SocketChannel sc = (SocketChannel) key.channel();

                        // Going with this from the tutorial for now.
                        // TODO: Implement proper boolean controls here
                        while (true) {
                            buffer.clear();

                            int read = sc.read(buffer);

                            if (read <= 0) {
                                // System.out.println("Bytes read: " + read);
                                System.out
                                        .println("No more bytes, breaking loop.");

                                break;
                            } else {

                                buffer.flip();
                                String result = new String(buffer.array());
                                System.out
                                        .println("Buffer Contents: " + result);

                            }
                        }
                        keyIterator.remove();
                        key.cancel();

                    }

                }

            }

        } catch (Exception e) {
            e.printStackTrace();
        }

    }

}

我还知道调用 ByteBuffer.array() 不会影响 byteBuffer 中的当前位置，因此它仍然看起来好像缓冲区尚未被读取。我应该以某种方式处理这个问题，还是在循环开始时调用 ByteBuffer.clear() 就足够了？

我打算继续尝试构建一个使用线程池来处理请求的 NIO 服务器，但我想确保到目前为止我对 NIO 的理解是正确的。

Answer 1

当 channel 的 readyOps() 包含 SelectionKey.OP_READ 时，它意味着可以读取一些数据，而不是可以读取整个 channel 直至其末尾。但这就是您在 while(true) 循环中所做的事情；您正在阅读并因此轮询一个 channel ，直到到达其末尾。

正确的处理方法是读取一次并且不要尝试再次读取，除非下一个select报告有更多数据需要读取。