ReplayingDecoder在解码时引发异常

Question

我已经创建了一个解码器来处理客户端发送的字节。给你

import java.util.List;

import io.netty.buffer.ByteBuf;
import io.netty.channel.ChannelHandlerContext;
import io.netty.handler.codec.ReplayingDecoder;

public class MessageDecoder extends ReplayingDecoder<DecoderState> {

    private int length;

    public MessageDecoder()
    {
        super(DecoderState.READ_LENGTH);
    }

    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf buf, List<Object> out) throws Exception{
        System.out.println(buf.readableBytes());
        switch(state()){
            case READ_LENGTH:
                length=buf.readInt();
                System.out.println("length is: "+length);
                checkpoint(DecoderState.READ_CONTENT);
            case READ_CONTENT:
                ByteBuf frame = buf.readBytes(length);
                checkpoint(DecoderState.READ_LENGTH);
                out.add(frame);
                break;
            default:
                throw new Error("Shouldn't reach here");
        }
    }
}

并在客户端发送字节时抛出下一个错误

Io.netty.handler.codec.DecoderException：java.lang.IllegalArgumentException：MinimumReadableBytes：-603652096（预期:>=0)在io.netty.handler.codec.ReplayingDecoder.CallDecode(replayingDecoder.java:431)在io.netty.handler.codecer.ChannelRead(BytetomessageDecoder.ChannelRead(BytetomessageDecoder.java:245)在loop.java:371)在io.netty.util.concurrent.SingleThreadeVentExecutor$2处运行(SingleThreadeVentExecutor.java:112)在io.netty.util.concurrent.DefaultThreadFactory$DefaultUnnableDecorator.Run（DefaultThreadFactor.java:137)在java.lang.Thread.Run（未知源）

这段代码来自官方文档http://netty.io/4.0/api/io/netty/handler/codec/replayingdecoder.html，所以我真的不明白为什么它不能工作

Answer 1

远程对等方可能确实将int编写为未签名。也许您想要的是使用readUnsignedInt（）？