轉自：https://sanwen8.cn/p/1bfoy1F.html

Netty為了提升報文的讀寫效能，預設會採用“零拷貝”模式，即訊息讀取時使用非堆的DirectBuffer來減少ByteBuffer的記憶體拷貝，如下圖所示：

如果需要修改接收Buffer的型別，例如從DirectByteBuf修改為HeapByteBuf，首先需要在初始化Channel的時候對接收緩衝區進行設定，客戶端程式碼示例如下：

 b.group(group)

.channel(NioSocketChannel.class)

 .option(ChannelOption.TCP_NODELAY, true)

 .option(ChannelOption.ALLOCATOR, PooledByteBufAllocator.DEFAULT)

 .option(ChannelOption.RCVBUF_ALLOCATOR, AdaptiveRecvByteBufAllocator.DEFAULT)

如果是服務端，則需要在鏈路建立之後，初始化時對Channel的SocketChannelConfig的Allocator屬性進行設定，程式碼如下：

.childHandler(new ChannelInitializer<SocketChannel>() {           

 @Override

  public void initChannel(SocketChannel ch) throws Exception {

  ch.config().setAllocator(UnpooledByteBufAllocator.DEFAULT);

無論是通過ChannelOption.RCVBUF_ALLOCATOR還是Allocator，都只能設定Allocator的型別，無法直接設定ByteBufAllocator分配的ByteBuf型別。下面我們接著分析訊息讀取時的ByteBuf分配機制。訊息讀取時，呼叫的是NioByteUnsafe的read方法，程式碼如下：

首先從SocketChannelConfig中獲取ByteBufAllocator，

 @Override

    public ByteBuf ioBuffer() {

        if (PlatformDependent.hasUnsafe()) {

            return directBuffer(0);

        }

        return heapBuffer(0);

    }

如果非Unsafe模式，則會使用堆記憶體heapBuffer，接著看hasUnsafe方法實現，它最終會呼叫如下方法：

設定io.netty.noUnsafe屬性為true，則預設會使用Heap堆記憶體建立ByteBuf，下面我們在啟動時設定-Dio.netty.noUnsafe為true進行測試

設定完成之後，使用Echo程式進行測試，測試結果如下：

總結

利用ch.config().setAllocator或Bootstrap.option(ChannelOption.ALLOCATOR, ByteBufAllocator)，結合-Dio.netty.noUnsafe，可以靈活的在如下四種ByteBuf之間進行切換：

• UnpooledHeapByteBuf

• PooledHeapByteBuf

• UnpooledDirectByteBuf

• PooledDirectByteBuf