配置 SDK

package otel;

import io.opentelemetry.sdk.OpenTelemetrySdk;
import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdk;

public class AutoConfiguredSdk {
  public static OpenTelemetrySdk autoconfiguredSdk() {
    return AutoConfiguredOpenTelemetrySdk.initialize().getOpenTelemetrySdk();
  }
}

package otel;

import io.opentelemetry.sdk.OpenTelemetrySdk;
import io.opentelemetry.sdk.autoconfigure.AutoConfiguredOpenTelemetrySdk;
import java.util.Collections;

public class CustomizedAutoConfiguredSdk {
  public static OpenTelemetrySdk autoconfiguredSdk() {
    return AutoConfiguredOpenTelemetrySdk.builder()
        // 可以选择性地自定义 TextMapPropagator.
        .addPropagatorCustomizer((textMapPropagator, configProperties) -> textMapPropagator)
        // 可以选择性地自定义 Resource.
        .addResourceCustomizer((resource, configProperties) -> resource)
        // 可以选择性地自定义 Sampler.
        .addSamplerCustomizer((sampler, configProperties) -> sampler)
        // 可以选择性地自定义 SpanExporter.
        .addSpanExporterCustomizer((spanExporter, configProperties) -> spanExporter)
        // 可以选择性地自定义 SpanProcessor.
        .addSpanProcessorCustomizer((spanProcessor, configProperties) -> spanProcessor)
        // 可以选择性地提供额外属性.
        .addPropertiesSupplier(Collections::emptyMap)
        // 可以选择性地自定义 ConfigProperties.
        .addPropertiesCustomizer(configProperties -> Collections.emptyMap())
        // 可以选择性地自定义 SdkTracerProviderBuilder.
        .addTracerProviderCustomizer((builder, configProperties) -> builder)
        // 可以选择性地自定义 SdkMeterProviderBuilder.
        .addMeterProviderCustomizer((builder, configProperties) -> builder)
        // 可以选择性地自定义 MetricExporter.
        .addMetricExporterCustomizer((metricExporter, configProperties) -> metricExporter)
        // 可以选择性地自定义 MetricReader.
        .addMetricReaderCustomizer((metricReader, configProperties) -> metricReader)
        // 可以选择性地自定义 SdkLoggerProviderBuilder.
        .addLoggerProviderCustomizer((builder, configProperties) -> builder)
        // 可以选择性地自定义 LogRecordExporter.
        .addLogRecordExporterCustomizer((logRecordExporter, configProperties) -> logRecordExporter)
        // 可以选择性地自定义 LogRecordProcessor.
        .addLogRecordProcessorCustomizer((processor, configProperties) -> processor)
        .build()
        .getOpenTelemetrySdk();
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.ResourceProvider;
import io.opentelemetry.sdk.resources.Resource;

public class CustomResourceProvider implements ResourceProvider {

  @Override
  public Resource createResource(ConfigProperties config) {
    // 为资源提供属性的回调函数。
    return Resource.builder().put("my.custom.resource.attribute", "abc123").build();
  }

  @Override
  public int order() {
    // 可选地影响调用顺序。
    return 0;
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.AutoConfigurationCustomizer;
import io.opentelemetry.sdk.autoconfigure.spi.AutoConfigurationCustomizerProvider;
import java.util.Collections;

public class CustomizerProvider implements AutoConfigurationCustomizerProvider {

  @Override
  public void customize(AutoConfigurationCustomizer customizer) {
    // 可选择自定义 TextMapPropagator。
    customizer.addPropagatorCustomizer((textMapPropagator, configProperties) -> textMapPropagator);
    // 可选择自定义 Resource。
    customizer.addResourceCustomizer((resource, configProperties) -> resource);
    // 可选择自定义 Sampler。
    customizer.addSamplerCustomizer((sampler, configProperties) -> sampler);
    // 可选择自定义 SpanExporter。
    customizer.addSpanExporterCustomizer((spanExporter, configProperties) -> spanExporter);
    // 可选择自定义 SpanProcessor。
    customizer.addSpanProcessorCustomizer((spanProcessor, configProperties) -> spanProcessor);
    // 可选择提供额外的属性。
    customizer.addPropertiesSupplier(Collections::emptyMap);
    // 可选择自定义 ConfigProperties。
    customizer.addPropertiesCustomizer(configProperties -> Collections.emptyMap());
    // 可选择自定义 SdkTracerProviderBuilder。
    customizer.addTracerProviderCustomizer((builder, configProperties) -> builder);
    // 可选择自定义 SdkMeterProviderBuilder。
    customizer.addMeterProviderCustomizer((builder, configProperties) -> builder);
    // 可选择自定义 MetricExporter。
    customizer.addMetricExporterCustomizer((metricExporter, configProperties) -> metricExporter);
    // 可选择自定义 MetricReader。
    customizer.addMetricReaderCustomizer((metricReader, configProperties) -> metricReader);
    // 可选择自定义 SdkLoggerProviderBuilder。
    customizer.addLoggerProviderCustomizer((builder, configProperties) -> builder);
    // 可选择自定义 LogRecordExporter。
    customizer.addLogRecordExporterCustomizer((exporter, configProperties) -> exporter);
    // 可选择自定义 LogRecordProcessor。
    customizer.addLogRecordProcessorCustomizer((processor, configProperties) -> processor);
  }

  @Override
  public int order() {
    // 可选地影响调用顺序。
    return 0;
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.traces.ConfigurableSpanExporterProvider;
import io.opentelemetry.sdk.trace.export.SpanExporter;

public class CustomSpanExporterProvider implements ConfigurableSpanExporterProvider {

  @Override
  public SpanExporter createExporter(ConfigProperties config) {
    // 当 OTEL_TRACES_EXPORTER 包含 getName() 的值时调用的回调函数。
    return new CustomSpanExporter();
  }

  @Override
  public String getName() {
    return "custom-exporter";
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.metrics.ConfigurableMetricExporterProvider;
import io.opentelemetry.sdk.metrics.export.MetricExporter;

public class CustomMetricExporterProvider implements ConfigurableMetricExporterProvider {

  @Override
  public MetricExporter createExporter(ConfigProperties config) {
    // 当 OTEL_METRICS_EXPORTER 包含 getName() 的值时调用的回调函数。
    return new CustomMetricExporter();
  }

  @Override
  public String getName() {
    return "custom-exporter";
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.logs.ConfigurableLogRecordExporterProvider;
import io.opentelemetry.sdk.logs.export.LogRecordExporter;

public class CustomLogRecordExporterProvider implements ConfigurableLogRecordExporterProvider {

  @Override
  public LogRecordExporter createExporter(ConfigProperties config) {
    // 当 OTEL_LOGS_EXPORTER 包含 getName() 的值时调用的回调函数。
    return new CustomLogRecordExporter();
  }

  @Override
  public String getName() {
    return "custom-exporter";
  }
}

package otel;

import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.traces.ConfigurableSamplerProvider;
import io.opentelemetry.sdk.trace.samplers.Sampler;

public class CustomSamplerProvider implements ConfigurableSamplerProvider {

  @Override
  public Sampler createSampler(ConfigProperties config) {
    // 当 OTEL_TRACES_SAMPLER 设置为 getName() 的值时调用的回调函数。
    return new CustomSampler();
  }

  @Override
  public String getName() {
    return "custom-sampler";
  }
}

package otel;

import io.opentelemetry.context.propagation.TextMapPropagator;
import io.opentelemetry.sdk.autoconfigure.spi.ConfigProperties;
import io.opentelemetry.sdk.autoconfigure.spi.ConfigurablePropagatorProvider;

public class CustomTextMapPropagatorProvider implements ConfigurablePropagatorProvider {
  @Override
  public TextMapPropagator getPropagator(ConfigProperties config) {
    // 当 OTEL_PROPAGATORS 包含 getName() 的值时调用的回调函数。
    return new CustomTextMapPropagator();
  }

  @Override
  public String getName() {
    return "custom-propagator";
  }
}