rabbitmq整合skywalking并编写自界说插件加强

rabbitmq整合skywalking

起首先下载准备好skywalking 的服务端和ui控制台，java-agent
https://skywalking.apache.org/downloads/

整合skywalking

我的流程是在生产者和消费者服务中去引入一个mq的sdk，具体SDK的内容可以检察这篇文章
在sdk的pom文件中引入了skywalking依靠

1. <!-- skywalking -->
2. <dependency>
3.     <groupId>org.apache.skywalking</groupId>
4.     <artifactId>apm-toolkit-logback-1.x</artifactId>
5.     <version>9.3.0</version>
6. </dependency>
7. <dependency>
8.     <groupId>org.apache.skywalking</groupId>
9.     <artifactId>apm-toolkit-trace</artifactId>
10.     <version>9.3.0</version>
11. </dependency>

复制代码

引入之后进行logback的配置，也大概你们是使用log4j这些，配置自行百度就行
生产者logback.xml配置

1. <?xml version="1.0" encoding="UTF-8"?>
2. <configuration>
3.     <conversionRule conversionWord="tid" converterClass="org.apache.skywalking.apm.toolkit.log.logback.v1.x.LogbackPatternConverter"/>
5.     <!-- 日志存放路径 -->
6.         <property name="log.path" value="logs/sms-platform" />
7.     <!-- 日志输出格式 -->
8.         <property name="log.pattern" value="%d{HH:mm:ss.SSS} [%tid] [%thread] %-5level %logger{20} - [%method,%line] - %msg%n" />
10.         <!-- 控制台输出 -->
11.         <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
12.         <encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
13.             <layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.TraceIdPatternLogbackLayout">
14.                 <Pattern>${log.pattern}</Pattern>
15.             </layout>
16.         </encoder>
17.         </appender>
19.        
20.         <!-- 系统日志输出 -->
21.         <appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
22.             <file>${log.path}/sys-info.log</file>
23.         <!-- 循环政策：基于时间创建日志文件 -->
24.                 <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
25.             <!-- 日志文件名格式 -->
26.                         <fileNamePattern>${log.path}/sys-info.%d{yyyy-MM-dd}.log</fileNamePattern>
27.                         <!-- 日志最大的历史 60天 -->
28.                         <maxHistory>60</maxHistory>
29.                 </rollingPolicy>
30.         <encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
31.             <layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.mdc.TraceIdMDCPatternLogbackLayout">
32.                 <Pattern>${log.pattern}</Pattern>
33.             </layout>
34.         </encoder>
35.                 <filter class="ch.qos.logback.classic.filter.LevelFilter">
36.             <!-- 过滤的级别 -->
37.             <level>INFO</level>
38.             <!-- 匹配时的操作：接收（记录） -->
39.             <onMatch>ACCEPT</onMatch>
40.             <!-- 不匹配时的操作：拒绝（不记录） -->
41.             <onMismatch>DENY</onMismatch>
42.         </filter>
43.         </appender>
44.        
45.         <appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
46.             <file>${log.path}/sys-error.log</file>
47.         <!-- 循环政策：基于时间创建日志文件 -->
48.         <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
49.             <!-- 日志文件名格式 -->
50.             <fileNamePattern>${log.path}/sys-error.%d{yyyy-MM-dd}.log</fileNamePattern>
51.                         <!-- 日志最大的历史 60天 -->
52.                         <maxHistory>60</maxHistory>
53.         </rollingPolicy>
54.         <encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
55.             <layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.mdc.TraceIdMDCPatternLogbackLayout">
56.                 <Pattern>${log.pattern}</Pattern>
57.             </layout>
58.         </encoder>
59.         <filter class="ch.qos.logback.classic.filter.LevelFilter">
60.             <!-- 过滤的级别 -->
61.             <level>ERROR</level>
62.                         <!-- 匹配时的操作：接收（记录） -->
63.             <onMatch>ACCEPT</onMatch>
64.                         <!-- 不匹配时的操作：拒绝（不记录） -->
65.             <onMismatch>DENY</onMismatch>
66.         </filter>
67.     </appender>
68.        
69.         <!-- 用户访问日志输出  -->
70.     <appender name="sys-user" class="ch.qos.logback.core.rolling.RollingFileAppender">
71.                 <file>${log.path}/sys-user.log</file>
72.         <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
73.             <!-- 按天回滚 daily -->
74.             <fileNamePattern>${log.path}/sys-user.%d{yyyy-MM-dd}.log</fileNamePattern>
75.             <!-- 日志最大的历史 60天 -->
76.             <maxHistory>60</maxHistory>
77.         </rollingPolicy>
78.         <encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
79.             <layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.mdc.TraceIdMDCPatternLogbackLayout">
80.                 <Pattern>${log.pattern}</Pattern>
81.             </layout>
82.         </encoder>
83.     </appender>
85.     <appender name="grpc" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
86.         <encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
87.             <layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.mdc.TraceIdMDCPatternLogbackLayout">
88.                 <Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%X{tid}] [%thread] %-5level %logger{36} -%msg%n</Pattern>
89.             </layout>
90.         </encoder>
91.     </appender>
92.        
93.         <!-- 系统模块日志级别控制  -->
94.         <logger name="com.aasee" level="info" />
95.         <!-- Spring日志级别控制  -->
96.         <logger name="org.springframework" level="warn" />
98.         <root level="info">
99.                 <appender-ref ref="console" />
100.         <appender-ref ref="grpc"/>
101.         </root>
102.        
103.         <!--系统操作日志-->
104.     <root level="info">
105.         <appender-ref ref="file_info" />
106.         <appender-ref ref="file_error" />
107.     </root>
108.        
109.         <!--系统用户操作日志-->
110.     <logger name="sys-user" level="info">
111.         <appender-ref ref="sys-user"/>
112.     </logger>
113. </configuration>

复制代码

消费者logback.xml配置

1. <?xml version="1.0" encoding="UTF-8"?>
2. <configuration>
4.     <conversionRule conversionWord="tid" converterClass="org.apache.skywalking.apm.toolkit.log.logback.v1.x.LogbackPatternConverter"/>
5.     <!-- 日志存放路径 -->
6.         <property name="log.path" value="logs/sms-consumer" />
7.     <!-- 日志输出格式 -->
8.         <property name="log.pattern" value="%d{HH:mm:ss.SSS} [%tid] [%thread] %-5level %logger{20} - [%method,%line] - %msg%n" />
10.         <!-- 控制台输出 -->
11.         <appender name="console" class="ch.qos.logback.core.ConsoleAppender">
12.                 <encoder>
13.                         <pattern>${log.pattern}</pattern>
14.                 </encoder>
15.         </appender>
18.     <appender name="grpc" class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.log.GRPCLogClientAppender">
19.         <encoder class="ch.qos.logback.core.encoder.LayoutWrappingEncoder">
20.             <layout class="org.apache.skywalking.apm.toolkit.log.logback.v1.x.mdc.TraceIdMDCPatternLogbackLayout">
21.                 <Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%X{tid}] [%thread] %-5level %logger{36} -%msg%n</Pattern>
22.             </layout>
23.         </encoder>
24.     </appender>
25.        
26.         <!-- 系统日志输出 -->
27.         <appender name="file_info" class="ch.qos.logback.core.rolling.RollingFileAppender">
28.             <file>${log.path}/sys-info.log</file>
29.         <!-- 循环政策：基于时间创建日志文件 -->
30.                 <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
31.             <!-- 日志文件名格式 -->
32.                         <fileNamePattern>${log.path}/sys-info.%d{yyyy-MM-dd}.log</fileNamePattern>
33.                         <!-- 日志最大的历史 60天 -->
34.                         <maxHistory>60</maxHistory>
35.                 </rollingPolicy>
36.                 <encoder>
37.                         <pattern>${log.pattern}</pattern>
38.                 </encoder>
39.                 <filter class="ch.qos.logback.classic.filter.LevelFilter">
40.             <!-- 过滤的级别 -->
41.             <level>INFO</level>
42.             <!-- 匹配时的操作：接收（记录） -->
43.             <onMatch>ACCEPT</onMatch>
44.             <!-- 不匹配时的操作：拒绝（不记录） -->
45.             <onMismatch>DENY</onMismatch>
46.         </filter>
47.         </appender>
48.        
49.         <appender name="file_error" class="ch.qos.logback.core.rolling.RollingFileAppender">
50.             <file>${log.path}/sys-error.log</file>
51.         <!-- 循环政策：基于时间创建日志文件 -->
52.         <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
53.             <!-- 日志文件名格式 -->
54.             <fileNamePattern>${log.path}/sys-error.%d{yyyy-MM-dd}.log</fileNamePattern>
55.                         <!-- 日志最大的历史 60天 -->
56.                         <maxHistory>60</maxHistory>
57.         </rollingPolicy>
58.         <encoder>
59.             <pattern>${log.pattern}</pattern>
60.         </encoder>
61.         <filter class="ch.qos.logback.classic.filter.LevelFilter">
62.             <!-- 过滤的级别 -->
63.             <level>ERROR</level>
64.                         <!-- 匹配时的操作：接收（记录） -->
65.             <onMatch>ACCEPT</onMatch>
66.                         <!-- 不匹配时的操作：拒绝（不记录） -->
67.             <onMismatch>DENY</onMismatch>
68.         </filter>
69.     </appender>
70.        
71.         <!-- 用户访问日志输出  -->
72.     <appender name="sys-user" class="ch.qos.logback.core.rolling.RollingFileAppender">
73.                 <file>${log.path}/sys-user.log</file>
74.         <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
75.             <!-- 按天回滚 daily -->
76.             <fileNamePattern>${log.path}/sys-user.%d{yyyy-MM-dd}.log</fileNamePattern>
77.             <!-- 日志最大的历史 60天 -->
78.             <maxHistory>60</maxHistory>
79.         </rollingPolicy>
80.         <encoder>
81.             <pattern>${log.pattern}</pattern>
82.         </encoder>
83.     </appender>
84.        
85.         <!-- 系统模块日志级别控制  -->
86.         <logger name="com.aasee" level="info" />
87.         <!-- Spring日志级别控制  -->
88.         <logger name="org.springframework" level="warn" />
90.         <root level="info">
91.                 <appender-ref ref="console" />
92.         <appender-ref ref="grpc"/>
93.         </root>
94.        
95.         <!--系统操作日志-->
96.     <root level="info">
97.         <appender-ref ref="file_info" />
98.         <appender-ref ref="file_error" />
99.     </root>
100.        
101.         <!--系统用户操作日志-->
102.     <logger name="sys-user" level="info">
103.         <appender-ref ref="sys-user"/>
104.     </logger>
105. </configuration>

复制代码

发现问题

在完成了上述配置之后，启动项目，我发现消费者不停无法打印tid始终为n/a，经过一番查询后发现原来skywalking官方提供的消费插件不得当我们，其只针对官方原生Client实现扩展，但我们一般都是使用Spring Rabbitmq stater，以是我们无法实现链路追踪。@RabbitListener的工作原理可以看这篇文章https://blog.csdn.net/m0_72397750/article/details/140558744
总的来说就是我们一般使用注解来实现监听的，那么手动埋点就应该埋在开始处置处罚消息的executeListener()方法这

将消息头复制回来

详细的代码我放在了https://github.com/Aas-ee/skywalking-apm-sniffer 解释很详细 内里另有skywalking-rabbitmq的官方插件代码可以用来对照学习，可以拉取后直接打成jar包放到skywalking-agent/plugin目录下使用（觉得有效的话贫苦点点star，这对我很紧张），同时对于callback的打印也做了加强，但是不一定适用大家，主要用于学习思想和原理。

免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。