异步任务 Trace 传播原理：Context Propagation、W3C Trace Context 与 Baggage

在异步任务中，Trace 的完整性与准确性直接取决于上下文（Context）能否在跨线程、跨进程、跨服务边界正确传递。本章深入剖析 OTel 中 Context Propagation 的核心机制、W3C Trace Context 标准协议，以及 Baggage 在异步链路中的传递策略，帮助你在工程落地时避免“断链”与“数据丢失”。

4.1 Context Propagation 机制：异步链路的“隐形线”

Context Propagation 是分布式追踪的基石。它确保一个请求产生的 Trace 信息（TraceId、SpanId、Baggage 等）能够跟随执行流，从入口传递到每一个异步分支，最终汇聚成完整的调用链。

4.1.1 同步 vs 异步传播对比

4.1.2 OTel Context Propagation 工作流程

下图展示了 OTel 中 Context 在异步任务中的注入与提取过程：

4.1.3 异步传播的工程实现

在 Java 环境中，OTel 提供了 Context.taskWrapping() 和 Context.current().wrap() 来包装异步任务。以下是一个典型的使用示例：

// 1. 获取当前 Context
Context currentContext = Context.current();

// 2. 包装异步任务
Runnable wrappedTask = currentContext.wrap(() -> {
    // 此处的 Context 已被自动恢复
    Span span = tracer.spanBuilder("async-task").startSpan();
    try (Scope scope = span.makeCurrent()) {
        // 执行异步业务逻辑
        processAsyncWork();
    } finally {
        span.end();
    }
});

// 3. 提交到线程池
executorService.submit(wrappedTask);

4.2 W3C Trace Context 标准：跨服务 Trace 的通用语言

W3C Trace Context 是分布式追踪的行业标准，定义了 traceparent 和 tracestate 两个 HTTP 头，用于在服务间传递 Trace 信息。OTel 默认使用该标准进行传播。

4.2.1 traceparent 头结构

完整示例：traceparent: 00-0af7651916cd43dd8448eb211c80319c-b7ad6b7169203331-01

4.2.2 tracestate 头：供应商扩展

tracestate 用于携带供应商特定的 Trace 元数据，格式为键值对列表，以逗号分隔：

tracestate: vendor1=value1,vendor2=value2

OTel 在传播时会自动合并多个供应商的 tracestate，并遵循 W3C 的“最左优先”合并规则。

4.2.3 W3C Trace Context 在异步消息中的传递

对于消息队列（如 Kafka、RabbitMQ），traceparent 和 tracestate 需要被序列化到消息头中。以下是一个 Kafka 生产者的注入示例：

// 生产者端：注入 Trace Context
ProducerRecord<String, String> record = new ProducerRecord<>("topic", key, value);
TextMapSetter<ProducerRecord<?, ?>> setter = (carrier, key, value) ->
    carrier.headers().add(key, value.getBytes(StandardCharsets.UTF_8));

OpenTelemetry.getPropagators().getTextMapPropagator()
    .inject(Context.current(), record, setter);
producer.send(record);

// 消费者端：提取 Trace Context
ConsumerRecord<String, String> record = ...;
TextMapGetter<ConsumerRecord<?, ?>> getter = new TextMapGetter<>() {
    @Override
    public Iterable<String> keys(ConsumerRecord<?, ?> carrier) {
        return carrier.headers().headers().stream()
            .map(Header::key).collect(Collectors.toList());
    }
    @Override
    public String get(ConsumerRecord<?, ?> carrier, String key) {
        Header header = carrier.headers().lastHeader(key);
        return header != null ? new String(header.value(), StandardCharsets.UTF_8) : null;
    }
};

Context extractedContext = OpenTelemetry.getPropagators().getTextMapPropagator()
    .extract(Context.current(), record, getter);
try (Scope scope = extractedContext.makeCurrent()) {
    // 处理消息，此时 Span 已正确关联
    processMessage(record);
}

4.3 Baggage 在异步链路中的传递

Baggage 是 OTel 中用于传递键值对元数据的机制，与 Trace 绑定但独立于 Span。它常用于传递用户 ID、请求来源、AB 测试标签等业务上下文。

4.3.1 Baggage 与 Span 属性的区别

4.3.2 Baggage 在异步任务中的传递策略

Baggage 的传递依赖于 Context Propagation。在异步场景中，需要确保 Baggage 被正确注入到异步载体的消息头中。下图展示了 Baggage 在异步链路中的完整传递路径：

4.3.3 Baggage 的工程注意事项

• 数据量控制： Baggage 会随每个 Span 传播，建议单个 Baggage 值不超过 256 字节，总大小不超过 4KB。
• 敏感信息： Baggage 可能被第三方系统读取，避免传递密码、Token 等敏感数据。
• 异步线程池： 使用 Context.wrap() 时，Baggage 会自动被包装，无需额外处理。
• 跨语言传递： W3C Baggage 标准使用 baggage 头，格式为 key1=value1;property1,key2=value2，所有 OTel SDK 均支持。

4.4 异步链路传播的工程检查清单