Java nio — ByteBuffer

缓冲区本质是一块可以写入数据,然后可以从中读取数据的内存,这块内存被包裹成NIO buffer对象,并且提供了一些方法来访问该块内存。

1.ByteBuffer的分配

ByteBuffer是一个抽象类,所以我们不能直接通过new 来创建我们需要的缓冲对象,当然也不用通过重写抽象方法来创建对象。

ByteBuffer内部提供了两个静态方法来帮助我们创建内存:

分别是分配HeapByteBuffer的:

 public static ByteBuffer allocate(int capacity) {

        if (capacity < 0)

            throw new IllegalArgumentException();

        return new HeapByteBuffer(capacity, capacity);

    }

分配DirectByteBuffer的:

public static ByteBuffer allocateDirect(int capacity) {
        return new DirectByteBuffer(capacity);
    }

都是分配内存,为什么需要两种不同的方法呢?其实我们从他们的名字就能看出来,前者分配内存的区域是在Heap区域,当flush到远程的时候会拷贝到直接内存。而后者则是在C heap上分配内存,可以得到非常快速的网络交互。

HeapByteBuffer和DirectByteBuffer都是包内私有,无法被我们访问的。只能通过ByteBuffer间接访问。

通过源码,我们能看到创建实例的方法如下:

HeapByteBuffer:

HeapByteBuffer(int cap, int lim) {            // package-private

        super(-1, 0, lim, cap, new byte[cap], 0);
        /*
        hb = new byte[cap];
        offset = 0;
        */
    }

该缓冲区依旧委托给父类进行创建。除了调用父类构造方法,也没有其他的操作。
我们来看一看创建一块ByteBuffer需要哪些参数:

ByteBuffer(int mark, int pos, int lim, int cap,   // package-private
                 byte[] hb, int offset)
    {
        super(mark, pos, lim, cap);
        this.hb = hb;
        this.offset = offset;
    }

还记得吗?我们在调用allocate()方法的时候仅仅向里面传递了一个cap。
而HeapByteBuffer传回将lim = cap, pos = 0, offset = 0 mark = -1 (即 undefine)
这几个参数一会儿我们来讨论其意义。

继续向上调用构造函数

Buffer(int mark, int pos, int lim, int cap) {       // package-private
        if (cap < 0)
            throw new IllegalArgumentException("Negative capacity: " + cap);
        this.capacity = cap;
        limit(lim);
        position(pos);
        if (mark >= 0) {
            if (mark > pos)
                throw new IllegalArgumentException("mark > position: ("
                                                   + mark + " > " + pos + ")");
            this.mark = mark;
        }
    }

调用的是Buffer的构造函数,其实现类很多,在此不论。

创建完成之后,此时内存空间重要参数布局是这样的:


bt1.png

DirectByteBuffer

DirectByteBuffer(int cap) {                   // package-private
        super(-1, 0, cap, cap);
        boolean pa = VM.isDirectMemoryPageAligned();
        int ps = Bits.pageSize();
        long size = Math.max(1L, (long)cap + (pa ? ps : 0));
        Bits.reserveMemory(size, cap);

        long base = 0;
        try {
            base = unsafe.allocateMemory(size);
        } catch (OutOfMemoryError x) {
            Bits.unreserveMemory(size, cap);
            throw x;
        }
        unsafe.setMemory(base, size, (byte) 0);
        if (pa && (base % ps != 0)) {
            // Round up to page boundary
            address = base + ps - (base & (ps - 1));
        } else {
            address = base;
        }
        cleaner = Cleaner.create(this, new Deallocator(base, size, cap));
        att = null;
    }

由于该缓冲区是堆外申请的内存,我们可以看到除了调用父类的构造函数,还进行了很多其他操作。
该类继承自MappedByteBuffer类,关于该类的具体资料:
http://blog.csdn.net/linxdcn/article/details/72903422

这些额外的操作主要就要获取address(堆外内存地址),还有就是直接内存不是分配在JVM堆中的,而是用JNI直接调用的内存。并不受Minor GC的影响,只有当老年代执行Full gc的时候才会回收直接内存。而只有当众多DirectByteBuffer被送入老年代后才会触发Full gc。

关于堆外内存的回收机制:
http://www.importnew.com/26334.html

分配后内存参数和HeapByteBuffer相同。

这两种内存空间模型如下:

HeapByteBuffer

JVM Heap <----> JVM用户空间 <----> OS内核空间<----->网卡驱动空间;

DirectByteBuffer

JVM用户空间 <----> OS内核空间<----->网卡驱动空间。

directBytebuffer虽然看似要快许多,但在数据量较少的时候并无太大的优势,而且内存需要手动释放,容易出现问题。
所以如果没有性能瓶颈尽可能使用HeapByteBuffer来作为缓冲区。

2.ByteBuffer的读写及参数意义:

主要参数有:

  • capacity
  • position
  • limit
  • mark
    关于bytebuffer的读写原理见插图:


    image

capacity

作为一个内存块,Buffer有一个固定的大小值,也叫“capacity”.你只能往里写capacity个byte、long,char等类型。一旦Buffer满了,需要将其清空(通过读数据或者清除数据)才能继续写数据往里写数据。

position

当你写数据到Buffer中时,position表示当前的位置。初始的position值为0.当一个byte、long等数据写到Buffer后, position会向前移动到下一个可插入数据的Buffer单元。position最大可为capacity – 1.

当读取数据时,也是从某个特定位置读。当将Buffer从写模式切换到读模式,position会被重置为0. 当从Buffer的position处读取数据时,position向前移动到下一个可读的位置。

limit

在写模式下,Buffer的limit表示你最多能往Buffer里写多少数据。 写模式下,limit等于Buffer的capacity。

当切换Buffer到读模式时, limit表示你最多能读到多少数据。因此,当切换Buffer到读模式时,limit会被设置成写模式下的position值。换句话说,你能读到之前写入的所有数据(limit被设置成已写数据的数量,这个值在写模式下就是position)

除了以上方法外,还能使用类似bytebuffer.put(127)向缓冲区中写数据。

了解了这几个参数的意义后,我们来看看几个重要方法的

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

flip()方法应该是最常用的方法,因为bytebuffer的结构,在读数据的时候,我们会将pos = 0, limit = pos,这个意思就是我们可以并且只能读取我们之前写入的数据。

clear()方法
public final Buffer clear() {
        position = 0;
        limit = capacity;
        mark = -1;
        return this;
    }

如源码所示,将一切属性设置为来初始化状态。

rewind()方法
public final Buffer rewind() {
        position = 0;
        mark = -1;
        return this;
    }

将pos=0,可以重新读取所有内容。

remain()方法
    public final int remaining() {
        return limit - position;
    }

读写模式下表示可读/可写范围。

compact()

方法将所有未读的数据拷贝到Buffer起始处。然后将position设到最后一个未读元素正后面。limit属性依然像clear()方法一样,设置成capacity。现在Buffer准备好写数据了,但是不会覆盖未读的数据。
由于此处涉及到分配内存,所以HeapByteBuffer和DirectByteBuffer的实现又不一样。详情见源码。

在前面我们已经讨论过了pos, lim, cap三个参数,还有一个mark参数未讨论。
看其字面意思,其实就是标记的意思。

mark()方法
public final Buffer mark() {
        mark = position;
        return this;
    }

将mark=pos.
该参数需要配合

reset()方法
public final Buffer reset() {
        int m = mark;
        if (m < 0)
            throw new InvalidMarkException();
        position = m;
        return this;
    }

当我们需要记住前一个pos的时候(此时,我们已经调用了rewind或者clear了),可以使用mark参数。

equals()与compareTo()方法

equals()

当满足下列条件时,表示两个Buffer相等:

有相同的类型(byte、char、int等)。
Buffer中剩余的byte、char等的个数相等。
Buffer中所有剩余的byte、char等都相同。
如你所见,equals只是比较Buffer的一部分,不是每一个在它里面的元素都比较。实际上,它只比较Buffer中的剩余元素。

compareTo()方法

compareTo()方法比较两个Buffer的剩余元素(byte、char等), 如果满足下列条件,则认为一个Buffer“小于”另一个Buffer:

第一个不相等的元素小于另一个Buffer中对应的元素 。
所有元素都相等,但第一个Buffer比另一个先耗尽(第一个Buffer的元素个数比另一个少)。

剩余元素 : pos -> limit

参考资料:

最后编辑于
©著作权归作者所有,转载或内容合作请联系作者
  • 序言:七十年代末,一起剥皮案震惊了整个滨河市,随后出现的几起案子,更是在滨河造成了极大的恐慌,老刑警刘岩,带你破解...
    沈念sama阅读 215,384评论 6 497
  • 序言:滨河连续发生了三起死亡事件,死亡现场离奇诡异,居然都是意外死亡,警方通过查阅死者的电脑和手机,发现死者居然都...
    沈念sama阅读 91,845评论 3 391
  • 文/潘晓璐 我一进店门,熙熙楼的掌柜王于贵愁眉苦脸地迎上来,“玉大人,你说我怎么就摊上这事。” “怎么了?”我有些...
    开封第一讲书人阅读 161,148评论 0 351
  • 文/不坏的土叔 我叫张陵,是天一观的道长。 经常有香客问我,道长,这世上最难降的妖魔是什么? 我笑而不...
    开封第一讲书人阅读 57,640评论 1 290
  • 正文 为了忘掉前任,我火速办了婚礼,结果婚礼上,老公的妹妹穿的比我还像新娘。我一直安慰自己,他们只是感情好,可当我...
    茶点故事阅读 66,731评论 6 388
  • 文/花漫 我一把揭开白布。 她就那样静静地躺着,像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上,一...
    开封第一讲书人阅读 50,712评论 1 294
  • 那天,我揣着相机与录音,去河边找鬼。 笑死,一个胖子当着我的面吹牛,可吹牛的内容都是我干的。 我是一名探鬼主播,决...
    沈念sama阅读 39,703评论 3 415
  • 文/苍兰香墨 我猛地睁开眼,长吁一口气:“原来是场噩梦啊……” “哼!你这毒妇竟也来了?” 一声冷哼从身侧响起,我...
    开封第一讲书人阅读 38,473评论 0 270
  • 序言:老挝万荣一对情侣失踪,失踪者是张志新(化名)和其女友刘颖,没想到半个月后,有当地人在树林里发现了一具尸体,经...
    沈念sama阅读 44,915评论 1 307
  • 正文 独居荒郊野岭守林人离奇死亡,尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 37,227评论 2 331
  • 正文 我和宋清朗相恋三年,在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 39,384评论 1 345
  • 序言:一个原本活蹦乱跳的男人离奇死亡,死状恐怖,灵堂内的尸体忽然破棺而出,到底是诈尸还是另有隐情,我是刑警宁泽,带...
    沈念sama阅读 35,063评论 5 340
  • 正文 年R本政府宣布,位于F岛的核电站,受9级特大地震影响,放射性物质发生泄漏。R本人自食恶果不足惜,却给世界环境...
    茶点故事阅读 40,706评论 3 324
  • 文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹,春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 31,302评论 0 21
  • 文/苍兰香墨 我抬头看了看天上的太阳。三九已至,却和暖如春,着一层夹袄步出监牢的瞬间,已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 32,531评论 1 268
  • 我被黑心中介骗来泰国打工, 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留,地道东北人。 一个月前我还...
    沈念sama阅读 47,321评论 2 368
  • 正文 我出身青楼,却偏偏与公主长得像,于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子,可洞房花烛夜当晚...
    茶点故事阅读 44,248评论 2 352

推荐阅读更多精彩内容

  • Buffer的基本用法 使用Buffer读写数据一般遵循以下四个步骤:1、分配空间2、写入数据到Buffer3、调...
    平凡的小Y阅读 1,805评论 0 4
  • Java NIO(New IO)是从Java 1.4版本开始引入的一个新的IO API,可以替代标准的Java I...
    JackChen1024阅读 7,555评论 1 143
  • 转自 http://www.ibm.com/developerworks/cn/education/java/j-...
    抓兔子的猫阅读 2,300评论 0 22
  • Buffer和Channel总是成对出现,在Java NIO中Buffer用于和NIO通道进行交互,数据总是从Ch...
    zhanglbjames阅读 607评论 0 0
  • 随笔: 今天在电台里听到一篇好文章,大概讲的是那些会打扮又努力的人,也是生活中容易成功的人。这让我想起上次看到的一...
    夕影西逝阅读 136评论 0 2