netty极简教程(三): nio Channel意义以及FileChannel使用

上一章接单介绍了jdk nio中的容器 Buffer 的原理及使用: (netty极简教程(二): nio Buffer的原理及使用)[ www.jianshu.com/p/9a9feee60… ], 接下来我们继续聊聊jdk nio中的Channel

示例源码github.com/jsbintask22…

Channel介绍

在nio中,所有channel继承自*Channel(java.nio.channels.Channel)*接口,它代表一个可以进行io操作的连接,可以是硬件设备,文件,网络等等.

我们以FileChannel为例,介绍下Channel的使用以及接口实现作用

netty极简教程(三): nio Channel意义以及FileChannel使用
int write(ByteBuffer src)
int read(ByteBuffer dst)
long write(ByteBuffer[] srcs)
long read(ByteBuffer[] dsts)

FileChannel使用

写入数据

FileChannel fileChannel = FileChannel.open(Paths.get("", "file_channel_example.txt"),  // 1
                StandardOpenOption.WRITE,
                StandardOpenOption.READ);

String src = "hello from jsbintask.cn zh中文/n...test";

// write
ByteBuffer writeBuffer = ByteBuffer.wrap(src.getBytes(StandardCharsets.UTF_8));
fileChannel.write(writeBuffer); // 2
复制代码
  1. 通过FileChannel open方法获取代表该文件连接的channel
  2. 从buffer中向channel写入数据(写入到对应的文件)

这里值得注意的是,对于获取channel的步骤,改写法需要文件已经事先存在,如若文件不存在,可换另一种写法: fileChannel = new FileOutputStream("file_channel_example.txt");.getChannel(); 通过bio进行转换

读取数据

FileInputStream fis = new FileInputStream("file_channel_example.txt");
FileChannel fileChannel = fis.getChannel();  

// read
ByteBuffer readBuffer = ByteBuffer.allocate(100);
int length = fileChannel.read(readBuffer);   // 1
// method 1
System.out.println(new String(readBuffer.array()));   // 2

// method 2
readBuffer.flip();
byte[] data = new byte[length];
int index = 0;
while (readBuffer.hasRemaining()) {
    data[index++] = readBuffer.get();
}
System.out.println(new String(data));   // 3
复制代码
  1. 将channel的数据读取都buffer
  2. 直接获取buffer中的字节数据打印
  3. 利用buffer的position指针获取有效数据然后打印

值得注意的是,这里调用了buffer的flip方法,因为上面的channel.read()方法已经移动了buffer中的指针

拷贝

有了上面的写,读 已经知道了拷贝的写法,这里我们假设分配的buffer很小,则需要分多次才能copy完成

// copy:  file_1.txt => file_2.txt
FileChannel fileChannel = new FileInputStream("file_channel_example.txt").getChannel();

// write
FileChannel writeChannel = new FileOutputStream("file_channel_example_copy.txt").getChannel();

// 只分配一块很小的 缓存 分多次读
ByteBuffer readBuffer = ByteBuffer.allocate(3);  // 1
int len = -1;
while ((len = fileChannel.read(readBuffer)) != -1) {  // 2
    readBuffer.flip();    // 3
    writeChannel.write(readBuffer);

    readBuffer.clear(); // 4
}
复制代码

零拷贝

FileChannel有一个省去中间buffer的方法,即我们所谓的 零拷贝

readChannel.transferTo(0, fis.available(), writeChannel);

writeChannel.transferFrom(readChannel, fis.available(), fis.available());
复制代码

总结

  1. channel的意义以及作用
  2. writable, readable, gatherting, Scattering 接口中新增的方法
  3. FileChannel的使用以及零拷贝

原文 

https://juejin.im/post/5ef0948ff265da02dc2d26f7

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » netty极简教程(三): nio Channel意义以及FileChannel使用

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址