如何配置Spring Boot 3+Micrometer+Spring Stream(RabbitMQ)实现Zipkin链路不拆分

问题根源 #

用tryNextEmit异步发送消息时，默认不会自动携带当前的Trace上下文，导致框架生成新的TraceId，链路就此断裂。

解决步骤 #

1. 手动将Trace上下文带入异步发射逻辑 #

调用tryNextEmit时，先捕获当前请求的Trace上下文，再在发射代码块中恢复它，调整后的代码示例如下：

// 捕获当前请求的Trace上下文
TraceContext traceContext = TraceContextHolder.current();

// 发射消息时恢复上下文
messageChannel.tryNextEmit(message -> {
    try (TraceContext.Scope scope = traceContext.openScope()) {
        message.payload("你的业务数据");
        // 其他消息属性设置逻辑
        return true;
    }
});

2. 开启Spring Stream RabbitMQ的链路追踪开关 #

在配置文件（application.yml或application.properties）中，给对应的输入、输出绑定开启追踪配置，确保框架自动传递Trace相关头信息：

spring:
  cloud:
    stream:
      rabbit:
        bindings:
          你的输出绑定名:
            producer:
              enable-tracing: true
          你的输入绑定名:
            consumer:
              enable-tracing: true

注意替换配置中的你的输出绑定名和你的输入绑定名为项目实际使用的绑定名称。

3. 验证链路完整性 #

发送消息后，检查RabbitMQ消息头中的traceparent字段，确认其值与当前请求的TraceId一致，而非新生成的ID。同时登录Zipkin查看链路，确认上下游服务的TraceId相同，形成完整的一条链路。

额外注意事项 #

• 确保所有关联服务的Micrometer Tracing（如Zipkin依赖）版本统一，避免版本兼容性问题导致链路传递异常。
• 如果使用自定义消息转换器，需保证转换器不会过滤traceparent、tracestate等Trace相关头信息。

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