Java NIO （二）NIO Buffer类的重要方法

1 allocate()方法

? ? ? ? 在使用Buffer实例前，我们需要先获取Buffer子类的实例对象，并且分配内存空间。需要获取一个Buffer实例对象时，并不是使用子类的构造器来创建，而是调用子类的allocate()方法。

public class AllocateTest {
    static IntBuffer intBuffer = null;//一个整型的Buffer静态变量
    public static void main(String[] args) {
        //创建一个intbuffer 实例对象
        intBuffer = IntBuffer.allocate(20);
        System.out.println("afer allocate ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
    }
}

? ? ? ? 本例中，IntBuffer是具体的Buffer子类，通过调用IntBuffer.allocate(20)创建了一个intBuffer实例对象，并且分配了20*4字节的内存空间。运行程序后，通过输出结果，可以查看一个新建缓冲区实例对象的主要属性值。

? ? ? ? 从上面的运行结果可以看出：一个缓冲区在新建后处于写模式，position属性（代表写入位置）的值是0，缓冲区的capacity值是初始化时allocate方法的参数值，而limit最大可写上限值也为allocate方法的初始化参数值。

2 put()方法

? ? ? ? 在调用allocate方法分配内存、返回了实例对象后，缓冲区实例对象处于写模式，可以写入对象，如果要把对象写入缓冲区，就需要调用put()方法。put方法很简单，只有一个参数，即需要写入的独享，只不过要求写入的数据类型与缓冲区的类型保持一致。接着上面的例子向刚刚创建的intBuffer缓存实例对象写入5个整数。

public class AllocateTest {
    static IntBuffer intBuffer = null;//一个整型的Buffer静态变量
    public static void main(String[] args) {
        //创建一个intbuffer 实例对象
        intBuffer = IntBuffer.allocate(20);
        System.out.println("before put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        for (int i = 0; i < 5; i++) {
            intBuffer.put(i);
        }
        System.out.println("after put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
    }
}

?

? ? ? ? 从结果可以看到，写入了5个元素后，缓冲区的position属性值变成了5，所以指向了第6个（从0开始）可以进行写入的元素位置。limit、capacity两个属性的值没有发生变化。

3 flip()方法?

? ? ? ? 向缓冲区写入数据之后，是否可以直接从缓冲区读取数据呢？答案是否定的。这时缓冲区还处于写模式，如果需要读取数据，要将缓冲区转换成读模式。flip()翻转方法是Buffer类提供的一个模式转变的重要方法，作用是将写模式转换成读模式。接着前面的例子演示flip()方法。

public class AllocateTest {
    static IntBuffer intBuffer = null;//一个整型的Buffer静态变量
    public static void main(String[] args) {
        //创建一个intbuffer 实例对象
        intBuffer = IntBuffer.allocate(20);
        System.out.println("before put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        for (int i = 0; i < 5; i++) {
            intBuffer.put(i);
        }
        System.out.println("after put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.flip();
        System.out.println("after flip ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
    }
}

? ? ? ? 调用flip方法后，新模式可读上限limit的值变成了之前写模式下的position的值，也就是5；而新模式下的position的值变成了0，表示从头开始读取。

? ? ? ? 对flip()方法从写入到读取转换的规则，再一次详细介绍：

? ? ? ? 首先，设置可读上限limit的属性值。将写模式下的缓冲区中内容的最后写入位置position的值作为读模式下的limit上限值。

? ? ? ? 其次，把读的起始位置position的值设为0，表示从头开始读。

? ? ? ? 最后，清除之前的mark标记，因为mark保存的是写模式下的临时位置，发生模式转换后，如果继续使用旧的mark标记，就会造成位置混乱。

? ? ? ? 上面三步可以查看Buffer.flip()方法的源码，具体如下：

 public Buffer flip() {
        //设置可读上限limit，设置为写模式下的position值
        limit = position;
        //把读的起始位置position的值设为0，表示从头开始读
        position = 0;
        //清除之前的mark标记
        mark = -1;
        return this;
   }

? ? ? ? ?新的问题来了：在读取完后，如果再一次将缓冲区切换成写模式呢？答案是：可以调用Buffer.clear()清空或者Buffer.compact()压缩方法，它们可以将缓冲区切换为写模式。

4 get()方法

? ? ? ? 调用flip()方法将缓冲区切换成读模式后，就可以开始从缓冲区读取数据了。读取数据的方法很简单，可以调用get()方法从position的位置读取一个数据，并且进行相应的缓冲区属性的调整。接着前面调用flip()方法的实例，演示缓冲区的读取操作。

public class AllocateTest {
    static IntBuffer intBuffer = null;//一个整型的Buffer静态变量
    public static void main(String[] args) {
        //创建一个intbuffer 实例对象
        intBuffer = IntBuffer.allocate(20);
        System.out.println("before put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        for (int i = 0; i < 5; i++) {
            intBuffer.put(i);
        }
        System.out.println("after put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.flip();
        System.out.println("after flip ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        //先读取两个数据
        for (int i = 0; i < 2; i++) {
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after get 第一次 ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        //再读取三个数据
        for (int i = 0; i < 3; i++) {
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after get 第二次 ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
    }
}

? ? ? ? 从输出看到，读取操作会改变可读位置position的值，而可读上限limit的值不会改变。在position值和limit值相等时，表示所有数据读取完成，position指向了一个没有数据的元素位置，已经不能在读了。这里强调一下，在读完之后是否可以立即对缓冲区进行数据写入呢？答案是不能。现在还处于读模式，必须调用clear()或compact()方法，即清空或压缩缓冲区，将缓冲区切换成写模式。

5 rewind()方法

? ? ? ? 已经读完的数据，如果需要再读一遍，可以调用rewind()方法。rewind()方法也叫倒带，就像播放磁带一样，再重新播放。接着前面的代码，继续rewind()方法使用的演示。

public class AllocateTest {
    static IntBuffer intBuffer = null;//一个整型的Buffer静态变量
    public static void main(String[] args) {
        //创建一个intbuffer 实例对象
        intBuffer = IntBuffer.allocate(20);
        System.out.println("before put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        for (int i = 0; i < 5; i++) {
            intBuffer.put(i);
        }
        System.out.println("after put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.flip();
        System.out.println("after flip ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        //先读取两个数据
        for (int i = 0; i < 2; i++) {
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after get 第一次 ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        //再读取三个数据
        for (int i = 0; i < 3; i++) {
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after get 第二次 ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.rewind();
        System.out.println("after rewind -- ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
    }
}

?

? ? ? ? rewind()方法主要是调整了缓冲区的position属性与mark属性，调整规则如下：

? ? ? ? 1、position重置为0，所以可以重读缓冲区的所有数据。

? ? ? ? 2、limit保持不变，数据量还是一样的，仍然可以从缓冲区读取的元素数量。

? ? ? ? 3、mark被清理，表示之前的临时位置不能再用了。

? ? ? ? rewind()源码如下：

public Buffer rewind() {
        //重置为0，所以可以重读缓冲区中的所有数据
        position = 0;
        //mark被清理，表示之前的临时位置不能再用了
        mark = -1;
        return this;
    }

? ? ? ? ?通过源码可以看到rewind()和flip()方法很像，区别在于：rewind()方法不会影响limit属性值；而flip()方法会重设limit属性值。

6 mark()和reset()方法

? ? ? ? mark()和reset()方法是配套使用的：mark()方法将当前position的值保存起来放在mark属性中，让mark属性记住这个临时位置；然后可以调用reset()方法将mark的值恢复到position中。

? ? ? ? 例如，在前面重复读取的示例代码中，在读到第三个元素（i=2时）时，可以调用mark方法，把当前位置position的值保存到mark属性中，这时mark属性值是2。

? ? ? ? 接下来可以调用reset()方法，将mark属性的值恢复到position中，这样就可以从位置2（第三个元素）开始重复读取了。

public class AllocateTest {
    static IntBuffer intBuffer = null;//一个整型的Buffer静态变量
    public static void main(String[] args) {
        //创建一个intbuffer 实例对象
        intBuffer = IntBuffer.allocate(20);
        System.out.println("before put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        for (int i = 0; i < 5; i++) {
            intBuffer.put(i);
        }
        System.out.println("after put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.flip();
        System.out.println("after flip ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        //先读取两个数据
        for (int i = 0; i < 2; i++) {
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after get 第一次 ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        //再读取三个数据
        for (int i = 0; i < 3; i++) {
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after get 第二次 ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.rewind();
        System.out.println("after rewind -- ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        for (int i = 0; i < 5; i++) {
            if(i == 2){
                intBuffer.mark();
            }
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after mark -- ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.reset();
        for (int i = 2; i < 5; i++) {
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after reset -- ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
    }
}

? ? ? ? 在上面的代码中，首先调用reset方法把mark中的值恢复到position中，因此读取的位置position就是2，表示可以再次开始从第三个元素开始读取数据。调用reset方法后，position的值是2，此时去读取缓冲区，输出后面的三个元素2 、3 、4。

7 clear()方法

? ? ? ? 在读模式下，调用clear方法将缓冲区切换成写模式。此方法的作用是：

? ? ? ? （1）将position清零。

? ? ? ? （2）limit设置为capacity最大容量值，可以一直写入，直到缓冲区写满。

? ? ? ? 接着上面的示例，调用clear方法。

????????

public class AllocateTest {
    static IntBuffer intBuffer = null;//一个整型的Buffer静态变量
    public static void main(String[] args) {
        //创建一个intbuffer 实例对象
        intBuffer = IntBuffer.allocate(20);
        System.out.println("before put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        for (int i = 0; i < 5; i++) {
            intBuffer.put(i);
        }
        System.out.println("after put ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.flip();
        System.out.println("after flip ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        //先读取两个数据
        for (int i = 0; i < 2; i++) {
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after get 第一次 ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        //再读取三个数据
        for (int i = 0; i < 3; i++) {
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after get 第二次 ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.rewind();
        System.out.println("after rewind -- ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        for (int i = 0; i < 5; i++) {
            if(i == 2){
                intBuffer.mark();
            }
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after mark -- ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.reset();
        for (int i = 2; i < 5; i++) {
            int j = intBuffer.get();
            System.out.println("j = " + j);
        }
        System.out.println("after reset -- ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
        intBuffer.clear();
        System.out.println("after clear -- ----------------");
        System.out.println("position = " + intBuffer.position());
        System.out.println("limit = " + intBuffer.limit());
        System.out.println("capacity = " + intBuffer.capacity());
    }
}

?

? ? ? ? 在缓冲区处于读模式时，调用clear方法，缓冲区被切换成写模式，可以看到清空了position的值，值被设置为0，?并且limit值为最大容量。

8 使用Buffer类的基本步骤

? ? ? ? 总体来说，使用Java NIO Buffer类的基本步骤如下：

? ? ? ? （1）使用创建子类实例对象的allocate()方法创建一个Buffer类的实例对象。

? ? ? ? （2）调用put()方法将数据写入缓冲区。

? ? ? ? （3）写入完成后，再开始读取数据之前调用flip()方法，将缓冲区切换成读模式。

? ? ? ? （4）调用get()方法，可以从缓冲区读取数据。

? ? ? ? （5）读取完成后，调用clear()或compact()方法，将缓冲区从读模式切换成写模式，可以继续写入数据。

?