java nio selector需用readyops()与interestops()按位与判断就绪事件,读就绪须检查read()返回值并清理buffer,写就绪仅在缓冲区满时临时注册且写完立即取消,遍历selectedkeys时必须调用iterator.remove()。

Java NIO 的 Selector 通过轮询 SelectionKey 的就绪集(ready set)来识别通道(Channel)是否可读、可写。关键在于:**不能仅靠 key.isReadable() 或 key.isWritable() 判断,而必须结合就绪操作位(key.readyOps())与注册时感兴趣的事件(key.interestOps())做按位与判断,且需在处理后手动清理就绪状态(通常由 selector.select() 下次调用自动重置,但逻辑上应视为“一次性”)。**
读就绪事件的正确处理方式
当一个 SocketChannel 注册了 OP_READ,且内核缓冲区有数据可读时,其 SelectionKey 就绪集会包含 OP_READ。处理时需注意:
- 用
(key.readyOps() & SelectionKey.OP_READ) != 0检查读就绪,比key.isReadable()更明确(后者本质就是该判断) - 调用
channel.read(buffer),并检查返回值:-1 表示对端关闭,0 表示暂无新数据(非错误),>0 表示读到字节 - 若读到 -1(连接关闭),应关闭通道、取消 key、清理资源;避免继续注册读事件导致空轮询
- Buffer 需在读前调用
buffer.clear()(或compact()若还有未消费数据)
写就绪事件的常见误用与规范做法
OP_WRITE 容易被误解为“可以无压力发数据”,其实它多数情况下**始终就绪**(除非发送缓冲区满),盲目注册写事件会导致 CPU 空转。正确做法是:
在 Java 中初始化和管理阿里云 SDK客户端。包括单例模式、线程安全、endpoint 与 region 配置、VPC 终端节点、同步与异步等。
- 一般不长期注册
OP_WRITE;只在写操作因buffer.hasRemaining()为 true 但channel.write()返回 0(即内核缓冲区满)时,才临时注册OP_WRITE - 收到写就绪通知后,尝试继续写入剩余数据;若写完,立即调用
key.interestOps(key.interestOps() & ~SelectionKey.OP_WRITE)取消写关注 - 写操作同样要检查
write()返回值:-1 无效(不应出现),0 表示仍需等待,>0 表示写出字节数
就绪事件处理中的关键细节
SelectionKey 的就绪状态不是“锁住”的,而是每次 select() 返回时由内核更新的一份快照。因此:
- 一个 key 在单次
selectedKeys()遍历中可能同时满足读和写就绪(如半双工场景),应分别处理,顺序不限 - 处理过程中若发生异常(如 IOException),应取消 key 并关闭通道,防止残留 key 导致后续 select 异常
- 不要在处理 key 时直接调用
key.cancel()后又访问key.channel()—— 已取消的 key 渠道可能不可用 - 使用
Iterator<selectionkey></selectionkey>遍历时,必须调用iterator.remove(),否则下次 select 可能重复返回该 key
一个最小可运行的读写事件分发片段
以下逻辑体现核心判断与清理:
while (selector.select() > 0) {
Iterator<selectionkey> iter = selector.selectedKeys().iterator();
while (iter.hasNext()) {
SelectionKey key = iter.next();
iter.remove(); // 必须移除
if (!key.isValid()) continue;
if ((key.readyOps() & SelectionKey.OP_READ) != 0) {
handleRead(key);
}
if ((key.readyOps() & SelectionKey.OP_WRITE) != 0) {
handleWrite(key);
}
}
}
</selectionkey>
其中 handleRead 和 handleWrite 内部完成具体 IO 和 interestOps 动态调整。
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南










