当前位置：首页 > news >正文

SpringCloudSleuth异步线程支持和传递

news 2025/8/23 21:14:43

场景

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

调整内容

方式一

使用@Async实现异步线程

开启异步线程池

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

异步线程实现

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

调用异步线程

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

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

方式二

使用TraceRunnable

自定线程

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

自定义线程池

@RestController
@Slf4j
public class LizzController { @AutowiredTracing 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);}}