org.slf4j.MDC介绍-笔记

发布于:2025-05-14 ⋅ 阅读:(8) ⋅ 点赞:(0)

1. 功能简介

MDC(Mapped Diagnostic Context)是 SLF4J 提供的一个接口,用于在多线程环境中为每个线程存储上下文信息。这些信息通常用于日志记录,帮助开发者快速定位问题。MDC 是基于 ThreadLocal 实现的,这意味着每个线程拥有独立的上下文副本,适用于 Web 应用、异步任务等多线程场景。


主要功能

  • 存储上下文信息:通过 MDC.put(key, value) 向当前线程中放入键值对。
  • 获取上下文信息:通过 MDC.get(key) 获取当前线程中的值。
  • 清除上下文信息:通过 MDC.clear() 清除当前线程中的所有上下文信息。
  • 支持日志模板:在日志配置中通过 %X{key} 占位符引用上下文中的值。

使用场景

  • 请求跟踪:为每个请求生成唯一的 traceId,并记录到日志中,便于排查问题。
  • 用户标识:记录当前用户的 ID,便于分析用户行为。
  • 事务标识:标识某个事务的上下文,便于日志聚合。

2. 使用示例

2.1 代码演示

step1.创建一个使用MDC的过滤器

import org.slf4j.MDC;
import org.springframework.stereotype.Component;

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 java.io.IOException;
import java.util.UUID;


// 使用@Component,Spring Boot 会自动识别实现了 Filter 接口的 Bean,并将其注册为过滤器。
@Component
public class TraceFilter implements Filter {
    @Override
    public void init(FilterConfig filterConfig) throws ServletException {
        // 初始化逻辑(可选)
    }

    @Override
    public void doFilter(ServletRequest request, ServletResponse response, FilterChain chain)
        throws IOException, ServletException {
        // 生成唯一 traceId
        String traceId = UUID.randomUUID().toString();
        // 将 traceId 放入 MDC
        MDC.put("traceId", traceId);

        try {
            // 继续处理请求
            chain.doFilter(request, response);
        } finally {
            // 清除 MDC 上下文,避免内存泄漏
            MDC.clear();
        }
    }

    @Override
    public void destroy() {
        // 销毁逻辑(可选)
    }
}

step2.配置日志输出格式

这里以logback-spring.xml 示例:

    <?xml version="1.0" encoding="UTF-8"?>
    <configuration>
        <appender name="STDOUT" class="ch.qos.logback.core.ConsoleAppender">
            <encoder>
                <pattern>custom-log-pattern: %d{HH:mm:ss.SSS} [%thread] %-5level %logger{36} -traceId:%X{traceId} - %msg%n</pattern>
            </encoder>
        </appender>
    
        <root level="info">
            <appender-ref ref="STDOUT" />
        </root>
    </configuration>
    

    这里的 %X{traceId} 是 日志模板的关键语法,表示:

    • 从当前线程的 MDC 中查找键为 traceId 的值;
    • 如果存在,就将这个值插入到日志中。

    step3.创建测试Controller

    创建个MdcTestController,用于测试 MDC 记录日志:

    import org.slf4j.Logger;
    import org.slf4j.LoggerFactory;
    import org.springframework.web.bind.annotation.GetMapping;
    import org.springframework.web.bind.annotation.RestController;
    
    
    @RestController
    public class MdcTestController {
        private static final Logger logger = LoggerFactory.getLogger(MdcTestController.class);
    
        @GetMapping("MdcTestController/hello")
        public String hello() {
            logger.info("Processing request...");
            return "hello world";
        }
    }
    

    step4. 测试

    浏览器发起请求: http://127.0.0.1:8080/MdcTestController/hello ,最终的日志输出如下:

    custom-log-pattern: 21:23:40.538 [http-nio-8080-exec-1] INFO  o.e.b.t.slf4jMdc.MdcTestController - traceId:9b4e2949-9494-48bf-83ab-bfded7919061 - Processing request...
    

    2.2 注意事项

    1. 线程池与异步处理

    MDC 是基于 ThreadLocal 的,因此在使用线程池(如 Spring 的 @Async 或 CompletableFuture)时,原始线程的 MDC 上下文不会自动传递到新线程中。需要手动复制上下文信息。

    ExecutorService executor = Executors.newFixedThreadPool(5);
    Map<String, String> contextMap = MDC.getCopyOfContextMap();
    executor.submit(() -> {
        if (contextMap != null) {
            MDC.setContextMap(contextMap);
        }
        try {
            // 执行任务
        } finally {
            MDC.clear();
        }
    });
    

    2. 清理上下文

    务必在请求处理完成后调用 MDC.clear(),否则可能导致线程池中残留的上下文污染后续请求。

    2.3 总结

    MDC 是一个强大的工具,能够显著提升日志的可读性和调试效率。通过结合 Web 过滤器、日志模板和适当的清理机制,可以轻松实现请求级别的日志追踪。在处理异步任务时,需注意上下文传递的问题。

    3. 相关文档

    javax.servlet.Filter 介绍-笔记-CSDN博客


    网站公告

    今日签到

    点亮在社区的每一天
    去签到