Apache Camel路由中MDC.get(key)无法获取值问题求助

我来帮你搞定这个MDC值在Camel路由里丢失的问题——这其实是个很常见的坑，根源在于MDC是线程本地（ThreadLocal）存储的，而Camel很多组件（比如Kafka）是异步执行的，路由执行过程中一旦切换线程，原来的MDC上下文就跟着旧线程走了，新线程自然拿不到。下面给你几个具体的解决办法：

1. 开启Camel自带的MDC上下文传递 #

Camel本身提供了MDC传递的支持，只需要简单配置就能让框架自动帮你在线程切换时同步MDC上下文：

方式一：通过配置文件（application.properties/yaml） #

# 启用MDC日志支持
camel.mdc.enabled=true
# 开启MDC上下文在线程间的传递
camel.mdc.transfer=true

方式二：通过Java配置类 #

@Configuration
public class CamelMdcConfig {
    @Bean
    public CamelContextConfiguration camelContextConfiguration() {
        return context -> {
            // 启用MDC日志
            context.setUseMDCLogging(true);
            // 开启MDC上下文传递
            context.setTransferMDC(true);
        };
    }
}

这个配置会让Camel在Exchange在不同线程间传递时，自动把MDC的键值对复制过去，大部分场景下这就够了。

2. 针对异步组件手动传递MDC值 #

如果用的是像Kafka这类异步消息组件，可能因为组件本身的线程模型，Camel的自动传递没生效，这时候可以手动把MDC值放到Exchange的属性里，在消费端再恢复到MDC中：

生产者端路由（存MDC+存Exchange属性） #

from("direct:sendToKafka")
    .process(exchange -> {
        // 存入MDC
        String traceId = UUID.randomUUID().toString();
        MDC.put("traceId", traceId);
        // 同时把值放到Exchange属性，确保异步传递时不会丢
        exchange.setProperty("traceId", traceId);
    })
    .to("kafka:myEndPoint");

消费者端路由（从Exchange属性恢复MDC） #

from("kafka:myEndPoint")
    .process(exchange -> {
        // 从Exchange属性取出值，重新存入MDC
        String traceId = exchange.getProperty("traceId", String.class);
        if (traceId != null) {
            MDC.put("traceId", traceId);
        }
    })
    .to("mock:Something");

3. 检查日志框架的配置 #

别忘记确认你的日志框架（Logback/Log4j2）已经配置了MDC变量的输出，比如Logback的pattern配置：

<appender name="CONSOLE" class="ch.qos.logback.core.ConsoleAppender">
    <encoder>
        <pattern>%d{yyyy-MM-dd HH:mm:ss.SSS} [%thread] %-5level %logger{36} [%X{traceId}] - %msg%n</pattern>
    </encoder>
</appender>

这里的%X{traceId}就是用来输出MDC中traceId的值的，如果没配置，就算MDC里有值也看不到。

4. 测试代码的优化建议 #

在你的MDCTest里，建议用MockEndpoint的断言来验证MDC相关的属性，确保路由执行完成后再检查：

@Test
public void testMdcValueTransfer() throws InterruptedException {
    MockEndpoint mockEndpoint = camelContext.getEndpoint("mock:Something", MockEndpoint.class);
    // 预期收到1条消息，且消息属性中包含traceId
    mockEndpoint.expectedMessageCount(1);
    mockEndpoint.message(0).property("traceId").isNotNull();

    // 发送测试消息
    producerTemplate.sendBody("direct:sendToKafka", "test payload");

    // 等待路由执行完成并验证断言
    mockEndpoint.assertIsSatisfied();
}

按照上面的步骤来，基本就能解决MDC值丢失的问题了。

内容的提问来源于stack exchange，提问作者fakhruddin tahery