Netty 的接收和發(fā)送 ByteBuffer 采用 DIRECT BUFFERS,使用堆外直接內(nèi)存進(jìn)行 Socket 讀寫,不需要進(jìn)行字節(jié)緩沖區(qū)的二次拷貝。堆內(nèi)存多了一次內(nèi)存拷貝,JVM 會(huì)將堆內(nèi)存Buffer 拷貝一份到直接內(nèi)存中,然后才寫入 Socket 中。
ByteBuffer 由 ChannelConfig 分配,而 ChannelConfig 創(chuàng)建 ByteBufAllocator 默認(rèn)使用 Direct BufferCompositeByteBuf 類可以將多個(gè) ByteBuf 合并為一個(gè)邏輯上的 ByteBuf, 避免了傳統(tǒng)通過內(nèi)存拷貝的方式將幾個(gè)小 Buffer 合并成一個(gè)大的 Buffer。addComponents 方法將 header 與 body 合并為一個(gè)邏輯上的 ByteBuf, 這兩個(gè) ByteBuf 在 CompositeByteBuf 內(nèi)部都是單獨(dú)存在的, CompositeByteBuf 只是邏輯上是一個(gè)整體
通過 FileRegion 包裝的 FileChannel.tranferTo 方法 實(shí)現(xiàn)文件傳輸, 可以直接將文件緩沖區(qū)的數(shù)據(jù)發(fā)送到目標(biāo) Channel,避免了傳統(tǒng)通過循環(huán) write 方式導(dǎo)致的內(nèi)存拷貝問題。
通過 wrap 方法, 我們可以將 byte[] 數(shù)組、ByteBuf、ByteBuffer 等包裝成一個(gè) NettyByteBuf 對(duì)象, 進(jìn)而避免了拷貝操作。
Selector BUG:若 Selector 的輪詢結(jié)果為空,也沒有 wakeup 或新消息處理,則發(fā)生空輪詢,CPU 使用率 100%,
Netty 的解決辦法:對(duì) Selector 的 select 操作周期進(jìn)行統(tǒng)計(jì),每完成一次空的 select 操作進(jìn)行一次計(jì)數(shù),若在某個(gè)周期內(nèi)連續(xù)發(fā)生 N 次空輪詢,則觸發(fā)了 epoll 死循環(huán) bug。重建
Selector,判斷是否是其他線程發(fā)起的重建請(qǐng)求,若不是則將原 SocketChannel 從舊的
Selector 上去除注冊(cè),重新注冊(cè)到新的 Selector 上,并將原來的 Selector 關(guān)閉。