Netty 服务器的 channelRead 收到大小为 0 的空 ButBuf

------------ 客户端管道(客户端可以发送任何类型的消息,即 HTTP 请求或二进制数据包)--------


Bootstrap bootstrap = new Bootstrap()

        .group(group)

     //   .option(ChannelOption.TCP_NODELAY, true)

    //    .option(ChannelOption.SO_KEEPALIVE, true)

        .channel(NioSocketChannel.class)

        .handler(new ChannelInitializer() {

            @Override

            protected void initChannel(Channel channel) throws Exception {

                channel.pipeline()

                        .addLast("agent-traffic-shaping", ats)

                        .addLast("length-decoder", new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4, 0, 4))

                        .addLast("agent-client", new AgentClientHandler())

                        .addLast("4b-length", new LengthFieldPrepender(4))

                ;

            }

        });

------------------------------ 服务器端管道---------------- ——


ServerBootstrap b = new ServerBootstrap()

        .group(group)

  //      .option(ChannelOption.TCP_NODELAY, true)

 //       .option(ChannelOption.SO_KEEPALIVE, true)

        .channel(NioServerSocketChannel.class)

        .localAddress(new InetSocketAddress(port))

        .childHandler(new ChannelInitializer() {

                          @Override

                          protected void initChannel(Channel channel) throws Exception {

                              channel.pipeline()

                                      .addLast("agent-traffic-shaping", ats)

                                      .addLast("length-decoder", new LengthFieldBasedFrameDecoder(Integer.MAX_VALUE, 0, 4, 0, 4))

                                      .addLast(new AgentServerHandler())

                                      .addLast("4b-length", new LengthFieldPrepender(4));

                          }

                      }

        );


ChannelFuture f = b.bind().sync();

log.info("Started agent-side server at Port {}", port);

然而,服务器收到一个大小为零的空 ByteBuf。这里可能是什么原因?


慕容森
浏览 377回答 1
1回答
打开App,查看更多内容
随时随地看视频慕课网APP

相关分类

Java