Scatter/Gather
- 分散(scatter从Channel中读取是指在读操作时将读取的数据写入多个buffer中。因此Channel将从Channel中读取的数据"分散(scatter)"到多个Buffer中。
- 聚集(gather写入Channel是指在写操作时将多个buffer的数据写入同一个Channel,因此Channel将多个Buffer中的数据"聚集(gather)"后发送到Channel。
1. Scattering Reads
Scattering Reads是指数据从一个channel读取到多个buffer中。如下图描述:
java
ByteBuffer header = ByteBuffer.allocate(128);
ByteBuffer body = ByteBuffer.allocate(1024);
ByteBuffer[] bufferArray = { header, body };
channel.read(bufferArray);
read()方法按照 buffer 在数组中的顺序将从 channel 中读取的数据写入到 buffer,当一个 buffer 被写满后,channel 紧接着向另一个 buffer 中写。 意味着如果存在消息头和消息体,消息头必须完成填充(例如 128byte),Scattering Reads 才能正常工作。
2. Gathering Writes
Gathering Writes 是指数据从多个 buffer 写入到同一个 channel。如下图描述:
java
ByteBuffer header = ByteBuffer.allocate(128);
ByteBuffer body = ByteBuffer.allocate(1024);
ByteBuffer[] bufferArray = { header, body };
channel.write(bufferArray);
buffers数组是write()方法的入参,write()方法会按照buffer在数组中的顺序,将数据写入到channel,注意只有position和limit之间的数据才会被写入。因此如果一个buffer的容量为128byte,但是仅仅包含58byte的数据,那么这58byte的数据将被写入到channel中。因此与Scattering Reads相反Gathering Writes能较好的处理动态消息。