Spring Boot 3+RabbitMQ集成Zipkin时TraceId不一致问题求助

我使用Spring Boot 3和RabbitMQ时遇到链路追踪异常：微服务A通过RabbitMQ调用微服务B，Zipkin上显示两个完全独立的请求——一个是微服务A的请求，另一个是微服务B与RabbitMQ的交互请求，二者TraceId不同，属于同一业务流程却无法展示依赖关系，求解决办法。

现有配置信息 #

pom.xml依赖 #

<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-actuator</artifactId>
</dependency>
<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-tracing-bridge-brave</artifactId>
</dependency>
<dependency>
    <groupId>io.zipkin.reporter2</groupId>
    <artifactId>zipkin-reporter-brave</artifactId>
</dependency>

application.yml配置 #

rabbitmq:
  in:
    requests:
      queue: q.requests.creation
      exchange: sms_requests
  out:
    books:
      queue: q.books.availabilities
      exchange: sms_books
      routingkey: sms_books_routingkey

logging:
  pattern:
    level: '%5p [${spring.application.name:},%X{traceId:-},%X{spanId:-}]'

management:
  tracing:
    sampling:
      probability: 1.0
    propagation:
      type: w3c, b3_multi, b3
    exporter:
      zipkin:
        enabled: true

自定义配置类 #

@Configuration
public class MyConfiguration implements WebMvcConfigurer {
    @Bean
    ContainerCustomizer<SimpleMessageListenerContainer> containerCustomizer() {
        return container -> container.setObservationEnabled(true);
    }
}

解决方案建议 #

1. 开启RabbitTemplate的观测功能 #

消息发送端需要确保RabbitTemplate将追踪上下文注入到消息头中，添加以下配置：

@Bean
RabbitTemplateCustomizer rabbitTemplateCustomizer() {
    return rabbitTemplate -> rabbitTemplate.setObservationEnabled(true);
}

2. 匹配监听容器的观测配置 #

如果使用的是DirectMessageListenerContainer而非SimpleMessageListenerContainer，需对应配置：

@Bean
ContainerCustomizer<DirectMessageListenerContainer> directContainerCustomizer() {
    return container -> container.setObservationEnabled(true);
}

3. 补充链路追踪依赖 #

确保micrometer-observation依赖存在，它是Spring Boot 3观测功能的核心：

<dependency>
    <groupId>io.micrometer</groupId>
    <artifactId>micrometer-observation</artifactId>
</dependency>

4. 统一追踪传播格式 #

避免混合多种传播格式导致解析异常，建议统一配置为b3或w3c：

management:
  tracing:
    propagation:
      type: b3

5. 验证消息头的追踪字段 #

在消费端打印消息头，确认是否携带X-B3-TraceId或traceparent等追踪字段：

@RabbitListener(queues = "${rabbitmq.in.requests.queue}")
public void handleMessage(Message message) {
    System.out.println("TraceId: " + message.getMessageProperties().getHeader("X-B3-TraceId"));
}

额外排查点 #

• 确认微服务A和B的Spring Boot版本一致，避免版本兼容性问题
• 检查是否有中间件修改RabbitMQ消息头，导致追踪字段丢失
• 验证Zipkin服务器版本是否支持Spring Boot 3的追踪格式

内容的提问来源于stack exchange，提问作者user12663622