上边几次都是说的单体的拦截埋点,应用的内部进行的,很多的情况系统都是分布式的,怎么去监听RPC(远程过程调用),dubbo,RMI,springcloud,http。只要远程调用,跨进程调用都属于RPC,也不可能所有的能都涉及到,很多公司都有自己的封装,例如阿里的HFS,这次只针对dubbo这种RPC进行调用。源码:https://github.com/limingios/netFuture/tree/master/源码/『互联网架构』调⽤链系统工程结构(111)
对于dubbo的埋点,首先要了解dubbo的执行过程
节点 | 角色说明 |
---|---|
Provider | 暴露服务的服务提供方 |
Consumer | 调用远程服务的服务消费方 |
Registry | 服务注册与发现的注册中心 |
Monitor | 统计服务的调用次数和调用时间的监控中心 |
Container | 服务运行容器 |
名称 | 类型 | 描述 |
---|---|---|
servicePath | string | 服务路径 |
serviceName | string | 服务 |
inParam | json | 返回结果 |
outParam | json | 返回结果 |
ErrorMessage | string | 异常信息 |
ErrorStack | text | 异常堆栈 |
ResultState | string | 执行状态 |
beginTime | date | 开始时间 |
endTime | date | 结束时间 |
addressIp | string | 远程IP |
fromIp | string | 调用者IP |
埋点位置 | ||
如何才能完整的捕捉到以上信息呢?那么就需要了解Dubbo内部的调用 1.分解调用过程为多个步骤。2.这些步骤分别是在哪些协作线程上完成的?3.经过了哪些方法?4.经过了哪些过滤器? | ||
调用过程分解&线程协作 | ||
如何才能完整的捕捉到以上信息呢?那么就需要了解Dubbo内部的调用 1.分解调用过程为多个步骤。2.这些步骤分别是在哪些协作线程上完成的?3.经过了哪些方法?4.经过了哪些过滤器?
DubboInvoker.doInvoke拦截源码参见 :com.cbt.agent.collects.dubbo.DubboConsumerRpcExceptionMonitorHandle#invokerBefore FutureFilter.invoke拦截源码参见 :com.cbt.agent.collects.dubbo.DubboConsumerMonitorHandle#invokerBefore
经分析埋点位置选在离实际调用方法较远的EchoFilter过滤器理由是捕捉的信息更全面。
具体会话开启过程:
方案 | 优点 | 缺点 |
---|---|---|
应用层Control类 | 简单,风险因素低 | 判别成本高,有局限性,只能根据 HttpServlet 子类或@RequestMapping进行识别。 |
DispatcherServlet.doDispatch | 简单,适应性强 | 1、只能针对spring mvc 项目 2、spring boot 项目不支持 |
HttpServlet.service | 适应性强,与应用层和框架无关 | 1、不同的容器ClassPath不一样,存在兼容性问题。2、存在风险,几乎所有请求都会经过此方法 3、业务异常无法捕获 |
总合比较还是选择 HttpServlet.service 会更好些。
字节码插是指在数据装载前在HttpServlet.service 插入监控指令,以拦截Http请求,其插桩的过程。
请求拦截是指具体Http请求过来时进行拦截过滤,这么做主要是为了完成两个目的
1.开启监控会话 2.开启对Servlet响应过程的监控
方案 | 优点 | 缺点 |
---|---|---|
埋点jedis 类Get、Set等API方法 | 简单直接 | 工作量大,方法较多、需要了解每个方法特性 |
埋点 Connection sendCommand方法 | 全面、所有命令都会经过此方法 | 存在未知风险、不方便计算执行时间、和返回结果 |
埋点 Protocol | 全面、所有命令都会经过此方法 | 存在未知风险、不方便计算执行时间、和返回结果 |
PS:源码中可以查看DevelopBootMain类,我看这代码也看了2天,原来老写业务代码,看看这确实很容易懵X,确实这才是有技术含量的代码。其实有没有技术含量不太重要,重要是的有没有商业价值。