這篇文章將為大家詳細講解有關如何使用Apache SkyWalking對Apache Pulsar進行消息鏈路追蹤與性能監(jiān)控，文章內容質量較高，因此小編分享給大家做個參考，希望大家閱讀完這篇文章后對相關知識有一定的了解。

創(chuàng)新互聯(lián)公司主營淮安區(qū)網(wǎng)站建設的網(wǎng)絡公司,主營網(wǎng)站建設方案,成都app軟件開發(fā),淮安區(qū)h5重慶小程序開發(fā)公司搭建,淮安區(qū)網(wǎng)站營銷推廣歡迎淮安區(qū)等地區(qū)企業(yè)咨詢

??構建 Pulsar agent 插件
Apache Pulsar agent 插件將在 SkyWalking 6.5.0 正式發(fā)布。目前最新版本的 SkyWalking 為 6.4.0，因此，您需要從 SkyWalking 源代碼中構建 Pulsar agent 插件。1. 下載 SkyWalking 源代碼，構建 Pulsar agent 插件。  

     
   
   
   $ git clone https://github.com/apache/skywalking.git  
    
    $ cd skywalking  
    
    $ git submodule init  
    
    $ git submodule update  
    
    $ ./mvnw clean package -DskipTests

2. 解壓 apache-skywalking-apm-bin.tar.gz。  解壓后，所有 packages 會在 apm-dist/target 文件夾。  Pulsar agent 插件在 agent/plugins 文件夾。

     
   
   
   $ tar -xf apache-skywalking-apm-bin.tar.gz

恭喜你，你已成功構建 Pulsar agent 插件。

??啟動 SkyWalking 后臺服務

如果你已安裝 SkyWalking 后臺服務，可以忽略該步驟；如果未安裝，可參閱  (https://github.com/apache/skywalking/blob/master/docs/en/setup/backend/backend-ui-setup.md#deploy-backend-and-ui)  進行安裝。

????提示：

如果你在同一臺機器上運行 SkyWalking 后臺服務和 Pulsar broker，則需更改 SkyWalking 或 Pulsar broker 的網(wǎng)絡服務端口（默認情況下，它們都會使用 8080 端口）。

• 如需更改 Skywalking UI 的網(wǎng)絡服務端口，可參閱https://github.com/apache/skywalking/blob/master/docs/en/setup/backend/ui-setup.md。

• 如需更改 Pulsar broker 的網(wǎng)絡服務端口，可通過編輯 conf/broker.conf 配置文件進行更改。

??下載測試用例代碼

設置并開啟 Pulsar agent 插件本示例使用 Pulsar agent 集成測試的測試用例，你也可以編寫符合自身需求的測試用例。1. 下載 SkyWalking 集成測試源代碼。  

$ git clone https://github.com/SkyAPMTest/agent-auto-integration-testcases.git

下載后，該代碼庫中包含 pulsar-scenario 項目。2. 導入 pulsar-scenario 項目至 IDE。    本示例以 Intelli IDEA 為例。  如下圖所示，pulsar-scenario 項目是一個 Spring Boot 應用程序，包含一個 CaseController。 3. 設置 Pulsar agent 插件。  
啟動 Spring Boot 應用程序前，你需要設置 Pulsar agent 插件。????提示：  

• 如需設置 Java agent 及其屬性，參閱這里。
• 默認情況下，pulsar-scenario 項目使用 8082 端口。
• 下圖中的 VM 選項為：

         
       
       
       -javaagent:/apm-dist/target/apache-skywalking-apm-bin/agent/skywalking-agent.jar -DSW_AGENT_COLLECTOR_BACKEND_SERVICES=:11800 -DSW_AGENT_NAME=pulsar-demo -Dservice.url=pulsar://:6650

   

 

??測試并在 SkyWalking 中查看結果

至此，你已準備好了所需環(huán)境，下一步可以模擬請求并查看結果。執(zhí)行以下 HTTP 請求后，一些消息鏈路追蹤及監(jiān)控數(shù)據(jù)會上傳至 SkyWalking。此時，可以在 SkyWalking UI 中查看。

     
   
   
   $ curl http://localhost:8082/pulsar-scenario/case/pulsar-case

????面板視圖

面板顯示有 2 個 endpoint、1 個 service 和 1 個 MQ。

????拓撲視圖
拓撲視圖顯示以下信息：

• 用戶向服務（即，你的測試網(wǎng)絡應用程序）發(fā)送請求

• 服務向 Pulsar broker 發(fā)送消息和從 Pulsar broker 接收消息

????鏈路追蹤視圖  

鏈路追蹤視圖顯示每個請求的詳細信息。目前，Pulsar agent 插件支持 3 類 span：

• 生產(chǎn)者發(fā)送消息 span, 記錄生產(chǎn)者發(fā)送消息。
• 生產(chǎn)者發(fā)送消息回調 span：記錄消息已發(fā)送完成。

• 消費者接收消息 span：記錄消費者接收到消息。

關于如何使用Apache SkyWalking對Apache Pulsar進行消息鏈路追蹤與性能監(jiān)控就分享到這里了，希望以上內容可以對大家有一定的幫助，可以學到更多知識。如果覺得文章不錯，可以把它分享出去讓更多的人看到。
分享名稱：如何使用ApacheSkyWalking對ApachePulsar進行消息鏈路追蹤與性能監(jiān)控
網(wǎng)頁路徑：http://weahome.cn/article/iedjpi.html