Spring Boot Reactive：仅用WebClient过滤器传播MDC为何仍需Schedulers.onScheduleHook？

问题背景 #

在Spring Boot Reactive链中传递MDC变量，常见方案要求同时实现两项内容：

• ExchangeFilterFunction（WebClient过滤器，用于复制MDC上下文）
• Schedulers.onScheduleHook（用于复制MDC上下文的调度钩子）

但实际测试发现仅添加WebClient过滤器即可实现MDC上下文传播，因此疑问：为何仍需添加Schedulers.onScheduleHook？不添加该钩子会缺失什么功能？

核心原因与缺失功能 #

1. WebClient过滤器仅覆盖局部场景 #

你实现的ExchangeFilterFunction只在WebClient发起请求和接收响应的特定阶段（请求发送前的主线程、响应回调的Reactor线程）复制了MDC上下文，但它无法覆盖Reactor调度器切换线程的所有场景：

• 比如当反应式链中存在subscribeOn/publishOn切换线程池时，新线程的MDC上下文不会自动继承原线程内容；
• 或者在flatMap/concatMap等操作中，如果内部任务被调度到不同线程执行，MDC会直接丢失。

2. Schedulers.onScheduleHook实现全局线程上下文传递 #

Schedulers.onScheduleHook是全局生效的钩子，它会拦截Reactor调度器的所有线程调度行为：

• 每次线程执行任务前，自动复制当前MDC上下文到新线程；
• 任务执行完成后自动清理MDC，避免线程复用导致的上下文污染。

3. 不添加钩子的潜在问题 #

如果只使用WebClient过滤器，会出现以下场景下的MDC异常：

• 业务代码中手动切换线程池（如publishOn(Schedulers.boundedElastic())）后，后续日志无法获取MDC变量；
• WebClient响应处理后，后续的反应式操作（如数据库查询、异步计算）在其他线程执行时，MDC上下文丢失；
• 线程池复用导致MDC串扰：Reactor的线程是复用的，如果前一个任务的MDC未清理，会被下一个任务意外继承，引发日志混乱。

完整实现代码 #

// WebClient MDC过滤器
ExchangeFilterFunction function = (request, next) -> {
    // 运行在请求发起的主线程
    Map<String, String> map = MDC.getCopyOfContextMap();
    return next.exchange(request)
         .doOnNext(value -> {
              // 运行在Reactor的响应处理线程
              if (map != null) {
                  MDC.setContextMap(map);
              }
         });
};
    
WebClient webClient = WebClient.builder().filter(function).build();

// MDC调度钩子
Schedulers.onScheduleHook("mdc", runnable -> {
    Map<String, String> map = MDC.getCopyOfContextMap();
    return () -> {
        if (map != null) {
            MDC.setContextMap(map);
        }
        try {
            runnable.run();
        } finally {
            MDC.clear();
        }
    };
});

内容的提问来源于stack exchange，提问作者suraj bahl