栏目分类:
子分类:
返回
名师互学网用户登录
快速导航关闭
当前搜索
当前分类
子分类
实用工具
热门搜索
名师互学网 > IT > 面试经验 > 面试问答

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

面试问答 更新时间: 发布时间: IT归档 最新发布 模块sitemap 名妆网 法律咨询 聚返吧 英语巴士网 伯小乐 网商动力

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

Spring框架背后的想法是什么?

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();


转载请注明:文章转载自 www.mshxw.com
本文地址:https://www.mshxw.com/it/428954.html
我们一直用心在做
关于我们 文章归档 网站地图 联系我们

版权所有 (c)2021-2022 MSHXW.COM

ICP备案号:晋ICP备2021003244-6号