试用 Opentelemetry Trace

public final class ExampleConfiguration {  
  
  // Name of the service  
  private static final String SERVICE_NAME = "opentelemetry-trace-demo";  
  
  /** Adds a SimpleSpanProcessor initialized with ZipkinSpanExporter to the TracerSdkProvider */  
  static OpenTelemetry initializeOpenTelemetry(String ip, int port) {  
    String endpoint = String.format("http://%s:%s/api/v2/spans", ip, port);  
    ZipkinSpanExporter zipkinExporter = ZipkinSpanExporter.builder().setEndpoint(endpoint).build();  
  
    Resource serviceNameResource =  
        Resource.create(Attributes.of(ResourceAttributes.SERVICE_NAME, SERVICE_NAME));  
  
    // Set to process the spans by the Zipkin Exporter  
    SdkTracerProvider tracerProvider =  
        SdkTracerProvider.builder()  
            .addSpanProcessor(SimpleSpanProcessor.create(zipkinExporter))  
            .setResource(Resource.getDefault().merge(serviceNameResource))  
            .build();  
    OpenTelemetrySdk openTelemetry =  
        OpenTelemetrySdk.builder().setTracerProvider(tracerProvider).buildAndRegisterGlobal();  
  
    // add a shutdown hook to shut down the SDK  
    Runtime.getRuntime().addShutdownHook(new Thread(tracerProvider::close));  
  
    // return the configured instance so it can be used for instrumentation.  
    return openTelemetry;  
  }  
}

public static void main(String[] args) {  
    // Parsing the input  
    if (args.length < 2) {  
        System.out.println("Missing [hostname] [port]");  
        System.exit(1);  
    }  
  
    String ip = args[0];  
    int port = Integer.parseInt(args[1]);  
  
    // it is important to initialize the OpenTelemetry SDK as early as possible in your process.  
    OpenTelemetry openTelemetry = ExampleConfiguration.initializeOpenTelemetry(ip, port);  
    TracerProvider tracerProvider = openTelemetry.getTracerProvider();  
  
    try {  
        ZipkinExample example = new ZipkinExample(tracerProvider);  
        example.demoTrace();  
    } catch (InterruptedException e) {  
        throw new RuntimeException(e);  
    }  
  
}

public void demoTrace() throws InterruptedException {  
    Span span = tracer.spanBuilder("Demo Trace").startSpan();  
  
    try (Scope scope = span.makeCurrent()) {  
  
        methodA();  
        methodB();  
        methodC();  
  
  
    } catch (RuntimeException | InterruptedException e) {  
        span.recordException(e);  
        throw e;  
    } finally {  
        span.end();  
    }  
  
}