温馨提示×

温馨提示×

您好,登录后才能下订单哦!

密码登录×
登录注册×
其他方式登录
点击 登录注册 即表示同意《亿速云用户服务条款》

如何使用Apache SkyWalking对Apache Pulsar进行消息链路追踪与性能监控

发布时间:2021-11-09 18:54:59 来源:亿速云 阅读:310 作者:柒染 栏目:大数据

这篇文章将为大家详细讲解有关如何使用Apache SkyWalking对Apache Pulsar进行消息链路追踪与性能监控,文章内容质量较高,因此小编分享给大家做个参考,希望大家阅读完这篇文章后对相关知识有一定的了解。

⚙️构建 Pulsar agent 插件
Apache Pulsar agent 插件将在 SkyWalking 6.5.0 正式发布。目前最新版本的 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 的网络服务端口(默认情况下,它们都会使用 8080 端口)。


  • 如需更改 Skywalking UI 的网络服务端口,可参阅https://github.com/apache/skywalking/blob/master/docs/en/setup/backend/ui-setup.md。

  • 如需更改 Pulsar broker 的网络服务端口,可通过编辑 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。
如何使用Apache SkyWalking对Apache Pulsar进行消息链路追踪与性能监控
3. 设置 Pulsar agent 插件。  
启动 Spring Boot 应用程序前,你需要设置 Pulsar agent 插件。
????提示:  
  • 如需设置 Java agent 及其属性,参阅这里。
  • 默认情况下,pulsar-scenario 项目使用 8082 端口。
  • 下图中的 VM 选项为:
           
         
         
         -javaagent:<your-skywalking-home>/apm-dist/target/apache-skywalking-apm-bin/agent/skywalking-agent.jar -DSW_AGENT_COLLECTOR_BACKEND_SERVICES=<skywalking-backend-host>:11800 -DSW_AGENT_NAME=pulsar-demo -Dservice.url=pulsar://<your-pulsar-broker-ip>:6650
     

如何使用Apache SkyWalking对Apache Pulsar进行消息链路追踪与性能监控

 

⚙️测试并在 SkyWalking 中查看结果


至此,你已准备好了所需环境,下一步可以模拟请求并查看结果。
执行以下 HTTP 请求后,一些消息链路追踪及监控数据会上传至 SkyWalking。此时,可以在 SkyWalking UI 中查看。
     
   
   
   $ curl http://localhost:8082/pulsar-scenario/case/pulsar-case

????面板视图

面板显示有 2 个 endpoint、1 个 service 和 1 个 MQ。

如何使用Apache SkyWalking对Apache Pulsar进行消息链路追踪与性能监控
????拓扑视图

拓扑视图显示以下信息:
  • 用户向服务(即,你的测试网络应用程序)发送请求
  • 服务向 Pulsar broker 发送消息和从 Pulsar broker 接收消息

如何使用Apache SkyWalking对Apache Pulsar进行消息链路追踪与性能监控

????链路追踪视图  

链路追踪视图显示每个请求的详细信息。
目前,Pulsar agent 插件支持 3 类 span:
  • 生产者发送消息 span, 记录生产者发送消息。
  • 生产者发送消息回调 span:记录消息已发送完成。
  • 消费者接收消息 span:记录消费者接收到消息。

如何使用Apache SkyWalking对Apache Pulsar进行消息链路追踪与性能监控

关于如何使用Apache SkyWalking对Apache Pulsar进行消息链路追踪与性能监控就分享到这里了,希望以上内容可以对大家有一定的帮助,可以学到更多知识。如果觉得文章不错,可以把它分享出去让更多的人看到。
向AI问一下细节

免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。

AI