netty SimpleChannelInboundHandler消息最多只能接收16384条

Question

我已经用http://netty.io/wiki/user-guide-for-4.x.html链接但我得到的数据最多只有16384字节。

public class DiscardServerHandler extends ChannelInboundHandlerAdapter 
{   
    byte bNullArray[] = "".getBytes();
    String strFullData= new String(bNullArray,StandardCharsets.UTF_8);        
    @Override
    public void channelRead(ChannelHandlerContext ctx, Object msg) throws Exception  
    { 
        try 
        {
           String MsgRead;
           ByteBuf in = (ByteBuf) msg;
           MsgRead=in.toString(io.netty.util.CharsetUtil.UTF_8);
           // here I get data only upto 1024 and this method get called 16 times.
           // So total data received is == 1024*16 = 16384        
           strFullData = strFullData + MsgRead;    
        } 
        finally 
        {
            ReferenceCountUtil.release(msg);
        }
    }    
    @Override 
    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception 
    { 
        //WriteMyLog(strFullData);      
        //Here size of strFullData is 16384        
        strFullData = ProcessMyData(strFullData);       
        byte[] respByteBuf = strFullData.getBytes();                   
        ByteBuf Resp1 = ctx.alloc().buffer(respByteBuf.length);    
        Resp1.writeBytes(respByteBuf);                
        ctx.write(Resp1);            
        ctx.flush(); 
        ctx.close(); 
    }
}

如何获取更多数据？

Answer 1

当你的操作系统从套接字读取一些数据时，它会将其传递给用户空间（Java在你的情况下是netty）。16*1024是你的操作系统从套接字读取并传递给你的缓冲区大小。这意味着如果您的消息超过此大小，ChannelInundHandlerAdapter处理程序不适合您的情况。您需要使用ByteToMessageDecoder。类似于：

public class MyBigMessageDecoder extends ByteToMessageDecoder {
    @Override
    protected void decode(ChannelHandlerContext ctx, ByteBuf in, List<Object> out) { 
        if (in.readableBytes() < MY_BIG_MESSAGE_SIZE) {
            return; 
        }

        out.add(in.readBytes(MY_BIG_MESSAGE_SIZE));
    }
}

Netty还为不同的场景提供了一系列现成的处理程序，比如LineBasedFrameDecoder，LengthFieldBasedFrameDecoder，FixedLengthFrameDecoder，等等。我相信你可以使用其中的一些。

一般来说，它们都做相同的事情——继续读取收入字节，直到满足某些条件。当准备就绪时，它们会进一步传递读取字节。