------------ 客户端管道(客户端可以发送任何类型的消息,即 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。这里可能是什么原因?
添加回答
举报
0/150
提交
取消