OpenTelemetry系列 - 第2篇 Java端接入OpenTelemetry

import io.opentelemetry.api.trace.SpanKind;
import io.opentelemetry.context.Context;
import io.opentelemetry.sdk.trace.data.SpanData;
import io.opentelemetry.sdk.trace.export.SimpleSpanProcessor;
import io.opentelemetry.trace.Span;
import io.opentelemetry.trace.Tracer;
 
import java.util.Collections;
import java.util.List;
 
public class OpenTelemetryExample {
 
    // 初始化Tracer
    private final Tracer tracer;
 
    public OpenTelemetryExample(Tracer tracer) {
        this.tracer = tracer;
    }
 
    public void performAction() {
        // 创建一个Span
        Span span = tracer.spanBuilder("performAction").setSpanKind(SpanKind.INTERNAL).startSpan();
        span.setAttribute("important", true);
 
        try (Span ignored = span.startManual()) {
            // 执行操作
            Thread.sleep(1000); // 模拟耗时操作
        } catch (InterruptedException e) {
            Thread.currentThread().interrupt();
        } finally {
            // 结束Span
            span.end();
        }
    }
 
    public static void main(String[] args) {
        // 实现自定义的Tracer提供者（示例中省略了具体实现）
        MyTracerProvider tracerProvider = new MyTracerProvider();
 
        // 创建OpenTelemetryExample实例
        OpenTelemetryExample example = new OpenTelemetryExample(tracerProvider.get("my-service"));
 
        // 执行操作
        example.performAction();
 
        // 获取并输出Span数据
        List<SpanData> spans = tracerProvider.getFinishedSpans();
        for (SpanData span : spans) {
            System.out.println(span);
        }
    }
 
    // 自定义TracerProvider示例，需要实现OpenTelemetry中的相关接口
    private static class MyTracerProvider {
        public Tracer get(String serviceName) {
            // 实现获取Tracer的逻辑
            return null;
        }
 
        public List<SpanData> getFinishedSpans() {
            // 实现获取已完成Span数据的逻辑
            return Collections.emptyList();
        }
    }
}

这个代码示例展示了如何在Java中使用OpenTelemetry API来创建和管理一个Span。它首先初始化一个Tracer，然后创建一个Span来跟踪一个操作，操作完成后结束Span。最后，它提供了一个自定义的TracerProvider示例，用于获取Tracer和已完成的Span数据。在实际应用中，需要实现TracerProvider中的具体逻辑以连接到后端的OpenTelemetry收集器。