转载

netty极简教程(二): nio Buffer的原理及使用

我们知道,netty直接与jdk的原生nio开发的,可以说是jdk nio的增强,所以理解jdk nio的机制就变得非常重要,接下来将介绍jdk中关于nio的几个非常重要的组件, 示例源码: github.com/jsbintask22…

ByteBuffer介绍

对比jdk bio的写法,在从Socket读取数据的时候,不管是客户端还是服务端,我们通常需要将字节读取到一个字节数组,知道读取的数据长度满足所需要的条件:

netty极简教程(二): nio Buffer的原理及使用
InputStream is = socket.getInputStream();
byte[] buff = new byte[1024];
int len;

while ((len = is.read(buff)) != -1) {
    System.out.println("client msg: " + new String(buff, 0, len));
}
复制代码

这里的 buff 我们就可以认为是一个数据容器,后续的其他处理(比如这里的 new String)都会从这个数据容器中取。

而在nio编程中,这个字节数组改为了一个可重复使用的容器 Buffer(java.nio.Buffer) ,它有多种同类型的基本类型子类,它的结构如下:

netty极简教程(二): nio Buffer的原理及使用
假设有一个长度为 n

的容器。

  1. position指针代表洗一个可以读或者可以写入的位置索引,初始状态则指向0
  2. limit代表 下一个 不能写入或者读取的位置,初始位置则指向n(注意索引是从0开始的)
  3. capacity总是表示容器的大小,总是为n
  4. mark作为一个标志为,当调用mark()方法时,会将position赋值给mark, 这样在下次调用reset()方法的时候可以让position回到上次标志的位置 有了以上这些,在写入或者读取时总是会移动position的位置,而如果想重置复原则需要移动. 它们直接总是会满足这样的关系: mark <= position <= limit <= capacity

这里指的注意的是 position 代表的是下一个可以读或者可以写的位置,所以读写均会移动位置。

Buffer使用

以IntBuffer为例,介绍下它的使用,IntBuffer继承自Buffer,内部使用一个整型数组存储数据 final int[] hb;

  1. 向容器中存储数据: put(int i); , put(int index, int i); 从指定位置的存储不会移动 position 指针的位置。
  2. 获取数据: int get(); , int get(int index); 从指定索引位置获取数据不会移动 positon 位置.
  3. 检查是否有有效数据: 检查position 是否小于limit即可 . return position < limit;
IntBuffer intBuffer = IntBuffer.allocate(10); // 1
for (int i = 0; i < intBuffer.capacity(); i++) {
    intBuffer.put((i + 1));  // 2
}

intBuffer.flip();  // 3
while (intBuffer.hasRemaining()) {  // 4
    int i = intBuffer.get();  // 5
    System.out.println(i);
}

intBuffer.rewind();
while (intBuffer.hasRemaining()) {
    int i = intBuffer.get();
    System.out.println(i);
}
复制代码
limit = position; position = 0; remark = -1;

最后介绍下 rewind, flip, clear 三个方法的区别

position = 0; limit = capacity; mark = -1;
limit = position; position = 0; remark = -1;
position = 0; mark = -1;
原文  https://juejin.im/post/5ef093bfe51d45741c5432e8
正文到此结束
Loading...