Java NIO Channels(三)

举报
张俭 发表于 2023/12/29 15:27:41 2023/12/29
【摘要】 Java NIO Channels(三)通道提供了分散聚合的能力。就是说一次IO操作可以对应多个buffer。对于写操作(向通道中写入数据),数据从数个buffer中汇合然后沿通道发送对于读操作(从通道中读出数据),从通道中出来的数据分散到许多不同的buffer,尽可能地读取,直到数据或者buffer的可用空间被耗尽。许多现代操作系统支持native vectored(矢量) IO;当你在...

Java NIO Channels(三)

通道提供了分散聚合的能力。就是说一次IO操作可以对应多个buffer。

对于写操作(向通道中写入数据),数据从数个buffer中汇合然后沿通道发送
对于读操作(从通道中读出数据),从通道中出来的数据分散到许多不同的buffer,尽可能地读取,直到数据或者buffer的可用空间被耗尽。

许多现代操作系统支持native vectored(矢量) IO;当你在一个通道上发起一个分散聚合请求时,请求会被解释成native方法。这样子buffer的复制和系统调用可以减少甚至消除。最好使用direct buffer,得到最优的性能。

public interface ScatteringByteChannel extends ReadableByteChannel {
  public long read(ByteBuffer[] dsts) throws IOException;
  public long read(ByteBuffer[] dots,int offset, int length) throws IOException;
}

public interface GatheringByteChannel extends WritableByteChannel {
  public long write(ByteBuffer[] srcs) throws IOException;
  public long write(ByteBuffer[] srcs, int offset, int length) throws IOException;
}

看看下面的代码段

Channel+boolean isOpen+void closeReadableByteChannel+int readWritableByteChannel+int writeScatteringByteChannel+long read+long readGatheringByteChannel+long write+long writeByteChannel
ByteBuffer header = ByteBuffer.allocateDirect(10);
ByteBuffer body = ByteBuffer.allocateDirect(80);
ByteBuffer[] buffers = {header, body};
int bytesRead = channel.read(buffers);

如果返回值bytesRead为48,那么head中拥有最先的10个数据,body中有38个。

相似的,我们可以组装数据在不同的buffer中,然后发送聚合

  body.clear();
  body.put("FOO".getBytes()).flip();
  header.clear();
  header.putShort(TYPE_FILE).putLong(body.limit()).flip();
  long bytesWritten = channel.write(buffers);
【声明】本内容来自华为云开发者社区博主,不代表华为云及华为云开发者社区的观点和立场。转载时必须标注文章的来源(华为云社区)、文章链接、文章作者等基本信息,否则作者和本社区有权追究责任。如果您发现本社区中有涉嫌抄袭的内容,欢迎发送邮件进行举报,并提供相关证据,一经查实,本社区将立刻删除涉嫌侵权内容,举报邮箱: cloudbbs@huaweicloud.com
  • 点赞
  • 收藏
  • 关注作者

评论(0

0/1000
抱歉,系统识别当前为高风险访问,暂不支持该操作

全部回复

上滑加载中

设置昵称

在此一键设置昵称,即可参与社区互动!

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。

*长度不超过10个汉字或20个英文字符,设置后3个月内不可修改。