快捷導(dǎo)航

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

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

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

固定長度解碼器

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

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

看其類的定義

public class FixedLengthFrameDecoder extends ByteToMessageDecoder {
    //長度大小
    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 {
        //通過ByteBuf去解碼.解碼到對象之后添加到out上
        Object decoded = decode(ctx, in);
        if (decoded != null) {
            //將解析到byteBuf添加到對象里面
            out.add(decoded);
        }
    }
    protected Object decode(
            @SuppressWarnings("UnusedParameters") ChannelHandlerContext ctx, ByteBuf in) throws Exception {
        //字節(jié)是否小于這個(gè)固定長度
        if (in.readableBytes() < frameLength) {
            return null;
        } else {
            //當(dāng)前累加器中截取這個(gè)長度的數(shù)值
            return in.readRetainedSlice(frameLength);
        }
    }
}

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

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

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