Pinpoint
是韩国人编写的 APM 系统,是一个分析大规模分布式系统的平台,并提供处理大量跟踪数据的解决方案。
Pinpoint
特点
- 分布式事务追踪,跟踪跨分布式应用的消息
- 自动检测应用拓展
- 水平扩展,以便支持大规模服务器集群
- 提供代码级了践行,便于定位失败点和瓶颈
- 提供字节码增强技术,添加新功能无需修改代码
优势
- 非侵入式:使用字节码增强技术,添加新功能无需修改代码
- 资源消耗小:对性能影响最小(资源使用量增加约3%)
架构模块
- HBase:主要用于存储数据
- Pinpoint Collector:部署在 Web 容器上
- Pinpoint Web:部署在 Web 容器上
- Pinpoint Agent:附加到用于分析的 Java 应用程序
流程:首先通过 agent 收集调用应用的数据,将数据发送到 collector,collector 通过处理和分析数据,最后存储到 HBase 中,可以通过 Pinpoint Web UI 查看已经分析好的调用分析数据
数据结构
- Span:RPC 跟踪的基本单位,表示 RPC 到达时处理的工作,包含跟踪数据。Span 将子项标记未 SpanEvent,作为数据结构,每个 Span 包含一个 TraceId
- Trace:一系列跨度,由相关的 RPC(Span) 组成。同一跟踪中的跨距共享相同的 TransactionId。Trace 通过 SpanIds 和 ParentSpanIds 排序为分层树结构
- TraceId:由 TransactionId、SpanId、ParentSpanId 组成的秘钥集合。
TransactionId
代表消息id,SpanId 和 ParentSpanId 表示 RPC 父子关系TransactionId:来自单个事务的分布式系统发送、接收的消息id,必须在整个服务器组是全局唯一的
SpanId:接收 RPC 消息时处理的作业 ID,是在 RPC 到达节点时生成的
ParentSpanId:生成 RPC 的父 span 的 spanId,如果节点是事务的起始点,不会有父跨度。
兼容性
JDK 兼容性
Pinpoint 版本 | Agent 需要的 JDK 版本 | Collector 需要的 JDK 版本 | Web 需要的 JDK 版本 |
---|---|---|---|
1.0.x | 6-8 | 6+ | 6+ |
1.1.x | 6-8 | 7+ | 7+ |
1.5.x | 6-8 | 7+ | 7+ |
1.6.x | 6-8 | 7+ | 7+ |
1.7.x | 6-8 | 8+ | 8+ |
1.8.x | 6-8,9+ | 8+ | 8+ |
Base 兼容性
Pinpoint 版本 | HBase 0.94.x | HBase 0.98.x | HBase 1.0.x | HBase 1.1.x | HBase 1.2.x |
---|---|---|---|---|---|
1.0.x | √ | × | × | × | × |
1.1.x | × | not tested | √ | not tested | not tested |
1.5.x | × | not tested | √ | not tested | not tested |
1.6.x | × | not tested | not tested | not tested | √ |
1.7.x | × | not tested | not tested | not tested | √ |
1.8.x | × | not tested | not tested | not tested | √ |
Agent-Collector 兼容性
Agent 版本 | Collector 1.0.x | Collector 1.1.x | Collector 1.5.x | Collector 1.6.x | Collector 1.7.x | Collector 1.8.x |
---|---|---|---|---|---|---|
1.0.x | √ | √ | √ | √ | √ | √ |
1.1.x | not tested | √ | √ | √ | √ | √ |
1.5.x | × | × | √ | √ | √ | √ |
1.6.x | × | × | not tested | √ | √ | √ |
1.7.x | × | × | × | × | √ | √ |
1.8.x | × | × | × | × | × | √ |
Flink 兼容性
Pinpoint 版本 | flink 1.3.x | flink 1.4.x |
---|---|---|
1.7.x | √ | × |
实例
HBase 版本为 1.2.11,下载地址:http://mirrors.hust.edu.cn/apache/hbase/hbase-1.2.11/
Pinpoint 版本为 1.7.3,下载地址:https://github.com/naver/pinpoint/releases/tag/1.7.
Tomcat 版本为:8.x
其中,Pinpoint 需要下载 agent
、collector
、web
三个文件。
HBase
启动 HBase
解压 HBase,修改 config/hbase-env.sh
中 JAVA 目录
修改后启动 HBase: ./bin/start-hbase.sh
1 | starting master, logging to /opt/hbase/bin/../logs/hbase-root-master-localhost.localdomain.out |
稍等片刻后,jps
查看是否启动完成,若出现 HMaster
,则启动完成:
加载 Pinpoint HBase 脚本
在 https://github.com/naver/pinpoint/tree/master/hbase/scripts 中,获取 hbase-create.hbase
、hbase-drop.hbase
文件,新建目录 hbase-script
,执行脚本:
1 | ./bin/hbase shell /root/hbase-script/hbase-create.hbase |
Pinpoint
启动 Collector、Web
将 tomcat 解压为2个包,分别为 collector
、web
,删除 tomcat 目录下 webapps 下除 ROOT
的文件夹,并删除 ROOT
下所有文件。
将 collector、web 分别解压至对应 tomcat 的 ROOT 目录下,解压命令:
1 | jar -xvf pinpoint-collector-1.7.3.war |
分别修改两个 tomcat 的 config/server.xml
文件,修改端口 8005
、8080
、8443
、8009
端口,然后分别启动两个 tomcat。启动成功后访问 zipkin:http://192.168.67.136:28080/#/main
配置 Agent
创建四个文件夹:eureka
、provider
、consumer
、zuul
,并将四个服务移入对应文件夹,解压 agent.tar.gz,将解压后的文件放入四个文件夹:
配置 agent 中的 pinpoint.config
文件,修改 profiler.collector.ip
设置为 pinpoint-collector
的地址,如果在同一个服务器上,不用修改。
可以看到在 pinpoint.config
中监听了 9994
、9995
、9996
端口,这三个端口在 collector 启动后就开启了,默认即可。如果 collector 需要修改端口,需要修改 $COLLECTOR_TOMCAT_HOME/webapps/ROOT/WEB-INF/classes/pinpoint-collector.properties
文件。
启动服务
参数解释:-Dpinpoint.agentId
:表示 agent 的唯一标识-Dpinpoint.applicationName
:表示用用名称
eurekajava -javaagent:/usr/local/src/pinpoint/soft/eureka/pinpoint-agent-1.7.3/pinpoint-bootstrap-1.7.3.jar -Dpinpoint.agentId=eureka-server -Dpinpoint.applicationName=eureka-server -jar spring-cloud-eureka-server-simple-0.0.1-SNAPSHOT.jar
providerjava -javaagent:/usr/local/src/pinpoint/soft/eureka/pinpoint-agent-1.7.3/pinpoint-bootstrap-1.7.3.jar -Dpinpoint.agentId=provider -Dpinpoint.applicationName=provider -jar spring-cloud-apm-skywalking-provider-0.0.1-SNAPSHOT.jar
consumerjava -javaagent:/usr/local/src/pinpoint/soft/eureka/pinpoint-agent-1.7.3/pinpoint-bootstrap-1.7.3.jar -Dpinpoint.agentId=consumer -Dpinpoint.applicationName=consumer -jar spring-cloud-apm-skywlaking-consumer-0.0.1-SNAPSHOT.jar
zuuljava -javaagent:/usr/local/src/pinpoint/soft/eureka/pinpoint-agent-1.7.3/pinpoint-bootstrap-1.7.3.jar -Dpinpoint.agentId=zuul -Dpinpoint.applicationName=zuul -jar spring-cloud-apm-skywalking-zuul-0.0.1-SNAPSHOT.jar -Xms256m -Xmx256m
成功启动后,访问 pinpoint:http://192.168.67.136:28080/#/main
通过 zuul 获取数据:http://192.168.67.136:9020/client/get-info
再次查看 pinpoint,切换到 zuul 选项卡:
红色代表调用失败(第一次调用时需要从 eureka 获取数据,默认超时一秒)。数字代表调用次数
Inspector
:检查器,可以查看服务的调用信息。点击查看:
在 Inspector
中,Timeline 选项卡显示请求时间段,information
选项卡显示当前节点启动的信息,包括:应用名、agentId
、启动时间等,Heap Usage
显示堆使用情况,JVM/System Cpu Usage
显示 CPU 使用情况,Active Thread
显示线程使用情况。Response Time
显示响应时间,Data Source
显示数据库使用情况