DotNetty解码器异常：第二批接收数据包含已处理的首批数据

我之前做DotNetty项目时刚好踩过这个一模一样的坑！你遇到的“第二批数据混进第一批已处理数据”的问题，大概率不是DotNetty的内部bug，而是解码器没正确处理ByteBuf的读指针导致的——毕竟ByteToMessageDecoder是基于累积缓冲区工作的，要是没管好读指针，之前处理过的数据就会留在缓冲区里被重复解析。

问题根源分析 #

ByteToMessageDecoder的核心逻辑是持续把客户端发送的字节累积到同一个ByteBuf中，每次调用Decode方法时，这个buf里装的是所有还没被你处理的字节。如果你的解码逻辑没有在处理完一个完整数据包后，把buf的读指针移动到这个数据包的末尾，那么下一次调用Decode时，之前已经处理过的字节就会被再次读取，看起来就像是第二批数据里混了旧数据。

常见的错误场景包括：

• 用了Slice()或Duplicate()获取子缓冲区，但没有手动移动原buf的读指针（这两个方法不会改变原buf的指针）
• 解析完数据包后，忘记调用SkipBytes()跳过已处理的字节
• 处理不完整数据包时，没有正确回滚读指针，导致后续累积的数据和旧数据混在一起

修复方案及代码示例 #

下面是修正后的解码器代码，重点关注读指针的处理逻辑：

internal class JsonToPacketDecoder : ByteToMessageDecoder
{
    protected override void Decode(IChannelHandlerContext context, IByteBuf input, List<object> output)
    {
        // 第一步：检查是否有足够的字节读取数据包头部（假设头部是4字节的长度字段）
        if (input.ReadableBytes < 4)
        {
            return; // 字节不够，直接返回，等待DotNetty继续累积数据
        }

        // 标记当前读指针位置，万一后续发现字节不够可以回滚
        input.MarkReaderIndex();
        
        // 读取数据包总长度（头部+内容）
        int totalPacketLength = input.ReadInt();
        // 检查剩余字节是否足够读取整个数据包（已经读了4字节头部，所以要减4）
        if (input.ReadableBytes < totalPacketLength - 4)
        {
            input.ResetReaderIndex(); // 回滚到标记的位置，等待更多数据
            return;
        }

        // 读取完整的数据包内容
        IByteBuf packetBytes = input.ReadBytes(totalPacketLength - 4);
        try
        {
            // JSON反序列化转换成业务对象
            string jsonStr = packetBytes.ToString(Encoding.UTF8);
            var packet = JsonSerializer.Deserialize<YourPacketModel>(jsonStr);
            
            // 将解析后的对象传递给下一个Handler
            output.Add(packet);
        }
        finally
        {
            // 释放池化的ByteBuf，避免内存泄漏
            packetBytes.Release();
        }
    }
}

关键注意点 #

1. 自动移动读指针：使用ReadInt()、ReadBytes()这些方法时，DotNetty会自动移动buf的读指针，确保已处理的字节不会被重复读取。
2. 不完整数据包的处理：如果当前字节不够解析完整数据包，一定要直接返回，并且（如果之前标记过指针）回滚读指针，让DotNetty继续累积数据。
3. 手动操作指针的误区：如果必须手动操作读指针，处理完后一定要确保input.ReaderIndex()指向已处理数据的末尾，比如用input.SkipBytes(processedLength)来跳过已处理的字节。

内容的提问来源于stack exchange，提问作者user5405648