上一小節(jié)簡單介紹了AbstractByteBuf這個抽象類, 這一小節(jié)對其子類的分類做一個簡單的介紹

ByteBuf根據(jù)不同的分類方式 會有不同的分類結(jié)果

我們首先看第一種分類方式

1.Pooled和Unpooled

pooled是從一塊內(nèi)存里去取一段連續(xù)內(nèi)存封裝成byteBuf

具體標志是類名以Pooled開頭的ByteBuf, 通常就是Pooled類型的ByteBuf, 比如: PooledDirectByteBuf或者pooledHeapByteBuf

有關如何分配一塊連續(xù)的內(nèi)存, 我們之后的章節(jié)會講到

Unpooled是分配的時候直接調(diào)用系統(tǒng)api進行實現(xiàn), 具體標志是以Unpooled開頭的ByteBuf, 比如UnpooledDirectByteBuf, UnpooledHeapByteBuf

再看第二種分類方式

2.基于直接內(nèi)存的ByteBuf和基于堆內(nèi)存的ByteBuf

基于直接內(nèi)存的ByteBuf, 具體標志是類名中包含單詞Direct的ByteBuf, 比如UnpooledDirectByteBuf, PooledDirectByteBuf等

基于堆內(nèi)存的ByteBuf, 具體標志是類名中包含單詞heap的ByteBuf, 比如UnpooledHeapByteBuf, PooledHeapByteBuf

結(jié)合以上兩種方式, 這里通過其創(chuàng)建的方式去簡單對其分類做個解析

這里第一種分類的Pooled, 也就是分配一塊連續(xù)內(nèi)存創(chuàng)建byteBuf, 這一小節(jié)先不進行舉例, 會在之后的小節(jié)講到

這里主要就看Unpooled, 也就是調(diào)用系統(tǒng)api的方式創(chuàng)建byteBuf, 在直接內(nèi)存和堆內(nèi)存中有什么區(qū)別

這里以UnpooledDirectByteBuf和UnpooledHeapByteBuf這兩種為例, 簡單介紹其創(chuàng)建方式:

首先看UnpooledHeapByteBuf的byetBuf, 這是基于內(nèi)存創(chuàng)建ByteBuf, 并且是直接調(diào)用系統(tǒng)api

我們看UnpooledHeapByteBuf的byetBuf的構造方法:

protected UnpooledHeapByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity) {
     this(alloc, new byte[initialCapacity], 0, 0, maxCapacity);
 }

這里調(diào)用了自身的構造方法, 參數(shù)中創(chuàng)建了新的字節(jié)數(shù)組, 初始長度為初始化的內(nèi)存大小, 讀寫指針初始位置都是0, 并傳入了最大內(nèi)存大小

從這里看出, 有關堆內(nèi)存的Unpooled類型的分配, 是通過字節(jié)數(shù)組進行實現(xiàn)的

再往下跟:

protected UnpooledHeapByteBuf(ByteBufAllocator alloc, byte[] initialArray, int maxCapacity) {
    this(alloc, initialArray, 0, initialArray.length, maxCapacity);
}

繼續(xù)跟:

private UnpooledHeapByteBuf(
        ByteBufAllocator alloc, byte[] initialArray, int readerIndex, int writerIndex, int maxCapacity) {
    super(maxCapacity);
    //忽略驗證代碼
    this.alloc = alloc;
    setArray(initialArray);
    setIndex(readerIndex, writerIndex);
}

跟到setAarry方法中：

private void setArray(byte[] initialArray) {
    array = initialArray;
    tmpNioBuf = null;
}

將新創(chuàng)建的數(shù)組賦值為自身的array屬性

回到構造函數(shù)中, 跟進setIndex方法:

public ByteBuf setIndex(int readerIndex, int writerIndex) {
    //忽略驗證代碼
    setIndex0(readerIndex, writerIndex);
    return this;
}

這里實際上是調(diào)用了AbstractByteBuf的setIndex方法

我們跟進setIndex0方法中:

final void setIndex0(int readerIndex, int writerIndex) {
    this.readerIndex = readerIndex;
    this.writerIndex = writerIndex;
}

這里設置了讀寫指針, 根據(jù)之前的調(diào)用鏈我們知道, 這里將讀寫指針位置都設置為了0

介紹完UnpooledHeapByteBuf的初始化, 我們繼續(xù)看UnpooledDirectByteBuf這個類的構造, 顧明思議, 是基于堆外內(nèi)存, 并且同樣也是調(diào)用系統(tǒng)api的方式進行實現(xiàn)的

我們看其構造方法:

protected UnpooledDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity) {
    super(maxCapacity);
    //忽略驗證代碼
    this.alloc = alloc;
    setByteBuffer(ByteBuffer.allocateDirect(initialCapacity));
}

我們關注下setByteBuffer中的參數(shù)ByteBuffer.allocateDirect(initialCapacity)

我們在這里看到, 這里通過jdk的ByteBuffer直接調(diào)用靜態(tài)方法allocateDirect分配了一個基于直接內(nèi)存的ByteBuffer, 并設置了初始內(nèi)存

再跟到setByteBuffer方法中:

private void setByteBuffer(ByteBuffer buffer) {
    ByteBuffer oldBuffer = this.buffer;
    if (oldBuffer != null) {
        //代碼忽略
    }
    this.buffer = buffer;
    tmpNioBuf = null;
    capacity = buffer.remaining();
}

我們看到在這里將分配的ByteBuf設置到當前類的成員變量中

以上兩種實例, 我們會對上面所講到的兩種分類有個初步的了解

這里要注意一下, 基于堆內(nèi)存創(chuàng)建ByteBuf, 可以不用考慮對象回收, 因為虛擬機會進行垃圾回收, 但是堆外內(nèi)存在虛擬機的垃圾回收機制的作用域之外, 所以這里要考慮手動回收對象

最后, 我們看第三種分類方式:

3.safe和unsafe

首先從名字上看, safe代表安全的, unsafe代表不安全的

這個安全與不安全的定義是什么呢

其實在我們jdk里面有unsafe對象, 可以通過unsafe對象直接拿到內(nèi)存地址, 基于內(nèi)存地址可以進行讀寫操作

如果是Usafe類型的byteBuf, 則可以直接拿到byteBuf在jvm中的具體內(nèi)存, 可以通過調(diào)用jdk的Usafe對象進行讀寫, 所以這里代表不安全

而非Usafe不能拿到jvm的具體內(nèi)存, 所以這里代表安全

具體標志是如果類名中包含unsafe這個單詞的ByteBuf, 可以認為是一個unsafe類型的ByteBuf, 比如PooledUnsafeHeapByteBuf或者PooledUnsafeDirectByteBuf

以PooledUnsafeHeapByteBuf的_getByte方法為例:

protected byte _getByte(int index) {
    return UnsafeByteBufUtil.getByte(memory, idx(index));
}

這里memory代表byebuffer底層分配內(nèi)存的首地址, idx(index)代表當前指針index距內(nèi)存memory的偏移地址, UnsafeByteBufUtil的getByte方法, 就可以直接通過這兩個信息通過jdk底層的unsafe對象拿到jdk底層的值

有關AbstractByteBuf的主要實現(xiàn)類和繼承關系, 如下圖所示:

以上就是Netty分布式ByteBuf的分類方式源碼解析的詳細內(nèi)容，更多關于Netty分布式ByteBuf分類方式的資料請關注腳本之家其它相關文章！

最新評論