猿问

为什么 Spring 不为关系数据库提供响应式(非阻塞)客户端?

我使用Vert.x工具包创建响应式应用程序,支持MySQL 和 Postgres等关系数据库。我知道 Spring 为 Cassandra 和 Mongo 等一些 NoSQL DB 提供响应式支持,但他们愿意为关系 DB 提供相同的支持吗?


HUWWW
浏览 246回答 2
2回答

蛊毒传说

Spring 框架背后的想法是什么?Spring Framework 是一个用于提高开发人员生产力的库,Spring 的投资组合项目(如 Spring Data、Spring Security、Spring Cloud)也是如此。这些项目建立在现有 API 之上,这些 API 要么通过 JSR 或 JEP 标准化,要么建立在已证明有用且广泛使用的库之上。Spring 团队不会为数据库或其他集成构建驱动程序,这取决于数据库/驱动程序供应商。WebFlux 与 Vert.x 相比Spring WebFlux 是典型 Spring 模块的一个很好的例子。它建立在现有的非阻塞服务器(Project Reactor 通过 netty、Undertow 和 Jetty)之上。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 一起发布。有几个独立的驱动程序,例如Reactivese 的 reactive-pg-client。这些驱动程序带有特定于供应商的 API,并不真正适合 Spring 中更广泛的集成。我们需要提供额外的层来公开一个通用的 API,而且新的驱动程序不能只是插入到您的应用程序中,因此它可以开箱即用™。拥有标准 API 允许可插拔,因此拥有标准 API 具有巨大的价值。R2DBC 来救援?由于缺乏标准 API 和驱动程序不可用,Pivotal 的一个团队开始研究一种非常适合反应式编程目的的反应式关系 API。他们提出了R2DBC,它代表反应式关系数据库连接。到目前为止,R2DBC 是一个孵化器项目,用于评估可行性并开始讨论驱动程序供应商是否对支持反应式/非阻塞/异步驱动程序感兴趣。截至目前,共有三种驱动程序实现:PostgreSQLH2微软 SQL 服务器R2DBC 带有一个 API 规范 (&nbsp;r2dbc-spi) 和一个客户端 (&nbsp;r2dbc-client),使 SPI 可用于应用程序。我们开始探索Spring Data R2DBC集成,它通过数据库客户端和支持响应式存储库提供响应式 API。R2DBC 及其生态系统还很年轻,需要实验和反馈来收集用例,看看反应式关系数据库集成是否有意义。现在,您可以通过 Spring Data 使用 R2DBC,以下代码片段显示了DatabaseClient用法:PostgresqlConnectionFactory&nbsp;connectionFactory&nbsp;=&nbsp;new&nbsp;PostgresqlConnectionFactory(…);DatabaseClient&nbsp;databaseClient&nbsp;=&nbsp;DatabaseClient.create(connectionFactory);Mono<Integer>&nbsp;count&nbsp;=&nbsp;databaseClient.execute() &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.sql("INSERT&nbsp;INTO&nbsp;legoset&nbsp;(id,&nbsp;name,&nbsp;manual)&nbsp;VALUES($1,&nbsp;$2,&nbsp;$3)") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.bind("$1",&nbsp;42055) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.bind("$2",&nbsp;"Description") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.bindNull("$3",&nbsp;Integer.class) &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.fetch() &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.rowsUpdated();Flux<Map<String,&nbsp;Object>>&nbsp;rows&nbsp;=&nbsp;databaseClient.execute() &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.sql("SELECT&nbsp;id,&nbsp;name,&nbsp;manual&nbsp;FROM&nbsp;legoset") &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.fetch() &nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;&nbsp;.all();

哔哔one

Spring WebFlux 是创建非阻塞 REST 应用程序的好方法。开始使用 WebFlux 时遇到的一个问题是 JDBC,因为 JDBC 是阻塞的。像 Cassandra 或 Couchbase 这样的新学校数据库具有非阻塞驱动程序。在 Couchbase 的例子中,它的驱动程序使用 RXJava。在为数据库创建异步驱动程序方面付出了一些努力,Oracle 也在努力创建 ADBA。不幸的是,现在还处于早期阶段,如果您想与 JVM 上的 SQL 数据库通信,您会遇到阻塞驱动程序。实际上,Spring 不负责为关系数据库提供非阻塞驱动程序。
随时随地看视频慕课网APP

相关分类

Java
我要回答