Netty 中实现 Socket 通信解码

在 Netty 中实现 Socket 通信解码需要使用到 Netty 的解码器。Netty 提供了一系列的解码器，可以根据不同的传输协议进行解码。其中常用的有以下几种：

1. ByteToMessageDecoder：将字节流解码成消息对象。该解码器可以处理分包和粘包问题。
2. LengthFieldBasedFrameDecoder：根据消息的长度进行解码，可以处理粘包和分包问题。
3. LineBasedFrameDecoder：按行分割文本，通常用于处理文本协议。
4. DelimiterBasedFrameDecoder：按照指定的分隔符进行分割，通常也用于处理文本协议。

以下是一个使用 ByteToMessageDecoder 的示例代码，假设我们要将字节流解码成一个自定义的 Message 对象：

public class MessageDecoder extends ByteToMessageDecoder {
    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) throws Exception {
        if (in.readableBytes() < 4) {
            // 如果可读字节数小于 4，则返回等待更多数据
            return;
        }

        // 读取消息长度
        int length = in.readInt();

        if (in.readableBytes() < length) {
            // 如果可读字节数小于消息长度，则返回等待更多数据
            in.resetReaderIndex();
            return;
        }

        // 读取消息内容
        byte[] content = new byte[length];
        in.readBytes(content);

        // 将消息解码成 Message 对象，并添加到输出列表中
        Message message = decodeMessage(content);
        out.add(message);
    }

    private Message decodeMessage(byte[] content) {
        // 自定义消息解码逻辑
        return null;
    }
}

在上述代码中，我们继承了 ByteToMessageDecoder，重写了 decode 方法。该方法会在每次读取到数据时被调用，我们在该方法中进行解码操作，并将解码后的消息添加到输出列表中。在解码过程中，我们先读取消息的长度，再根据长度读取消息内容，最后将消息内容解码成 Message 对象。需要注意的是，由于 Netty 采用了零拷贝技术，我们无需手动释放 ByteBuf 对象，Netty 会自动释放。