使用MDC實現(xiàn)日志鏈路跟蹤
前言:
在微服務(wù)環(huán)境中,我們經(jīng)常使用Skywalking
、CAT等去實現(xiàn)整體請求鏈路的追蹤,但是這個整體運維成本高,架構(gòu)復(fù)雜,我們來使用MDC
通過Log來實現(xiàn)一個輕量級的會話事務(wù)跟蹤功能。
1.原理
MDC org.sl4j.MDC
其實內(nèi)部就是ThreadLocal,MDC提供了put/get/clear等幾個核心接口,用于操作ThreadLocal中的數(shù)據(jù);ThreadLocal中的K-V,可以在logback.xml中聲明,最終將會打印在日志中。
// java代碼 MDC.put("userId","laker"); ? // logback.xml %X{userId}
例如:
<property name="pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level [%X{userId}] %logger{20} - %msg%n"/>
2.實現(xiàn)
整體流程如下:
- 用戶登錄系統(tǒng),我們?nèi)罩局杏涗?code>userId:laker。
- 用戶發(fā)起請求,一個請求中可能實際產(chǎn)生多個http請求,這里可以前端生成一個
requestId
- 在返回體中,返回
requestId
。 - 研發(fā)運維人員,可以根據(jù)
userId
和requestId
去日志中撈請求鏈路。
3.過濾器
@Order(value = Ordered.HIGHEST_PRECEDENCE + 100) @Component @WebFilter(filterName = "MDCFilter", urlPatterns = "/*") public class MDCFilter extends OncePerRequestFilter { ? ? @Override ? ? protected void doFilterInternal(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, FilterChain filterChain) throws ServletException, IOException { ? ? ? ? try { ? ? ? ? ? ? MDC.put("userId", "laker"); ? ? ? ? ? ? MDC.put("requestId", IdUtil.fastUUID()); ? ? ? ? } catch (Exception e) { ? ? ? ? ? ? // ? ? ? ? } ? ? ? ? try { ? ? ? ? ? ? filterChain.doFilter(httpServletRequest, httpServletResponse); ? ? ? ? } finally { ? ? ? ? ? ? MDC.clear(); ? ? ? ? } ? ? } }
4.logback.xml
<?xml version="1.0" encoding="UTF-8"?> <configuration> ? ? <property name="LOG_HOME" value="logs"/> ? ? <property name="encoding" value="UTF-8"/> ? ? <appender name="DEFAULT" class="ch.qos.logback.core.rolling.RollingFileAppender"> ? ? ? ? <file>${LOG_HOME}/test.log</file> ? ? ? ? <Append>true</Append> ? ? ? ? <prudent>false</prudent> ? ? ? ? <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"> ? ? ? ? ? ? <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{50} %line - %m%n</pattern> ? ? ? ? </encoder> ? ? ? ? <!-- 按天回滾 daily --> ? ? ? ? <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"> ? ? ? ? ? ? <!--歸檔日志文件名--> ? ? ? ? ? ? <FileNamePattern>${LOG_HOME}/test.log.%d{yyyy-MM-dd}</FileNamePattern> ? ? ? ? ? ? <!-- 最多保存15天歷史文件 --> ? ? ? ? ? ? <maxHistory>15</maxHistory> ? ? ? ? </rollingPolicy> ? ? </appender> ? ? <!-- 日志輸出格式 --> ? ? <property name="log.pattern" ? ? ? ? ? ? ? value="%d{HH:mm:ss.SSS} [%thread] %-5level [%X{userId}|%X{requestId}] %logger{20} - [%method,%line] - %msg%n"/> ? ? <!-- 控制臺輸出 --> ? ? <appender name="console" class="ch.qos.logback.core.ConsoleAppender"> ? ? ? ? <encoder> ? ? ? ? ? ? <pattern>${log.pattern}</pattern> ? ? ? ? </encoder> ? ? </appender> ? ? <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"> ? ? ? ? <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"> ? ? ? ? ? ? <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{50} %line - %m%n</pattern> ? ? ? ? </encoder> ? ? </appender> ? ? <logger name="com.test.demo" level="DEBUG"> ? ? ? ? <appender-ref ref="DEFAULT"/> ? ? </logger> ? ? <!-- 日志輸出級別 --> ? ? <root level="INFO"> ? ? ? ? <appender-ref ref="DEFAULT"/> ? ? ? ? <appender-ref ref="console"/> ? ? </root> </configuration>
5.返回體
public class Response<T> { ? ? @ApiModelProperty(notes = "響應(yīng)碼,非200 即為異常", example = "200") ? ? private final int code; ? ? @ApiModelProperty(notes = "響應(yīng)消息", example = "提交成功") ? ? private final String msg; ? ? @ApiModelProperty(notes = "響應(yīng)數(shù)據(jù)") ? ? private final T data; ? ? @ApiModelProperty(notes = "請求id") ? ? private final String requestId; ? ? public Response(int code, String msg, T data) { ? ? ? ? this.code = code; ? ? ? ? this.msg = msg; ? ? ? ? this.data = data; ? ? ? ? this.requestId = MDC.get("requestId"); ? ? }
6.效果日志
響應(yīng):
{ ?? ?code: 200, ?? ?msg: "", ?? ?requestId: "74a269a8-3cb4-417e-853c-b968b77cce23" }
日志:
18:37:15.997 [http-nio-8080-exec-1] INFO ?[laker|90717490-5ef4-4e46-bc2c-605952fc3803] c.l.m.c.InfoController - [v2Map,17] - null 18:37:38.980 [http-nio-8080-exec-2] INFO ?[laker|82bde351-f86e-466f-97a0-c857a0c4c1c9] c.l.m.c.InfoController - [v2Map,17] - null 18:37:39.992 [http-nio-8080-exec-3] INFO ?[laker|74a269a8-3cb4-417e-853c-b968b77cce23] c.l.m
到此這篇關(guān)于使用MDC實現(xiàn)日志鏈路跟蹤的文章就介紹到這了,更多相關(guān)MDC實現(xiàn)日志鏈路跟蹤內(nèi)容請搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家!
相關(guān)文章
Java中ThreadLocal線程變量的實現(xiàn)原理
本文主要介紹了Java中ThreadLocal線程變量的實現(xiàn)原理,文中通過示例代碼介紹的非常詳細(xì),對大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價值,需要的朋友們下面隨著小編來一起學(xué)習(xí)學(xué)習(xí)吧2022-06-06JAVA-4NIO之Channel之間的數(shù)據(jù)傳輸方法
下面小編就為大家?guī)硪黄狫AVA-4NIO之Channel之間的數(shù)據(jù)傳輸方法。小編覺得挺不錯的,現(xiàn)在就分享給大家,也給大家做個參考。一起跟隨小編過來看看吧2017-06-06