标签:导致 read set equal 定义 index channel 之间 存储
从jdk1.4开始,java中引入了nio包,提供了非阻塞式的网络编程模型,提供网络性能。nio中核心组件有三个:channel、buffer、selector。这里主要探讨buffer的概念和使用。buffer本质上是数据容器,可以存储java中的各种原始数据类型,并提供了读、写等各种操作。
buffer是一个数据容器,确切的说是存储原始数据类型的数据容器(除了boolean类型)。
三者之间的关系: mark<= position <= limit <= capacity
buffer中的get和put操作分为两类:相对get/put操作(relative get/put operation)和绝对get/put操作(absolute get/put operation)。
get和put操作是在Buffer的子类中定义的。
capacity():获取buffer的容量
position():获取当前的position值
limit():获取当前的limit值
mark():设置mark变量的值,mark=position
reset():重置position,position=mark
clear():清空buffer,position=0, limit=capacity, mark=-1。该方法通常在使用通道读取数据或者put操作填充buffer之前调用。 注意:该方法并不会真的删除buffer中的数据。
flip():翻转buffer,limit=position, position=0, mark=-1。执行该方法为读取数据做准备。
rewind():执行该方法后,position=0, mark=-1,通常用于重新读取buffer中的数据。
remaining():获取buffer中的元素数量(limit-position)。
array():获取buffer中的数组。注意:如果改变buffer中的元素,会影响返回的数组中元素,反之亦然。
这里我以CharBuffer为例,解释buffer中的常见操作,以及容器是如何变化的。
下图展示了put(char c)操作(relative operation)引起的一些列变化,
(1)首先新建一个容量为5的buffer,次数position=0,limit=5(图中未标出来);
(2)第1次调用 put(char c),写入元素a,此时position变为1,limit不变;
(3)第2次调用put(char c),写入元素b,此时position变为2,limit不变;
(4)第2次调用put(char c),写入元素c,此时position变为3,limit不变;
(5)第2次调用put(char c),写入元素d,此时position变为4,limit不变;
(6)第2次调用put(char c),写入元素e,此时position变为5,limit不变(limit=position)
接下来演示flip()操作和get操作(relative operation)给buffer容器带来的变化
(1)执行flip()操作后,position=0,limit=5;
(2)执行get()操作后,返回元素a,position=1,limit=5;
(3)执行get()操作后,返回元素b,position=2,limit=5;
(4)执行get()操作后,返回元素c,position=3,limit=5;
(5)执行get()操作后,返回元素d,position=4,limit=5;
(6)执行get()操作后,返回元素e,position=5,limit=5;
注意:执行get()操作,容器内的元素并不会被删除。
绝对get和put操作我就不在这里演示了,只要容器里存在元素,你随时可以通过绝对get和put操作,读取、写入元素。
注意:绝对get和put操作不会抛出BufferUnderflowException和BufferOverflowException。
如果这时我们对buffer容器执行rewind()或者clear()操作,容器变化如下:
执行rewind操作后,position=0,limit保持不变(=5),容器内元素又变得可以读取了。因此,当我们想要重复读取容器内元素的时候,就可以借助rewind()来帮助我们达成目的。
注意:执行clear()操作后,position=0,limit=capacity=5,虽然这个时候我们仍然可以对buffer容器执行get操作,但是我们不应该这么做!!clear操作的目的是清空缓存区,为之后的channel-read或put操作服务的,使得它们可以再次填充buffer容器。
接下来我们再来看一下mark和reset操作,假设容器内部情况如下图:
容器内又五个元素,position=0,limit=5,接下来我们依此对容器执行下述几步操作:
get() ==> get() ==> mark() ==> get() ==> get() ==> reset() ==> get() ==> get()
容器变化情况如下图所示:
可以看到,通过mark和reset,我们可以重复读取某一区间内的元素。
CharBuffer buffer = CharBuffer.allocate(5);
char[] chars = buffer.array();
System.out.println(String.format("未存储任何元素之前,limit=%d, position=%d, chars=%s", buffer.limit(), buffer.position(), Arrays.toString(chars)));
// 写入第1个元素
buffer.put(‘a‘);
System.out.println(String.format("写入1个元素之后,limit=%d, position=%d, chars=%s", buffer.limit(), buffer.position(), Arrays.toString(chars)));
// 写入第2个元素
buffer.put(‘b‘);
System.out.println(String.format("写入2个元素之后,limit=%d, position=%d, chars=%s", buffer.limit(), buffer.position(), Arrays.toString(chars)));
// 写入第3个元素
buffer.put(‘c‘);
System.out.println(String.format("写入3个元素之后,limit=%d, position=%d, chars=%s", buffer.limit(), buffer.position(), Arrays.toString(chars)));
// 写入第4个元素
buffer.put(‘d‘);
System.out.println(String.format("写入4个元素之后,limit=%d, position=%d, chars=%s", buffer.limit(), buffer.position(), Arrays.toString(chars)));
// 写入第5个元素
buffer.put(‘e‘);
System.out.println(String.format("写入5个元素之后,limit=%d, position=%d, chars=%s", buffer.limit(), buffer.position(), Arrays.toString(chars)));
/*
// 如果继续往容器中写入元素,buffer会抛出BufferOverflowException
buffer.put("f"); // 执行这行代码会抛出BufferOverflowException异常
*/
// 执行flip操作,为读取buffer中的数据做准备
buffer.flip();
System.out.println("\n执行flip操作后---------------");
System.out.println(String.format("未读取任何元素之前,limit=%d, position=%d", buffer.limit(), buffer.position()));
System.out.println(String.format("读取1个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取2个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取3个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取4个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取5个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
// buffer.get(); // 执行这行代码会抛出BufferUnderflowException
// 执行rewind操作,重新读取buffer中的数据
buffer.rewind();
System.out.println("\n执行rewind操作后---------------");
System.out.println(String.format("未读取任何元素之前,limit=%d, position=%d", buffer.limit(), buffer.position()));
System.out.println(String.format("读取1个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取2个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取3个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取4个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取5个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println("\n测试absolute put/get operation");
System.out.println(buffer.get(0));
buffer.put(0, ‘s‘);
System.out.println(buffer.get(0));
System.out.println(String.format("limit=%d, position=%d", buffer.limit(), buffer.position()));
// 执行clear操作后,不应该再调用get()方法获取容器内元素!
/*
buffer.clear();
System.out.println(String.format("未读取任何元素之前,limit=%d, position=%d", buffer.limit(), buffer.position()));
System.out.println(String.format("读取1个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取2个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取3个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取4个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
System.out.println(String.format("读取5个元素之后,limit=%d, position=%d,当前读取的元素:%s", buffer.limit(), buffer.position(), buffer.get()));
*/
System.out.println("\n测试mark、reset");
buffer.rewind(); // 调用rewind,使得我们可以重新读取buffer中的元素
Assert.assertEquals(‘s‘, buffer.get());
Assert.assertEquals(‘b‘, buffer.get());
buffer.mark(); // mark=2,position=2
Assert.assertEquals(‘c‘, buffer.get());
Assert.assertEquals(‘d‘, buffer.get());
buffer.reset(); // position重新指向2,即position=2
Assert.assertEquals(‘c‘, buffer.get());
Assert.assertEquals(‘d‘, buffer.get());
标签:导致 read set equal 定义 index channel 之间 存储
原文地址:https://www.cnblogs.com/leekeggs/p/13379894.html