用于简单RESTful调用的反应式R2DBC

Question

由于R2DBC是反应式和非阻塞的，我想了解在简单的RESTful CRUD服务中使用R2DBC的好处

假设Spring Boot应用程序正在使用下面的存储库公开RESTful服务

public interface CustomerRepository extends ReactiveCrudRepository<Customer, Long> {

    @Query("SELECT * FROM customer WHERE last_name = :lastname")
    Flux<Customer> findByLastName(String lastName);

}

从服务调用此存储库，结果需要在服务中进行转换，然后才能返回控制器。

Flux<Customer> customers = repository.findAll();

为了访问完整的客户列表，我需要在通量上调用blockLast（），这使得它阻塞并违背了使用反应组件的目的

这是否意味着在这个简单的示例中使用R2DBC没有任何好处？我错过什么了吗？

如果通量集合的处理发生在不同的线程中，那么通量只能用于异步订阅吗？

Answer 1

1. 由于该方法重新启动Flux，它返回一个可以在未来某个时候完成的promise。
2. html" target="_blank">调用此方法的线程不应该阻塞-这就是反应式的全部意义。如果您使用. block Last（），您将使调用线程阻塞。正如Michael在这个答案中所说，只有在您将反应式和非反应式代码集成在一起时才应该这样做。
3. 这是一张解释异步计算如何工作的图表（反应式、CompletableFuture等）。希望这能消除您的疑虑；

如图所示，如果执行。blockLast（），您失去了真正的非阻塞。理想情况下，调用线程应该立即释放，以便可以执行其他工作。

“通量只能用于异步订阅，其中通量集合的处理发生在不同的线程中吗？”-通量只不过是一个promise，它可以在未来的某个时间完成。如图所示，回调将在异步线程上执行。计算完成。您可以使用. PublishOn（）切换此线程。

Answer 2

为了访问完整的客户列表，我需要在Flux上调用blockLast（），这使得它阻塞并违背了使用反应组件的目的

如果要实际获取对列表的引用，只需调用blockLast（）

如果您只想一次访问完整的客户列表，您可以明智地调用collectList（）以获得一个

这里唯一要注意的是内存占用-如果您只是处理Flux

这是否是一个问题取决于您的用例。如果你说的是10个左右的客户，那没问题。如果你说的是数十亿美元，那么这可能不是一个明智的解决方案。