Spring Integration错误流MDC传递问题及解决方案咨询

优先选择方案2，因为你的核心流程基于DirectChannel做同步处理，让错误处理和主线程同执行，完全不需要额外处理MDC，既符合原设计的同步语义，又能彻底解决MDC追溯问题，实现成本最低。

如果业务上要求错误处理必须异步（比如错误处理逻辑耗时较长，不想阻塞主线程），再考虑方案1。

方案3不推荐，MDC属于线程上下文的日志追溯元数据，而非消息本身的业务属性，将其序列化到消息头会增加消息耦合度，不符合消息驱动的设计原则。

问题根源在于你使用了QueueChannel作为错误通道，且配置了默认Poller，导致错误处理被异步调度。只需将错误通道改为同步的DirectChannel，并调整Poller配置即可：

修改GenericErrorFlow类：

@Configuration
public class GenericErrorFlow {

    public static final String CHANNEL = "errorChannel";

    // 将QueueChannel替换为DirectChannel，实现同步错误处理
    @Bean
    DirectChannel errorChannel() {
        DirectChannel dc = new DirectChannel();
        dc.setComponentName(CHANNEL);
        return dc;
    }

    // 移除默认Poller的errorChannel配置（若无需全局默认Poller可直接删除该Bean）
    @Bean(name = PollerMetadata.DEFAULT_POLLER)
    public PollerSpec poller() {
        return Pollers.fixedRate(500);
        // 去掉原来的.errorChannel(CHANNEL)配置
    }
}

修改后，当exampleFlow中抛出错误时，错误会直接在原线程路由到errorChannel，MDC上下文完全保留，无需额外处理。

若必须保留错误处理的异步特性，可通过自定义TaskExecutor实现MDC上下文的传递，让Poller在执行错误处理任务时复制主线程的MDC：

1. 实现带MDC传递的自定义TaskExecutor

import org.slf4j.MDC;
import org.springframework.core.task.TaskExecutor;
import java.util.Map;
import java.util.concurrent.Executors;

public class MdcTaskExecutor implements TaskExecutor {

    private final TaskExecutor delegate;

    public MdcTaskExecutor() {
        // 可根据业务需求调整线程池参数
        this.delegate = Executors.newFixedThreadPool(10);
    }

    @Override
    public void execute(Runnable task) {
        // 复制当前线程的MDC上下文
        Map<String, String> mdcContext = MDC.getCopyOfContextMap();
        delegate.execute(() -> {
            try {
                // 在错误线程恢复MDC
                if (mdcContext != null) {
                    MDC.setContextMap(mdcContext);
                }
                task.run();
            } finally {
                // 执行完毕清理MDC，避免线程池复用导致上下文污染
                MDC.clear();
            }
        });
    }
}

2. 修改GenericErrorFlow配置，让Poller使用该TaskExecutor

@Configuration
public class GenericErrorFlow {

    public static final String CHANNEL = "errorChannel";

    @Bean
    QueueChannel errorChannel() {
        return new QueueChannel(500);
    }

    // 注册自定义MDC TaskExecutor
    @Bean
    TaskExecutor mdcTaskExecutor() {
        return new MdcTaskExecutor();
    }

    @Bean(name = PollerMetadata.DEFAULT_POLLER)
    public PollerSpec poller() {
        return Pollers.fixedRate(500)
                .taskExecutor(mdcTaskExecutor()) // 指定自定义TaskExecutor
                .errorChannel(CHANNEL);
    }
}

这样，当错误被异步调度到错误线程时，会自动复制主线程的MDC上下文，日志中就能正确关联到源流的追踪信息。

内容的提问来源于stack exchange，提问作者Krittam Kothari