转载

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的使用以及接口实现作用

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
复制代码

通过FileChannel open方法获取代表该文件连接的channel
从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
复制代码

将channel的数据读取都buffer
直接获取buffer中的字节数据打印
利用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());
复制代码

总结

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

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

正文到此结束

所属分类：编程技术 Java

本文标签： 源码 cat src java example stream js 总结缓存 https 代码 BIO git GitHub IO ip Netty NIO db 数据 http tab UI ask
版权声明： 本文为互联网转载文章，出处已在文章中说明(部分除外)。如果侵权，请联系本站长删除，谢谢。
本文海报： 生成海报一生成海报二

其他链接

关于本站

本站定位：个人技术类博客

本站作用：写博客、记日志、闲聊扯淡鼓捣技术。

问题交流

netty极简教程（三）： nio Channel意义以及FileChannel使用

Channel介绍

FileChannel使用

写入数据

读取数据

拷贝

零拷贝

总结

热门推荐

相关文章

说给你听

本文目录

随机标签

书籍教程

近期评论

网站信息

其他链接

关于本站

问题交流