ReplayingDecoder déclenche une exception lors du décodage

Question

J'ai créé un décodeur pour traiter les octets envoyés par le client. Voici ce

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"); 
     } 
    } 
} 

Et il jette l'erreur suivante lorsque le client envoie les octets

io.netty.handler.codec.DecoderException: java.lang.IllegalArgumentException: minimumReadableBytes: -603652096 (prévu :> = 0) à io.netty.handler.codec.ReplayingDecoder.callDecode (ReplayingDecoder.java:431) à io.netty.handler.codec.ByteToMessageDecoder.channelRead (ByteToMessageDecoder.java:245) à io.netty .channel.AbstractChannelHandlerContext.invokeChannelRead (AbstractChannelHandlerContext.java:292) à io.netty.channel.AbstractChannelHandlerContext.fireChannelRead (AbstractChannelHandlerContext.java:278) à io.netty.channel.DefaultChannelPipeline.fireChannelRead (DefaultChannelPipeline.java:962) à io.netty.channel.nio.AbstractNioByteChannel $ NioByteUnsafe. lire (AbstractNioByteChannel.java:131) à io.netty.channel.nio.NioEventLoop.processSelectedKey (NioEventLoop.java:528) à io.netty.channel.nio.NioEventLoop.processSelectedKeysOptimized (NioEventLoop.java:485) à io.netty.channel.nio.NioEventLoop.processSelectedKeys (NioEventLoop.java:399) à io.netty.channel.nio.NioEventLoop.run (NioEventLoop.java:371) à io.netty.util.concurrent.SingleThreadEventExecutor $ 2 .run (SingleThreadEventExecutor.java:112) à io.netty.util.concurrent.DefaultThreadFactory $ DefaultRunnableDecorator.run (DefaultThreadFactory.java:137) à java.lang.Thread.run (Source inconnue)

Ce code est de la documentation officielle http://netty.io/4.0/api/io/netty/handler/codec/ReplayingDecoder.html donc je vraiment don Je ne comprends pas pourquoi cela ne fonctionne pas

Answer 1

Probablement l'homologue distant écrit l'int comme non signé. Peut-être que vous voulez utiliser readUnsignedInt()?