上篇 【从入门到放弃-Java】并发编程-NIO-Channel 中我们学习到channel是双向通道,数据通过channel在实体(文件、socket)和缓冲区(buffer)中可以双向传输。
本文我们就来学习下buffer
buffer即缓冲区,实际上是一块内存,可以用来写入、读取数据。是一个线性的、大小有限的、顺序承载基础数据类型的内存块。
buffer有三个重要的属性:
除了boolean外,每一个基础数据类型都有对应的buffer。如:ByteBuffer、CharBuffer、LongBuffer等
buffer不是线程安全的,如果要在多线程中使用 需要加锁控制
接下来以ByteBuffer为例开始学习。
public static ByteBuffer allocateDirect(int capacity) { //会创建一个容量大小为capacity的DirectByteBuffer(ByteBuffer的子类) return new DirectByteBuffer(capacity); }
public static ByteBuffer allocate(int capacity) { if (capacity < 0) throw createCapacityException(capacity); //会创建一个容量大小为capacity的HeapByteBuffer(ByteBuffer的子类) return new HeapByteBuffer(capacity, capacity); }
HeapByteBuffer和DirectByteBuffer的区别:
public static ByteBuffer wrap(byte[] array, int offset, int length) { try { return new HeapByteBuffer(array, offset, length); } catch (IllegalArgumentException x) { throw new IndexOutOfBoundsException(); } } public static ByteBuffer wrap(byte[] array) { return wrap(array, 0, array.length); }
将byte数组包装成一个ByteBuffer
//获取buffer中当前position的位置 public final int position() { return position; } //设置buffer的position为newPosition,注意newPosition要大于0且小于limit,如果remark大于newPosition则设置为-1 public Buffer position(int newPosition) { if (newPosition > limit | newPosition < 0) throw createPositionException(newPosition); position = newPosition; if (mark > position) mark = -1; return this; }
//获取buffer中当前limit的位置 public final int limit() { return limit; } //设置buffer的limit为newLimit,注意newLimit要大于0且小于capacity。如果position大于newLimit这设置为newLimit,如果remark大于newLimit则设置为-1 public Buffer limit(int newLimit) { if (newLimit > capacity | newLimit < 0) throw createLimitException(newLimit); limit = newLimit; if (position > limit) position = limit; if (mark > limit) mark = -1; return this; }
public Buffer mark() { //标记mark为当前position mark = position; return this; }
将当前位置做标记,在使用reset方法时,可以回到当前mark的位置
public Buffer reset() { int m = mark; if (m < 0) throw new InvalidMarkException(); //设置position为当前mark position = m; return this; }
回到之前设置mark的位置
public Buffer clear() { //设置position为0 position = 0; //limit设置为capacity大小 limit = capacity; //mark设置为-1(初始化) mark = -1; return this; }
读取完数据后调用clear,即将buffer逻辑上清空了,可以从0开始写入数据
public Buffer flip() { //limit设置为当前位置 limit = position; //position设置为0 position = 0; //mark设置为-1(初始化) mark = -1; return this; }
将buffer从写模式设置为读模式,limit设置为当前position的位置,即只能读取limit大小的数据
public Buffer rewind() { position = 0; mark = -1; return this; }
将position设置为0,即从头开始读取
public final int remaining() { return limit - position; }
返回buffer中还有多少byte是未读的
public final boolean hasRemaining() { return position < limit; }
是否已读完
public ByteBuffer compact() { System.arraycopy(hb, ix(position()), hb, ix(0), remaining()); position(remaining()); limit(capacity()); discardMark(); return this; }
将position和limit直接的数据copy到byteBuffer的起始处,将已读数据清空,并将新的position设置为当前未读数据的末尾。这样能避免clear方法会将未读数据也清空的问题
public ByteBuffer slice() { return new HeapByteBufferR(hb, -1, 0, this.remaining(), this.remaining(), this.position() + offset); } ByteBuffer slice(int pos, int lim) { assert (pos >= 0); assert (pos <= lim); int rem = lim - pos; return new HeapByteBufferR(hb, -1, 0, rem, rem, pos + offset); }
新创建一个ByteBuffer,将缓存区分片,设置一个子缓冲区,实际上内存还是共享的,数据发生改变,两个缓冲区读取的数据都会是改变后的。
Buffer最重要的三个属性:position、limit、capacity。牢记这三个属性的含义及读写切换时,设置值是如何变化的,Buffer的核心知识点就掌握了。
更多文章见: https://nc2era.com
本文作者:aloof_
阅读原文
本文为云栖社区原创内容,未经允许不得转载。