java为什么上下文不从（Reactor）Mono传播到（RxJava）Single？

Question

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

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

下游，我的控制器做这个

@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")));
}

以上各项都很好

如果我想从controller方法返回一个值呢？我尝试使用RxJava3Adapter.monoToSingle()，但它破坏了反应链

@GetMapping(path = "test")
public Single<String> test() throws Exception {
  final Mono<ContextView> contextMono = Mono.deferContextual(Mono::just);
  return RxJava3Adapter.monoToSingle(
    contextMono.flatMap(ctx -> Mono.just(ctx.get("my-context"))));
}

我的猜测是，因为我没有返回Mono，所以RxJava3Adapter中没有订阅此contextMono。这是正确的解释吗

在传递上下文时，是否有任何方法返回一个单字符

Answer 1

订阅本身工作正常。问题在于Context是反应堆特有的特性，不属于Reactive Streams标准的一部分。因此，当您将Mono转换为Single时，Context将丢失

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