如果只进行一次同步调用，Webflux会发生什么？

Question

我开始在Spring Boot中使用Webflux进行反应式Java编程。

我遇到了一个场景，很难被动地执行某个数据库调用。

如果我在Mono中执行单个阻塞数据库调用，会发生什么？

代码看起来像这样。。。

public Mono<ReturnThing> isThisAsyncOrNot() {
    //Async, non-blocking API call
    return webClient.doSomeAPIWork()
                     .flatMap(whatevers -> {
                         //Synchronous, blocking database call
                         ReturnThing returnThing= returnThingRepo.getByWhateverId(whatever.ID);
                         }
                         return returnThing;
                     });
}

现在是的，我知道有一个简单的方法可以被动地做到这一点。这不是我要问的问题（事实上，真正的代码要复杂得多）。

我真正想知道的是，同步数据库调用将对我的性能产生什么影响。整个方法是否仍然是异步非阻塞的（除了在进行db调用的部分，即阻塞期间）？或者这会以某种方式破坏整个反应范式，导致整个事情，从开始到结束，都被阻塞吗？

Answer 1

你需要理解反应的关键，你就能自己回答这个问题。反应过程中的每个操作员一次一个项目。每个操作员还具有一个队列，如果操作员忙，可以在其中对项目进行排队。现在考虑下面的代码：

Flux.fromIterable(Arrays.asList(1,2,3,4,5))
    .flatMap(a -> {
         Thread.sleep(2000);
         return Mono.just(a);
    }).subscribe(System.out::println);

您将看到项目每隔2秒打印一次。这是因为平地图的线程被阻塞了2秒，其余元素的项目都排队了。平地图的线程如果想消耗队列中的项目，就必须成为自由的。

在你的例子中，你说数据库调用被阻塞了。这将导致调用线程被阻塞。所以你的方法既不是非阻塞，也不是异步。但是，执行以下操作

Mono.just(whatever)
    .subscribeOn(Schedulers.elastic())
    .flatMap(whatever -> returnThingRepo.getByWhateverId(whatever.ID));

在flatMap中，您的方法将变成非阻塞和异步。这是因为调用线程在<代码>完成后立即变为空闲。subscribeOn（）运算符被调用。

希望这能回答你的问题。

这并没有打破反应范式。在我看来，反应式操作远不止是非阻塞的异步操作。除了NIO，惯用性和简单的多线程功能也是我的一大卖点。

Answer 2

要记住的金科玉律是，你永远不能让阻塞方法成为非阻塞方法。你可以从另一个角度去做一些琐碎的事情，你可以做各种各样的事情来避免完全破坏反应性范式，但是没有办法让它本质上是异步的。

或者这会以某种方式破坏整个反应范式，导致整个事情，从开始到结束，都被阻塞吗？

不幸的是，比这更糟。假设它不会使应用程序崩溃，那么在执行阻塞数据库调用时，它将导致少数几个反应线程之一（或者可能是单个反应线程）阻塞。这意味着需要使用该线程的所有其他反应性操作（这很可能是整个应用程序）都必须等到阻塞数据库调用完成后才能进行调度，这对性能造成了严重影响。

处理这些情况（需要从响应链进行阻塞调用）的公认方法是使用有界弹性调度程序，它将执行委托给后端线程池，以便不束缚主事件线程。