Quarkus OpenTelemetry：混合消息与REST调用时Trace ID中断问题咨询

问题原因 #

1. 线程上下文绑定缺失：ServiceB通过手动传播获得的Trace上下文，没有正确绑定到处理消息的当前线程。OpenTelemetry的RestClient自动 instrumentation依赖当前线程的Context中存在活跃Span，若未绑定，RestClient会认为没有父Span，生成新的Trace ID作为根Span。
2. RestClient未启用OpenTelemetry拦截器：手动构建的RestClient默认不会自动注入Trace上下文到HTTP请求头，导致ServiceC无法接收原Trace ID，只能生成新链路。
3. 混合场景的上下文断裂：全REST场景下自动 instrumentation会自动传递上下文，全消息场景下手动传播覆盖了上下文传递，但混合场景中，ServiceB的REST调用没有衔接手动传播来的上下文，导致链路分裂。

解决方法 #

1. 正确绑定Trace上下文到ServiceB的处理线程 #

在ServiceB消费消息的逻辑中，将从消息头提取的Trace上下文绑定到当前线程，并创建子Span：

// 从消息头提取Trace上下文
Context extractedContext = openTelemetry.getPropagators().getTextMapPropagator()
    .extract(Context.current(), messageHeaders, (carrier, key) -> carrier.get(key));

// 将上下文绑定到当前线程并创建子Span
try (Scope contextScope = extractedContext.makeCurrent()) {
    Span processSpan = openTelemetry.getTracer("service-b")
        .spanBuilder("process-message")
        .setParent(extractedContext)
        .startSpan();
    
    try (Scope spanScope = processSpan.makeCurrent()) {
        // 执行消息处理及后续REST调用
        restClient.get().uri("/service-c").retrieve().bodyToMono(String.class).block();
    } finally {
        processSpan.end();
    }
}

2. 为RestClient添加OpenTelemetry拦截器 #

确保RestClient构建时加入拦截器，自动将当前线程的Trace上下文注入HTTP请求头：

RestClient restClient = RestClient.builder()
    .requestInterceptor(new OpenTelemetryClientHttpRequestInterceptor(openTelemetry))
    .build();

如果使用Spring Boot，可通过引入opentelemetry-spring-boot-starter自动配置拦截器，无需手动添加。

3. 验证消息传递时的上下文注入完整性 #

ServiceA发送消息时，必须将当前Span的上下文注入到消息头中（使用W3C Trace Context标准格式）：

Span sendSpan = openTelemetry.getTracer("service-a")
    .spanBuilder("send-message-to-service-b")
    .startSpan();

try (Scope scope = sendSpan.makeCurrent()) {
    Map<String, Object> headersMap = new HashMap<>();
    // 将Trace上下文注入消息头
    openTelemetry.getPropagators().getTextMapPropagator()
        .inject(Context.current(), headersMap, Map::put);
    
    MessageHeaders messageHeaders = new MessageHeaders(headersMap);
    messageSender.send(new GenericMessage<>("message-payload", messageHeaders));
} finally {
    sendSpan.end();
}

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