SpringCloud集成OpenTelemetry的实现

import io.opentelemetry.api.trace.Span;
import io.opentelemetry.api.trace.Tracer;
import io.opentelemetry.context.Context;
import io.opentelemetry.context.propagation.TextMapPropagator;
import org.springframework.cloud.sleuth.Tracer;
import org.springframework.cloud.sleuth.propagation.PropagationType;
import org.springframework.cloud.sleuth.propagation.SleuthPropagator;
 
// 假设有一个Spring Cloud应用的Tracer bean
@Autowired
private Tracer sleuthTracer;
 
// 使用OpenTelemetry的API创建一个Span
Span span = sleuthTracer.spanBuilder("mySpan").startSpan();
try (Scope scope = span.makeCurrent()) {
    // 你的业务逻辑
} finally {
    span.end();
}
 
// 获取当前的Span上下文
Context context = span.storeInContext(Context.current());
 
// 使用OpenTelemetry的传播器传播Span信息
TextMapPropagator propagator = SleuthPropagator.getTextMapPropagator();
propagator.inject(context, PropagationType.TEXT_MAP, new MyTextMapCarrier());
 
// 你的业务逻辑
 
// 假设你需要从传递载体中提取Span信息
Span extractedSpan = propagator.extract(Context.current(), PropagationType.TEXT_MAP, new MyTextMapCarrier());

在这个例子中，我们首先使用Spring Cloud Sleuth提供的Tracer来创建一个新的Span。然后，我们使用OpenTelemetry的API将Span设置为当前的上下文，并且使用Sleuth的传播器将Span信息注入到一个自定义的传递载体MyTextMapCarrier中。最后，我们从传递载体中提取Span信息。这个过程展示了如何在Spring Cloud应用中整合OpenTelemetry进行追踪。