当前位置：移动技术网 > IT编程>开发语言>Java > JavaNIO第一话-Buffer

JavaNIO第一话-Buffer

2020年01月02日 | 移动技术网IT编程 | 我要评论

buffer是入门java nio的基础，本文希望通过一些形象的比喻来解释一下缓冲区的概念，帮助读者快速理解和记忆。

本文灵感来自于bilibili博主v若水若水分享的尚硅谷java视频_nio视频教程,有需要看视频学习的朋友可以在bilibili上搜索java nio找到相关视频学习。

本文中的英文摘自java.nio中相关类的注释。

buffer是什么？

a container for data of a specific primitive type.

buffer是特定基本类型数据的容器。

我愿意把buffer比作火车。

buffer能装什么？

buffer子类

buffer能装int，float，char，double，short，long，byte
buffer不能装boolean

整数	浮点数	字符	字节数
byte（8位）			1字节
short（16位）		char（16位）	2字节
int（32位）	float（32位）		3字节
long（64位）	double（64位）		4字节

buffer的重要属性及对应的获取方法

the essential properties of a buffer are its capacity, limit, and position

capacity，容量。火车有 n 节车厢
position，位置。这里需要再假想一辆小车，行驶在火车旁边的站台上。position表示当前小车停留在第 n 节车厢前。
limit，限制。火车的前 n 节车厢。

属性	属性获取方法
capacity	public final int capacity()
position	public final int position()
limit	public final int limit()

接下来的讨论都会紧紧围绕这三个属性

安排一列火车-allocate

以最常用的bytebuffer为例：

/**
 * 分配一个新的字节缓冲区。
 * <p>新缓冲区的位置position将为零，其限制limit等于
 * 容量capacity，其标记mark将是不确定的，并且其每个元素将是
 * 初始化为零。 它将有一个{@link #array backing array}，
 *，其{@link #arrayoffset array offset}将为零。
 */
public static bytebuffer allocate(int capacity) {
    if (capacity < 0)
        throw new illegalargumentexception();
    return new heapbytebuffer(capacity, capacity);
}

可以看到allocate方法会使用heapxxxbuffer类来实例化。
allocate将分配一个指定容量的缓冲区。存储哪类基本数据类型，这取决于你使用哪类buffer。

测试代码：

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    system.out.println(buffer.capacity());
    system.out.println(buffer.limit());
    system.out.println(buffer.position());
}

控制台输出：

1024
1024
0

通俗解释：
安排一辆1024节车厢的火车。容量为1024节车厢，允许装货1024节车厢，现在小车停在第0节车厢上。

学过数组的都知道，计算机中，一个长度为1024的数组下标是从0到1023

装货-put

装单个"货"

测试用例1

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.put((byte) 'a');
    system.out.println(buffer.capacity());
    system.out.println(buffer.limit());
    system.out.println(buffer.position());
}

控制台输出

1024
1024
1

通俗解释
把 a 装到火车的第 0 号车厢，成功装上之后，小车向前移了一个节车厢，停在了第 1 号车厢。

这里实际上装进bytebuffer的是由 a 转化得到的 8 位二进制数（01100001）。
8 位二进制正好就是1个字节。
a 是怎么得到二进制数的？这个问题可以查看ascii码表

测试用例2

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.put(11, (byte) 'a');
    system.out.println(buffer.capacity());
    system.out.println(buffer.limit());
    system.out.println(buffer.position());
}

控制台输出

1024
1024
0

结论
put(byte)会使得position发生改变，但是put(index, byte)不会使position发生改变

装一组"货"

测试代码

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.put("abcd".getbytes());
    system.out.println(buffer.capacity());
    system.out.println(buffer.limit());
    system.out.println(buffer.position());
}

控制台输出

1024
1024
4

通俗解释
把[a，b，c，d]依次装到火车的第 0, 1, 2, 3 号车厢，现在车厢旁边的小车停在 4 号车厢前。

这里实际上装进bytebuffer的是由 a，b，c，d 转化得到的二进制数。

结论
无论是put一个字节（byte）还是一个字节数组（byte[]），put成功后position都会向后移动。

装货时超载-bufferoverflowexception

测试代码

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.limit(2);
    system.out.println(buffer.capacity());
    system.out.println(buffer.limit());
    system.out.println(buffer.position());

    buffer.put("abc".getbytes());
}

控制台输出

1024
2
0
exception in thread "main" java.nio.bufferoverflowexception
at java.nio.heapbytebuffer.put(heapbytebuffer.java:189)
at java.nio.bytebuffer.put(bytebuffer.java:859)
at nio.main.main(main.java:14)

通俗解释
虽然这列火车有1024节车厢，但是规定 只能装在前2节车厢内 。因此当你同时派来了 3 辆小车，分别装着 a，b，c，从 0 号车厢排列到 2 号车厢，当你想同时装货到火车上的时候，你被列车管理员拒绝了，理由是你超载了！因此，现在*** a，b，c全都没装上火车 ***。

代码

public bytebuffer put(byte[] src, int offset, int length) {
    checkbounds(offset, length, src.length);
    if (length > remaining())
        throw new bufferoverflowexception();
    int end = offset + length;
    for (int i = offset; i < end; i++)
        this.put(src[i]);
    return this;
}

public final bytebuffer put(byte[] src) {
    return put(src, 0, src.length);
}

结论：全装or全部不给装
这里是先校验，后写入数据。要么全都正常写入，要么一个也不会写入。

可重复读-get

读单个

测试用例1

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.put((byte) 'a');
    system.out.println(buffer.get(0));
    system.out.println(buffer.position());
    system.out.println(buffer.get(0));
    system.out.println(buffer.position());
}

控制台输出

97
1
97
1

结论
get(index)不会改变position的位置，且可以重复读，读取结果总是一样的。

测试用例2

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.put("abcd".getbytes());
    system.out.println(buffer.position());

    byte[] bytes = new byte[2];
    buffer.get(bytes);
    system.out.println(arrays.tostring(bytes));
    system.out.println(buffer.position());
}

控制台输出

4
[0, 0]
6

通俗解释
在装货 [a, b, c, d] 之后，小车的位置已经移动到4号车厢前（第5节车厢），此时是不能从当前车厢读取到有效的货物信息的。另外，小车因为成功读取了2个车厢的货物信息（虽然结果为0），小车的位置已经发生了改变，目前小车移动到了6号车厢前（第7节车厢）。

如何让小车回到起始位置呢？

flip

/**
 * 在执行一系列<i> put </ i>操作之后，调用此方法以准备一系列相对
 * 的<i> get </ i>操作。
 */
public final buffer flip() {
    limit = position;
    position = 0;
    mark = -1;
    return this;
}

rewind

/**
 * 假设已正确设置了限制，请在执行一系列<i> get </ i>操作之前调用此方法。
 */
public final buffer rewind() {
    position = 0;
    mark = -1;
    return this;
}

clear

/**
 * 在使用一系列<i> put </ i>操作填充此缓冲区之前，请调用此方法。
 */
public final buffer clear() {
    position = 0;
    limit = capacity;
    mark = -1;
    return this;
}

结论
flip()和rewind()相同点，都是在准备调用get之前调用。
flip()和rewind()不同点，rewind需要用户事先确保limit正确。
clear()用于在准备重新调用put之前调用。

再探get

测试用例

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.put("abcd".getbytes());
    system.out.println(buffer.position());

    byte[] bytes = new byte[2];
    buffer.flip();
    buffer.get(bytes);
    system.out.println(arrays.tostring(bytes));
    system.out.println(buffer.position());

    buffer.rewind();
    buffer.get(bytes);
    system.out.println(arrays.tostring(bytes));
    system.out.println(buffer.position());
}

控制台输出

4
[97, 98]
2
[97, 98]
2

结论
在调用get(byte[])之前事先调用flip()则此次可以正常读取数据到数组中。调用rewind()则可以“倒带”(我愿意理解成把小车开回原点)，又可以再次读取。

小车越界-bufferunderflowexception

测试代码

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.put("abcd".getbytes());
    system.out.println(buffer.position());

    byte[] bytes = new byte[6];
    buffer.flip();
    buffer.get(bytes);
}

控制台输出

exception in thread "main" java.nio.bufferunderflowexception
at java.nio.heapbytebuffer.get(heapbytebuffer.java:151)
at java.nio.bytebuffer.get(bytebuffer.java:715)
at nio.main.main(main.java:15)

通俗解释
在调用flip()之后，列车管理员规定小车最多只能移到到4号车厢前面，因为只有0号到3号车厢装有货物可以读到货物信息，即只有4节车厢中是含有货物信息的，而小车却想获取6节车厢中货物信息，结果被列车管理员告知你越界了！

小车越界可不同于数组越界-indexoutofboundsexception

测试代码

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.put("abcd".getbytes());

    byte[] bytes = new byte[6];
    buffer.flip();
    buffer.get(bytes, 0, 7);
}

控制台输出

exception in thread "main" java.lang.indexoutofboundsexception
at java.nio.buffer.checkbounds(buffer.java:567)
at java.nio.heapbytebuffer.get(heapbytebuffer.java:149)
at nio.main.main(main.java:14)

结论
数组越界是表示对于数组的操作就有问题，与buffer中的属性关系不大。比如数组长度只有6，却想读取7个字节到数组中去，直接导致了数组越界。

标记和重置-mark&reset

marking and resetting

a buffer's mark is the index to which its position will be reset when the {@link #reset reset} method is invoked. the mark is not always defined, but when it is defined it is never negative and is never greater than the position. if the mark is defined then it is discarded when the position or the limit is adjusted to a value smaller than the mark. if the mark is not defined then invoking the {@link #reset reset} method causes an {@link invalidmarkexception} to be thrown.

测试代码

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.mark();
    buffer.put("ab".getbytes());
    system.out.println(buffer.position());

    buffer.reset();
    system.out.println(buffer.position());

    byte[] bytes = new byte[2];
    buffer.get(bytes);
    system.out.println(arrays.tostring(bytes));
}

控制台输出

2
0
[97, 98]

通俗解释
在一开始，小车就在0号车厢做了个标记，然后在完成对0号车厢和1号车厢的装货后，一个重置，小车位置由2号车厢回到了事先标记好的0号车厢，然后就可以开始读了。！！注意：这不是一种安全的读方式，这里仅仅是示例作用。

拓展知识1：buffer支持链式调用

测试代码

public static void main(string[] args) {
    byte[] bytes = new byte[4];

    byte result = ((bytebuffer)bytebuffer.allocate(1024)
        .put("abcd".getbytes())
        .flip())
        .get();

    system.out.println(result);
}

控制台输出

97

拓展知识2：clear不会清除buffer中原来存储的内容

测试代码

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.put("abcd".getbytes());
    system.out.println(buffer.position());

    buffer.clear();
    system.out.println(buffer.position());
    system.out.println(buffer.get(0));
    system.out.println(buffer.get(1));
    system.out.println(buffer.get(2));
    system.out.println(buffer.get(3));
}

控制台输出

4
0
97
98
99
100

拓展知识3：putchar('a')和put((byte)'a')有别

测试代码

public static void main(string[] args) {
    bytebuffer buffer = bytebuffer.allocate(1024);
    buffer.putchar('a');
    system.out.println(buffer.position());
    system.out.println(buffer.get(0));
    system.out.println(buffer.get(1));

    buffer.put((byte)'a');
    system.out.println(buffer.position());
    system.out.println(buffer.get(2));
    system.out.println(buffer.get(3));
}

控制台输出

2
0
97
3
97
0

结论
putchar('a')会放入2个字节到缓冲区，如果实际编码只有一个字节，那就会用0来表示前一个字节。而put((byte)'a')只会放入1个字节到缓冲区。你可以通过buffer.position()观察这一点。

您可能感兴趣的文章:

如对本文有疑问，点击进行留言回复！！

before社区电量是什么意思 Before社区电量获得方法

before社区电量是什么意思？怎么获得更多的电量？有的朋友对此可能还不太清楚，今天，小编为大家带来了before社区电量获得方法。感兴趣的朋友快来了解一下吧。... [阅读全文]
Before社区怎么同步快手 Before社区绑定快手教程

before社区怎么同步快手？在before社区中，用户可以绑定自己的快手，对快手账户进行关联，今天，小编为大家带来了before社区绑定快手教程。感兴趣的玩家... [阅读全文]
before社区怎么加入小组 before社区关注小组教程

before社区怎么加入小组？before社区是由快手推出的一个主要面向年轻人的兴趣社交平台，在before社区中有许多的小组，今天，小编为大家带来了befor... [阅读全文]
before社区怎么玩 Before社区玩法分享

before社区怎么玩？快手正式上线了一款青年文化社区产品before社区。产品定位是专为文艺青年打造的互动交友社区。今天，小编为大家带来了详细的介绍，感兴趣的... [阅读全文]
springboot解决跨域请求带cookie的问题

记录一次解决Spring boot加vue的跨域问题大家都知道vue跨域请求Spring boot的时候，后端服... [阅读全文]
RecycleView入门详解（教你全面掌握RecycleView用法）

RecycleView小白入门详解（教你全面掌握其用法）RecycleView概念效果展示RecycleView... [阅读全文]
Android Emoji表情字符列表

https://apps.timwhitlock.info/emoji/tables/unicodeimport... [阅读全文]
动态权限请求框架RxPermissions(几行代码搞定权限)

RxPermissions简单使用描述：随着社会的发展人们也开始重视对隐私的保护，谷歌也在Android6.0（... [阅读全文]
ExoPlayer之Extractor媒体文件解封装使用

ExoPlayer之ExtractorExtractor的作用接口说明Extractor的调用内置的Extrac... [阅读全文]
URL路径@PathVariable出现点号“.“时值遭截断问题

一：问题描述SpringMVC项目中通过下面的ＵＲＬ进行GET请求。当version有多个小数点的时候。如ver... [阅读全文]

网友评论


验证码：

JavaNIO第一话-Buffer

2020年01月02日 | 移动技术网IT编程 | 我要评论

buffer是什么？

buffer能装什么？

buffer的重要属性及对应的获取方法

安排一列火车-allocate

装货-put

装单个"货"

装一组"货"

装货时超载-bufferoverflowexception

可重复读-get

读单个

如何让小车回到起始位置呢？

flip

rewind

clear

再探get

小车越界-bufferunderflowexception

小车越界可不同于数组越界-indexoutofboundsexception

标记和重置-mark&reset

marking and resetting

拓展知识1：buffer支持链式调用

拓展知识2：clear不会清除buffer中原来存储的内容

拓展知识3：putchar('a')和put((byte)'a')有别

您可能感兴趣的文章:

相关文章:

网友评论