SpringCloudSleuth异步线程支持和传递

场景

        在使用Sleuth做链路跟踪时，默认情况下异步线程会断链，需要进行代码调整支持。

调整内容

方式一

使用@Async实现异步线程

• 开启异步线程池

@EnableAsync
@SpringBootApplication
public class LizzApplication {
    public static void main(String[] args) {
        SpringApplication.run(LizzApplication.class, args);
    }
}

• 异步线程实现

@Slf4j
@Service
public class SleuthExecutors {
    @Async
    public void go(){
        log.info("go");
    }
}

• 调用异步线程

@RestController
@Slf4j
public class LizzController {
    @Autowired
    SleuthExecutors sleuthExecutors;    
    @GetMapping("/asyncSleuth")
    public void asyncSleuth() {
        sleuthExecutors.go();
    }
}

 

• 66cf4e9594b9f60c为父线程traceid，18a498dde65276ec为子线程traceid 

方式二

使用TraceRunnable

• 自定线程

@Slf4j
@Service
public class SleuthExecutors implements Runnable {
    @Override
    public void run() {
        log.info("go");
    }
}

• 自定义线程池

@RestController
@Slf4j
public class LizzController { 
    @Autowired
    Tracing tracing;
   public static final ExecutorService executorService = Executors.newFixedThreadPool(5);
    @GetMapping("/traceRunnable")
    public void traceRunnable() {
        log.info("traceRunnable");
        // 线程加入到tracing中
        Runnable traceRunnableFromTracer = this.tracing.currentTraceContext()
                .wrap(sleuthExecutors);
        executorService.submit(traceRunnableFromTracer);
    }
 
}

• 跨线程的同一个traceid