NIO入门系列之第6章：分散和聚集第6章 分散和聚集

分散/聚集 I/O 是使用多个而不是单个缓冲区来保存数据的读写方法。

一个分散的读取就像一个常规通道读取，只不过它是将数据读到一个缓冲区数组中而不是读到单个缓冲区中。同样地，一个聚集写入是向缓冲区数组而不是向单个缓冲区写入数据。

分散/聚集 I/O 对于将数据流划分为单独的部分很有用，这有助于实现复杂的数据格式。

通道可以有选择地实现两个新的接口： ScatteringByteChannel 和 GatheringByteChannel。一个 ScatteringByteChannel 是一个具有两个附加读方法的通道：

<code>long</code> <code>read( ByteBuffer[] dsts );</code>

<code>long</code> <code>read( ByteBuffer[] dsts, </code><code>int</code> <code>offset, </code><code>int</code> <code>length );</code>

这些 long read()方法很像标准的 read 方法，只不过它们不是取单个缓冲区而是取一个缓冲区数组。

在分散读取中，通道依次填充每个缓冲区。填满一个缓冲区后，它就开始填充下一个。在某种意义上，缓冲区数组就像一个大缓冲区。

分散/聚集 I/O 对于将数据划分为几个部分很有用。例如，您可能在编写一个使用消息对象的网络应用程序，每一个消息被划分为固定长度的头部和固定长度的正文。您可以创建一个刚好可以容纳头部的缓冲区和另一个刚好可以容难正文的缓冲区。当您将它们放入一个数组中并使用分散读取来向它们读入消息时，头部和正文将整齐地划分到这两个缓冲区中。

我们从缓冲区所得到的方便性对于缓冲区数组同样有效。因为每一个缓冲区都跟踪自己还可以接受多少数据，所以分散读取会自动找到有空间接受数据的第一个缓冲区。在这个缓冲区填满后，它就会移动到下一个缓冲区。

聚集写入类似于分散读取，只不过是用来写入。它也有接受缓冲区数组的方法：

<code>long</code> <code>write( ByteBuffer[] srcs );</code>

<code>long</code> <code>write( ByteBuffer[] srcs, </code><code>int</code> <code>offset, </code><code>int</code> <code>length );</code>

聚集写对于把一组单独的缓冲区中组成单个数据流很有用。为了与上面的消息例子保持一致，您可以使用聚集写入来自动将网络消息的各个部分组装为单个数据流，以便跨越网络传输消息。

从例子程序UseScatterGather.java 中可以看到分散读取和聚集写入的实际应用。

<code>// UseScatterGather</code>

<code>import</code> <code>java.io.*;</code>

<code>import</code> <code>java.net.*;</code>

<code>import</code> <code>java.nio.*;</code>

<code>import</code> <code>java.nio.channels.*;</code>

<code>public</code> <code>class</code> <code>UseScatterGather</code>

<code>{</code>

<code>  </code><code>static</code> <code>private</code> <code>final</code> <code>int</code> <code>firstHeaderLength = </code><code>2</code><code>;</code>

<code>  </code><code>static</code> <code>private</code> <code>final</code> <code>int</code> <code>secondHeaderLength = </code><code>4</code><code>;</code>

<code>  </code><code>static</code> <code>private</code> <code>final</code> <code>int</code> <code>bodyLength = </code><code>6</code><code>;</code>

<code>  </code><code>static</code> <code>public</code> <code>void</code> <code>main( String args[] ) </code><code>throws</code> <code>Exception {</code>

<code>    </code><code>if</code> <code>(args.length!=</code><code>1</code><code>) {</code>

<code>      </code><code>System.err.println( </code><code>"Usage: java UseScatterGather port"</code> <code>);</code>

<code>      </code><code>System.exit( </code><code>1</code> <code>);</code>

<code>    </code><code>}</code>

<code>    </code><code>int</code> <code>port = Integer.parseInt( args[</code><code>0</code><code>] );</code>

<code>    </code><code>ServerSocketChannel ssc = ServerSocketChannel.open();</code>

<code>    </code><code>InetSocketAddress address = </code><code>new</code> <code>InetSocketAddress( port );</code>

<code>    </code><code>ssc.socket().bind( address );</code>

<code>    </code><code>int</code> <code>messageLength =</code>

<code>      </code><code>firstHeaderLength + secondHeaderLength + bodyLength;</code>

<code>    </code><code>ByteBuffer buffers[] = </code><code>new</code> <code>ByteBuffer[</code><code>3</code><code>];</code>

<code>    </code><code>buffers[</code><code>0</code><code>] = ByteBuffer.allocate( firstHeaderLength );</code>

<code>    </code><code>buffers[</code><code>1</code><code>] = ByteBuffer.allocate( secondHeaderLength );</code>

<code>    </code><code>buffers[</code><code>2</code><code>] = ByteBuffer.allocate( bodyLength );</code>

<code>    </code><code>SocketChannel sc = ssc.accept();</code>

<code>    </code><code>while</code> <code>(</code><code>true</code><code>) {</code>

<code>      </code><code>// Scatter-read into buffers</code>

<code>      </code><code>int</code> <code>bytesRead = </code><code>0</code><code>;</code>

<code>      </code><code>while</code> <code>(bytesRead &lt; messageLength) {</code>

<code>        </code><code>long</code> <code>r = sc.read( buffers );</code>

<code>        </code><code>bytesRead += r;</code>

<code>        </code><code>System.out.println( </code><code>"r "</code><code>+r );</code>

<code>        </code><code>for</code> <code>(</code><code>int</code> <code>i=</code><code>0</code><code>; i&lt;buffers.length; ++i) {</code>

<code>          </code><code>ByteBuffer bb = buffers[i];</code>

<code>          </code><code>System.out.println( </code><code>"b "</code><code>+i+</code><code>" "</code><code>+bb.position()+</code><code>" "</code><code>+bb.limit() );</code>

<code>        </code><code>}</code>

<code>      </code><code>}</code>

<code>      </code><code>// Process message here</code>

<code>      </code><code>// Flip buffers</code>

<code>      </code><code>for</code> <code>(</code><code>int</code> <code>i=</code><code>0</code><code>; i&lt;buffers.length; ++i) {</code>

<code>        </code><code>ByteBuffer bb = buffers[i];</code>

<code>        </code><code>bb.flip();</code>

<code>      </code><code>// Scatter-write back out</code>

<code>      </code><code>long</code> <code>bytesWritten = </code><code>0</code><code>;</code>

<code>      </code><code>while</code> <code>(bytesWritten&lt;messageLength) {</code>

<code>        </code><code>long</code> <code>r = sc.write( buffers );</code>

<code>        </code><code>bytesWritten += r;</code>

<code>      </code><code>// Clear buffers</code>

<code>        </code><code>bb.clear();</code>

<code>      </code><code>System.out.println( bytesRead+</code><code>" "</code><code>+bytesWritten+</code><code>" "</code><code>+messageLength );</code>

<code>  </code><code>}</code>

<code>}</code>

版权声明：原创作品，如需转载，请注明出处。否则将追究法律责任

本文转自 梦朝思夕 51CTO博客，原文链接:http://blog.51cto.com/qiangmzsx/1410776