1.1成員變量

private final ByteBufAllocator alloc;

private ByteBuffer buffer; private ByteBuffer tmpNioBuf; private int capacity; private boolean doNotFree;

1.2構(gòu)造方法

protected UnpooledDirectByteBuf(ByteBufAllocator alloc, int initialCapacity, int maxCapacity) {super(maxCapacity);if (alloc == null) {throw new NullPointerException("alloc");}if (initialCapacity < 0) {throw new IllegalArgumentException("initialCapacity: " + initialCapacity);}if (maxCapacity < 0) {throw new IllegalArgumentException("maxCapacity: " + maxCapacity);}if (initialCapacity > maxCapacity) {throw new IllegalArgumentException(String.format("initialCapacity(%d) > maxCapacity(%d)", initialCapacity, maxCapacity));}this.alloc = alloc;setByteBuffer(ByteBuffer.allocateDirect(initialCapacity));}

2.動態(tài)擴(kuò)展緩存

聯(lián)系一下上文的UploadHeapByteBuf的實(shí)現(xiàn)，其實(shí)發(fā)現(xiàn)好簡單的

3.寫操作

public ByteBuf setBytes(int index, ByteBuf src, int srcIndex, int length) {checkSrcIndex(index, length, srcIndex, src.capacity());if (src.nioBufferCount() > 0) {for (ByteBuffer bb: src.nioBuffers(srcIndex, length)) {int bbLen = bb.remaining();setBytes(index, bb);index += bbLen;}} else {src.getBytes(srcIndex, this, index, length);}return this;} public ByteBuf setBytes(int index, ByteBuffer src) {ensureAccessible();ByteBuffer tmpBuf = internalNioBuffer();if (src == tmpBuf) {src = src.duplicate();}tmpBuf.clear().position(index).limit(index + src.remaining());tmpBuf.put(src);return this;}

和Heap進(jìn)行對比，非常容易發(fā)現(xiàn)，heap因?yàn)樗褪嵌?#xff0c;直接對array進(jìn)行讀寫操作就行了，和內(nèi)存的直接對索引操作形成了對比。
讀寫操作差不多，不再贅述。

總結(jié)

以上是生活随笔為你收集整理的UnpooledDirectByteBuf源码分析的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。