从零搭建开发脚手架 使用MDC实现日志链路跟踪

架构 2023-07-05 17:29:38
29阅读

  • 序言
  • 基本原理
  • 完成
    • 过滤装置
    • logback.xml
    • 回到体
  • 实际效果日志

序言

在微服务架构自然环境中,大家常常应用Skywalking、CAT等去完成总体要求链接的跟踪,可是这一总体运维管理成本增加,构架繁杂,大家来应用MDC根据Log来完成一个轻量的对话事务管理追踪作用。

基本原理

MDC org.sl4j.MDC实际上內部便是ThreadLocal,MDC出示了put/get/clear等好多个关键插口,用以实际操作ThreadLocal中的数据信息;ThreadLocal中的K-V,能够在logback.xml中申明,最后可能打印出在日志中。

 
  1. // java编码 
  2. MDC.put("userId","laker");   
  3.  
  4. // logback.xml 
  5. %X{userId} 

比如:

 
  1. <property name="pattern" value="%d{HH:mm:ss.SSS} [%thread] %-5level [%X{userId}] %logger{20} - %msg%n"/> 

完成

总体步骤以下:

  • 账号登录系统软件,大家日志中纪录userId:laker。
  • 客户进行要求,一个要求中很有可能具体造成好几个http要求,这儿能够前面转化成一个requestId
  • 在回到体里,回到requestId。
  • 产品研发运维管理工作人员,能够依据 userId和requestId去日志中捞要求链接。

过滤装置

 
  1. @Order(value = Ordered.HIGHEST_PRECEDENCE   100) 
  2. @Component 
  3. @WebFilter(filterName = "MDCFilter", urlPatterns = "/*"
  4. public class MDCFilter extends OncePerRequestFilter { 
  5.  
  6.     @Override 
  7.     protected void doFilterInternal(HttpServletRequest httpServletRequest, HttpServletResponse httpServletResponse, FilterChain filterChain) throws ServletException, IOException { 
  8.         try { 
  9.             MDC.put("userId""laker"); 
  10.             MDC.put("requestId", IdUtil.fastUUID()); 
  11.         } catch (Exception e) { 
  12.             // 
  13.         } 
  14.  
  15.         try { 
  16.             filterChain.doFilter(httpServletRequest, httpServletResponse); 
  17.         } finally { 
  18.             MDC.clear(); 
  19.         } 
  20.     } 

logback.xml

 
  1. <?xml version="1.0" encoding="UTF-8"?> 
  2. <configuration> 
  3.     <property name="LOG_HOME" value="logs"/> 
  4.     <property name="encoding" value="UTF-8"/> 
  5.  
  6.     <appender name="DEFAULT" class="ch.qos.logback.core.rolling.RollingFileAppender"
  7.         <file>${LOG_HOME}/test.log</file> 
  8.         <Append>true</Append> 
  9.         <prudent>false</prudent> 
  10.         <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"
  11.             <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{50} %line - %m%n</pattern> 
  12.         </encoder> 
  13.         <!-- 按天回退 daily --> 
  14.         <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy"
  15.             <!--存档日志文件夹名称--> 
  16.             <FileNamePattern>${LOG_HOME}/test.log.%d{yyyy-MM-dd}</FileNamePattern> 
  17.             <!-- 数最多储存半个月历史时间文档 --> 
  18.             <maxHistory>15</maxHistory> 
  19.         </rollingPolicy> 
  20.     </appender> 
  21.  
  22.     <!-- 日志輸出文件格式 --> 
  23.     <property name="log.pattern" 
  24.               value="%d{HH:mm:ss.SSS} [%thread] %-5level [%X{userId}|%X{requestId}] %logger{20} - [%method,%line] - %msg%n"/> 
  25.  
  26.     <!-- 控制面板輸出 --> 
  27.     <appender name="console" class="ch.qos.logback.core.ConsoleAppender"
  28.         <encoder> 
  29.             <pattern>${log.pattern}</pattern> 
  30.         </encoder> 
  31.     </appender> 
  32.  
  33.     <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender"
  34.         <encoder class="ch.qos.logback.classic.encoder.PatternLayoutEncoder"
  35.             <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%t] %-5level %logger{50} %line - %m%n</pattern> 
  36.         </encoder> 
  37.     </appender> 
  38.  
  39.     <logger name="com.test.demo" level="DEBUG"
  40.         <appender-ref ref="DEFAULT"/> 
  41.     </logger> 
  42.     <!-- 日志輸出等级 --> 
  43.     <root level="INFO"
  44.         <appender-ref ref="DEFAULT"/> 
  45.         <appender-ref ref="console"/> 
  46.     </root> 
  47. </configuration> 

回到体

 
  1. public class Response<T> { 
  2.     @ApiModelProperty(notes = "回应码,非200 即是异常", example = "200"
  3.     private final int code; 
  4.     @ApiModelProperty(notes = "回应信息", example = "操作成功"
  5.     private final String msg; 
  6.     @ApiModelProperty(notes = "回应数据信息"
  7.     private final T data; 
  8.     @ApiModelProperty(notes = "要求id"
  9.     private final String requestId; 
  10.  
  11.     public Response(int code, String msg, T data) { 
  12.         this.code = code; 
  13.         this.msg = msg; 
  14.         this.data = data; 
  15.         this.requestId = MDC.get("requestId"); 
  16.     } 

实际效果日志

回应

 
  1.  code: 200, 
  2.  msg: ""
  3.  requestId: "74a269a8-3cb4-417e-853c-b968b77cce23" 

日志

 
  1. 18:37:15.997 [http-nio-8080-exec-1] INFO  [laker|90717490-5ef4-4e46-bc2c-605952fc3803] c.l.m.c.InfoController - [v2Map,17] - null 
  2. 18:37:38.980 [http-nio-8080-exec-2] INFO  [laker|82bde351-f86e-466f-97a0-c857a0c4c1c9] c.l.m.c.InfoController - [v2Map,17] - null 
  3. 18:37:39.992 [http-nio-8080-exec-3] INFO  [laker|74a269a8-3cb4-417e-853c-b968b77cce23] c.l.m.c.InfoController - [v2Map,17] - null 
the end
免责声明:本文不代表本站的观点和立场,如有侵权请联系本站删除!本站仅提供信息存储空间服务。