+---------------------------------------------------------------+
?
| 魔數(shù) 2byte | 協(xié)議版本號 1byte | 序列化算法 1byte | 報文類型 1byte  |
?
+---------------------------------------------------------------+
?
| 狀態(tài) 1byte |        保留字段 4byte     |      數(shù)據(jù)長度 4byte     | 
?
+---------------------------------------------------------------+
?
|                   數(shù)據(jù)內(nèi)容 （長度不定）                          |
?
+---------------------------------------------------------------+

public class StringToByteEncoder extends MessageToByteEncoder<String> {

    @Override
    protected void encode(ChannelHandlerContext channelHandlerContext, String data, ByteBuf byteBuf) throws Exception {
        byteBuf.writeBytes(data.getBytes());
    }
}

@Override
public void write(ChannelHandlerContext ctx, Object msg, ChannelPromise promise) throws Exception {
    ByteBuf buf = null;
    try {
        if (acceptOutboundMessage(msg)) { // 1. 消息類型是否匹配
            @SuppressWarnings("unchecked")
            I cast = (I) msg;
            buf = allocateBuffer(ctx, cast, preferDirect); // 2. 分配 ByteBuf 資源
            try {
                encode(ctx, cast, buf); // 3. 執(zhí)行 encode 方法完成數(shù)據(jù)編碼
            } finally {
                ReferenceCountUtil.release(cast);
            }
            if (buf.isReadable()) {
                ctx.write(buf, promise); // 4. 向后傳遞寫事件
            } else {
                buf.release();
                ctx.write(Unpooled.EMPTY_BUFFER, promise);
            }
            buf = null;
        } else {
            ctx.write(msg, promise);
        }
    } catch (EncoderException e) {
        throw e;
    } catch (Throwable e) {
        throw new EncoderException(e);
    } finally {
        if (buf != null) {
            buf.release();
        }
    }
}

@Override
protected void encode(ChannelHandlerContext ctx, CharSequence msg, List<Object> out) throws Exception {
    if (msg.length() == 0) {
        return;
    }
    out.add(ByteBufUtil.encodeString(ctx.alloc(), CharBuffer.wrap(msg), charset));
}

public abstract class ByteToMessageDecoder extends ChannelInboundHandlerAdapter {
    protected abstract void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception;
    protected void decodeLast(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        if (in.isReadable()) {
            decodeRemovalReentryProtection(ctx, in, out);
        }
    }
}

static void fireChannelRead(ChannelHandlerContext ctx, CodecOutputList msgs, int numElements) {
    for (int i = 0; i < numElements; i ++) {
        //循環(huán)傳播  有多少調(diào)用多少
        ctx.fireChannelRead(msgs.getUnsafe(i));
    }
}

public class MyTcpDecoder extends ByteToMessageDecoder {
?
    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        // 檢查ByteBuf數(shù)據(jù)是否完整
        if (in.readableBytes() < 4) {
            return;
        }
?
        // 標(biāo)記ByteBuf讀取索引位置
        in.markReaderIndex();
?
        // 讀取數(shù)據(jù)包長度
        int length = in.readInt();
?
        // 如果ByteBuf中可讀字節(jié)數(shù)不足一個數(shù)據(jù)包長度，則將讀取索引位置恢復(fù)到標(biāo)記位置，等待下一次讀取
        if (in.readableBytes() < length) {
            in.resetReaderIndex();
            return;
        }
?
        // 讀取數(shù)據(jù)
        ByteBuf data = in.readBytes(length);
?
        // 將數(shù)據(jù)傳遞給下一個解碼器進行轉(zhuǎn)換，轉(zhuǎn)換后的數(shù)據(jù)對象添加到out中
        ctx.fireChannelRead(data);
    }
}
?
public class MyDataDecoder extends MessageToMessageDecoder<ByteBuf> {
?
    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf msg, List<Object> out) throws Exception {
        // 將讀取到的ByteBuf數(shù)據(jù)轉(zhuǎn)換為自定義的數(shù)據(jù)對象
        MyData data = decode(msg);
        if (data != null) {
            // 將轉(zhuǎn)換后的數(shù)據(jù)對象添加到out中，表示解碼成功
            out.add(data);
        }
    }
?
    private MyData decode(ByteBuf buf) {
        // 實現(xiàn)自定義的數(shù)據(jù)轉(zhuǎn)換邏輯
        // ...
        return myData;
    }
}

/*
+---------------------------------------------------------------+
| 魔數(shù) 2byte | 協(xié)議版本號 1byte | 序列化算法 1byte | 報文類型 1byte  |
+---------------------------------------------------------------+
| 狀態(tài) 1byte |        保留字段 4byte     |      數(shù)據(jù)長度 4byte     | 
+---------------------------------------------------------------+
|                   數(shù)據(jù)內(nèi)容 （長度不定）                          |
+---------------------------------------------------------------+
 */
@Override
public final void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) {
    // 判斷 ByteBuf 可讀取字節(jié)
    if (in.readableBytes() < 14) { 
        return;
    }
    // 標(biāo)記 ByteBuf 讀指針位置
    in.markReaderIndex();
    // 跳過魔數(shù)
    in.skipBytes(2);
    // 跳過協(xié)議版本號
    in.skipBytes(1);
    byte serializeType = in.readByte();
     // 跳過報文類型
    in.skipBytes(1);
    // 跳過狀態(tài)字段
    in.skipBytes(1);
    // 跳過保留字段
    in.skipBytes(4);
    
    // 驗證報文長度，不對的話就重置指針位置
    int dataLength = in.readInt();
    if (in.readableBytes() < dataLength) {
        in.resetReaderIndex(); // 重置 ByteBuf 讀指針位置，這一步很重要
        return;
    }
    byte[] data = new byte[dataLength];
    in.readBytes(data);
    // 方式一：在解碼器中就將數(shù)據(jù)解碼成具體的對象
    SerializeService serializeService = getSerializeServiceByType(serializeType);
    Object obj = serializeService.deserialize(data);
    if (obj != null) {
        out.add(obj);
    }
    // 方式二：這一步可以不在解碼器中處理，將請求數(shù)據(jù)讀取到一個新的byteBuf然后丟給handler處理
    // 創(chuàng)建新的 ByteBuf 對象來存儲有效負載數(shù)據(jù)
    ByteBuf payload = Unpooled.buffer((int) dataSize);

    // 讀取有效負載數(shù)據(jù)并寫入到 payload 中
    in.readBytes(payload);
    if (payload.isReadable()) {
        out.add(payload);
    }
}