Spring MVC应用程序中JPA与反应代码的混合

Question

我有一个Spring MVC（不是WebFlux）应用程序，它使用WebFlux项目中的WebClient类。除了与WebClient相关的代码之外，应用程序中的所有现有代码都是基于CompletableFuture的异步代码，对JPA的阻塞调用通常是这样进行的：

@Service
public class MyService {
  private final MyRepository repo;
  private final Executor executor;  // configured by me & injected by Spring

  ...

  @Async
  public CompletableFuture<MyResult> doSomething() {
    return CompletableFuture
        .supplyAsync(() => repo.findById(...), executor)
        .thenApply(...);
  }
}

但是，对于WebClient，我不再确定如何根据WebClient返回的结果调用JPA。例如：

public Mono<Foo> fetchFooUsingWebClient() { ... }

public void saveFooBlocking(Foo foo) { /* uses JPA */ }

// Option 1
fetchFooUsingWebClient()
    .flatMap(foo -> {
      var cf = CompletableFuture.runAsync(() => saveFooBlocking(foo), executor);
      return Mono.fromFuture(cf);
    });

// Option 2
fetchFooUsingWebClient()
    .flatMap(foo -> Mono.fromRunnable(() => saveFooBlocking(foo)));

• mono.FromRunnable不接受执行器。它是否在自己的调度器线程上运行runnable？
• 我听说在Spring MVC应用程序中使用反应式WebClient也会带来性能优势。但是在我的例子中，我已经在整个MVC应用程序中使用了自己的执行器，使用mono.fromrunnable而不是自己的执行器不好吗？

（我找到了相关的Spring文档，它描述了如何使用publishon进行阻塞调用，但我认为这是针对我有反应性WebFlux应用程序的场景。对于MVC应用程序，我找不到任何相关文档。）

Answer 1

WebClient的工作线程非常有限，您不应该对这些线程执行阻塞操作（选项2)，我假设您不想使用选项1，它不容易阅读，也不是非常必要。在你的情况下，你可以做

fetchFooUsingWebClient()
.publishOn(Schedulers.boundedElastic())
.map(foo -> saveFooBlocking(foo))
//.bla - other operators, eg. doOnNext, doOnError, etc
.subscribe() // or .block() if you want to get the result, note, this will blcok the caller thread (which calls fetchFooUsingWebClient)