Netty中的LengthFieldBasedFrameDecoder解碼器

LengthFieldBasedFrameDecoder是一個基於長度解碼器, 它是Netty提供的4個解碼器中使用最廣泛的一個解碼器, RocketMQ中就是基於這個解碼器進行解碼消息的.

接下來分析下它是如何解碼消息的. 在它的類中主要有4個屬性:

<code>private final int lengthFieldOffset;
private final int lengthFieldLength;
private final int lengthAdjustment;
private final int initialBytesToStrip;/<code>

只有真正理解這4個屬性才能明白此解碼器的強大功能.

為了描述, 我們先把數據構造下. 假如我們要發送’你好’這兩個字, 轉成16進制就是27b0597d.

此時客戶端發送過來一串消息, 為了描述, 我們把消息都轉成16進制進行講解:

0xDC00000A006327b0597d

對於上面的消息, 如何將其解碼出來’你好’兩個字呢? 即如何解碼出來27b0597d, 就要使用到LengthFieldBasedFrameDecoder解碼器, 那麼我們就要設置上面的4個屬性了.

<code>lengthFieldOffset = 1
lengthFieldLength = 3
lengthAdjustment = -4
initialBytesToStrip = 6/<code>

(之所以為什麼這幾個屬性要設置這幾個數字,而不是其他數字, 其實是由消息結構和消息長度決定的)

我們說下每個值的含義:

lengthFieldOffset = 1表示長度域的偏移量是1, 那麼從最開始向後移動1個字節, 就到了0xDC的後面位置; lengthFieldLength = 3表示長度域是3個字節, 在C的後面繼續讀取3個字節, 即讀取到了0xDC

整體思路:

1.從消息開頭偏移lengthFieldOffset長度, 到達A位置

2.再從A位置讀取lengthFieldLength長度, 到達B位置, 內容是d

3.再從B位置讀取(d+lengthAdjustment)長度, 達到D位置

4.從消息開頭跳過initialBytesToStrip長度到達C位置

5.將C位置-D位置之間的內容傳送給接下來的處理器進行後續處理

用下面7個例子鍛鍊一下自己吧

閱讀更多 書唐瑞 的文章

關鍵字: 字節 int 位置