實現(xiàn)思路

1. 增加Filter處理請求，生成traceId保存到TreadLocal中（slf4j的MDC）
2. 增加返回AOP切面，返回數(shù)據(jù)之前把traceId寫到返回實體里
3. 日志logback.xml文件配置增加traceId打印

注意：線程池執(zhí)行和其他服務(wù)請求會丟失traceId，需要再做包裝，這里不實現(xiàn)文章來源地址http://www.zghlxwxcb.cn/news/detail-824242.html

定義過濾器

/**
 * @author lenjor
 * @description requst包裝類，構(gòu)建可重復(fù)讀取inputStream的request
 * @date 2024-01-24 11:13
 */
public class RepeatedlyRequestWrapper extends HttpServletRequestWrapper {
    private final byte[] body;

    public RepeatedlyRequestWrapper(HttpServletRequest request) throws IOException {
        super(request);
        body = HttpHelper.getBodyString(request).getBytes(StandardCharsets.UTF_8);
    }

    @Override
    public BufferedReader getReader() throws IOException {
        return new BufferedReader(new InputStreamReader(getInputStream()));
    }

    @Override
    public ServletInputStream getInputStream() throws IOException {
        final ByteArrayInputStream bais = new ByteArrayInputStream(body);
        return new ServletInputStream() {
            @Override
            public int read() throws IOException {
                return bais.read();
            }

            @Override
            public int available() throws IOException {
                return body.length;
            }

            @Override
            public boolean isFinished() {
                return false;
            }

            @Override
            public boolean isReady() {
                return false;
            }

            @Override
            public void setReadListener(ReadListener readListener) {

            }
        };
    }
}


/**
 * @author lenjor
 * @Description 全局請求增加traceId日志追蹤，保存到ThreadLocal的MDC中
 * @Date 2024-01-24 15:29
 */
public class TraceIdFilter implements Filter {
    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
        Filter.super.init(filterConfig);
    }

    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain) throws IOException, ServletException {
        try {
            HttpServletRequest httpRequest = (HttpServletRequest) request;
            String oldTraceId = httpRequest.getHeader("traceId");

            if(!StringUtils.isEmpty(oldTraceId)){
                MDC.put("traceId",oldTraceId);
            }else {
                // 生成唯一的traceId
                MDC.put("traceId", UUID.randomUUID().toString().replace("-", ""));
            }
            if (request instanceof HttpServletRequest && StringUtils.startsWithIgnoreCase(request.getContentType(), MediaType.APPLICATION_JSON_VALUE)) {
                ServletRequest requestWrapper = new RepeatedlyRequestWrapper((HttpServletRequest) request);
                chain.doFilter(requestWrapper, response);
            }else {
                chain.doFilter(request, response);
            }
        } finally {
            // 清除MDC的traceId值，確保在請求結(jié)束后不會影響其他請求的日志
            MDC.remove("traceId");
        }
    }

    @Override
    public void destroy() {
        Filter.super.destroy();
    }
}

/**
 * @author lenjor
 * @Description web請求全局traceId處理
 * @Date 2024-01-24 15:35
 */
@Configuration
public class GlobalWebTraceIdConfig {
    @Bean
    public FilterRegistrationBean<TraceIdFilter> loggingFilter() {
        FilterRegistrationBean<TraceIdFilter> registrationBean = new FilterRegistrationBean<>();
        registrationBean.setFilter(new TraceIdFilter());
        registrationBean.addUrlPatterns("/*"); // 設(shè)置過濾的URL模式
        return registrationBean;
    }
}

返回參數(shù)增加traceId

/**
 * @author lenjor
 * @Description 請求返回AOP切面增強，增加traceId返回
 * @Date 2024-01-24 16:06
 */
@ControllerAdvice(basePackages = "com.yingzi.idp.edge.app.v2.interfaces.rest")
public class TraceIdResponseAdvice implements ResponseBodyAdvice<ResultDTO> {
    @Override
    public boolean supports(MethodParameter returnType, Class<? extends HttpMessageConverter<?>> converterType) {
        return returnType.getMethod().getReturnType().isAssignableFrom(ResultDTO.class);
    }

    @Override
    public ResultDTO beforeBodyWrite(ResultDTO body, MethodParameter returnType, MediaType selectedContentType, Class<? extends HttpMessageConverter<?>> selectedConverterType, ServerHttpRequest request, ServerHttpResponse response) {
        if (Objects.nonNull(body)) {
            body.setTraceId(MDC.get("traceId"));
        }
        return body;
    }
}

logback.xml增加traceId

        <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder">
            <pattern>
                %d{yyyy-MM-dd HH:mm:ss.SSS} %-5level [%thread]{traceId: %X{traceId}}::: %class{0}.%method\(%line\)
                %msg%n
            </pattern>
        </encoder>

到了這里，關(guān)于SpringBoot增加全局traceId日志追蹤的文章就介紹完了。如果您還想了解更多內(nèi)容，請在右上角搜索TOY模板網(wǎng)以前的文章或繼續(xù)瀏覽下面的相關(guān)文章，希望大家以后多多支持TOY模板網(wǎng)！