PinPoint解析，RPC发送过程

短命女 2022-05-13 07:10 196阅读 0赞

最近需要对PinPoint监控进行了解，项目工程需要除了性能进行监控外，业务层面也得进行个性化定制。因此做了些关于PinPoint的研究，网上关于PinPoint的使用更多是安装教程和一些简单的说明。更多关于一些解析的资料则是比较匮乏，现在把自己所获得的一些感悟拿出来分享。

# 1.什么是pinpoint #

首先我们要知道PinPoint的定位是款开源的 APM (Application Performance Management/应用性能管理)工具，用于基于java的大规模分布式系统。我们可以从它的页面大概知道pinpoint的功能

![70][]

从这可以看出pinpoint是一款更注重性能监控的监控性应用，对于一些物理上的应用信息进行监视（如应用的cpu使用，内存的占用），而我觉得作为一款性能监控的应用，PinPoint的强大之处，还在于，首先它是一款用于监控整个链路级别的监控应用。（后面会讲），其次，采取的字节码增强技巧使得它可以实现监控应用的无代码级别的侵入方式。这也是很多人采用它的原因。毕竟随着时间推移，一些古老应用可能难以维护和修改，谁也不愿意去修改这里面的代码，然而还得实时对应用的状况进行监视

。

# 2.链路级别的监控，基于RPC的收发机制（实现） #

下面说说什么是基于链路级别的监控，也是PinPoint的一个消息传输机制。

首先得明白RPC是什么,

RPC（Remote Procedure Call）—[远程过程调用][Link 1]，它是一种通过[网络][Link 2]从远程计算机程序上请求服务，而不需要了解底层网络技术的协议。[RPC协议][RPC]假定某些[传输协议][Link 3]的存在，如TCP或UDP，为通信程序之间携带信息数据。在OSI[网络通信][Link 4]模型中，RPC跨越了[传输层][Link 5]和[应用层][Link 6]。RPC使得开发包括网络[分布式][Link 7]多程序在内的应用程序更加容易。

RPC采用客户机/服务器模式。请求程序就是一个客户机，而服务提供程序就是一个服务器。首先，客户机调用进程发送一个有进程参数的调用信息到服务进程，然后等待应答信息。在服务器端，进程保持睡眠状态直到调用信息到达为止。当一个调用信息到达，服务器获得进程参数，计算结果，发送答复[信息][Link 8]，然后等待下一个调用信息，最后，客户端调用进程接收答复信息，获得进程结果，然后调用执行继续进行。

对的，百度原话，也是我觉得迄今为止描述最清楚的。说白了，你可以把它当一个复杂的http请求（有一定误差，便于比喻罢了），当请求发送至服务器端时，首先到达前端，然后发送两个RPC到服务器B和C。B会马上做出反应，但是C需要和后端的D和E交互之后再返还给A，由A来响应最初的请求。对于这样一个请求，简单实用的分布式跟踪的实现，就是为服务器上每一次你发送和接收动作来收集跟踪标识符(message identifiers)和时间戳(timestamped events)。吐槽下 pinpoint 采取的是

# **thrift框架进行RPC调用** #

![img1.png][]

上述是一个简单的请求调用过程，简单讲解了一次rpc调用时如何跟踪整个应用链的消息，并进行记录。

拆分和补充下

当在 TomcatA 和 TomcatB 中安装pinpoint的数据。可以把单个节点的跟踪数据看成single traction，提现分布式事务跟踪的流程。

1.  当请求到达TomcatA时, Pinpoint agent 产生一个 TraceId.
    
     *  TX\_ID: TomcatA^TIME^1
     *  SpanId: 10
     *  ParentSpanId: -1(Root)
2.  从spring MVC 控制器中记录数据
3.  插入HttpClient.execute()方法的调用并在HTTPGet中配置TraceId
    
     *  创建一个子TraceId
        
         *  TX\_ID: TomcatA^TIME^1 -> TomcatA^TIME^1
         *  SPAN\_ID: 10 -> 20
         *  PARENT\_SPAN\_ID: -1 -> 10 (父 SpanId)
     *  在HTTP header中配置子 TraceId
        
         *  HttpGet.setHeader(PINPOINT\_TX\_ID, "TomcatA^TIME^1")
         *  HttpGet.setHeader(PINPOINT\_SPAN\_ID, "20")
         *  HttpGet.setHeader(PINPOINT\_PARENT\_SPAN\_ID, "10")
4.  传输打好tag的请求到TomcatB.
    
     *  TomcatB 检查传输过来的请求的header
        
        HttpServletRequest.getHeader(PINPOINT\_TX\_ID)
     *  TomcatB 作为子节点工作因为它识别了header中的TraceId
        
         *  TX\_ID: TomcatA^TIME^1
         *  SPAN\_ID: 20
         *  PARENT\_SPAN\_ID: 10
5.  从spring mvc控制器中记录数据并完成请求
6.  当从tomcatB回来的请求完成时，pinpoint agent发送跟踪数据到pinpoint collector就此存储在HBase中
7.  在对tomcatB的HTTP调用结束后，TomcatA的请求也完成了。pinpoint agent发送跟踪数据到pinpoint collector就此存储在HBase中
8.  UI从HBase中读取跟踪数据并通过排序树来创建调用栈

当然，其实PinPoint这一套并不是自己独创的，而是基于谷歌的Dapper系统借鉴而来（棒子们的借鉴精神），原文可以看

[http://bigbully.github.io/Dapper-translation/][http_bigbully.github.io_Dapper-translation]

# 3.字节码增强技术实现无侵入式监控 #

讲了那么多到了这才是PinPoint的技术精华，这方面网上有比较好的资料

这篇博客我觉得是讲的比较细致的

[https://blog.csdn.net/wang\_wpw/article/details/80917012][https_blog.csdn.net_wang_wpw_article_details_80917012]

[70]: /images/20220513/ef1a47cc37164eb8840053de4baffddc.png
[Link 1]: https://baike.baidu.com/item/%E8%BF%9C%E7%A8%8B%E8%BF%87%E7%A8%8B%E8%B0%83%E7%94%A8/7854346
[Link 2]: https://baike.baidu.com/item/%E7%BD%91%E7%BB%9C/143243
[RPC]: https://baike.baidu.com/item/RPC%E5%8D%8F%E8%AE%AE
[Link 3]: https://baike.baidu.com/item/%E4%BC%A0%E8%BE%93%E5%8D%8F%E8%AE%AE/8048821
[Link 4]: https://baike.baidu.com/item/%E7%BD%91%E7%BB%9C%E9%80%9A%E4%BF%A1/9636548
[Link 5]: https://baike.baidu.com/item/%E4%BC%A0%E8%BE%93%E5%B1%82/4329536
[Link 6]: https://baike.baidu.com/item/%E5%BA%94%E7%94%A8%E5%B1%82/4329788
[Link 7]: https://baike.baidu.com/item/%E5%88%86%E5%B8%83%E5%BC%8F
[Link 8]: https://baike.baidu.com/item/%E4%BF%A1%E6%81%AF/111163
[img1.png]: /images/20220513/5036bf7b28c246098fbdeb2f292cdaeb.png
[http_bigbully.github.io_Dapper-translation]: http://bigbully.github.io/Dapper-translation/
[https_blog.csdn.net_wang_wpw_article_details_80917012]: https://blog.csdn.net/wang_wpw/article/details/80917012