Sleuth、Spring Integration与ThreadPoolExecutor：如何为每个生成线程创建一个Span？

核心问题 #

你的思路偏差在于忽略了线程切换时的Trace上下文传递：

• 关闭Spring Integration追踪（spring.sleuth.integration.enabled: false）时，Sleuth不会自动处理ExecutorChannel触发的线程切换，自定义线程池/BlockingExecutor中启动的新线程无法获取主线程的Trace上下文，@NewSpan生成的Span无法关联到父Span，最终仅显示主线程的Span。
• 启用追踪并配置patterns时，若自定义BlockingExecutor未被Sleuth的线程包装器处理，同样会丢失上下文传递，导致新线程的Span无法被正确关联和上报。

最佳实现方式 #

方式一：关闭Spring Integration追踪，手动处理线程池的上下文传递 #

保持spring.sleuth.integration.enabled: false，通过Sleuth提供的包装类让自定义线程池支持Trace上下文传递：

1. 在配置类中，使用TraceableExecutorService包装原生ThreadPoolExecutor：

import org.springframework.cloud.sleuth.instrument.async.TraceableExecutorService;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import java.util.concurrent.ExecutorService;
import java.util.concurrent.Executors;

@Configuration
public class ThreadPoolConfig {

    @Bean
    public ExecutorService traceableThreadPoolExecutor(Tracer tracer) {
        ExecutorService nativeThreadPool = Executors.newFixedThreadPool(10); // 你的原生线程池配置
        return new TraceableExecutorService(nativeThreadPool, tracer);
    }
}

2. 让自定义BlockingExecutor使用上述被包装后的线程池，而非原生线程池。

3. 在最终调用的方法上保留@NewSpan注解，确保该方法所在类是Spring管理的Bean（Sleuth会自动代理这类Bean以识别注解）。

这样线程切换时，Trace上下文会被自动传递到新线程，@NewSpan生成的Span会正确关联主线程的父Span，Zipkin中就能展示完整的链路。

方式二：开启Spring Integration追踪，精准配置并确保线程池被处理 #

若选择保留Spring Integration追踪，需修正配置并确保线程池被Sleuth包装：

1. 配置spring.sleuth.integration.enabled: true，并精准指定需要追踪的出站通道名称（匹配通道的Bean ID或名称）：

spring.sleuth.integration.patterns=your-target-outbound-channel-name

2. 同样需要将自定义BlockingExecutor中的原生ThreadPoolExecutor用TraceableExecutorService包装，确保上下文传递。

关键注意事项 #

• @NewSpan仅对Spring管理的Bean方法生效，若目标方法所在类未被Spring容器管理，注解不会触发Span生成。
• 无论哪种方式，线程池必须被Sleuth的线程包装器处理，否则线程切换时必然丢失Trace上下文，导致新线程的Span无法关联父Span。

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