基于Pinpoint對SpringCloud微服務項目實現全鏈路監(jiān)控的問題

更新時間：2022年02月17日 14:10:04 作者：Jiangxl~

這篇文章主要介紹了基于Pinpoint對SpringCloud微服務項目實現全鏈路監(jiān)控的問題,本文通過圖文并茂的形式給大家介紹的非常詳細，對大家的學習或工作具有一定的參考借鑒價值，需要的朋友可以參考下

1.全鏈路監(jiān)控的概念

隨著微服務架構的流行，服務按照不同的緯度進行拆分，一次請求往往需要設計到多個微服務程序，這些服務可能使用不同的編程語言開發(fā)，不同的團隊開發(fā)，可能部署很多歌副本，因此就需要一些可以幫助理解系統(tǒng)行為，用于分析性能問題的工具，以便發(fā)生故障的時候，能夠快速定位和解決問題，這個工具就是全鏈路監(jiān)控組件。

全鏈路監(jiān)控組件可以監(jiān)控每個微服務程序之間通信的一個數據指標，可以幫助運維好很好的分析一個請求時如何轉發(fā)到各個微服務之間以及微服務之間的調度。

全鏈路性能監(jiān)控，從整體緯度到局部緯度展示各項指標，將跨應用的所有調度鏈性能信息幾種展現，方便度量整體和局部的性能，并且方面找到故障產生的源頭，生產上可以極大縮短故障的排除時間。

全鏈路監(jiān)控解決的問題：

請求鏈路追蹤

通過監(jiān)控可以分析服務之間的調用關系，繪制運行時的拓撲信息，可視化展示。

調用情況衡量

各個調用環(huán)節(jié)的性能分析，例如吞吐量、響應時間、錯誤次數

容器規(guī)劃參考

根據監(jiān)控數據的分析，可以及時的對微服務進行擴容/縮容、服務降級、流量控制

運行情況反饋

通過監(jiān)控數據和業(yè)務日志快速定位錯誤信息

全鏈路監(jiān)控工具有很多種，應該從下面幾種方面去選擇

探針的性能消耗

全鏈路監(jiān)控工具都需要開啟一個探針才能對微服務的鏈路進行監(jiān)控，因此我們要選擇對服務的影響盡可能的少、數據分析的要快，性能占用小的工具。

代碼的侵入性

部分的鏈路監(jiān)控工具還需要在應用程序的代碼中集成，我們應該選擇盡可能不改業(yè)務程序代碼的同時也能把微服務監(jiān)控起來的工具，減少開發(fā)人員的負擔。

監(jiān)控緯度

監(jiān)控的數據要全方面、要到位、監(jiān)控指標越多越好。

可擴展性

工具可以支持分部署部署，具備良好的擴展性。

主流的鏈路監(jiān)控工具由zipkin、skywalking、pinpoint。

2.pinpoint鏈路監(jiān)控組件的介紹

pinpoint是一個APM（應用程序性能管理）的工具，適用于JAVA/PHP編寫的大型分布式系統(tǒng)。

pinpoint的特性：

服務地圖（serverMap）：通過可視化分布式系統(tǒng)的模塊和他們之間的相互來展示系統(tǒng)拓撲，點擊某個節(jié)點會展示該模塊的詳情，比如當前的狀態(tài)和請求數量。
實時活動性線程圖（Realtime Active Thread Chart）：實時監(jiān)控應用內部的活動線程。
請求響應分布圖（Request/Response Scatter Chart）：長期可視化請求數量和應答模式來定位潛在問題。
調用棧（CallStack）：在分布式環(huán)境中為每個調用生成代碼級別的可視圖，在單個視圖中定位瓶頸和失敗點檢查器（Inspector）：查看應用上的其他詳細信息，比如CPU使用率、內存/垃圾回收、TPS和JVM參數。

pinpoint架構

pinpoint agent會部署在程序服務器上，程序啟動時會指定agent服務，由pinpoint collector獲取微服務之間的鏈路監(jiān)控，然后存儲在Hbase數據庫中，pinpoint web ui展示監(jiān)控數據。

3.使用docker部署pinpoint監(jiān)控組件

pinpoint托管在github上，拉取鏡像非常慢，可以從百度網盤上獲取。

pinpoint對docker-compose的版本也要要求，最好在1.25版本以上。

1.下載docker-compose
# curl -L https://github.com/docker/compose/releases/download/1.25.0/docker-compose-Linux-x86_64 -o /usr/local/bin/docker-compose 
# chmod a+x /usr/local/bin/docker-compose 

2.下載pinpoint docker部署安裝包
# wget https://codeload.github.com/pinpoint-apm/pinpoint-docker/zip/refs/tags/1.8.5

3.部署pinpoint
# unzip pinpoint-docker-1.8.5.zip
# docker-compose pull && docker-compose up -d

4.如果網速不行，就采用下載的方式部署
#導入pinpoint鏡像
[root@binary-k8s-node2 ~]# cd pinpoint-image/
[root@binary-k8s-node2 pinpoint-image]# for i in `ls`; do docker load -i $i; done
#部署pinpoint
[root@binary-k8s-node2 ~]# unzip pinpoint-docker-1.8.5.zip >/dev/null
[root@binary-k8s-node2 ~]# cd pinpoint-docker-1.8.5/
[root@binary-k8s-node2 pinpoint-docker-1.8.5]# docker-compose up -d
Creating pinpoint-docker-185_zoo2_1 ... done
Creating pinpoint-flink-jobmanager  ... done
Creating pinpoint-docker-185_zoo1_1 ... done
Creating pinpoint-hbase             ... done
Creating pinpoint-mysql             ... done
Creating pinpoint-docker-185_zoo3_1 ... done
Creating pinpoint-flink-taskmanager ... done
Creating pinpoint-collector         ... done
Creating pinpoint-web               ... done
Creating pinpoint-agent             ... done
Creating pinpoint-quickstart        ... done

[root@binary-k8s-node2 pinpoint-docker-1.8.5]# docker-compose ps

在這里插入圖片描述

pinpoint-web容器提供頁面展示，已經將容器的8080端口映射成了8039端口，直接訪問8079端口即可。

pinpoint自帶了一個quickapp的展示模板

在這里插入圖片描述

4.在微服務中集成pinpoint-agent

4.1.pinpoint-agent的接入方式

Tomcat方式接入pinpoint-agent方式
需要修改bin/catalina.sh腳本
CATALINA_OPTS="$CATALINA_OPTS -javaagent:"$AGENT_PATH/pinpoint-bootstrap-$VERSION.jar"
CATALINA_OPTS="$CATALINA_OPTS -Dpinpoint.agentId="$AGENT_ID"
CATALINA_OPTS="$CATALINA_OPTS -Dpinpoint.applicationName="$APPLICATION_NAME"

java -jar啟動程序的方式如下
直接在啟動命令中增加即可
java -jar -javaagent:$AGENT_PATH/pinpoint-bootstrap-$VERSION.jar -Dpinpoint.agentId=$AGENT_ID
-Dpinpoint.applicationName=$APPLICATION_NAME xxx.jar

-javaagent:$AGENT_PATH/pinpoint-bootstrap-$VERSION.jar			#agent程序的的jar包
-Dpinpoint.agentId=$AGENT_ID					#程序計入pinpoint的一個id號，每個微服務副本節(jié)點都要求唯一
-Dpinpoint.applicationName=$APPLICATION_NAME				#應用組名，一個相同的微服務他們的應用組名要保持一樣

下載pinpoint-agent程序

點擊設置—>installation

https://github.com/pinpoint-apm/pinpoint/releases/download/1.8.5/pinpoint-agent-1.8.5.tar.gz

在這里插入圖片描述

4.2.配置pinpoint-agent

配置pinpoint-agent，然后將pinpoint-agent目錄拷貝到每一個微服務的程序代碼目錄中。

1.下載pinpoint-agent
[root@binary-k8s-master1 ~]# wget https://github.com/pinpoint-apm/pinpoint/releases/download/1.8.5/pinpoint-agent-1.8.5.tar.gz

2.配置pinpoint
[root@binary-k8s-master1 ~]# vim pinpoint-agent/pinpoint.config 
profiler.collector.ip=192.168.20.13				#指定pinpoint collector組件的IP地址

3.將pinpoint拷貝到每個微服務的代碼目錄中
[root@binary-k8s-master1 ~]# cp -rp pinpoint-agent springcloud/simple-microservice-dev1/{eureka-service,gateway-service,portal-service}
[root@binary-k8s-master1 ~]# cp -rp pinpoint-agent springcloud/simple-microservice-dev1/product-service/product-service-biz/
[root@binary-k8s-master1 ~]# cp -rp pinp springcloud/simple-microservice-dev1/stock-service/stock-service-biz/
[root@binary-k8s-master1 ~]# cp -rp pinpoint-agent springcloud/simple-microservice-dev1/stock-service/stock-service-biz/

4.3.修改每個微服務程序的Dockerfile接入pinpoint-agent

修改每個微服務程序的Dockerfile，將pinpoint的程序目錄拷貝到容器中，然后在程序的啟動命令中加上pinpoint-agent參數，接入pinpoint，其中-Dpinpoint.agentId字段的值采用pod的名稱來定義，Dpinpoint.applicationName字段的值采用simple-服務名稱來定義。

eureke-service服務

[root@binary-k8s-master1 simple-microservice-dev1]# vim eureka-service/Dockerfile 
FROM 192.168.20.11/base/centos-java:v1
RUN mkdir /data/simple-microservice/eureka-service -p
COPY ./target/eureka-service.jar /data/simple-microservice/eureka-service/
COPY pinpoint-agent /pinpoint-agent
RUN echo -e "#!/bin/bash \njava -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=\${HOSTNAME} -Dpinpoint.applicationName=simple-eureka -Deureka.instance.hostname=${MY_POD_NAME}.eureka-service.simple-ms /data/simple-microservice/eureka-service/eureka-service.jar > /data/simple-microservice/eureka-service/eureka-service.log & \ntail -f /data/simple-microservice/eureka-service/eureka-service.log" > /data/entrypoint.sh && chmod a+x /data/entrypoint.sh
EXPOSE 8080
ENTRYPOINT /data/entrypoint.sh


############################################
java -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=${HOSTNAME} -Dpinpoint.applicationName=simple-eureka -Deureka.instance.hostname=${MY_POD_NAME}.eureka-service.simple-ms /data/simple-microservice/eureka-service/eureka-service.jar

gateway-service服務

[root@binary-k8s-master1 simple-microservice-dev1]# vim gateway-service/Dockerfile 
FROM 192.168.20.11/base/centos-java:v1
RUN mkdir /data/simple-microservice/gateway-service -p
COPY ./target/gateway-service.jar /data/simple-microservice/gateway-service/
COPY pinpoint-agent /pinpoint-agent
RUN echo -e "#!/bin/bash \njava -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=\${HOSTNAME} -Dpinpoint.applicationName=simple-gateway /data/simple-microservice/gateway-service/gateway-service.jar > /data/simple-microservice/gateway-service/gateway-service.log & \ntail -f /data/simple-microservice/gateway-service/gateway-service.log" > /data/entrypoint.sh && chmod a+x /data/entrypoint.sh
EXPOSE 8080
ENTRYPOINT /data/entrypoint.sh


############################################
java -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=${HOSTNAME} -Dpinpoint.applicationName=simple-gateway /data/simple-microservice/gateway-service/gateway-service.jar

order-service服務

[root@binary-k8s-master1 simple-microservice-dev1]# vim order-service/order-service-biz/Dockerfile 
FROM 192.168.20.11/base/centos-java:v1
RUN mkdir /data/simple-microservice/order-service -p
COPY ./target/order-service-biz.jar /data/simple-microservice/order-service/
COPY pinpoint-agent /pinpoint-agent
RUN echo -e "#!/bin/bash \njava -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=\${HOSTNAME} -Dpinpoint.applicationName=simple-order  /data/simple-microservice/order-service/order-service-biz.jar > /data/simple-microservice/order-service/order-service-biz.log & \ntail -f /data/simple-microservice/order-service/order-service-biz.log" > /data/entrypoint.sh && chmod a+x /data/entrypoint.sh
EXPOSE 8080
ENTRYPOINT /data/entrypoint.sh


############################################
java -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=${HOSTNAME} -Dpinpoint.applicationName=simple-order  /data/simple-microservice/order-service/order-service-biz.jar

portal-service服務

[root@binary-k8s-master1 simple-microservice-dev1]# vim portal-service/Dockerfile 
FROM 192.168.20.11/base/centos-java:v1
RUN mkdir /data/simple-microservice/portal-service -p
COPY ./target/portal-service.jar /data/simple-microservice/portal-service/
COPY pinpoint-agent /pinpoint-agent
RUN echo -e "#!/bin/bash \njava -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=\${HOSTNAME} -Dpinpoint.applicationName=simple-portal /data/simple-microservice/portal-service/portal-service.jar > /data/simple-microservice/portal-service/portal-service.log & \ntail -f /data/simple-microservice/portal-service/portal-service.log" > /data/entrypoint.sh && chmod a+x /data/entrypoint.sh
EXPOSE 8080
ENTRYPOINT /data/entrypoint.sh


############################################
java -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=${HOSTNAME} -Dpinpoint.applicationName=simple-protal /data/simple-microservice/portal-service/portal-service.jar

product-service服務

[root@binary-k8s-master1 simple-microservice-dev1]# vim product-service/product-service-biz/Dockerfile 
FROM 192.168.20.11/base/centos-java:v1
RUN mkdir /data/simple-microservice/product-service -p
COPY ./target/product-service-biz.jar /data/simple-microservice/product-service/
COPY pinpoint-agent /pinpoint-agent
RUN echo -e "#!/bin/bash \njava -jar -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=\${HOSTNAME} -Dpinpoint.applicationName=simple-product /data/simple-microservice/product-service/product-service-biz.jar > /data/simple-microservice/product-service/product-service-biz.log & \ntail -f /data/simple-microservice/product-service/product-service-biz.log" > /data/entrypoint.sh && chmod a+x /data/entrypoint.sh
EXPOSE 8080
ENTRYPOINT /data/entrypoint.sh


############################################
java -jar -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=${HOSTNAME} -Dpinpoint.applicationName=simple-product /data/simple-microservice/product-service/product-service-biz.jar

stock-service服務

[root@binary-k8s-master1 simple-microservice-dev1]# vim stock-service/stock-service-biz/Dockerfile 
FROM 192.168.20.11/base/centos-java:v1
RUN mkdir /data/simple-microservice/stock-service -p
COPY ./target/stock-service-biz.jar /data/simple-microservice/stock-service/
COPY pinpoint-agent /pinpoint-agent
RUN echo -e "#!/bin/bash \njava -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=\${HOSTNAME} -Dpinpoint.applicationName=simple-stock /data/simple-microservice/stock-service/stock-service-biz.jar > /data/simple-microservice/stock-service/stock-service-biz.log & \ntail -f /data/simple-microservice/stock-service/stock-service-biz.log" > /data/entrypoint.sh && chmod a+x /data/entrypoint.sh
EXPOSE 8080
ENTRYPOINT /data/entrypoint.sh


java -jar -javaagent:/pinpoint-agent/pinpoint-bootstrap-1.8.5.jar -Dpinpoint.agentId=${HOSTNAME} -Dpinpoint.applicationName=simple-stock /data/simple-microservice/stock-service/stock-service-biz.jar

4.4.先將product商品服務接入到pinpoint觀察效果

我們接入pinpoint的Dockerfile已經寫好，直接使用腳本將produce重新部署一下即可。

sh deploy_k8s.sh product-service
[root@binary-k8s-master1 k8s]# kubectl get pod -n simple-ms
NAME                       READY   STATUS    RESTARTS   AGE
eureka-0                   1/1     Running   1          6d17h
eureka-1                   1/1     Running   0          6d17h
eureka-2                   1/1     Running   1          6d17h
gateway-7bb79fdbc4-vvnct   1/1     Running   0          6d11h
order-6694f4c474-rg7kw     1/1     Running   0          6d17h
portal-697fdf95dd-ml86k    1/1     Running   0          6d16h
product-847bb6d9fc-cs692   1/1     Running   0          10m						#重新部署
stock-6cf98bb445-l8gxb     1/1     Running   0          6d19h

product部署好之后在portal門戶網站上購買一個商品，產生product商品微服務的請求，觀察pinpoint上的鏈路狀態(tài)。

product商品微服務下單之后會調用stock庫存微服務，stock微服務還沒有接入到pinpoint中，所以在看pinpoint上鏈路監(jiān)控時，就會發(fā)現stock只會以ip的形式展示。

可以在鏈路監(jiān)控視圖中看到服務之間調用請求的次數，以及是如何調用的。

4.5.將所有的微服務接入到pinpoint系統(tǒng)

Dockerfile已經調整好，只需要執(zhí)行咱們寫好的部署腳本，將所有的微服務根據最新的Dockerfile制作出最新的鏡像，然后在K8S集群中重新部署一下即可。

deploy_k8s腳本不跟任何位置參數就表示將所有的微服務程序全部更新部署。

[root@binary-k8s-master1 k8s]# sh deploy_k8s.sh

在門戶網站中購買兩個商品觀察微服務之間的調用。

在這里插入圖片描述

5.pinpoint監(jiān)控系統(tǒng)簡單使用

在監(jiān)控視圖的右側可以選擇不同的微服務副本節(jié)點、程序之間的調用、請求成功失敗的次數

在這里插入圖片描述

5.1.查看程序代碼類之間是怎么調用其他微服務的

1）點擊view servers可以隨機切換各個副本節(jié)點

在這里插入圖片描述

2）點擊右側最上面的統(tǒng)計圖，然后找到圖中的小點，選中這個小點就會跳轉到代碼調用的頁面

在這里插入圖片描述

3）選中完之后會立即跳轉，然后點擊該請求

請求成功的監(jiān)控內容

在這里插入圖片描述

請求失敗的監(jiān)控內容

在這里插入圖片描述

4）這里還會有比之前更豐富的視圖

在這里插入圖片描述

5）點擊mixed view會看到更加豐富的展示視圖

請求成功的

在這里插入圖片描述

請求失敗的

在這里插入圖片描述

5.2.查看微服務的JVM監(jiān)控信息

1）點擊inspector

在這里插入圖片描述

2）選擇指定的副本節(jié)點

這些名稱都是通過在啟動命令中加的-Dpinpoint.agentId=${HOSTNAME}參數生效的

在這里插入圖片描述

到此這篇關于基于Pinpoint對SpringCloud微服務項目實現全鏈路監(jiān)控的文章就介紹到這了,更多相關Pinpoint全鏈路監(jiān)控內容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關文章希望大家以后多多支持腳本之家！

您可能感興趣的文章:

Springboot整合Active消息隊列
這篇文章主要介紹了Springboot整合Active消息隊列的步驟，幫助大家更好的理解和使用springboot框架，感興趣的朋友可以了解下
2020-12-12
關于Unsupported Media Type的解決方案
在Web開發(fā)中,415錯誤表示服務器無法處理請求附帶的媒體格式,本文介紹了導致HTTP 415錯誤的原因以及解決該問題的兩種方法,首先,415錯誤通常是由于客戶端請求的內容類型與服務器期望的不匹配引起的,例如,服務器可能期望JSON格式的數據
2024-10-10
使用Cloud Toolkit在IDEA中極速創(chuàng)建dubbo工程
這篇文章主要介紹了使用Cloud Toolkit在IDEA中極速創(chuàng)建dubbo工程，文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值，需要的朋友們下面隨著小編來一起學習學習吧
2019-11-11
Java中JDK動態(tài)代理的超詳細講解
JDK 的動態(tài)代理是基于攔截器和反射來實現的,JDK代理是不需要第三方庫支持的,只需要JDK環(huán)境就可以進行代理,下面這篇文章主要給大家介紹了關于Java中JDK動態(tài)代理的超詳細講解,需要的朋友可以參考下
2022-10-10
swagger2隱藏在API文檔顯示某些參數的操作
這篇文章主要介紹了swagger2隱藏在API文檔顯示某些參數的操作，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2021-06-06
SpringBoot整合任務系統(tǒng)quartz和SpringTask的方法
這篇文章主要介紹了SpringBoot整合任務系統(tǒng)（quartz和SpringTask）,Quartz是一個比較成熟了的定時任務框架，但是捏，它稍微的有些許繁瑣，本文先給大家講解下Quartz的一些基本概念結合實例代碼給大家詳細講解，需要的朋友可以參考下
2022-10-10
關于JSqlparser使用攻略(高效的SQL解析工具)
這篇文章主要介紹了關于JSqlparser使用攻略(高效的SQL解析工具)，具有很好的參考價值，希望對大家有所幫助。如有錯誤或未考慮完全的地方，望不吝賜教
2022-11-11
淺談java的守護線程與非守護線程
這篇文章主要介紹了淺談java的守護線程與非守護線程，小編覺得挺不錯的，現在分享給大家，也給大家做個參考。一起跟隨小編過來看看吧
2017-10-10
使用Java接收和處理OpenTelemetry數據的完整指南
在現代分布式系統(tǒng)中,OpenTelemetry 成為了一種常見的標準,用于跟蹤和監(jiān)控應用程序的性能和行為,OTLP是 OpenTelemetry 社區(qū)定義的一種數據傳輸協(xié)議,文將介紹如何使用 Java 編寫代碼來接收和處理 OTLP 數據,需要的朋友可以參考下
2024-04-04
springboot實現郵箱驗證碼功能
這篇文章主要為大家詳細介紹了springboot實現郵箱驗證碼功能，文中示例代碼介紹的非常詳細，具有一定的參考價值，感興趣的小伙伴們可以參考一下
2020-02-02