分散读取是一次read按序填满多个bytebuffer,如先填4字节headerbuf再填bodybuf,适用于固定头+变长体协议,需非阻塞通道与selector配合。

Java NIO 的 Scatter(分散读取)和 Gather(聚集写入)机制,本质是让一个 Channel 与多个 ByteBuffer 协同完成单次 I/O 操作,避免手动拼接或拆解数据,提升结构化协议处理效率。核心不在于“多缓冲区”本身,而在于用数组组织 Buffer,由底层按序填充或提取有效数据段。
分散读取:一次 read 填满 header + body
适用于固定头+变长体的协议,比如前 4 字节表示 body 长度。关键不是“同时读”,而是按 Buffer 容量顺序填满:
- 分配两个 DirectByteBuffer:headerBuf(capacity = 4)、bodyBuf(capacity ≥ 最大预期负载)
- 确保 SocketChannel 已 configureBlocking(false),并注册到 Selector 监听 OP_READ
- 调用 channel.read(new ByteBuffer[]{headerBuf, bodyBuf}) —— NIO 先填满 headerBuf,再把剩余字节写入 bodyBuf
- 检查返回值:若 read() 返回值 ,说明 header 未收全,不能 flip;只有 ≥ 4 才对 headerBuf.flip() 并读出长度字段
- 再判断 body 是否收齐:bodyBuf.position() == length,否则继续等待下一次 OP_READ 就绪
聚集写入:一次 write 发送 status + payload + separator
适合构造逻辑一体、物理分离的响应报文,比如 “OK\r\n{json}\r\n”。无需合并字节数组,直接按序写出:
- 准备多个已写入数据并 flip() 的 Buffer:statusBuf.put(“OK”.getBytes()).flip()、jsonBuf.put(jsonBytes).flip()、crlfBuf.put((byte)’\r’).put((byte)’\n’).flip()
- 调用 channel.write(new ByteBuffer[]{statusBuf, jsonBuf, crlfBuf}) —— NIO 按数组索引顺序,只写出每个 Buffer 的 position 到 limit 区间内容
- 检查返回值:若 write() 返回值小于总 remaining(),说明网络缓冲区已满,未写完的 Buffer 保持当前 position/limit,下次可直接复用 write() 继续发送
- 无需 clear 或重新 flip,也不用调整 capacity 或 backing array
必须注意的硬性约束
Scatter/Gather 不是万能语法糖,有明确限制:
- 仅支持 FileChannel 和非阻塞 SocketChannel / ServerSocketChannel;DatagramChannel 和阻塞模式 SocketChannel 不支持
- 所有 Buffer 类型需一致:建议全部使用 DirectByteBuffer,避免 heap buffer 引发 JVM 堆内拷贝
- Buffer 数组顺序即数据布局顺序:Scatter 严格从左到右填满,Gather 严格从左到右写出
- 单次操作不保证原子完成,必须检查 read()/write() 返回值,尤其在非阻塞场景下需结合 Selector 循环重试
为什么不用自己拼接?
手动 byte[] 合并会触发 GC、产生临时对象、增加内存拷贝次数。Scatter/Gather 让操作系统或 JVM 底层直接操作多个内存段,数据在内核态完成线性组装或拆分,省去用户态中转。高频小消息场景下,吞吐提升明显,且代码更贴近协议语义——header 就是 header,body 就是 body,职责清晰。
Java免费学习笔记:立即使用
解锁 Java 大师之旅:从入门到精通的终极指南











