OpenTelemetry 中实现跨进程上下文注入（Inject）的正确方式-java教程-PHP中文网

OpenTelemetry 中实现跨进程上下文注入（Inject）的正确方式

在 OpenTelemetry 中，inject 操作通过 TextMapPropagator 完成，用于将当前追踪上下文序列化到传输载体（如 HTTP 请求头），替代 OpenTracing 中的 tracer.inject()。

在 opentelemetry 中，`inject` 操作通过 `textmappropagator` 完成，用于将当前追踪上下文序列化到传输载体（如 http 请求头），替代 opentracing 中的 `tracer.inject()`。

OpenTracing 的 inject() 方法（如 tracer.inject(spanContext, FORMAT, injector)）主要用于将 Span 上下文注入到请求载体中，常用于客户端发起远程调用前传播追踪信息。在 OpenTelemetry 中，该能力已统一抽象为 上下文传播器（Propagators），核心实现位于 TextMapPropagator 接口。

✅ 等效写法（Java）

import io.opentelemetry.api.OpenTelemetry;
import io.opentelemetry.api.trace.Span;
import io.opentelemetry.context.Context;
import io.opentelemetry.api.trace.Tracer;

// 假设 openTelemetry 已初始化（如通过 OpenTelemetrySdk.builder().build()）
OpenTelemetry openTelemetry = ...;

// 获取当前 Span 所属的 Context（注意：OpenTelemetry 不再直接暴露 SpanContext 给用户手动注入）
Context currentContext = Context.current(); // 或 Span.current().storeInContext(Context.current())

// 定义传输载体（例如 HTTP headers Map）
Map<string string> headers = new HashMap();

// 定义 setter —— 将 key-value 写入载体
TextMapSetter<map string>> setter = new TextMapSetter() {
    @Override
    public void set(Map<string string> carrier, String key, String value) {
        carrier.put(key, value);
    }
};

// 执行注入：将当前 Context 中的 TraceID、SpanID、TraceFlags 等写入 headers
openTelemetry.getPropagators()
    .getTextMapPropagator()
    .inject(currentContext, headers, setter);</string></map></string>

⚠️ 关键注意事项

不再操作 SpanContext：OpenTelemetry 强制通过 Context 传递追踪状态，Span.current() 返回的是 Span 实例，其上下文需通过 Span.fromContext(Context) 或 Span.makeCurrent() 管理；手动提取 SpanContext 并注入是反模式。
Propagator 是可插拔的：默认使用 W3C TraceContext + Baggage 传播器，也可自定义（如 Jaeger、B3 兼容格式），需在 SDK 初始化时配置：
```
OpenTelemetrySdk.builder()
    .setPropagators(ContextPropagators.create(W3CTraceContextPropagator.getInstance()))
    .build();
```
务必确保 Context 正确激活：若未在 Span 作用域内调用 inject()（例如未执行 span.makeCurrent()），Context.current() 可能不含追踪信息，导致注入空上下文。

✅ 总结

OpenTracing	OpenTelemetry
`tracer.inject(spanCtx, FORMAT, injector)`	`propagator.inject(Context.current(), carrier, setter)`
核心对象：`SpanContext`	核心对象：`Context`（含 `Span`, `Baggage`, 其他属性）
注入逻辑由 Tracer 管理	注入逻辑由独立的 `TextMapPropagator` 统一管理