SpringCloud通過MDC實現分布式鏈路追蹤

更新時間：2024年11月03日 09:34:46 作者：YB_account

在DDD領域驅動設計中,我們使用SpringCloud來去實現,但排查錯誤的時候,通常會想到Skywalking,但是引入一個新的服務,增加了系統(tǒng)消耗和管理學習成本,對于大型項目比較適合,但是小的項目顯得太過臃腫了,所以本文介紹了SpringCloud通過MDC實現分布式鏈路追蹤

引言

在DDD領域驅動設計中，我們使用SpringCloud來去實現，但排查錯誤的時候，通常會想到Skywalking，但是引入一個新的服務，增加了系統(tǒng)消耗和管理學習成本，對于大型項目比較適合，但是小的項目顯得太過臃腫了，我們此時就可以使用TraceId，將其存放到MDC中，返回的時候參數帶上它，訪問的時候日志打印出來，每次訪問生成的TraceId不同，這樣可以實現分布式鏈路追蹤的問題。

通用部分

封裝TraceIdUtil工具類

import org.apache.commons.lang3.StringUtils;
import org.slf4j.MDC;
import cn.hutool.core.util.IdUtil;

public class TraceIdUtil {

    public static final String TRACE_ID_KEY = "TraceId";

    /**
     * 生成TraceId
     * @return
     */
    public static String generateTraceId(){
        String traceId = IdUtil.fastSimpleUUID().toUpperCase();
        MDC.put(TRACE_ID_KEY,traceId);
        return traceId;
    }

    /**
     * 生成TraceId
     * @return
     */
    public static String generateTraceId(String traceId){
        if(StringUtils.isBlank(traceId)){
            return generateTraceId();
        }
        MDC.put(TRACE_ID_KEY,traceId);
        return traceId;
    }

    /**
     * 獲取TraceId
     * @return
     */
    public static String getTraceId(){
        return MDC.get(TRACE_ID_KEY);
    }

    /**
     * 移除TraceId
     * @return
     */
    public static void removeTraceId(){
        MDC.remove(TRACE_ID_KEY);
    }
}

logback.xml日志文件的修改

<Pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [TRACEID:%X{TraceId}]  [%thread] %-5level %logger{36} -%msg%n</Pattern>

需注意：

biff 模塊

創(chuàng)建過濾器

import java.io.IOException;
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.annotation.WebFilter;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.lang3.StringUtils;
import com.karry.admin.bff.common.util.TraceIdUtil;
import cn.hutool.core.util.IdUtil;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@WebFilter
public class TraceFilter implements Filter {

    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
        log.info("Init Trace filter   init.......");
        System.out.println("Init Trace filter  init.......");
    }

    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain filterChain) throws IOException, ServletException {
        try {
            HttpServletRequest servletRequest = (HttpServletRequest) request;
            String gateWayTraceId = ((HttpServletRequest) request).getHeader(TraceIdUtil.TRACE_ID_KEY);
            String traceId = TraceIdUtil.generateTraceId(StringUtils.isEmpty(gateWayTraceId)
                    ? IdUtil.fastSimpleUUID().toUpperCase()
                    : gateWayTraceId
            );
            // 創(chuàng)建新的請求包裝器
            log.info("TraceIdUtil.getTraceId():"+TraceIdUtil.getTraceId());
            //將請求和應答交給下一個處理器處理
            filterChain.doFilter(request,response);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            //最后移除，不然有可能造成內存泄漏
            TraceIdUtil.removeTraceId();
        }
    }

    @Override
    public void destroy() {
        log.info("Init Trace filter  destroy.......");
    }
}

配置過濾器生效

import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.Ordered;
import org.springframework.core.annotation.Order;
import com.karry.admin.bff.common.filter.TraceFilter;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Configuration
public class WebConfiguration {

    @Bean
    @ConditionalOnMissingBean({TraceFilter.class})
    @Order(Ordered.HIGHEST_PRECEDENCE + 100)
    public FilterRegistrationBean<TraceFilter> traceFilterBean(){
        FilterRegistrationBean<TraceFilter> bean = new FilterRegistrationBean<>();
        bean.setFilter(new TraceFilter());
        bean.addUrlPatterns("/*");
        return bean;
    }
}

figen接口發(fā)送的head修改

此處修改了發(fā)送的請求的header，在其他模塊就可以獲取從biff層生成的traceId了。

import org.springframework.context.annotation.Configuration;
import com.karry.admin.bff.common.util.TraceIdUtil;
import feign.RequestInterceptor;
import feign.RequestTemplate;

@Configuration
public class FeignRequestInterceptor implements RequestInterceptor {
    @Override
    public void apply(RequestTemplate template){
        String traceId = TraceIdUtil.getTraceId();
        //當前線程調用中有traceId，則將該traceId進行透傳
        if (traceId != null) {
            template.header(TraceIdUtil.TRACE_ID_KEY,TraceIdUtil.getTraceId());
        }
    }
}

統(tǒng)一返回處理

此種情況時針對BaseResult，，這種統(tǒng)一返回的對象無法直接修改的情況下使用的，如果可以直接修改：

    /**
     * 鏈路追蹤TraceId
     */
    public String traceId = TraceIdUtil.getTraceId();

不可以直接修改就用響應攔截器進行處理：

import org.springframework.core.MethodParameter;
import org.springframework.http.MediaType;
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;
import com.karry.app.common.utils.TraceIdUtil;
import com.karry.order.sdk.utils.BeanCopyUtils;
import com.souche.platform.common.model.base.BaseResult;
import lombok.SneakyThrows;


@ControllerAdvice
public class ResponseAdvice implements ResponseBodyAdvice {
    /**
     * 開關，如果是true才會調用beforeBodyWrite
     */
    @Override
    public boolean supports(MethodParameter returnType, Class converterType) {
        return true;
    }


    @SneakyThrows//異常拋出，相當于方法上throw一個異常
    @Override
    public Object beforeBodyWrite(Object object, MethodParameter methodParameter, MediaType mediaType, Class aClass,
            ServerHttpRequest serverHttpRequest, ServerHttpResponse serverHttpResponse) {
        BaseResult result = BeanCopyUtils.copy(object, BaseResult.class);
        result.setTraceId(TraceIdUtil.getTraceId());
        return result;
    }

}

非biff模塊

創(chuàng)建過濾器

import java.io.IOException;
import javax.servlet.Filter;
import javax.servlet.FilterChain;
import javax.servlet.FilterConfig;
import javax.servlet.ServletException;
import javax.servlet.ServletRequest;
import javax.servlet.ServletResponse;
import javax.servlet.annotation.WebFilter;
import javax.servlet.http.HttpServletRequest;
import org.apache.commons.lang3.StringUtils;
import com.karry.app.common.utils.TraceIdUtil;
import cn.hutool.core.util.IdUtil;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@WebFilter
public class TraceFilter implements Filter {

    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
        log.info("Init Trace filter   init.......");
    }

    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain filterChain) throws IOException, ServletException {
        try {
            HttpServletRequest servletRequest = (HttpServletRequest) request;
            String gateWayTraceId = ((HttpServletRequest) request).getHeader(TraceIdUtil.TRACE_ID_KEY);
            String traceId = TraceIdUtil.generateTraceId(StringUtils.isEmpty(gateWayTraceId)
                    ? IdUtil.fastSimpleUUID().toUpperCase()
                    : gateWayTraceId
            );
            //將請求和應答交給下一個處理器處理
            filterChain.doFilter(request,response);
        }catch (Exception e){
            e.printStackTrace();
        }finally {
            //最后移除，不然有可能造成內存泄漏
            TraceIdUtil.removeTraceId();
        }
    }

    @Override
    public void destroy() {
        log.info("Init Trace filter  destroy.......");
    }
}

配置過濾器生效

import org.springframework.boot.autoconfigure.condition.ConditionalOnMissingBean;
import org.springframework.boot.web.servlet.FilterRegistrationBean;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.core.Ordered;
import org.springframework.core.annotation.Order;
import com.karry.admin.bff.common.filter.TraceFilter;
import lombok.extern.slf4j.Slf4j;

@Slf4j
@Configuration
public class WebConfiguration {

    @Bean
    @ConditionalOnMissingBean({TraceFilter.class})
    @Order(Ordered.HIGHEST_PRECEDENCE + 100)
    public FilterRegistrationBean<TraceFilter> traceFilterBean(){
        FilterRegistrationBean<TraceFilter> bean = new FilterRegistrationBean<>();
        bean.setFilter(new TraceFilter());
        bean.addUrlPatterns("/*");
        return bean;
    }
}

線程池

上面對于單線程的情況可以進行解決，traceId和Threadlocal很像，是鍵值對模式，會有內存溢出問題，還是線程私有的。所以在多線程的情況下就不能獲取主線程的traceId了。我們就需要設置線程工廠包裝 Runnable 來解決這個問題。

import org.slf4j.MDC;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;

import java.util.Map;
import java.util.concurrent.ArrayBlockingQueue;
import java.util.concurrent.Executors;
import java.util.concurrent.ThreadFactory;
import java.util.concurrent.ThreadPoolExecutor;
import java.util.concurrent.TimeUnit;

@Configuration
public class MyThreadPoolConfig {
    @Bean
    public ThreadPoolExecutor threadPoolExecutor() {
        // 自定義 ThreadFactory
        ThreadFactory threadFactory = new ThreadFactory() {
            private final ThreadFactory defaultFactory = Executors.defaultThreadFactory();
            private final String namePrefix = "Async---";

            @Override
            public Thread newThread(Runnable r) {
                // 獲取主線程的 MDC 上下文
                Map<String, String> contextMap = MDC.getCopyOfContextMap();

                // 包裝 Runnable 以設置 MDC 上下文
                Runnable wrappedRunnable = () -> {
                    try {
                        // 設置 MDC 上下文
                        MDC.setContextMap(contextMap);
                        // 執(zhí)行任務
                        r.run();
                    } finally {
                        // 清除 MDC 上下文
                        MDC.clear();
                    }
                };

                Thread thread = defaultFactory.newThread(wrappedRunnable);
                thread.setName(namePrefix + thread.getName());
                return thread;
            }
        };

        ThreadPoolExecutor executor = new ThreadPoolExecutor(
                5,
                10,
                30L,
                TimeUnit.SECONDS,
                new ArrayBlockingQueue<>(500),
                threadFactory,
                new ThreadPoolExecutor.CallerRunsPolicy());
        return executor;
    }
}

以上就是SpringCloud通過MDC實現分布式鏈路追蹤的詳細內容，更多關于SpringCloud MDC鏈路追蹤的資料請關注腳本之家其它相關文章！

您可能感興趣的文章:

Java使用Condition實現精準喚醒線程詳解
這篇文章主要為大家詳細介紹了Java如何使用Condition實現精準喚醒線程效果，文中的示例代碼講解詳細，感興趣的小伙伴可以跟隨小編一起了解一下
2023-02-02
Java數據結構及算法實例：選擇排序 Selection Sort
這篇文章主要介紹了Java數據結構及算法實例：選擇排序 Selection Sort,本文直接給出實現代碼,代碼中包含詳細注釋,需要的朋友可以參考下
2015-06-06
手把手教你如何搭建SpringBoot+Vue前后端分離
這篇文章主要介紹了手把手教你如何搭建SpringBoot+Vue前后端分離,前后端分離是目前開發(fā)中常用的開發(fā)模式,達成充分解耦,需要的朋友可以參考下
2023-03-03
如何根據帶賬號密碼的WSDL地址生成JAVA代碼
這篇文章主要介紹了如何根據帶賬號密碼的WSDL地址生成JAVA代碼,文中通過示例代碼介紹的非常詳細，對大家的學習或者工作具有一定的參考學習價值,需要的朋友可以參考下
2020-10-10
使用Maven進行依賴漏洞檢查的實現指南
在現代軟件開發(fā)中,開源庫的使用變得愈加普遍和重要,然而,這些開源庫中的漏洞往往會成為潛在的安全風險,在本文中,我們將探討如何使用 Maven 進行依賴漏洞檢查,以確保項目的安全性和穩(wěn)定性,需要的朋友可以參考下
2024-05-05
SpringBoot集成LiteFlow實現輕量級工作流引擎的詳細過程
LiteFlow 是一款專注于邏輯驅動流程編排的輕量級框架,它以組件化方式快速構建和執(zhí)行業(yè)務流程,有效解耦復雜業(yè)務邏輯,下面給大家介紹SpringBoot集成LiteFlow實現輕量級工作流引擎,感興趣的朋友一起看看吧
2025-06-06
maven的pom.xml中repositories和distributionManagement使用
這篇文章主要介紹了maven的pom.xml中repositories和distributionManagement使用方式,具有很好的參考價值,希望對大家有所幫助,如有錯誤或未考慮完全的地方,望不吝賜教
2024-03-03
Spring中@Configuration和@Component注解的區(qū)別及原理
這篇文章主要介紹了Spring中@Configuration和@Component注解的區(qū)別及原理,從功能上來講,這些注解所負責的功能的確不相同,但是從本質上來講,Spring內部都將其作為配置注解進行處理,需要的朋友可以參考下
2023-11-11
Java獲取漢字對應的拼音(全拼或首字母)
這篇文章主要介紹了Java如何獲取漢字對應的拼音(全拼或首字母),文中實現的方法是引用了pinyin4j-2.5.0.jar，然后給出了完整的示例代碼，有需要的朋友可以參考借鑒，下面來一起看看吧。
2017-01-01
spring(java,js,html) 截圖上傳圖片實例詳解
這篇文章主要介紹了spring(java,js,html) 截圖上傳圖片實例詳解的相關資料,非常不錯，具有參考借鑒價值，需要的朋友可以參考下
2016-07-07