为什么Spring不为关系数据库提供反应式（非阻塞）客户端？

Question

我已经使用Vert.x工具包来创建反应性应用程序，并支持MySQL和Postgres等关系数据库。我知道Spring为某些NoSQL数据库（例如Cassandra和Mongo）提供了响应式支持，但他们愿意为关系数据库提供相同的支持吗？

Answer 1

Spring Framework是一个用于提高开发人员生产力的库，Spring的投资组合项目（例如Spring Data，Spring
Security，Spring Cloud）也是如此。

这些项目建立在现有的API之上，这些API通过JSR或JEP进行了标准化，或者建立在已被证明是有用且广泛使用的库之上。Spring团队不为数据库或其他集成构建驱动程序，这取决于数据库/驱动程序供应商。

WebFlux与Vert.x的比较

Spring WebFlux是典型的Spring模块的一个很好的例子。它基于现有的非阻塞服务器（通过netty，Undertow和Jetty的Project
Reactor）之上。WebFlux为利用Spring组件的无阻塞，反应式应用程序提供了运行时容器，以帮助开发和运行此类应用程序。

Vert.x是集成环境的一个很好的例子，它提供了自己的底层实现。Vert.x经过了高度优化，并且这样的生态系统需要优化的集成。Vert.x提出了自己的用于各种数据库的实现，并提供了在Vert.x上下文中运行良好的API，但这些API并非JDBC。

关系数据库API

正如M-Razavi所提到的，Java使用JDBC与关系数据库集成，而JDBC具有阻塞性-
减轻JDBC的阻塞性没有明智的选择。将JDBC调用卸载到Executor（通常是Thread池）的用途受到限制，因为该池最终会因请求而饱和）。TL;
DR，没有可用的API，我们可以在其上提供反应性关系数据库集成。

那有什么选择呢？

M-Razavi]已经提到了ADBA，这是Oracle的一项举措，旨在为使用期货的Java中的异步数据库访问提供标准化的API。ADBA中的所有内容仍在进行中，ADBA背后的团队很高兴获得反馈。一群Postgres人员正在研究可用于首次实验的Postgres
ADBA驱动程序。

但是，ADBA是未来的目标，我希望我们不会看到ADBA与Java 12一起发布。

有几个独立的驱动程序，例如Reactiverse的react-pg-
client。这些驱动程序带有特定于供应商的API，并不真正适合于Spring中的更广泛的集成。我们将需要提供更多的层来公开通用的API，并且不能将新的驱动程序仅插入到您的应用程序中，因此它可以即开即用地运行。拥有标准API可以实现可插入性，因此拥有标准API具有巨大的价值。

R2DBC可以救援吗？

缺乏标准的API和驱动程序不可用，Pivotal的团队开始研究反应性关系API，该API非常适合反应性编程目的。他们提出了R2DBC，R2DBC代表反应式关系数据库连接。到目前为止，R2DBC是一个孵化器项目，旨在评估可行性并开始讨论驱动程序供应商是否对支持反应性/非阻塞/异步驱动器完全感兴趣。

到目前为止，有三种驱动程序实现：

• PostgreSQL的
• H2
• Microsoft SQL服务器

R2DBC带有API规范（r2dbc-spi）和客户端（r2dbc-client），使SPI可用于应用程序。我们开始探索Spring Data
R2DBC集成，该集成通过数据库客户端和支持响应存储库提供响应API。

R2DBC及其生态系统还很年轻，要求进行实验和反馈以收集用例，并查看反应性关系数据库集成是否有意义。

现在，您可以通过Spring Data使用R2DBC，以下代码段显示了DatabaseClient用法：

PostgresqlConnectionFactory connectionFactory = new PostgresqlConnectionFactory(…);

DatabaseClient databaseClient = DatabaseClient.create(connectionFactory);

Mono<Integer> count = databaseClient.execute()
                .sql("INSERT INTO legoset (id, name, manual) VALUES($1, $2, $3)")
                .bind("$1", 42055)
                .bind("$2", "Description")
                .bindNull("$3", Integer.class)
                .fetch()
                .rowsUpdated();

Flux<Map<String, Object>> rows = databaseClient.execute()
                .sql("SELECT id, name, manual FROM legoset")
                .fetch()
                .all();