《精通并发与Netty》学习笔记（15 - 详解NIO中Buffer之position,limit,capacity）

1、前言
熟悉NIO的人想必必定不会陌生buffer中position,limit,capacity这三个属性吧，以前在学习的时候遇到一个问题:就是当你先往缓冲区写入一部分数据，而后调用flip()方法，再所有读取完数据，而后再调用flip()方法，此时这三个值的变化是怎样的，研究了一下，决定写下来分享一下。

2、正文
一、介绍

position： 它指的是下一次读取或写入的位置。

limit： 指定还有多少数据须要写出(在从缓冲区写入通道时)，或者还有多少空间能够读入数据(在从通道读入缓冲区时)，它初始化是与capacity的值同样，当调用flip()方法以后，它的值会改变成position的值，而position被置0。它箭头所指的位置是最后一位元素的下一位所在的位置*

capacity： 指定了能够存储在缓冲区中的最大数据容量，实际上，它指定了底层数组的大小，或者至少是指定了准许咱们使用的底层数组的容量，这个初始化后就不会再改变了。

二、图示

以上三个属性值之间有一些相对大小的关系：0 <= position <= limit <= capacity。若是咱们建立一个新的容量大小为7的ByteBuffer对象，在初始化的时候，position设置为0，limit和 capacity被设置为7，在之后使用ByteBuffer对象过程当中，capacity的值不会再发生变化，而其它两个个将会随着使用而变化。三个属性值分别如图所示：

初始化：

 

假设咱们如今要往这个缓冲区里面写入3个字节，写完以后，position的箭头就会指向3的位置，而limit不变：

     

此时咱们想从缓冲区读取这3个字节，就必须调用flip()方法，调用了flip()方法事后，limit置为position的位置，而position被置为0，也正应证了上面所说的，position它指的是下一次读取或写入的位置，limit它箭头所指的位置是最后一位元素的下一位所在的位置：

 

如今咱们能够调用get()方法，一直从缓冲区里面取数据，直到取完为止，也就是当position与limit的值同样时，就取完了：   

 
这一次简单的读写操做就完成了，若是想恢复成初始状态的话，能够调用clear()方法：

以前学到这里的时候有个疑问，不知道你们想过没有，就是咱们在调用了get()方法从缓冲区取完里面的数据，立马去调用flip()方法，那这三个属性的值会是什么变化？若是当我只读了2个字节的数据以后，就不读了，而后再去调用flip()，这三个值又会是怎么变化？其实无论怎么绕，你只要懂得原理，就不难，我们先看flip()源代码作了什么：

public final Buffer flip() {
limit = position;
position = 0;
mark = -1;
return this;
}

这里不难发现，调用flip()方法，无非就是给这几个变量赋值，将当前的position值赋给limit，而后将position的值置为0，Mark是一个标志变量，我们之后会提到。熟悉以上代码就不难解决我提出的2个问题：

当你读取完调用flip()的方法 positon:0 limit:3 capacity:7
当你读取2个字节以后调用flip()方法 positon:0 limit:2 capacity:7

这里就解决了我以前遇到的这三个属性值变化的问题！！！

3、测试代码
读取完调用flip：

package com.cing.nio;

import java.io.FileInputStream;
import java.nio.Buffer;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;

public class NioTest1 {
public static void main(String[] args) throws Exception{

FileInputStream fis = new FileInputStream("D:\\A.txt");
FileChannel fc = fis.getChannel();

ByteBuffer buffer = ByteBuffer.allocate(7);
output("初始化", buffer);

fc.read(buffer);
output("调用READ方法", buffer);

buffer.flip();
output("第一次调用flip", buffer);

while (buffer.remaining() > 0) {
byte b = buffer.get();
}
output("get()", buffer);

buffer.flip();
output("第二次flip", buffer);

fis.close();
}

public static void output(String step, Buffer buffer) {
System.out.println(step + " : ");
System.out.println("buffer: " + buffer + ", ");
}
}

输出结果为：

初始化 : 
buffer: java.nio.HeapByteBuffer[pos=0 lim=7 cap=7], 
调用READ方法 : 
buffer: java.nio.HeapByteBuffer[pos=3 lim=7 cap=7], 
第一次调用flip : 
buffer: java.nio.HeapByteBuffer[pos=0 lim=3 cap=7], 
get() : 
buffer: java.nio.HeapByteBuffer[pos=3 lim=3 cap=7], 
第二次flip : 
buffer: java.nio.HeapByteBuffer[pos=0 lim=3 cap=7], 

读取2字节以后调用flip：

package com.cing.nio;

import java.io.FileInputStream;
import java.nio.Buffer;
import java.nio.ByteBuffer;
import java.nio.channels.FileChannel;

public class NioTest1 {
public static void main(String[] args) throws Exception{

FileInputStream fis = new FileInputStream("D:\\A.txt");
FileChannel fc = fis.getChannel();

ByteBuffer buffer = ByteBuffer.allocate(7);
output("初始化", buffer);

fc.read(buffer);
output("调用READ方法", buffer);

buffer.flip();
output("第一次调用flip", buffer);

while (buffer.remaining() > 1) {
byte b = buffer.get();
}
output("get()", buffer);

buffer.flip();
output("第二次flip", buffer);

fis.close();
}

public static void output(String step, Buffer buffer) {
System.out.println(step + " : ");
System.out.println("buffer: " + buffer + ", ");
}
}

输出结果为：

初始化 : 
buffer: java.nio.HeapByteBuffer[pos=0 lim=7 cap=7], 
调用READ方法 : 
buffer: java.nio.HeapByteBuffer[pos=3 lim=7 cap=7], 
第一次调用flip : 
buffer: java.nio.HeapByteBuffer[pos=0 lim=3 cap=7], 
get() : 
buffer: java.nio.HeapByteBuffer[pos=2 lim=3 cap=7], 
第二次flip : 
buffer: java.nio.HeapByteBuffer[pos=0 lim=2 cap=7],