Sleuth 信息在线程之间的传递

1. 问题

上期说，Sleuth做为微服务下的调用链框架，支持traceId在各类多线程状况下的传递。很抱歉，这个结论是错的，我在这里向你们道歉

2. 分析

得出这个结论是由于官方文档的一句话连接：

We’re providing LazyTraceExecutor, TraceableExecutorService and TraceableScheduledExecutorService. Those implementations are creating Spans each time a new task is submitted, invoked or scheduled.

翻译：咱们提供LazyTraceExecutor, TraceableExecutorService和TraceableScheduledExecutorService这三个实现类，以期在一个新线程任务提交、执行或调度时建立新的Span

这句话颇有迷惑性，很容易让人误解(好吧我认可，目前只有我)，认为Sleuth支持各类多线程。遗憾的是，若是你手动建立了一个Thread，调用下一级服务时，Sleuth并不能感知到

3. 证实

3.1 方法一

写个Demo看下，是否TraceId可以正常传过去

3.2 方法二

咱们看下LazyTraceExecutor是怎么作的

public class LazyTraceExecutor implements java.util.concurrent.Executor {

    private static final Log log = LogFactory.getLog(MethodHandles.lookup().lookupClass());

    private Tracer tracer;
    private final BeanFactory beanFactory;
    private final Executor delegate;
    private TraceKeys traceKeys;
    private SpanNamer spanNamer;

    public LazyTraceExecutor(BeanFactory beanFactory, Executor delegate) {
        this.beanFactory = beanFactory;
        this.delegate = delegate;
    }

    @Override
    public void execute(Runnable command) {
        if (this.tracer == null) {
            try {
                this.tracer = this.beanFactory.getBean(Tracer.class);
            }
            catch (NoSuchBeanDefinitionException e) {
                this.delegate.execute(command);
                return;
            }
        }
        this.delegate.execute(new SpanContinuingTraceRunnable(this.tracer, traceKeys(), spanNamer(), command));
    }
}

使用方式

@Configuration
public class MyConfiguration {
    @Autowired
    BeanFactory beanFactory;
    @Bean
    public Executor executor() {
        ThreadPoolTaskExecutor executor = new ThreadPoolTaskExecutor();
        // CUSTOMIZE HERE
        executor.setCorePoolSize(7);
        executor.setMaxPoolSize(42);
        executor.setQueueCapacity(11);
        executor.setThreadNamePrefix("MyExecutor-");
        // DON'T FORGET TO INITIALIZE
        executor.initialize();
        return new LazyTraceExecutor(this.beanFactory, executor);
    }
}

因此它能在线程之间传递traceId并不稀奇，由于它根本就是要你使用它的多线程工具。

4.可否让子线程获取父线程信息呢

4.1 能：InheritableThreadLocal

通常来讲，每一个线程一个副本，咱们都是用ThreaLocal。但是，若是你想要该线程和它的子线程都能读这个副本，那就能够用InheritableThreadLocal了。
用法很简单Demo：

private static final ThreadLocal<String> sessionInfoHolder1 = new ThreadLocal<String>();
    private static final ThreadLocal<String> sessionInfoHolder2 = new InheritableThreadLocal<String>();

5. 思考

既然Sleuth不支持用户本身建立线程，而使用InheritableThreadLocal能够解决这个问题，那么是否是说，Sleuth这个短板实际上是能够解决的?

5.1 方案

1. Filter中获取TraceId,存入：InheritableThreadLocal
2. TraceFeignClient中判断当前线程或其父线程中是否有traceId，若是有，就证实是用户new的线程，便可复用Trace信息。
3. 有兴趣的读者能够去Sleuth拉个分支试下，说不定会被管理员merge