Netty分布式固定長(zhǎng)度解碼器實(shí)現(xiàn)原理剖析

更新時(shí)間：2022年03月29日 09:57:43 作者：向南是個(gè)萬(wàn)人迷

這篇文章主要為大家介紹了Netty分布式固定長(zhǎng)度解碼器原理剖析，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪

固定長(zhǎng)度解碼器

我們了解到, 解碼器需要繼承ByteToMessageDecoder, 并重寫(xiě)decode方法, 將解析出來(lái)的對(duì)象放入集合中集合, ByteToMessageDecoder中可以將解析出來(lái)的對(duì)象向下進(jìn)行傳播, 這一小節(jié)帶大家剖析一個(gè)最簡(jiǎn)單的解碼器FixedLengthFrameDecoder, 從它入手了解碼器的相關(guān)原理

FixedLengthFrameDecoder是一個(gè)固定長(zhǎng)度的解碼器, 功能就是根據(jù)固定長(zhǎng)度, 截取固定大小的字節(jié)數(shù)進(jìn)行解碼

看其類的定義

public class FixedLengthFrameDecoder extends ByteToMessageDecoder {
    //長(zhǎng)度大小
    private final int frameLength;
    public FixedLengthFrameDecoder(int frameLength) {
        if (frameLength <= 0) {
            throw new IllegalArgumentException(
                    "frameLength must be a positive integer: " + frameLength);
        }
        //保存當(dāng)前frameLength
        this.frameLength = frameLength;
    }
    @Override
    protected final void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        //通過(guò)ByteBuf去解碼.解碼到對(duì)象之后添加到out上
        Object decoded = decode(ctx, in);
        if (decoded != null) {
            //將解析到byteBuf添加到對(duì)象里面
            out.add(decoded);
        }
    }
    protected Object decode(
            @SuppressWarnings("UnusedParameters") ChannelHandlerContext ctx, ByteBuf in) throws Exception {
        //字節(jié)是否小于這個(gè)固定長(zhǎng)度
        if (in.readableBytes() < frameLength) {
            return null;
        } else {
            //當(dāng)前累加器中截取這個(gè)長(zhǎng)度的數(shù)值
            return in.readRetainedSlice(frameLength);
        }
    }
}

我們看到這個(gè)類繼承了ByteToMessageDecoder, 重寫(xiě)了decode方法

這個(gè)類只有一個(gè)屬性叫frameLength, 并在構(gòu)造方法中初始化了該屬性

再看decode方法, 在decode方法中又調(diào)用了自身另一個(gè)重載的decode方法進(jìn)行解析, 解析出來(lái)之后將解析后的數(shù)據(jù)放在集合out中

再看重載的decode方法

重載的decode方法中首先判斷累加器的字節(jié)數(shù)是否小于固定長(zhǎng)度, 如果小于固定長(zhǎng)度則返回null, 代表不是一個(gè)完整的數(shù)據(jù)包, 直接返回null

如果大于等于固定長(zhǎng)度, 則直接從累加器中截取這個(gè)長(zhǎng)度的數(shù)值

in.readRetainedSlice(frameLength) 會(huì)返回一個(gè)新的截取后的ByteBuf, 并將原來(lái)的累加器讀指針后移frameLength個(gè)字節(jié)

如果累計(jì)器中還有數(shù)據(jù), 則會(huì)通過(guò)ByteToMessageDecoder中callDecode方法里while循環(huán)的方式, 繼續(xù)進(jìn)行解碼

這樣, 就是實(shí)現(xiàn)了固定長(zhǎng)度的解碼工作

到此這篇關(guān)于Netty分布式固定長(zhǎng)度解碼器實(shí)現(xiàn)原理剖析的文章就介紹到這了,更多相關(guān)Netty分布式固定長(zhǎng)度解碼器內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！

您可能感興趣的文章: