问题

在微服务架构中，一次业务执行完可能需要跨多个服务，这个时候，我们想看到业务完整的日志信息，就要从各个服务中获取，即便是使用了ELK把日志收集到一起，但如果不做处理，也是无法完整把一次业务请求的日志完整链路串联起来。有人说，可以在日志中加入某个业务参数，比如订单id等，但是不可能所有业务都是有这样的参数给你用的。

解决方案

在打印日志的时候加入一个可以贯穿整个业务请求的唯一标识，我们把它称traceId。下面是在一个物联网项目的微服务架构中，使用dubbo时的基本流程：

拿到traceId，该怎么使用呢？答案也很简单，用过logback的都知道，是可以在日志信息里配置一些公共参数的，比如方法名，类名，线程名等，我们把traceId也设置进去就可以了。
logback配置如下：

        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"><pattern>%date{yyyy-MM-dd HH:mm:ss} [%-5level]  [%X{traceId}]  [%thread] [%logger{80}] [%file:%line] [%method]>>>>>> %msg%n</pattern><charset>utf-8</charset></encoder>

代码中设置：
web过滤器，针对的是HTTP请求，

@Configuration
public class TraceFilter extends OncePerRequestFilter {@Overrideprotected void doFilterInternal(HttpServletRequest request, HttpServletResponse response,FilterChain filterChain) throws IOException, ServletException {try {String uuid = UUID.randomUUID().toString();MDC.put("traceId",uuid);filterChain.doFilter(request, response);} finally {// 必须清除MDC.clear();}}
}

跨服务调用走dubbo：
消费者过滤器：

@Activate(group = {CommonConstants.CONSUMER})
public class ConsumerDubboFilter implements org.apache.dubbo.rpc.Filter{@Overridepublic Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {Map<String, Object> attachments = invocation.getObjectAttachments();// 获取traceIdString traceId = MDC.get("traceId");// 传递日志追踪信息attachments.put("traceId",traceId);return invoker.invoke(invocation);}
}

生产者过滤器：

@Activate(group = {CommonConstants.PROVIDER})
public class ProviderDubboFilter implements org.apache.dubbo.rpc.Filter{@Overridepublic Result invoke(Invoker<?> invoker, Invocation invocation) throws RpcException {try {// 获取到traceIdString traceId = (String)invocation.getObjectAttachment("traceId");// 设置traceIdMDC.put("traceId",traceId);return invoker.invoke(invocation);}finally {// 必须清除MDC.clear();}}
}

有聪明的小伙伴，此时已经想到了一个问题，那就是如果在子线程中打印日志依然是拿不到traceId的，没关系，照样可以解决，子线程传递上下文信息，第一个想到的是什么？对，阿里的TTL，
在pom中引入：

        <dependency><groupId>com.ofpay</groupId><artifactId>logback-mdc-ttl</artifactId><version>1.0.2</version></dependency>

logback的xml配置中加入一行代码：

<contextListener class="com.ofpay.logback.TtlMdcListener"/>

还有伙伴会问，如果用的是OpenFeign呢，其实原理一样，使用OpenFeign的拦截器，在跨服务调用之前拦截，拿到traceId，再放入HTTP请求头中，下游服务在过滤器中再从请求头中获取即可。这里代码就不再展示，直接搜feign的拦截器使用就行了。

扩展

既然traceId可以这样透传，那么其他的一些公共的信息当然也可以透传，比如分页信息，用户信息，ThreadLocal中上下文信息，都可以使用这样的方式去透传，让开发人员感觉还是在单服务中一样简便。

下一篇：MQTT+Disruptor提高并发