带有multithreading的Java NIO SocketChannel.read()

我正在使用Java NIO实现一个简单的文件服务器,其中包含一个选择线程和多个工作线程(用于执行实际读/写)。

代码的主要部分如下所示:

while (true) { int num = selector.select(); if (num > 0) { Iterator keys = selector.selectedKeys().iterator(); final SelectionKey key = keys.next(); keys.remove(); if (key.isValid()) { if (key.isAcceptable()) { accept(key); } else if (key.isReadable()) { performReadInWorkerThread (key); } else if (key.isWritable()) { performWriteInWorkerThread (key); } } } } 

从代码片段中可以看出,当选择可读/可写通道时,我将读/写从选择线程卸载到工作线程。

现在的问题是,当一个可读通道被移交给工作线程时,在它完成/开始从通道读取之前,选择线程再次循环,并且selector.select()选择先前选择的可读通道(因为仍然存在通道中的输入缓冲区尚未被先前分配的工作线程完全占用,因此通道再次移交给另一个工作线程,导致多个工作线程读取同一通道

我相信这是一个设计问题。 我的问题是如何确保只有一个线程同时读取一个频道?

为什么? 读取不会阻止。 在当前线程中执行此操作。 你只是以这种方式解决无穷无尽的问题。 在移交给读取线程之前,您必须取消注册OP_READ,这很容易,但困难的是当读取线程完成读取时,它必须重新注册OP_READ,这需要(i)选择器wakeup(),导致select线程在可能无事可做时运行,这很浪费,或者(ii)使用挂起重新注册队列,这会延迟该通道上的下一次读取,直到下一次选择器之后醒来,这也是浪费,否则你必须在添加到队列时立即唤醒选择器,如果没有准备就绪也是浪费。 我从未见过使用不同选择和读取线程的令人信服的NIO架构。

不要这样做。 如果必须具有multithreading,请将通道组织成组,每个组都有自己的选择器和自己的线程,并让所有这些线程都自己读取。

类似地,不需要在单独的线程中写入。 只要你有写东西就写。

对于NIO,只需记住一个原则: 在主选择线程中进行读/写。 这个原则是硬件性质的反映。 不要担心主选择线程中的读取不是很快。 在现代服务器中,CPU总是比网卡快。 因此,一个线程中的无阻塞读取也比网卡操作更快。 一个线程已足以读取数据包。 我们不需要任何线程了。

检查SelectionKey.cancel()方法。