dubbo-客户端请求连接并发数量监控

实现

步骤

1.配置

开启监控功能

2.代码

dubbo提供了RpcStatus类,读监控数据。我们可以自定义dubbo拦截器,然后在拦截器里打印监控数据。

配置

为什么要配置?

因为dubbo自带了监控,我们要做的只是使用,很多框架都是自带了监控(比如阿里的druid数据库连接池),一般来说就是使用即可。

如何配置?

### dubbo线程池调优 ###
# 作为提供者,单个方法接收的最大并发请求数量(所有消费者)
dubbo.provider.executes=200
# 作为提供者,单个方法接收的最大并发请求数量(单个消费者)
dubbo.provider.actives=200
# 作为消费者,调用远程方法的最大并发请求数量
dubbo.consumer.actives=200

说明

这几个参数本来是调优的作用,因为一般情况下只需要配置线程池的数量即可,但是如果想要限制单个方法或单个客户端的并发请求数量,从而避免单个服务或单个客户端把系统拖垮,就可以配置以上的几个参数。配置了之后,就自动开启了监控功能。

代码

自定义dubbo拦截器类

if ("provider".equals(side)) { //只在提供者打印监控数据,因为监控一般都是在服务器端

//dubbo请求连接数量监控
                RpcStatus status = RpcStatus.getStatus(invoker.getUrl(), inv.getMethodName());
                URL url = invoker.getUrl();
                String methodName = inv.getMethodName();
                int max = url.getMethodParameter(methodName, "executes", 0);
                if (max <= 0) {
                    max = url.getMethodParameter(methodName, "default.executes", 0);
                }
                int left = max - status.getActive();
                logger.info("dubbo status:[method:{},status:{},max:{},left:{}]", new Object[]{methodName, JSONObject.toJSONString(status), max, left});

字段说明

测试数据

2020-07-09 16:52:22.286|INFO |dw4Vq9rvpwaA-61-0|xxx.common.filter.dubbo.AccessLogExtFilter.invoke:167||
dubbo status:[method:getQrcodeInfoById,status:{"active":9,"averageElapsed":1252,"averageTps":0,"failed":0,"failedAverageElapsed":0,
"failedElapsed":0,"failedMaxElapsed":0,"maxElapsed":1258,"succeeded":42,"succeededAverageElapsed":1252,"succeededElapsed":52611,
"succeededMaxElapsed":1258,"total":42,"totalElapsed":52611},max:200,left:191]

2020-07-09 16:52:22.287|INFO |xypAIqCmPDQ4-22-11|xxx.common.filter.dubbo.AccessLogExtFilter.invoke:167||
dubbo status:[method:getQrcodeInfoById,status:{
"active":2, //当前活跃的请求连接数量
"averageElapsed":1252, //平均耗时
"averageTps":0, //每秒请求数量
"failed":0, //失败数量
"failedAverageElapsed":0, //失败平均耗时
"failedElapsed":0, //失败请求总耗时
"failedMaxElapsed":0, //失败请求的最大耗时
"maxElapsed":1258, //最大耗时 
"succeeded":49, //成功请求数量
"succeededAverageElapsed":1252, //成功平均耗时
"succeededElapsed":61388, //请求成功总耗时
"succeededMaxElapsed":1258, //成功请求的最大耗时
"total":49 //总的请求次数(当前统计数据不包含当前请求,是之前的请求之和)
"totalElapsed":61388 //总耗时
},

max:200, //execute拦截器的数量
left:198 //剩余可使用的连接数量 = max - activce
]

说明

监控结果示例(监控数据是在当前请求之前的数据,不包括本次的,活跃连接数,成功数都要少一个)。

测试的时候,这几个拦截器配置的数量是200

### dubbo线程池调优 ###
# 作为提供者,单个方法接收的最大并发请求数量(所有消费者)
dubbo.provider.executes=200
# 作为提供者,单个方法接收的最大并发请求数量(单个消费者)
dubbo.provider.actives=200
# 作为消费者,调用远程方法的最大并发请求数量
dubbo.consumer.actives=200

所以

"total":49 //总的请求次数(当前统计数据不包含当前请求,是之前的请求之和)。

max:200, //execute拦截器的数量
left:198 //剩余可使用的连接数量 = max - activce

本质

dubbo提供了监控功能,其实就是拦截器功能,

原理

开启监控功能,需要前置开通服务消费方的最大连接数和服务提供方的最大连接数。服务消费方的连接数打开会带来影响,每一次请求都会过一遍ActiveLimitFilter,检查并发数是否超过最大并发数,超过了就等待,直至超时;

服务提供方每一次请求会过一遍ExecuteLimitFilter,检查并发数是否超过最大并发数,超过最大并发数直接异常。

参考

https://my.oschina.net/liangx…

原文 

https://segmentfault.com/a/1190000023210547

本站部分文章源于互联网,本着传播知识、有益学习和研究的目的进行的转载,为网友免费提供。如有著作权人或出版方提出异议,本站将立即删除。如果您对文章转载有任何疑问请告之我们,以便我们及时纠正。

PS:推荐一个微信公众号: askHarries 或者qq群:474807195,里面会分享一些资深架构师录制的视频录像:有Spring,MyBatis,Netty源码分析,高并发、高性能、分布式、微服务架构的原理,JVM性能优化这些成为架构师必备的知识体系。还能领取免费的学习资源,目前受益良多

转载请注明原文出处:Harries Blog™ » dubbo-客户端请求连接并发数量监控

赞 (0)
分享到:更多 ()

评论 0

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址