本文共 736 字，大约阅读时间需要 2 分钟。

1、调用writeAndFlush方法之后获取ChannelFuture； 2、新增消息发送ChannelFutureListener，监听消息发送结果，如果消息写入网络Socket成功，则Netty会回调ChannelFutureListener的operationComplete方法； 3、在消息发送ChannelFutureListener的operationComplete方法中进行性能统计。 示例代码如下：  ChannelFuture future=socketChannel.writeAndFlush(msg); future.addListener(new ChannelFutureListener() { @Override public void operationComplete(ChannelFuture future) throws Exception { logger.info("seqId={} sent",msg.getSeqId()); }

});

    @Override

    public void channelReadComplete(ChannelHandlerContext ctx) throws Exception {         ctx.fireChannelReadComplete();     }

还是public void channelRead0(ChannelHandlerContext ctx, RpcMsg msg)这个读到消息的早，测试

 void channelWritabilityChanged(ChannelHandlerContext ctx) throws Exception;高低水位变化测试

默认水位值测试

转载地址：https://jiangguilong2000.blog.csdn.net/article/details/48112027 如侵犯您的版权，请留言回复原文章的地址，我们会给您删除此文章，给您带来不便请您谅解！