初识内存分配ByteBuf

初识ByteBuf：

　　ByteBuf 是Netty 整个结构里面最为底层的模块，主要负责把数据从底层IO 里面读到ByteBuf，然后传递给应用程序，应用程序处理完成之后再把数据封装成ByteBuf 写回到IO。所以，ByteBuf 是直接与底层打交道的一层抽象。这块内容，相对于Netty 其他模块来说，是非常复杂的。从不同角度来分析ByteBuf 的分配和回收。主要从内存与内存管理器的抽象、不同规格大小和不同类别的内存的分配策略以及内存的回收过程来展开。

ByteBuf 的基本结构：

　　我们可以首先来看一下源码中对ByteBuf 的描述如下：

　　从上面ByteBuf 的结构来看，我们发现ByteBuf 有三个非常重要的指针，分别是readerIndex(记录读指针的开始位置)、writerIndex(记录写指针的开始位置)和capacity(缓冲区的总长度)，三者的关系是readerIndex<=writerIndex<=capacity。然后，从0 到readerIndex 为discardable bytes 表示是无效的，从readerIndex 到writerIndex 为readablebytes 表示可读数据区，从writerIndex 到capacity 为writable bytes 表示这段区间空闲可以往里面写数据。除了这三个指针，其实ByteBuf 里面还有一个maxCapacity，这就相当于是ByteBuf 扩容的最大阈值，我们看它的源码中有定义：

/**返回此缓冲区的最大允许容量。此值提供一个上限
* Returns the maximum allowed capacity of this buffer. This value provides an upper
* bound on {@link #capacity()}.
*/
public abstract int maxCapacity();

　　这个指针可以看做是capactiy 之后的这段，当Netty 发现writable bytes 写数据超出空间大小时，ByteBuf 会提前帮我们自动扩容，扩容之后，就有了足够的空间来写数据，同时capactiy 也会同步更新，maxCapacity 就是扩容后capactiy的最大值。

ByteBuf 的重要API：

　　接下来我们来看ByteBuf 的基本API，主要包括read()、write()、set()以及mark()、reset()方法。我们用下面的表格对ByteBuf 最重要的API 做一个详细说明：

readByte()：从当前readerIndex 指针开始往后读1 个字节的数据并移动readerIndex，将数据转化为byte。
readUnsignedByte() ：读取一个无符号的byte 数据。
readShort()：从当前readerIndex 指针开始往后读2 个字节的数据并移动readerIndex，将数据转化为short。
readInt()：从当前readerIndex 指针开始往后读4 个字节的数据并移动readerIndex，将数据转化为int。
readLong() ：从当前readerIndex 指针开始往后读8 个字节的数据并移动readerIndex，将数据转化为long。
writeByte() ：从当前writerIndex 指针开始往后写1 个字节的数据并移动writerIndex。
setByte() ：将byte 数据写入到指定位置，不移动writerIndex。
markReaderIndex() ：在读数据之前，将readerIndex 的状态保存起来，方便在读完数据之后将readerIndex 复原。
resetReaderIndex() ：将readerIndex 复原到调用markReaderIndex()之后的状态。
markWriterIndex() ：在写数据之前，将writerIndex 的状态保存起来，方便在读完数据之后将writerIndex 复原。
resetWriterIndex() ：将writerIndex 复原到调用markWriterIndex()之后的状态。
readableBytes()：获取可读数据区大小，相当于获取当前writerIndex 减去readerIndex 的值。
writableBytes()：获取可写数据区大小，相当于获取当前capactiy 减去writerIndex 的值。
maxWritableBytes()：获取最大可写数据区的大小，相当于获取当前maxCapactiy 减去writerIndex 的值。

　　在Netty 中，ByteBuf 的大部分功能是在AbstractByteBuf 中来实现的，我们可以先进入AbstractByteBuf 的源码看看：

public abstract class AbstractByteBuf extends ByteBuf {
　　 ......
　　 int readerIndex;//读指针
    int writerIndex;//写指针
    private int markedReaderIndex;//mark 之后的读指针
    private int markedWriterIndex;//mark 之后的写指针
    private int maxCapacity;//最大容量
　　 ......
}

　　最重要的几个属性readerIndex、writerIndex、markedReaderIndex、markedWriterIndex、maxCapacity 被定义在AbstractByteBuf 这个抽象类中，下面我们可以来看看基本读写的骨架代码实现。例如，几个基本的判断读写区间的API，我们来看一下它的具体实现：

@Override
public boolean isReadable() {return writerIndex > readerIndex;}

@Override
public boolean isReadable(int numBytes) {return writerIndex - readerIndex >= numBytes;}

@Override
public boolean isWritable() {return capacity() > writerIndex;}

@Override
public boolean isWritable(int numBytes) {return capacity() - writerIndex >= numBytes;}

@Override
public int readableBytes() {return writerIndex - readerIndex;}

@Override
public int writableBytes() {return capacity() - writerIndex;}

@Override
public int maxWritableBytes() {return maxCapacity() - writerIndex;}

@Override
public ByteBuf markReaderIndex() {
        markedReaderIndex = readerIndex;
        return this;
}

@Override
public ByteBuf resetReaderIndex() {
    readerIndex(markedReaderIndex);
    return this;
}

@Override
public ByteBuf markWriterIndex() {
    markedWriterIndex = writerIndex;
    return this;
}

@Override
public ByteBuf resetWriterIndex() {
    writerIndex(markedWriterIndex);
    return this;
}
//再来看几个读写操作的API，具体源码如下：

@Override
public byte readByte() {
    checkReadableBytes0(1);
    int i = readerIndex;
    byte b = _getByte(i);
    readerIndex = i + 1;
    return b;
}

@Override
public ByteBuf writeByte(int value) {
    ensureWritable0(1);
    _setByte(writerIndex++, value);
    return this;
}

@Override
public byte getByte(int index) {
    checkIndex(index);
    return _getByte(index);
}

protected abstract byte _getByte(int index);

protected abstract void _setByte(int index, int value);

　　我们看到，上面的代码中readByte()方法和getByte()方法都调用了一个抽象的_getByte()，这个方法在AbstractByteBuf的子类中实现。在writeByte()方法中有调用一个抽象的_setByte()方法，这个方法同样也是在子类中实现。

ByteBuf 的基本分类：

　　AbstractByteBuf 之下有众多子类，大致可以从三个维度来进行分类，分别如下：

Pooled：池化内存，就是从预先分配好的内存空间中提取一段连续内存封装成一个ByteBuf 分给应用程序使用。
Unsafe：是JDK 底层的一个负责IO 操作的对象，可以直接拿到对象的内存地址，基于内存地址进行读写操作。
Direct：堆外内存，是直接调用JDK 的底层API 进行物理内存分配，不在JVM 的堆内存中，需要手动释放。

　　综上所述，其实ByteBuf 一共会有六种组合：Pooled 池化内存和Unpooled 非池化内存；Unsafe 和非Unsafe；Heap堆内存和Direct 堆外内存。下图是ByteBuf 最重要的继承关系类结构图，通过命名就能一目了然：

　　ByteBuf 最基本的读写API 操作在AbstractByteBuf 中已经实现了，其众多子类采用不同的策略来分配内存空间，下面对重要的几个子类总结如下：

PooledHeapByteBuf ：池化的堆内缓冲区
PooledUnsafeHeapByteBuf ：池化的Unsafe 堆内缓冲区
PooledDirectByteBuf ：池化的直接(堆外)缓冲区
PooledUnsafeDirectByteBuf ：池化的Unsafe 直接(堆外)缓冲区
UnpooledHeapByteBuf ：非池化的堆内缓冲区
UnpooledUnsafeHeapByteBuf ：非池化的Unsafe 堆内缓冲区
UnpooledDirectByteBuf ：非池化的直接(堆外)缓冲区
UnpooledUnsafeDirectByteBuf ：非池化的Unsafe 直接(堆外)缓冲区

　　初步认识了ByteBuf的结构，接下去我们来看看在Netty中是怎么管理这些Buf及分配的。