在Netty底层监控消息发送到Socket的时间

简介: 在Netty底层监控消息发送到Socket的时间

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;高低水位变化测试

默认水位值测试

目录
相关文章
|
8月前
|
网络协议
【Netty 网络通信】Socket 通信原理
【1月更文挑战第9天】【Netty 网络通信】Socket 通信原理
|
4月前
|
监控 网络协议 数据库连接
Python3 监控端口:使用 socket 库
Python3 监控端口:使用 socket 库
61 0
|
4月前
|
监控 网络协议 数据库连接
Python3 监控端口:使用 socket 库
Python3 监控端口:使用 socket 库
69 0
|
监控 前端开发 存储
实时通信:企业员工监控管理软件中的Socket.io实现
在企业环境中,实时监控员工的工作状态和行为对于提高生产效率和确保数据安全至关重要。本文将介绍如何使用Socket.io实现企业员工监控管理软件中的实时通信功能,通过这种方式实现对员工的即时监控和数据收集。
231 0
|
8月前
|
监控 Unix Linux
socket监控进程,并对程序执行有关操作。
socket监控进程,并对程序执行有关操作。
|
Web App开发 监控 前端开发
如果监控摄像头不支持Web Socket,猿大师播放器还能在网页中播放RTSP流吗?
猿大师播放器在前端用web socket是浏览器和中间件及播放程序之间的通讯协议,和实际播放无关,只要浏览器支持web socket就可以播放,现在大部分浏览器都支持web socket,所以就算监控设备不支持Websocket,用猿大师播放器播放RTSP也是是没问题的。
234 0
如果监控摄像头不支持Web Socket,猿大师播放器还能在网页中播放RTSP流吗?
|
JSON 网络协议 Android开发
Kotlin + Netty 在 Android 上实现 Socket 的服务端
Kotlin + Netty 在 Android 上实现 Socket 的服务端
853 0
Kotlin + Netty 在 Android 上实现 Socket 的服务端
Socket粘包问题终极解决方案—Netty版(2W字)!(11)
Socket粘包问题终极解决方案—Netty版(2W字)!(11)
137 0
Socket粘包问题终极解决方案—Netty版(2W字)!(11)
Socket粘包问题终极解决方案—Netty版(2W字)!(9)
Socket粘包问题终极解决方案—Netty版(2W字)!(9)
221 0
Socket粘包问题终极解决方案—Netty版(2W字)!(9)
|
安全 Android开发 Kotlin
Kotlin + Netty 在 Android 上实现 Socket 的服务端(续篇)
Kotlin + Netty 在 Android 上实现 Socket 的服务端(续篇)
837 0