基于LengthFieldBasedFrameDecoder手写一个简单的编码器解决tcp粘包拆包问题（Netty）

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.MessageToByteEncoder;
 
public class MyMessageEncoder extends MessageToByteEncoder<MyMessage> {
 
    @Override
    protected void encode(ChannelHandlerContext ctx, MyMessage msg, ByteBuf out) throws Exception {
        // 将消息转换为字节，并写入ByteBuf
        out.writeInt(msg.getLength()); // 写入消息长度
        out.writeBytes(msg.getData()); // 写入消息数据
    }
}
 
class MyMessage {
    private int length;
    private byte[] data;
 
    // 构造函数、getter和setter省略
 
    public int getLength() {
        return length;
    }
 
    public byte[] getData() {
        return data;
    }
}

这个简单的示例展示了如何使用MessageToByteEncoder来编码自定义的消息对象。在这个例子中，我们假设MyMessage有一个整数字段表示数据的长度和一个字节数组表示实际的数据内容。在encode方法中，我们将消息的长度和数据写入ByteBuf中，以便它可以被发送。这个编码器可以被用在Netty的编码器链中，与LengthFieldPrepender一起用于解决TCP粘包和拆包问题。