日志排查问题困难？分布式日志链路跟踪来帮你

开发排查系统问题用得最多的手段就是查看系统日志，在分布式环境中一般使用ELK来统一收集日志，但是在并发大时使用日志定位问题还是比较麻烦，由于大量的其他用户/其他线程的日志也一起输出穿行其中导致很难筛选出指定请求的全部相关日志，以及下游线程/服务对应的日志。

• 每个请求都使用一个唯一标识来追踪全部的链路显示在日志中，并且不修改原有的打印方式(代码无入侵)
• 使用Logback的MDC机制日志模板中加入traceId标识，取值方式为%X{traceId}

MDC（Mapped Diagnostic Context，映射调试上下文）是 log4j 和 logback 提供的一种方便在多线程条件下记录日志的功能。MDC 可以看成是一个与当前线程绑定的Map，可以往其中添加键值对。MDC 中包含的内容可以被同一线程中执行的代码所访问。当前线程的子线程会继承其父线程中的 MDC 的内容。当需要记录日志时，只需要从 MDC 中获取所需的信息即可。MDC 的内容则由程序在适当的时候保存进去。对于一个 Web 应用来说，通常是在请求被处理的最开始保存这些数据。

由于MDC内部使用的是ThreadLocal所以只有本线程才有效，子线程和下游的服务MDC里的值会丢失；所以方案主要的难点是解决值的传递问题。

logback配置文件模板格式添加标识%X{traceId}

生成traceId并通过header传递给下游服务

@Component
public class TraceFilter extends ZuulFilter {
    @Autowired
    private TraceProperties traceProperties;

    @Override
    public String filterType() {
 return FilterConstants.PRE_TYPE;
    }

    @Override
    public int filterOrder() {
 return FORM_BODY_WRAPPER_FILTER_ORDER - 1;
    }

    @Override
    public boolean shouldFilter() {
 //根据配置控制是否开启过滤器
 return traceProperties.getEnable();
    }

    @Override
    public Object run() {
 //链路追踪id
 String traceId = IdUtil.fastSimpleUUID();
 MDC.put(CommonConstant.LOG_TRACE_ID, traceId);
 RequestContext ctx = RequestContext.getCurrentContext();
 ctx.addZuulRequestHeader(CommonConstant.TRACE_ID_HEADER, traceId);
 return null;
    }
}

public class TraceInterceptor implements HandlerInterceptor {
    @Override
    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) {
 String traceId = request.getHeader(CommonConstant.TRACE_ID_HEADER);
 if (StrUtil.isNotEmpty(traceId)) {
     MDC.put(CommonConstant.LOG_TRACE_ID, traceId);
 }
 return true;
    }
}

public class DefaultWebMvcConfig extends WebMvcConfigurationSupport {
  @Override
  protected void addInterceptors(InterceptorRegistry registry) {
    //日志链路追踪拦截器
    registry.addInterceptor(new TraceInterceptor()).addPathPatterns("
    @Override
    public void execute(Runnable runnable) {
 Map mdcContext = MDC.getCopyOfContextMap();
 super.execute(() -> run(runnable, mdcContext));
    }

    @Override
    public  Future submit(Callable task) {
 Map mdcContext = MDC.getCopyOfContextMap();
 return super.submit(() -> call(task, mdcContext));
    }

    
    private void run(Runnable runnable, String tenantId, Map mdcContext) {
 // 将父线程的MDC内容传给子线程
 if (mdcContext != null) {
     MDC.setContextMap(mdcContext);
 }
 try {
     // 执行异步操作
     runnable.run();
 } finally {
     // 清空MDC内容
     MDC.clear();
 }
    }

    
    private  T call(Callable task, Map mdcContext) throws Exception {
 // 将父线程的MDC内容传给子线程
 if (mdcContext != null) {
     MDC.setContextMap(mdcContext);
 }
 try {
     // 执行异步操作
     return task.call();
 } finally {
     // 清空MDC内容
     MDC.clear();
 }
    }
}