上一小节简单介绍了 AbstractByteBuf这个抽象类 , 这一小节对其子类的分类做一个简单的介绍
ByteBuf根据不同的分类方式 会有不同的分类结果
我们首先看第一种分类方式
1.Pooled和Unpooled
pooled是从一块内存里去取一段连续内存封装成byteBuf
具体标志是类名以Pooled开头的ByteBuf, 通常就是Pooled类型的ByteBuf, 比如: PooledDirectByteBuf或者pooledHeapByteBuf
有关如何分配一块连续的内存, 我们之后的章节会讲到
Unpooled是分配的时候直接调用系统api进行实现, 具体标志是以Unpooled开头的ByteBuf, 比如UnpooledDirectByteBuf, UnpooledHeapByteBuf
再看第二种分类方式
2.基于直接内存的ByteBuf和基于堆内存的ByteBuf
基于直接内存的ByteBuf, 具体标志是类名中包含单词Direct的ByteBuf, 比如UnpooledDirectByteBuf, PooledDirectByteBuf等
基于堆内存的ByteBuf, 具体标志是类名中包含单词heap的ByteBuf, 比如UnpooledHeapByteBuf, PooledHeapByteBuf
结合以上两种方式, 这里通过其创建的方式去简单对其分类做个解析
这里第一种分类的Pooled, 也就是分配一块连续内存创建byteBuf, 这一小节先不进行举例, 会在之后的小节讲到
这里主要就看Unpooled, 也就是调用系统api的方式创建byteBuf, 在直接内存和堆内存中有什么区别
这里以UnpooledDirectByteBuf和UnpooledHeapByteBuf这两种为例, 简单介绍其创建方式:
首先看UnpooledHeapByteBuf的byetBuf, 这是基于内存创建ByteBuf, 并且是直接调用系统api
我们看UnpooledHeapByteBuf的byetBuf的构造方法:
|
1 2 3 |
protected UnpooledHeapByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity) { this (alloc, new byte [initialCapacity], 0 , 0 , maxCapacity); } |
这里调用了自身的构造方法, 参数中创建了新的字节数组, 初始长度为初始化的内存大小, 读写指针初始位置都是0, 并传入了最大内存大小
从这里看出, 有关堆内存的Unpooled类型的分配, 是通过字节数组进行实现的
再往下跟:
|
1 2 3 |
protected UnpooledHeapByteBuf(ByteBufAllocator alloc, byte [] initialArray, int maxCapacity) { this (alloc, initialArray, 0 , initialArray.length, maxCapacity); } |
继续跟:
|
1 2 3 4 5 6 7 8 |
private UnpooledHeapByteBuf( ByteBufAllocator alloc, byte [] initialArray, int readerIndex, int writerIndex, int maxCapacity) { super (maxCapacity); //忽略验证代码 this .alloc = alloc; setArray(initialArray); setIndex(readerIndex, writerIndex); } |
跟到setAarry方法中：
|
1 2 3 4 |
private void setArray( byte [] initialArray) { array = initialArray; tmpNioBuf = null ; } |
将新创建的数组赋值为自身的array属性
回到构造函数中, 跟进setIndex方法:
|
1 2 3 4 5 |
public ByteBuf setIndex( int readerIndex, int writerIndex) { //忽略验证代码 setIndex0(readerIndex, writerIndex); return this ; } |
这里实际上是调用了AbstractByteBuf的setIndex方法
我们跟进setIndex0方法中:
|
1 2 3 4 |
final void setIndex0( int readerIndex, int writerIndex) { this .readerIndex = readerIndex; this .writerIndex = writerIndex; } |
这里设置了读写指针, 根据之前的调用链我们知道, 这里将读写指针位置都设置为了0
介绍完UnpooledHeapByteBuf的初始化, 我们继续看UnpooledDirectByteBuf这个类的构造, 顾明思议, 是基于堆外内存, 并且同样也是调用系统api的方式进行实现的
我们看其构造方法:
|
1 2 3 4 5 6 |
protected UnpooledDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity) { super (maxCapacity); //忽略验证代码 this .alloc = alloc; setByteBuffer(ByteBuffer.allocateDirect(initialCapacity)); } |
我们关注下setByteBuffer中的参数ByteBuffer.allocateDirect(initialCapacity)
我们在这里看到, 这里通过jdk的ByteBuffer直接调用静态方法allocateDirect分配了一个基于直接内存的ByteBuffer, 并设置了初始内存
再跟到setByteBuffer方法中:
|
1 2 3 4 5 6 7 8 9 |
private void setByteBuffer(ByteBuffer buffer) { ByteBuffer oldBuffer = this .buffer; if (oldBuffer != null ) { //代码忽略 } this .buffer = buffer; tmpNioBuf = null ; capacity = buffer.remaining(); } |
我们看到在这里将分配的ByteBuf设置到当前类的成员变量中
以上两种实例, 我们会对上面所讲到的两种分类有个初步的了解
这里要注意一下, 基于堆内存创建ByteBuf, 可以不用考虑对象回收, 因为虚拟机会进行垃圾回收, 但是堆外内存在虚拟机的垃圾回收机制的作用域之外, 所以这里要考虑手动回收对象
最后, 我们看第三种分类方式:
3.safe和unsafe
首先从名字上看, safe代表安全的, unsafe代表不安全的
这个安全与不安全的定义是什么呢
其实在我们jdk里面有unsafe对象, 可以通过unsafe对象直接拿到内存地址, 基于内存地址可以进行读写操作
如果是Usafe类型的byteBuf, 则可以直接拿到byteBuf在jvm中的具体内存, 可以通过调用jdk的Usafe对象进行读写, 所以这里代表不安全
而非Usafe不能拿到jvm的具体内存, 所以这里代表安全
具体标志是如果类名中包含unsafe这个单词的ByteBuf, 可以认为是一个unsafe类型的ByteBuf, 比如PooledUnsafeHeapByteBuf或者PooledUnsafeDirectByteBuf
以PooledUnsafeHeapByteBuf的_getByte方法为例:
|
1 2 3 |
protected byte _getByte( int index) { return UnsafeByteBufUtil.getByte(memory, idx(index)); } |
这里memory代表byebuffer底层分配内存的首地址, idx(index)代表当前指针index距内存memory的偏移地址, UnsafeByteBufUtil的getByte方法, 就可以直接通过这两个信息通过jdk底层的unsafe对象拿到jdk底层的值
有关AbstractByteBuf的主要实现类和继承关系, 如下图所示:
以上就是Netty分布式ByteBuf的分类方式源码解析的详细内容，更多关于Netty分布式ByteBuf分类方式的资料请关注其它相关文章！
原文链接：https://www.cnblogs.com/xiangnan6122/p/10205344.html
查看更多关于Netty分布式ByteBuf的分类方式源码解析的详细内容...