求助客户端与Netty服务端通信，大量消息时会有丢包问题

服务端：1、ServerInitializer继承ChannelInitializer<SocketChannel> ,
重写initChannel方法，里面
pipelie.addLast(new ProtobufEncoder());
pipelie.addLast(new ProtobufDencoder(xxxx));
pipelie.addLast(new ServerHandler());
2、ServerHandler继承SimpleChannelInboundHandler<xxxx>,重写channelRead0方法。

客户端：
1、ClientInitializer继承ChannelInitializer<SocketChannel> ,
重写initChannel方法，里面
pipelie.addLast(new ProtobufEncoder());
pipelie.addLast(new ProtobufDencoder(xxxx));
pipelie.addLast(new ServerHandler());
2、ClientHandler继承SimpleChannelInboundHandler<xxxx>,重写channelRead0方法,channelActive方法，

在channelActive方法里面写个for循环给服务器发送消息，ctx.writeAndFlush(message);

问题：
1、服务器收到的包跟客户端发过来的包不对应，存在丢包，比如客户端发连续发1000次过来，可能会收到800次。
2、但是如果客户端的ctx.writeAndFlush(message); 后写Thread.sleep(500); 服务器就不会丢包

以上问题是什么原因导致的？

是粘包了吗。
服务端有没有异常打出来

引用：JackJiang 发表于 2020-02-24 23:15
是粘包了吗。
服务端有没有异常打出来

netty的 ProtobufEncoder()  和  ProtobufDencoder() 不是解决了粘包和拆包问题了吗？ 自己自定义编码解码协议，继承MessageToByteEncoder / ReplayingDecoder 则正常！

注意看ProtobufDecoder的注释部分，“Please note that this decoder must
* be used with a proper {@link ByteToMessageDecoder} such as {@link ProtobufVarint32FrameDecoder}
* or {@link LengthFieldBasedFrameDecoder} ”   需要添加一个恰当的ByteToMessageDecoder