Spring Webflux Reactor Context求助：test2无法获取test/test1上下文值

碰到这种理论上应该能访问上游Context但实际不行的情况，大概率是订阅链或者Context传递路径出了问题，我给你梳理几个核心排查方向：

• 先检查订阅链是否断裂
  Reactor Context是跟着订阅链走的，如果中间有操作触发了新的订阅（比如调用subscribe()、block()），或者创建了完全独立的新流，那下游的test2就不在同一个Context传递链上，自然拿不到上游的值。举个典型的错误例子：

  // 错误：内部提前订阅导致链断裂
  public static Mono<Void> test() {
      return Mono.just("test")
          .contextWrite(ctx -> ctx.put("key1", "value1"))
          .subscribe(); // 这里直接触发订阅，后续test2的流是全新的链
  }
  

  要确保所有相关操作都在同一个流链上，没有提前终止或分支到独立流。

• 确认Context写入的位置是否正确
  Reactor Context遵循“下游可见上游”的规则，contextWrite必须放在需要访问它的操作的上游。如果test/test1里的Context是写在某个分支流上，而test2没有合并到这个分支，那肯定访问不到。比如：

  // 错误：Context仅存在于未被test2复用的分支
  public static Mono<Void> test() {
      // 这个分支的Context不会传递到test2
      Mono.just("test").contextWrite(ctx -> ctx.put("key1", "value1")).subscribe();
      return Mono.empty();
  }
  

• 排查是否用了会隔离Context的操作符
  有些操作符会创建新的上下文环境，比如早期版本的publishOn()（Reactor 3.2+已修复）、parallel()，或者flatMap内部创建的流没有继承外部Context。遇到这种情况，可以用deferContextual手动传递上游Context：

  // 正确：将上游Context传递到flatMap内部
  public static Mono<Void> test1() {
      return Mono.deferContextual(parentCtx -> 
          Mono.just("test1")
              .contextWrite(parentCtx)
              .flatMap(v -> {
                  // 这里能拿到parentCtx里的key1
                  return Mono.empty();
              })
      );
  }
  

• 打印Context验证传递路径
  可以在关键节点加入doOnEach来打印当前Context，定位丢失的节点：

  public static Mono<Void> test() {
      return Mono.just("test")
          .contextWrite(ctx -> ctx.put("key1", "value1"))
          .doOnEach(signal -> {
              System.out.println("当前Context内容：" + signal.getContextView());
          });
  }
  

  这样能直观看到Context是在哪个环节消失的。

• Spring环境下的特殊排查点
  如果是在Spring WebFlux里，还要注意：

  • 控制器返回的流是否和过滤器/拦截器的流在同一条链上
  • 有没有用@Async这类会创建独立线程/流的注解，这类操作会隔离Reactor Context
  • 不要把Spring的ApplicationContext和Reactor Context搞混，两者作用域完全不同

内容的提问来源于stack exchange，提问作者Jack Zhang