『互联网架构』dubbo 调用埋点

『互联网架构』dubbo 调用埋点

上边几次都是说的单体的拦截埋点，应用的内部进行的，很多的情况系统都是分布式的，怎么去监听RPC（远程过程调用），dubbo，RMI，springcloud，http。只要远程调用，跨进程调用都属于RPC，也不可能所有的能都涉及到，很多公司都有自己的封装，例如阿里的HFS，这次只针对dubbo这种RPC进行调用。

####（一）Dubbo执行过程

对于dubbo的埋点，首先要了解dubbo的执行过程

（二）调用端埋点实现

埋点目的1.捕捉消费者调用信息（远程接口、URL、参数、用时、返回结果、异常）2.传递TraceRequest 调用信息模型表结构

经过对源码的分析，埋点的位置如下:DubboInvoker.doInvoke()FutureFilter.invoke()DubboInvoker.doInvoke() 方法最靠近调用方，异常捕捉范围较大，但是该位置无法通过Attachment 向下传递TraceRequest 参数，所以需要FutureFilter.invoke() 进行补充，其具体分工如下：·1.DubboInvoker.doInvoke捕获如下信息： 1、开始时间 2、服务路径 3、服务方法 4、输入参数 5、异常信息 6、本地地址2.FutureFilter.invoke 基于Attachment 向下传递参数 2、异常信息与堆栈 3、返回结果 DubboInvoker.doInvoke拦截源码参见 ：com.cbt.agent.collects.dubbo.DubboConsumerRpcExceptionMonitorHandle#invokerBefore

FutureFilter.invoke拦截源码参见 ：com.cbt.agent.collects.dubbo.DubboConsumerMonitorHandle#invokerBefore

（三）调用端埋点实现

埋点目的接收TraceRequest信息 ，并创建会话

经分析埋点位置选在离实际调用方法较远的EchoFilter过滤器理由是捕捉的信息更全面。

具体会话开启过程：

基于Attachment获取TraceId、ParentId、TraceProperties。 封装TraceRequest ，并此为参数开启会话。 在调用结束时关闭会话。具体源码参见：com.cbt.agent.collects.dubbo.DubboProviderMonitorHandle#invokerBefore

（二）Servlet处理埋点

Servlet埋点目的1.生成TraceId2.开启关闭监控会话3.捕捉Http请求（url、客户端IP、参数、响应时长、响应状态码） 埋点埋在哪？1.每一个Control方法2.DispatcherServlet.doDispatch方法3.HttpServlet.service 方法 方案对比

总合比较还是选择 HttpServlet.service 会更好些。

HttpServlet.service 埋点需要做的工作：1.字节码插桩2.请求拦截并获取请求信息 字节码插桩流程 字节码插是指在数据装载前在HttpServlet.service 插入监控指令，以拦截Http请求，其插桩的过程。

请求拦截是指具体Http请求过来时进行拦截过滤，这么做主要是为了完成两个目的

1.开启监控会话2.开启对Servlet响应过程的监控

（三）Redis 调用埋点

埋点可选方案

PS：源码中可以查看DevelopBootMain类，我看这代码也看了2天，原来老写业务代码，看看这确实很容易懵X，确实这才是有技术含量的代码。其实有没有技术含量不太重要，重要是的有没有商业价值。

版权声明：本文内容由网络用户投稿，版权归原作者所有，本站不拥有其著作权，亦不承担相应法律责任。如果您发现本站中有涉嫌抄袭或描述失实的内容，请联系我们jiasou666@gmail.com 处理，核实后本网站将在24小时内删除侵权内容。