小编Sam*_*Cox的帖子

在 JAX-RS 支持的服务器中使用 Reactor 时如何处理阻塞调用？

为了处理 HTTP 请求，我们必须将阻塞调用（例如 JDBC 调用）作为Mono/Flux基于进程的一部分。我们目前的计划是这样的：

// I renamed getSomething to processJaxrsHttpRequest
CompletionStage<String> processJaxrsHttpRequest(String input) {
  return Mono.just(input)
      .map(in -> process(in))
      .flatMap(str -> Mono.fromCallable(() -> jdbcCall(str)).subscribeOn(fixedScheduler))
      .flatMap(str -> asyncHttpCall(str))
      .flatMap(str -> Mono.fromCallable(() -> jdbcCall(str)).subscribeOn(fixedScheduler))
      .toFuture();
}

Run Code Online (Sandbox Code Playgroud)

wherefixedScheduler在 HTTP 请求中同时使用。

我们希望得到一些关于这种在相当数量的通量内处理块调用的策略的反馈。当然，我们知道，如果我们所有的请求都流经这些阻塞调用，那么我们最好不要使用反应器（除了公认的良好处理 API 之外）。

更新：感谢bsideup的回答。然而，我应该更具体地回答我的问题。

我的总体问题是，如果可以大量创建/订阅这些通量，如何有效地跨多个通量使用阻塞调用。我们尝试了建议的方法，但它会导致线程爆炸并很快出现 OOM。所以我们正在考虑使用共享调度程序。所以..这是我的问题。