java中scatter分散读和gather聚集写通过channel配合bytebuffer数组实现，分别由scatteringbytechannel和gatheringbytechannel接口支持，按顺序处理多个缓冲区以提升i/o效率，适用于协议解析、消息头体分离等场景。
Java 中的 Scatter（分散）和 Gather（聚集）读写，主要通过 Channel 配合 ByteBuffer 数组 实现，核心是 ScatteringByteChannel 和 GatheringByteChannel 接口。它们不操作单个缓冲区，而是按顺序处理多个缓冲区，提升 I/O 效率，尤其适合协议解析、消息头/体分离等场景。
分散读（Scatter Read）：从 Channel 一次读入多个 ByteBuffer
适用于将数据按逻辑结构拆分到不同缓冲区，例如先读 4 字节长度字段，再读对应长度的内容。
- Channel 需实现
ScatteringByteChannel（如FileChannel、SocketChannel） - 调用
read(ByteBuffer[] buffers)或带 offset/length 的重载方法 - 数据按缓冲区顺序填充：先填满第一个 buffer，再填第二个，依此类推
- 返回值为实际读取的总字节数；若返回 0，表示当前无数据可读（非 EOF）
示例：
ByteBuffer header = ByteBuffer.allocate(4);
ByteBuffer body = ByteBuffer.allocate(1024);
int bytesRead = channel.read(new ByteBuffer[]{header, body});
// header 中存前 4 字节（如消息长度），body 存后续内容
聚集写（Gather Write）：向 Channel 一次写出多个 ByteBuffer
适用于将逻辑上分离的数据（如协议头 + 有效载荷）合并发送，避免多次系统调用。
- Channel 需实现
GatheringByteChannel（如FileChannel、SocketChannel） - 调用
write(ByteBuffer[] buffers)，数据按缓冲区顺序写出 - 每个 buffer 的
position到limit区间被写出；写完后 position 自动推进 - 返回值为实际写出的总字节数
示例：
ByteBuffer header = ByteBuffer.wrap(new byte[]{0x00, 0x00, 0x04, 0x00}); // 长度 1024ByteBuffer payload = ByteBuffer.wrap("Hello".getBytes());
int bytesWritten = channel.write(new ByteBuffer[]{header, payload});
关键细节与注意事项
-
缓冲区状态必须正确：读前确保 buffer
clear()或flip()后 position/limit 设置合理；写前需flip()让数据可读 -
非阻塞模式下可能返回 0：需结合
SelectionKey判断是否就绪，不能仅靠返回值判断 EOF -
部分写/读是正常行为：尤其在网络通道中，一次
write()可能只写出部分数据，需循环处理直到全部完成 - FileChannel 支持直接内存映射缓冲区（MappedByteBuffer），但 scatter/gather 不支持 MappedByteBuffer 与普通 ByteBuffer 混用
常见适用场景
- 网络协议解析：HTTP 请求行、头、体分离读取
- 序列化框架：将对象元信息和二进制数据分别写入不同 buffer 再批量发出
- 日志聚合：同时写入时间戳 buffer、线程 ID buffer、日志内容 buffer
- 零拷贝优化：配合
transferTo()/transferFrom()减少用户态拷贝（注意：这两个方法本身不参与 scatter/gather）
Java免费学习笔记：立即使用
解锁 Java 大师之旅：从入门到精通的终极指南
