超溜网站建设,网页设计流程要怎么写,企业站模板,公司企业邮箱后缀MDC实现微服务链路追踪
一、问题背景
在微服务架构中#xff0c;我们没办法快速定位用户在一次请求中对应的所有日志#xff0c;在排查生产问题的时候会非常困难#xff0c;那是因为我们在输出的日志的时候没把请求的唯一标示输出到我们的日志中#xff0c;导致我们没办法…MDC实现微服务链路追踪
一、问题背景
在微服务架构中我们没办法快速定位用户在一次请求中对应的所有日志在排查生产问题的时候会非常困难那是因为我们在输出的日志的时候没把请求的唯一标示输出到我们的日志中导致我们没办法根据一个请求或者用户身份标识来做日志的过滤。
二、MDC简介
MDCMapped Diagnostic Context映射调试上下文是 log4j 和 logback 提供的一种方便在多线程条件下记录日志的功能。MDC 可以看成是一个与当前线程绑定的Map可以往其中添加键值对。MDC 中包含的内容可以被同一线程中执行的代码所访问。当前线程的子线程会继承其父线程中的 MDC 的内容。当需要记录日志时只需要从 MDC 中获取所需的信息即可。MDC 的内容则由程序在适当的时候保存进去。对于一个 Web 应用来说通常是在请求被处理的最开始保存这些数据。
API说明:
clear() 移除所有MDC
get (String key) 获取当前线程MDC中指定key的值
getContext() 获取当前线程MDC的MDC
put(String key, Object o) 往当前线程的MDC中存入指定的键值对
remove(String key) 删除当前线程MDC中指定的键值对 。三、实现方式
由于 MDC 内部使用的是 ThreadLocal 所以只有本线程才有效子线程和下游的服务 MDC 里的值会丢失,所以方案主要的难点是解决值的传递问题;
1. 工具类
public class TraceIdUtil {public static final String TRACE_ID traceId;public static String getTraceId() {String traceId MDC.get(TRACE_ID);return traceId null ? : traceId;}public static void setTraceId(String traceId) {MDC.put(TRACE_ID, traceId);}public static void remove() {MDC.remove(TRACE_ID);}public static void clear() {MDC.clear();}public static String generateTraceId() {return UUID.randomUUID().toString().replace(-, );}}logback日志,这里的[%X{traceId}] 就是MDC中的,切不可写错key
property nameconsole.log.patternvalue%red(%d{yyyy-MM-dd HH:mm:ss}) %green([%thread]) %highlight(%-5level) %boldMagenta(%logger{36}) [%X{traceId}] - %msg%n/2. 拦截器
通过拦截器拦截请求,判断请求头中是否存在traceId,如果存在则存入MDC上下文中,不存在则生成traceId存入MDC中.
public class MdcInterceptor implements HandlerInterceptor {Overridepublic boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {//如果有上层调用就用上层的IDString traceId request.getHeader(TraceIdUtil.TRACE_ID);if (StrUtil.isEmpty(traceId)) {TraceIdUtil.setTraceId(TraceIdUtil.generateTraceId());} else {TraceIdUtil.setTraceId(traceId);}return true;}Overridepublic void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {//调用结束后删除TraceIdUtil.remove();}}注册拦截器
Component
public class WebAppConfigurer implements WebMvcConfigurer {Overridepublic void addInterceptors(InterceptorRegistry registry) {// 可添加多个registry.addInterceptor(new MdcInterceptor()).addPathPatterns(/**);}
}3. 请求头传递
这里使用的是openFeign的解决方案,其他的类似,在请求头中塞入traceId
Component
public class MyFeignRequestInterceptor implements RequestInterceptor {Overridepublic void apply(RequestTemplate requestTemplate) {String traceId TraceIdUtil.getTraceId();// 传递请求头if (StrUtil.isNotBlank(traceId)) {requestTemplate.header(TraceIdUtil.TRACE_ID, traceId);} else {requestTemplate.header(TraceIdUtil.TRACE_ID, TraceIdUtil.generateTraceId());}}
}4. 线程父子间传递
由于MDC的底层是ThreadLocal,所以会导致子线程拿不到主线程里的数据
public class ThreadMdcUtil {public static void setTraceIdIfAbsent() {if (MDC.get(TraceIdUtil.TRACE_ID) null) {MDC.put(TraceIdUtil.TRACE_ID, TraceIdUtil.generateTraceId());}}public static T CallableT wrap(final CallableT callable, final MapString, String context) {return () - {if (context null) {MDC.clear();} else {MDC.setContextMap(context);}setTraceIdIfAbsent();try {return callable.call();} finally {MDC.clear();}};}public static Runnable wrap(final Runnable runnable, final MapString, String context) {return () - {if (context null) {MDC.clear();} else {MDC.setContextMap(context);}//设置traceIdsetTraceIdIfAbsent();try {runnable.run();} finally {MDC.clear();}};}
}自定义线程池
public class ThreadPoolExecutorMdcWrapper extends ThreadPoolTaskExecutor {private static final long serialVersionUID 3940722618853093830L;Overridepublic void execute(Runnable task) {super.execute(ThreadMdcUtil.wrap(task, MDC.getCopyOfContextMap()));}Overridepublic T FutureT submit(CallableT task) {return super.submit(ThreadMdcUtil.wrap(task, MDC.getCopyOfContextMap()));}Overridepublic Future? submit(Runnable task) {return super.submit(ThreadMdcUtil.wrap(task, MDC.getCopyOfContextMap()));}
}Configuration
public class ThreadPoolTaskExecutorConfig{//最大可用的CPU核数public static final int PROCESSORS Runtime.getRuntime().availableProcessors();Beanpublic ThreadPoolExecutorMdcWrapper getExecutor(){ThreadPoolExecutorMdcWrapper executor new ThreadPoolExecutorMdcWrapper();executor.setCorePoolSize(PROCESSORS *2);executor.setMaxPoolSize(PROCESSORS * 4);executor.setQueueCapacity(50);executor.setKeepAliveSeconds(60);executor.setThreadNamePrefix(Task-A);executor.setRejectedExecutionHandler(new ThreadPoolExecutor.AbortPolicy());executor.initialize();return executor;}
}单线程的做法(不建议)
public class MDCRunable implements Runnable {private MapString, String copyOfContextMap;private Runnable runnable;public MDCRunable(Runnable runnable) {this.copyOfContextMap MDC.getCopyOfContextMap();this.runnable runnable;}Overridepublic void run() {if (!copyOfContextMap.isEmpty()) {MDC.setContextMap(copyOfContextMap);}try {runnable.run();} finally {if (!copyOfContextMap.isEmpty()) {MDC.clear();}}}
}5. 测试结果
上游日志
2023-02-27 18:58:05 [http-nio-8099-exec-2] INFO c.s.c.controller.ConsumerController [65f8173c73f945d99ea5b0ab209164fd] - consumer-打印日志2
2023-02-27 18:58:05 [DefaultAsync-1] INFO c.s.c.controller.ConsumerController [65f8173c73f945d99ea5b0ab209164fd] - consumer-thread-01测试线程
2023-02-27 18:58:05 [pool-9-thread-1] INFO c.s.c.controller.ConsumerController [65f8173c73f945d99ea5b0ab209164fd] - consumer-mdc-thread下游日志
2023-02-27 18:58:05 [http-nio-8089-exec-1] INFO c.s.f.p.c.ProviderController [65f8173c73f945d99ea5b0ab209164fd] - provider-测试日志
2023-02-27 18:58:05 [DefaultAsync-1] INFO c.s.f.p.c.ProviderController [65f8173c73f945d99ea5b0ab209164fd] - provider-thread-02测试线程参考:
https://www.zhangshengrong.com/p/9MNlDOKvNJ/ 我是一零贰肆一个关注Java技术和记录生活的博主。
欢迎扫码关注“一零贰肆的公众号”一起学习共同进步多看路少踩坑。
