为什么上下文不会从ReactorMono 传播到RxJavaSingle？

问题描述

例如，假设我有一个编写一些上下文的 WebFilter

make_test([](int a,double b) { std::cout << a << b << "\n"; });

下游，我的控制器执行此操作

public Mono<Void> filter(ServerWebExchange exchange,WebFilterChain chain) {
  return chain.filter(exchange)
    .contextWrite(Context.of("my-context","foobar"));
}

以上一切正常。

如果我想从控制器方法返回一个 Single 怎么办？我尝试使用 @GetMapping(path = "test") public Mono<String> test() throws Exception { final Mono<ContextView> contextMono = Mono.deferContextual(Mono::just); return contextMono.flatMap(ctx -> Mono.just(ctx.get("my-context"))); } 但它破坏了反应堆链。

RxJava3Adapter.monoToSingle()

我的猜测是，由于我没有返回 Mono，因此在 RxJava3Adapter 中没有任何内容订阅此 contextMono。这是正确的解释吗？

有没有办法在传入上下文的同时返回 Single ？

解决方法

订阅本身运行良好。问题是 Context 是 Reactor 特定的功能，它不是 Reactive Streams 标准的一部分。因此，当您将 Mono 转换为 Single 时，Context 会丢失。

在您附加的代码中，您应该简单地省略 Rx 部分以使其工作，但我想您的实际用例可能会更加复杂。一个好的方法是尽早将 Rx 代码转换为 Reactor（例如，当您调用返回 Rx 类型的第三方库时），并在代码库的其余部分（包括控制器返回类型）中使用 Reactor。>