基于Spring Boot + Dubbo的全链路日志追踪是怎样的

基于Spring Boot + Dubbo的全链路日志追踪是怎样的，针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。

一、概要

完成分析之后，就要具体的实现了。

service-a: 实现dubbo服务。

service-b: 实现web服务，并调用service-a实现的服务。

二、实现

2.1 日志采集及存储

本例直接使用【阿里云·日志服务】进行数据存储和检索，使用Aliyun Log Logback Appender进行日志收集及上传。

其实就是阿里自己实现了一个Logback Appender。当然我们也可以自己实现，比如上传至自建的ELK中。

2.2 项目中traceId生成、传递、销毁

2.2.1 traceId生成、销毁

2.2.1.1 客户端请求等触发(外部)

外部类请求触发情况，使用拦截器处理。

请求过来之后，生成traceId，并写入org.slf4j.MDC。

请求完成之后，将traceId从org.slf4j.MDC中移除。

package com.example.dubboserviceb.interceptor;import com.example.dubboserviceb.constants.Constants;import org.slf4j.MDC;import org.springframework.web.servlet.HandlerInterceptor;import org.springframework.web.servlet.ModelAndView;import javax.servlet.http.HttpServletRequest;import javax.servlet.http.HttpServletResponse;import java.util.UUID;/** * @author lpe234 * @since 2019/5/25 14:43 */public class TraceIdInterceptor implements HandlerInterceptor {    @Override    public boolean preHandle(HttpServletRequest request, HttpServletResponse response, Object handler) throws Exception {        // generate traceId        String traceId = UUID.randomUUID().toString().replace("-", "");        // put traceId        MDC.put(Constants.TRACE_ID, traceId);        return true;    }    @Override    public void postHandle(HttpServletRequest request, HttpServletResponse response, Object handler, ModelAndView modelAndView) throws Exception {    }    @Override    public void afterCompletion(HttpServletRequest request, HttpServletResponse response, Object handler, Exception ex) throws Exception {        // clear traceId        MDC.remove(Constants.TRACE_ID);    }}

2.2.1.2 定时任务等触发(内部)

(略...)

2.2.1 traceId传递

2.2.1.1 WEB类传递

简单的接口返回类，增加traceId字段。

package com.example.dubboserviceb.utils;import lombok.Data;/** * @author lpe234 * @since 2019/5/25 14:55 */@Datapublic class RestResponse {    private Integer code;    private String msg;    private T data;    private String traceId;    public RestResponse() {    }    public RestResponse(Integer code, String msg, T data) {        this.code = code;        this.msg = msg;        this.data = data;    }    public static  RestResponse ok(T data) {        return new RestResponse<>(200, "ok", data);    }    public static  RestResponse error(T data) {        return new RestResponse<>(400, "error", data);    }}

当请求响应结果生成前，获取当前org.slf4j.MDC中的traceId，设置到RestResponse中。

package com.example.dubboserviceb.advice;import com.example.dubboserviceb.constants.Constants;import com.example.dubboserviceb.utils.RestResponse;import org.slf4j.MDC;import org.springframework.core.MethodParameter;import org.springframework.http.MediaType;import org.springframework.http.converter.HttpMessageConverter;import org.springframework.http.server.ServerHttpRequest;import org.springframework.http.server.ServerHttpResponse;import org.springframework.web.bind.annotation.ControllerAdvice;import org.springframework.web.servlet.mvc.method.annotation.ResponseBodyAdvice;/** * @author lpe234 * @since 2019/5/25 15:03 */@ControllerAdvicepublic class ResponseModifyAdvice implements ResponseBodyAdvice