1
<parent>
2
    <groupId>org.springframework.boot</groupId>
3
    <artifactId>spring-boot-starter-parent</artifactId>
4
    <version>3.4.4</version>
5
    <relativePath/>
6
</parent>
7
<properties>
8
    <java.version>21</java.version>
9
    <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
10
    <opentelemetry-instrumentation.version>2.9.0-alpha</opentelemetry-instrumentation.version>
11
</properties>
12
<dependencies>
15 collapsed lines
13
    <dependency>
14
      <groupId>org.springframework.boot</groupId>
15
      <artifactId>spring-boot-starter-actuator</artifactId>
16
    </dependency>
17
    <!-- Micrometer Tracing -->
18
    <dependency>
19
      <groupId>io.micrometer</groupId>
20
      <artifactId>micrometer-tracing-bridge-otel</artifactId>
21
    </dependency>
22
    <dependency>
23
        <groupId>io.opentelemetry</groupId>
24
        <artifactId>opentelemetry-exporter-otlp</artifactId>
25
    </dependency>
26
    <dependency>
27
        <groupId>io.opentelemetry.instrumentation</groupId>
28
        <artifactId>opentelemetry-jdbc</artifactId>
29
        <version>${opentelemetry-instrumentation.version}</version>
30
    </dependency>
31
 </dependencies>

1
management:
2
  tracing:
3
    sampling:
4
      probability: ${OTEL_TRACING_SAMPLING_PROBABILITY:0.1} # 采样率，范围0.0~1.0
5
  otlp:
6
    tracing:
7
      endpoint: ${OTEL_EXPORTER_OTLP_TRACES_ENDPOINT:http://localhost:8200/v1/traces}
8
      transport: http
9
      headers:
10
        Authorization: ${OTEL_EXPORTER_OTLP_HEADERS_AUTHORIZATION:} # 如果你的Elastic APM Server开启了AUTH

1
@Configuration
2
public class OtelJdbcConfig {
3

4
    @Bean
5
    public BeanPostProcessor otelDataSourceBeanPostProcessor(ObjectProvider<OpenTelemetry> openTelemetryProvider) {
6
        return new BeanPostProcessor() {
7
            @Override
8
            public Object postProcessAfterInitialization(Object bean, String beanName) {
9
                if (bean instanceof DataSource dataSource) {
10
                    if (bean instanceof OpenTelemetryDataSource) {
11
                        return bean;
12
                    }
13
                    OpenTelemetry openTelemetry = openTelemetryProvider.getIfAvailable();
14
                    if (openTelemetry == null) {
15
                        return new OpenTelemetryDataSource(dataSource);
16
                    }
17
                    return new OpenTelemetryDataSource(dataSource, openTelemetry);
18
                }
19
                return bean;
20
            }
21
        };
22
    }
23
}

1
// 基本用法
2
ThreadLocal<String> userId = new ThreadLocal<>();
3

4
// 线程A
5
userId.set("user-123");
6
userId.get(); // → "user-123"
7

8
// 线程B（完全隔离）
9
userId.get(); // → null

1
┌─────────────────────────────────────────────┐
2
│                   JVM                        │
3
│  ┌─────────────┐    ┌─────────────┐         │
4
│  │  Thread-A   │    │  Thread-B   │         │
5
│  │  ┌───────┐  │    │  ┌───────┐  │         │
6
│  │  │userId │  │    │  │userId │  │         │
7
│  │  │"123"  │  │    │  │ null  │  │         │
8
│  │  └───────┘  │    │  └───────┘  │         │
9
│  └─────────────┘    └─────────────┘         │
10
└─────────────────────────────────────────────┘
11
        ↑ 互不干扰，线程安全

1
// Context 是一个在线程内不可变的上下文记录
2
Context ctx = Context.current();
3

4
// 以OpenTelemetry为例，里面装着：
5
// - 当前 Span（谁是我的父节点？）
6
// - Baggage（跨服务传递的业务数据）
7
// - 其他自定义数据
8

9
Span span = Span.fromContext(ctx); // 取出当前 Span

1
HTTP 请求进来
2
    │
3
    ▼
4
┌─────────────────────────────────────────────────────┐
5
│  Context: { traceId: "abc", spanId: "001" }         │
6
│      │                                              │
7
│      ▼                                              │
8
│  Controller.handleRequest()                         │
9
│      │                                              │
10
│      ▼  传递 Context                                │
11
│  Service.doSomething()                              │
12
│      │                                              │
13
│      ▼  继续传递                                    │
14
│  Repository.query()  ← 这里创建的 span 知道父级是谁  │
15
└─────────────────────────────────────────────────────┘

1
// 调用这个时，背后就是 ContextStorage 在工作
2
Context current = Context.current();

1
// OpenTelemetry 默认的 ContextStorage 简化版
2
public class ThreadLocalContextStorage implements ContextStorage {
3

4
    private static final ThreadLocal<Context> CURRENT = new ThreadLocal<>();
5

6
    @Override
7
    public Context current() {
8
        Context ctx = CURRENT.get();
9
        return ctx != null ? ctx : Context.root();
10
    }
11

12
    @Override
13
    public Scope attach(Context toAttach) {
14
        Context previous = CURRENT.get();
15
        CURRENT.set(toAttach);
16
        return () -> CURRENT.set(previous); // 返回时恢复
17
    }
18
}

1
┌────────────────────────────────────────────────────────────┐
2
│                        应用代码                             │
3
│                           │                                │
4
│                           ▼                                │
5
│                  Context.current()                         │
6
│                           │                                │
7
│                           ▼                                │
8
│  ┌─────────────────────────────────────────────────────┐  │
9
│  │              ContextStorage（接口）                   │  │
10
│  │                        │                             │  │
11
│  │                        ▼                             │  │
12
│  │  ┌─────────────────────────────────────────────┐    │  │
13
│  │  │     ThreadLocalContextStorage（默认实现）     │    │  │
14
│  │  │                     │                        │    │  │
15
│  │  │                     ▼                        │    │  │
16
│  │  │           ThreadLocal<Context>               │    │  │
17
│  │  │                     │                        │    │  │
18
│  │  │                     ▼                        │    │  │
19
│  │  │    Thread-1: Context{traceId=abc, span=001}  │    │  │
20
│  │  │    Thread-2: Context{traceId=xyz, span=002}  │    │  │
21
│  │  └─────────────────────────────────────────────┘    │  │
22
│  └─────────────────────────────────────────────────────┘  │
23
└────────────────────────────────────────────────────────────┘