引言

缓冲区是一个用于特定基本类型的容器。由java.nio 包定义，所有缓冲区都是 Buffer 抽象类的子类。

Java NIO 中的 Buffer ，主要用于与NIO 通道进行交互。数据从通道存入缓冲区，从缓冲区取出到通道中。

一、创建缓冲区

缓冲区的本质是数组，用于存储不同类型的数据，根据数据类型（boolean 除外），提供了相应类型的缓冲区，如ByteBuffer、IntBuffer等。这些缓冲区的管理方式都是类似的，都是通过 allocate() 方法指定容量并创建缓冲区。

// 创建一个 1 KB 大小的缓冲区
ByteBuffer buf = ByteBuffer.allocate(1024);

一般情况下，我们通过 allocate() 方法创建缓冲区，但是在需要高性能的地方，有时候往往需要使用 allocateDirect() 方法。

allocate() 创建非直接缓冲区，allocateDirect() 创建直接缓冲区。

二、缓冲区的四个核心属性

缓冲区的本质实际上是一个数组，最常用的ByteBuffer，本身就是一个 byte[] 数组，根据数据读取的场景，设计者为Buffer 设置了四个核心属性，定义在 Buffer 抽象类中：

private int mark = -1;
private int position = 0;
private int limit;
private int capacity;

缓冲区的操作实际上是借由这四个 int 标记来完成的，可以理解为抽象的指针。它们的关系如下：

0 <= mark <= position <= limit <= capacity

position 表示位置，表示当前程序正在操作的数据的下一个索引值。

mark 表示标记，通过 mark() 方法，记录当前数据的索引。可以通过 reset() 重新找到 mark 所指向的数据。

limit 界限，表示缓冲区中可以操作数据的大小，limit 后的数据不能进行读写。

capacity 缓冲区容量，因为缓冲区本身就是数组，因此一旦声明不能改变该值。

2.1 初始的指针状态

假设我们声明了一个 capacity 为 5 的字节缓冲区：

ByteBuffer buf = ByteBuffer.allocate(5);

那么，缓冲区的初始状态就是如下图所示：

2.2 当缓冲区中有数据的状态

由于缓冲区独特的构造，在读和写的时候，limit 与 position 指针是有一定区别的。

// 写模式
byteBuffer.put("Tom".getBytes());

// 读模式
byteBuffer.get();

三、缓冲区的核心方法

3.1 存取数据

缓冲区既然作为数据的容器，必然涉及到数据的存取操作，但要注意，存和取操作不可以连续执行，两个动作之间需要有一个 “翻转” 的操作。

put() 方法将数据放入到缓冲区中；get() 方法从缓冲区中取出数据。

3.2 flip()翻转、rewind()倒带、clear()清空

flip() : 翻转，将缓冲区进行读写切换。

rewind() : 倒带，可以将 position 和 limit 回退到上一次操作前。

clear() ：清空缓冲区，官方说明是“clears the buffer”，但详细解释是将 position 和 limit 恢复“出厂设置”，并丢弃 mark。注意，缓冲区中的数据并非清空，只是将两个指针重置，数据处在一种“被遗忘”状态，如果进行 get()操作依然可以取出。同时，clear 执行之后的缓冲区无法通过 rewind() 回退指针。

3.3 mark()标记、reset()定位

mark()方法可以记录当前 position 的位置，并可以通过 reset() 方法恢复到 mark()

3.4 hasRemaining()是否有未读数据、remaining()获取未读数据数量

hasRemaining() 用于判断读模式下的 Buffer 中是否还有未读数据；

remaining() 方法可以返回剩余可操作的元素个数。其值与 limit - position 的差值相等。

3.5 示例程序

从一开始创建一个 Buffer 开始，通过存入、读取数据来观察各个属性：capacity、limit、position、mark 等的变化。

创建：

// 分配 1 KB 大小的缓冲区
ByteBuffer byteBuffer = ByteBuffer.allocate(1024);
System.out.println("=============allocate()===========");
System.out.println("position = " + byteBuffer.position());
System.out.println("limit = " + byteBuffer.limit());
System.out.println("capacity = " + byteBuffer.capacity());

存数据：

System.out.println("=============put()===========");
String name = "abcde";
byteBuffer.put(name.getBytes());
System.out.println("position = " + byteBuffer.position());
System.out.println("limit = " + byteBuffer.limit());
System.out.println("capacity = " + byteBuffer.capacity());

反转：

System.out.println("============flip()===========");
byteBuffer.flip();
System.out.println("position = " + byteBuffer.position());
System.out.println("limit = " + byteBuffer.limit());
System.out.println("capacity = " + byteBuffer.capacity());

读数据：

System.out.println("============get()===========");
byte[] dst = new byte[byteBuffer.limit()];
byteBuffer.get(dst);
System.out.println("position = " + byteBuffer.position());
System.out.println("limit = " + byteBuffer.limit());
System.out.println("capacity = " + byteBuffer.capacity());
System.out.println(new String(dst));

倒带：

System.out.println("============rewind()===========");
byteBuffer.rewind();
System.out.println("position = " + byteBuffer.position());
System.out.println("limit = " + byteBuffer.limit());
System.out.println("capacity = " + byteBuffer.capacity());

清空：

System.out.println("============clear()===========");
byteBuffer.clear();
System.out.println("position = " + byteBuffer.position());
System.out.println("limit = " + byteBuffer.limit());
System.out.println("capacity = " + byteBuffer.capacity());

标记、定位标记：

ByteBuffer buf = ByteBuffer.allocate(5);
buf.put("abcde".getBytes());
buf.flip();
byte[] dst = new byte[buf.limit()];
buf.get(dst, 0, 2); // get(byte[] dst, int offset, int length)
System.out.println("第一次取出结果：" + new String(dst));
System.out.println("position：" + buf.position());
// mark()标记
buf.mark();
buf.get(dst, 2, 2); // get(byte[] dst, int offset, int length)
System.out.println("第二次取出结果：" + new String(dst));
System.out.println("position：" + buf.position());
// 恢复到mark
buf.reset();
System.out.println("reset 恢复到 mark 位置");
System.out.println("position：" + buf.position());

查询剩余数据：

// remaining() 获取缓冲区中还可以操作的数量
if (buf.hasRemaining()) {System.out.println(buf.remaining());System.out.println("limit - position = " + (buf.limit() - buf.position()));
}

四、直接缓冲区与非直接缓冲区

字节缓冲区要么是 直接缓冲区，要么是 非直接缓冲区。

非直接缓冲区属于常规操作，传统的 IO 流和 allocate() 方法分配的缓冲区都是非直接缓冲区，建立在 JVM 内存中。这种常规的非直接缓冲区会将内核地址空间中的内容拷贝到用户地址空间（中间缓冲区）后再由程序进行读或写操作，换句话说，磁盘上的文件在与应用程序交互的过程中会在两个缓存中来回进行复制拷贝。

而直接缓冲区绝大多数情况用于显著提升性能，缓冲区直接建立在物理内存（相对于JVM 的内存空间）中，省去了在两个存储空间中来回复制的操作，可以通过调用 ByteBuffer 的 allocateDirect() 工厂方法来创建。直接缓冲区中的内容可以驻留在常规的垃圾回收堆之外，因此它们对应用程序的内存需求量造成的影响可能并不明显。另外，直接缓冲区还可以通过 FileChannel 的 map() 方法将文件直接映射到内存中来创建，该方法将返回 MappedByteBuffer 。

直接或非直接缓冲区只针对字节缓冲区而言。字节缓冲区是那种类型可以通过 isDirect() 方法来判断。

注意！！！直接缓冲区性能虽然好，但是缓冲区直接建立在物理内存中，无法由 GC来释放，可控性差，同时分配和销毁成本很高！在对性能不是特别依赖的场景不建议使用！

Java NIO ———— Buffer 缓冲区详解相关推荐

java.nio.ByteBuffer常用方法详解
一.前言在Java nio中,主要有三大组件:Buffer,Channel和Selector.这三者之间的关系可以按照如下方式进行理解: Buffer提供了一个字节缓冲区,其可以不断的从Channe ...
Java NIO 底层原理详解
写在前面很多的小伙伴,被java IO 模型,搞得有点儿晕,一会儿是4种模型,一会儿又变成了5种模型. 很多的小伙伴,也被nio这个名词搞晕了,一会儿java 的nio 不叫非阻塞io,一会儿ja ...
java执行cmd命令详解
前言 Java应用程序主要是通过Runtime和Process两个类来执行cmd命令. Runtime.exec方法创建本机进程并返回Process子类的实例,该实例可用于控制进程并获取有关它的信息. ...
JAVA文件上传详解（附源码）
文章目录 JAVA文件上传详解(附源码) 1.准备工作 2.使用类介绍 FileItem类 ServletFileUpload类 3.代码编写 JAVA文件上传详解(附源码) 在web应用中,文件上传 ...
java.nio.Buffer flip()方法
碰到java.nio.Buffer flip()方法,不明白是干什么用的,于是就赶快查看中文API,API上面翻译的是:"反转此缓冲区.首先对当前位置设置限制,然后将该位置设置为零.如果已定 ...
java nio.Buffer的属性变化
java nio.Buffer的属性变化认识Buffer Channel 提供从文件.网络读取数据的渠道,但是读取或写入的数据都必须经由 Buffer.Buffer,实际上是一个连续数组. 常用的 ...
Java 内存模型 JMM 详解
转载自 Java 内存模型 JMM 详解 JMM简介 Java Memory Model简称JMM, 是一系列的Java虚拟机平台对开发者提供的多线程环境下的内存可见性.是否可以重排序等问题的无关具体 ...
java 8 新功能详解_Java 8的8个新功能
java 8 新功能详解注意:确保还检查了我们的详细教程Java 8 Features – ULTIMATE Guide . Jdk 1.8(又名Java 8)今天发布,这意味着它的通用发布版本已经 ...
Java内存模型(JMM)详解
在Java JVM系列文章中有朋友问为什么要JVM,Java虚拟机不是已经帮我们处理好了么?同样,学习Java内存模型也有同样的问题,为什么要学习Java内存模型.它们的答案是一致的:能够让我们更好的 ...

Java NIO ———— Buffer 缓冲区详解

引言