Spring Boot3迁移后线程间Baggage共享：复刻Sleuth旧行为方案咨询

要解决Micrometer迁移中的MDC竞态问题，无需手动实现TraceableExecutorService，可以利用Micrometer Tracing提供的ObservedExecutorService或Observation API，复刻Sleuth中每个异步任务创建独立Span、隔离线程上下文的行为。

核心问题解析 #

Sleuth的TraceableExecutorService会为每个提交的任务自动创建子Span，并为任务绑定独立的上下文；而你当前使用的ContextExecutorService仅传播父上下文，未为任务创建新Span，导致线程复用时代码中更新的Baggage（关联MDC）出现跨任务的竞态。

方法1：使用ObservedExecutorService（推荐） #

Micrometer提供了ObservedExecutorService，对应Sleuth的TraceableExecutorService，自动为每个任务创建子Span并隔离上下文：

import io.micrometer.tracing.observation.ObservedExecutorService;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

private final ObservationRegistry observationRegistry;

// 构造函数注入ObservationRegistry
public YourService(ObservationRegistry observationRegistry) {
    this.observationRegistry = observationRegistry;
}

private ExecutorService produceExecutor(int threads) {
    ExecutorService delegate = Executors.newFixedThreadPool(threads);
    // 包装为ObservedExecutorService，自动为每个任务创建子Span
    return ObservedExecutorService.builder(delegate)
            .observationRegistry(observationRegistry)
            .observationName("async.task.executor") // 自定义Span名称
            .build();
}

使用这个ExecutorService后，原有业务逻辑代码无需修改：

ExecutorService executorService = produceExecutor(threads);
List<CompletableFuture<O>> futures = inputList.stream().map(
    input -> CompletableFuture.supplyAsync(() ->
        businessLogic.apply(input), executorService))
    .toList();
CompletableFuture.allOf(futures.toArray(new CompletableFuture[0])).get();

方法2：手动用Observation API包裹任务 #

如果需要更细粒度的控制，可以在任务提交时手动创建Observation（对应Span），确保每个任务的上下文独立：

import io.micrometer.observation.Observation;

// 封装工具方法，为任务创建独立Span
private <T> Callable<T> wrapWithObservation(String spanName, Callable<T> task) {
    return () -> Observation.createNotStarted(spanName, observationRegistry)
            .observe(task::call);
}

// 业务逻辑调用时使用
List<CompletableFuture<O>> futures = inputList.stream().map(input ->
    CompletableFuture.supplyAsync(wrapWithObservation("async.business.logic", () -> {
        BaggageField.getByName(MY_BAGGAGE).updateValue(String.valueOf(input));
        return businessLogic.apply(input);
    }), executorService)
).toList();

关键注意事项 #

1. Baggage配置：确保你的BaggageField创建时允许更新值：

   public static final BaggageField MY_BAGGAGE = BaggageField.create("my-baggage",
           BaggageFieldConfig.updateValue(true));
   

2. 自动配置支持：Spring Boot 3中ObservationRegistry会自动配置，无需手动注册ThreadLocalAccessor（除非有自定义需求）。

内容的提问来源于stack exchange，提问作者dcolazin