SpringBoot+slf4j线程池全链路调用日志跟踪问题及解决思路(二)
本项目源码已在多个项目中实践
接着上一篇文章,项目中使用了线程池,那么子线程中日志就会丢失traceId,下面讲解如何实现子线程中的traceId日志跟踪。
解决思路
子线程在打印日志的过程中traceId将丢失,解决方式为重写线程池,将主线程的traceId继续传递到子线程中。当然,对于直接new创建线程的情况不考略【实际应用中应该避免这种用法】。
继承ThreadPoolExecutor,重写执行任务的方法
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 | public final class OverrideThreadPoolExecutor extends ThreadPoolExecutor { @Override public void execute(Runnable task) { super .execute(ThreadMdcUtil.wrap(task, MDC.getCopyOfContextMap())); } @Override public <T> Future<T> submit(Runnable task, T result) { return super .submit(ThreadMdcUtil.wrap(task, MDC.getCopyOfContextMap()), result); } @Override public <T> Future<T> submit(Callable<T> task) { return super .submit(ThreadMdcUtil.wrap(task, MDC.getCopyOfContextMap())); } @Override public Future<?> submit(Runnable task) { return super .submit(ThreadMdcUtil.wrap(task, MDC.getCopyOfContextMap())); } } |
封装ThreadMdcUtil工具类
以封装Callable为例:
- 判断当前线程对应MDC的Map是否存在,如果存在则设置子线程的ContextMap为当前线程的;
- 如果不存在,则重新生成traceId;
- 执行run方法
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 | public final class ThreadMdcUtil { public static void setTraceIdIfAbsent() { if (MDC.get(TraceConstant.MDC_TRACE) == null || MDC.get(TraceConstant.MDC_TRACE).length() == 0 ) { String tid = UUID.randomUUID().toString().replace( "-" , "" ); MDC.put(TraceConstant.MDC_TRACE, tid); } } public static <T> Callable<T> wrap( final Callable<T> callable, final Map<String, String> context) { return () -> { if (context == null ) { MDC.clear(); } else { MDC.setContextMap(context); } setTraceIdIfAbsent(); try { return callable.call(); } finally { MDC.clear(); } }; } } |
测试子线程中traceId的传递,本项目中ExecutorService已经重写了线程池
1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 | @RestController @RequestMapping ( "trace" ) @Slf4j @AllArgsConstructor public class TestTraceController { private final ExecutorService executorService; @GetMapping ( "traceLog" ) public String traceLog() { log.info( "---接口调用了---" ); traceService(); asyncTrace(); return "success" ; } private void traceService(){ log.error( "## 执行traceService方法" ); } private void asyncTrace(){ CompletableFuture.runAsync(()->{ log.info( "执行线程池中的方法asyncTrace,未重写了线程池" ); }, executorService); } } |
未重写ThreadPoolExecutor效果如下:
重写ThreadPoolExecutor效果如下:
到此这篇关于SpringBoot+slf4j线程池全链路调用日志跟踪的文章就介绍到这了,更多相关SpringBoot全链路调用日志跟踪内容请搜索脚本之家以前的文章或继续浏览下面的相关文章希望大家以后多多支持脚本之家!
微信公众号搜索 “ 脚本之家 ” ,选择关注
程序猿的那些事、送书等活动等着你
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。
如若内容造成侵权/违法违规/事实不符,请将相关资料发送至 reterry123@163.com 进行投诉反馈,一经查实,立即处理!
相关文章
基于RecyclerChart的KLine绘制Volume实现详解
这篇文章主要为大家介绍了基于RecyclerChart的KLine绘制Volume实现详解,有需要的朋友可以借鉴参考下,希望能够有所帮助,祝大家多多进步,早日升职加薪2023-03-03MyBatis-Plus+达梦数据库实现高效数据持久化的示例
这篇文章主要介绍了MyBatis-Plus和达梦数据库实现高效数据持久化,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧2023-08-08
最新评论