开发排查系统问题用得最多的手段就是查看系统日志，在分布式环境中一般使用ELK来统一收集日志，但是在并发大时使用日志定位问题还是比较麻烦，由于大量的其他用户/其他线程的日志也一起输出穿行其中导致很难筛选出指定请求的全部相关日志，以及下游线程/服务对应的日志。
创新互联是专业的迁安网站建设公司，迁安接单;提供成都网站设计、网站建设、外贸网站建设,网页设计,网站设计,建网站,PHP网站建设等专业做网站服务;采用PHP框架,可快速的进行迁安网站开发网页制作和功能扩展;专业做搜索引擎喜爱的网站,专业的做网站团队,希望更多企业前来合作!
重庆分公司
重庆分公司
唯一标识来追踪全部的链路显示在日志中，并且不修改原有的打印方式(代码无***)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;
}
}接收并保存traceId的值
拦截器
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("/**");
super.addInterceptors(registry);
}
}继续把当前服务的traceId值传递给下游服务
public class FeignInterceptorConfig {
@Bean
public RequestInterceptor requestInterceptor() {
RequestInterceptor requestInterceptor = template -> {
//传递日志traceId
String traceId = MDC.get(CommonConstant.LOG_TRACE_ID);
if (StrUtil.isNotEmpty(traceId)) {
template.header(CommonConstant.TRACE_ID_HEADER, traceId);
}
};
return requestInterceptor;
}
}主要针对业务会使用线程池(异步、并行处理)，并且spring自己也有@Async注解来使用线程池，所以需要扩展ThreadPoolTaskExecutor线程池实现将父线程的MDC内容复制给子线程
public class CustomThreadPoolTaskExecutor extends ThreadPoolTaskExecutor {
/**
* 把父线程的MDC内容赋值给子线程
* @param runnable
*/
@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));
}
/**
* 子线程委托的执行方法
* @param runnable {@link Runnable}
* @param mdcContext 父线程MDC内容
*/
private void run(Runnable runnable, String tenantId, Map mdcContext) {
// 将父线程的MDC内容传给子线程
if (mdcContext != null) {
MDC.setContextMap(mdcContext);
}
try {
// 执行异步操作
runnable.run();
} finally {
// 清空MDC内容
MDC.clear();
}
}
/**
* 子线程委托的执行方法
* @param task {@link Callable}
* @param mdcContext 父线程MDC内容
*/
private T call(Callable task, Map mdcContext) throws Exception {
// 将父线程的MDC内容传给子线程
if (mdcContext != null) {
MDC.setContextMap(mdcContext);
}
try {
// 执行异步操作
return task.call();
} finally {
// 清空MDC内容
MDC.clear();
}
}
} 
网关生成traceId值为13d9800c8c7944c78a06ce28c36de670
显示的traceId与网关相同，这里特意模拟发生异常的场景
traceId查询整条链路日志当系统出现异常时，可直接通过该异常日志的traceId的值，在日志中心中询该请求的所有日志信息
附上我的开源微服务框架(包含本文中的代码)，欢迎 star 关注
https://gitee.com/zlt2000/microservices-platform
推荐阅读
