如何通过Project Reactor的Subscriber Context传递数据？现有方案是否可行？

作为Reactor新手，你当前的实现存在几个违背Reactor设计原则的问题，不仅会破坏异步非阻塞特性，还会引发严重的线程安全和数据串扰问题，具体拆解如下：

1. SubscriberContext使用完全错误 #

你在saveHeader里创建的monoHeader绑定的是调用saveHeader瞬间的上下文，但控制器里的saveHeader是在Mono订阅前同步执行的，此时根本没有当前请求对应的订阅上下文。而且你把monoHeader作为Service的成员变量，多个请求会互相覆盖这个变量，导致后续请求拿到错误的header值，出现跨请求的上下文污染。

2. 滥用block()彻底破坏异步特性 #

在getData()里调用monoHeader.block()会直接阻塞当前线程，把异步流程硬生生拉成同步，完全浪费了Reactor的异步非阻塞优势。如果monoHeader没有被正确初始化（比如请求顺序异常），还会抛出空指针或者阻塞超时的问题。

3. 成员变量引发线程安全隐患 #

Spring的Service默认是单例的，monoHeader作为成员变量，多个请求同时调用saveHeader和getData时，会互相覆盖这个变量的值，导致请求之间的数据串扰，高并发场景下会引发严重的业务错误。

正确的实现方式 #

你应该通过SubscriberContext在请求链中传递header，而非用成员变量存储，同时全程避免阻塞操作。修改后的代码如下：

控制器代码 #

@RestController
public class Controller {
    private final Service service;

    // 构造注入替代@Autowired（更符合Spring最佳实践）
    public Controller(Service service) {
        this.service = service;
    }

    @PostMapping("/path")
    public Mono<String> test(@RequestHeader Map<String, String> headers) {
        String headerValue = headers.get("header");
        // 将header放入当前请求的订阅上下文
        return service.getData()
            .subscriberContext(ctx -> ctx.put("header", headerValue));
    }
}

服务代码 #

@Service
public class Service {
    private final InteractionService interactor;

    public Service(InteractionService interactor) {
        this.interactor = interactor;
    }

    public Mono<String> getData() {
        // 从上下文获取header，再异步调用交互服务
        return Mono.subscriberContext()
            .map(ctx -> ctx.get("header"))
            // 如果interactor.interact是同步方法，用fromCallable包装成异步
            .flatMap(header -> Mono.fromCallable(() -> interactor.interact(header)));
    }
}

额外优化建议 #

如果你的InteractionService.interact方法本身支持异步（比如返回Mono），可以直接替换Mono.fromCallable为该方法的调用，进一步提升异步效率：

.flatMap(header -> interactor.interactAsync(header));

这样每个请求的上下文都是独立的，不会互相干扰，全程保持异步非阻塞，也不存在线程安全问题，完全符合Reactor的设计理念。

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