最近线上排查问题时候,发现请求太多导致日志错综复杂,没办法把用户在一次或多次请求的日志关联在一起,所以就利用SpringBoot+Logback手写了一个简单的链路追踪,下面详细介绍下。

Spring Boot默认使用LogBack日志系统,并且已经引入了相关的jar包,所以我们无需任何配置便可以使用LogBack打印日志。

MDC(Mapped Diagnostic Context,映射调试上下文)是log4j和logback提供的一种方便在多线程条件下记录日志的功能。

实现思路是在一个请求开始时,将请求相关的上下文信息(例如客户ID、客户的IP地址、sessionId、请求参数等)添加到MDC,然后配置好logback-spring.xml,则Logback组件将会在每条日志中打印出存放到MDC的信息,从而实现一个ID贯穿用户的所有操作。

新建一个spring boot项目spring-boot-log,按照下面步骤操作。

  1. 新建日志拦截器

日志拦截器在请求开始获取用户的sessionId,当然也可以生成一个UUID,生成后存放到MDC中。
SessionInterceptor代码如下:

  1. /**
  2. * 日志拦截器
  3. * @Author: Java碎碎念
  4. *
  5. */
  6. public class SessionInterceptor extends HandlerInterceptorAdapter {
  7. /**
  8. * 会话ID
  9. */
  10. private final static String SESSION_KEY = "sessionId";
  11. @Override
  12. public void postHandle(HttpServletRequest arg0, HttpServletResponse arg1,
  13. Object arg2, ModelAndView arg3) throws Exception {
  14. }
  15. @Override
  16. public boolean preHandle(HttpServletRequest request,
  17. HttpServletResponse response, Object handler) throws Exception {
  18. // String token = UUID.randomUUID().toString().replaceAll("-","");
  19. //本例测试使用sessionId,也可以使用UUID等
  20. String token = request.getSession().getId();
  21. MDC.put(SESSION_KEY, token);
  22. return true;
  23. }
  24. @Override
  25. public void afterCompletion(HttpServletRequest arg0,
  26. HttpServletResponse arg1, Object arg2, Exception arg3)
  27. throws Exception {
  28. // 删除
  29. MDC.remove(SESSION_KEY);
  30. }
  31. }
  1. 新建配置类

新建InterceptorConfig,注册刚才的日志拦截器。

InterceptorConfig代码如下:

  1. @Configuration
  2. public class InterceptorConfig implements WebMvcConfigurer {
  3. @Bean
  4. public SessionInterceptor getSessionInterceptor() {
  5. return new SessionInterceptor();
  6. }
  7. @Override
  8. public void addInterceptors(InterceptorRegistry registry) {
  9. registry.addInterceptor(getSessionInterceptor()).addPathPatterns("/*");
  10. }
  11. }
  1. 修改logback-spring.xml

配置logback-spring.xml,获取日志拦截器添加的sessionId并打印到日志中,配置文件中获取方式如下:

  1. %X{sessionId}

本例中打印sessionId到控制台和文件,完整配置如下:

  1. <?xml version="1.0" encoding="UTF-8"?>
  2. <configuration>
  3. <property name="log.base" value="./log/logback"/>
  4. <appender name="stdout" class="ch.qos.logback.core.ConsoleAppender">
  5. <encoder>
  6. <pattern> %date [%thread] [%X{sessionId}] %-5level %logger{80} - %msg%n
  7. </pattern>
  8. </encoder>
  9. </appender>
  10. <appender name="logfile"
  11. class="ch.qos.logback.core.rolling.RollingFileAppender">
  12. <File>${log.base}.log</File>
  13. <rollingPolicy class="ch.qos.logback.core.rolling.TimeBasedRollingPolicy">
  14. <FileNamePattern>${log.base}.%d{yyyy -MM-dd}.log.zip</FileNamePattern>
  15. </rollingPolicy>
  16. <encoder>
  17. <pattern> %date [%thread] [%X{sessionId}] %-5level %logger{80} - %msg%n
  18. </pattern>
  19. </encoder>
  20. </appender>
  21. <logger name="com.sample" level="TRACE"/>
  22. <root>
  23. <level value="INFO"/>
  24. <appender-ref ref="stdout"/>
  25. <appender-ref ref="logfile"/>
  26. </root>
  27. </configuration>
  1. 添加controller

新建TestLogController,打印日志。

代码如下:

  1. @RestController
  2. public class TestLogController {
  3. Logger log = LoggerFactory.getLogger(getClass());
  4. /**
  5. * 测试登录
  6. */
  7. @RequestMapping(value = "/testLogin")
  8. public String testLogin() {
  9. log.info("用户登录成功!");
  10. return "ok";
  11. }
  12. /**
  13. * 测试下单
  14. */
  15. @RequestMapping(value = "/testNewOrder")
  16. public String testNewOrder() {
  17. log.info("用户创建了订单!");
  18. log.info("请求完成,返回ok!");
  19. return "ok";
  20. }
  21. /**
  22. * 测试购买
  23. */
  24. @RequestMapping(value = "/testPay")
  25. public String testPay() {
  26. log.info("用户付款!");
  27. return "ok";
  28. }
  29. }

打开浏览器连续访问接口testLogin、testNewOrder和testPay,模拟用户登录、下单、付款操作,控制台和文件中打印的日志中已经包含了sessonId信息,打印的结果如下:

  1. [http-nio-8888-exec-1] [CB8E7DB250A31F2BE6C05B30633B9A95] INFO com.example.springbootlog.controller.TestLogController - 用户登录成功!
  2. [http-nio-8888-exec-2] [CB8E7DB250A31F2BE6C05B30633B9A95] INFO com.example.springbootlog.controller.TestLogController - 用户创建了订单!
  3. [http-nio-8888-exec-2] [CB8E7DB250A31F2BE6C05B30633B9A95] INFO com.example.springbootlog.controller.TestLogController - 请求完成,返回ok
  4. [http-nio-8888-exec-3] [CB8E7DB250A31F2BE6C05B30633B9A95] INFO com.example.springbootlog.controller.TestLogController - 用户付款!

到此SpringBoot+Logback手写一个简单的链路追踪功能已经全部实现,有问题欢迎留言沟通哦!

完整源码地址: https://github.com/suisui2019/springboot-study

推荐阅读

1.SpringBoot中如何优雅的读取yml配置文件?
2.SpringBoot中如何灵活的实现接口数据的加解密功能?
3.SpringBoot中神奇的@Enable*注解?
4.Java中Integer.parseInt和Integer.valueOf,你还傻傻分不清吗?
5.SpringCloud系列-整合Hystrix的两种方式


限时领取免费Java相关资料,涵盖了Java、Redis、MongoDB、MySQL、Zookeeper、Spring Cloud、Dubbo/Kafka、Hadoop、Hbase、Flink等高并发分布式、大数据、机器学习等技术。
关注下方公众号即可免费领取:

Java碎碎念公众号

版权声明:本文为haha12原创文章,遵循 CC 4.0 BY-SA 版权协议,转载请附上原文出处链接和本声明。
本文链接:https://www.cnblogs.com/haha12/p/11770526.html