使用反应式关系数据库连接规范R2DBC操作MySQL数据库
1. 简介
三月份已经介绍过R2DBC,它是一种异步的、非阻塞的关系式数据库连接规范。尽管一些NoSQL数据库供应商为其数据库提供了反应式数据库客户端,但对于大多数项目而言,迁移到NoSQL并不是一个理想的选择。这促使了一个通用的响应式关系数据库连接规范的诞生。 作为拥有庞大用户群的关系式数据库MySQL也有了反应式驱动,不过并不是官方的。但是Spring官方将其纳入了依赖池,说明该类库的质量并不低。所以今天就尝尝鲜,试一下使用R2DBC连接MySQL。
2. 环境依赖
基于Spring Boot 2.3.1和Spring Data R2DBC,还有反应式Web框架Webflux,同时也要依赖r2dbc-mysql库,所有的Maven依赖为:
<!--r2dbc mysql 库--> <dependency> <groupId>dev.miku</groupId> <artifactId>r2dbc-mysql</artifactId> </dependency> <!--Spring r2dbc 抽象层--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-r2dbc</artifactId> </dependency> <!--自动配置需要引入的一个嵌入式数据库类型对象--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-jdbc</artifactId> </dependency> <!--反应式web框架--> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-webflux</artifactId> </dependency>
MySQL版本为5.7,没有测试其它版本。
3. R2DBC配置
所有的R2DBC自动配置都在org.springframework.boot.autoconfigure.data.r2dbc
包下,如果要配置MySQL必须针对性的配置对应的连接工厂接口ConnectionFactory
,当然也可以通过application.yml
配置。个人比较喜欢JavaConfig
。
@Bean ConnectionFactory connectionFactory() { return MySqlConnectionFactory.from(MySqlConnectionConfiguration.builder() .host("127.0.0.1") .port(3306) .username("root") .password("123456") .database("database_name") // 额外的其它非必选参数省略 .build()); }
详细配置可参考r2dbc-mysql的官方说明:https://github.com/mirromutth/r2dbc-mysql
当ConnectionFactory
配置好后,就会被注入DatabaseClient
对象。该对象是非阻塞的,用于执行数据库反应性客户端调用与反应流背压请求。我们可以通过该接口反应式地操作数据库。
4. 编写反应式接口
我们先创建一张表并写入一些数据:
create table client_user ( user_id varchar(64) not null comment '用户唯一标示' primary key, username varchar(64) null comment '名称', phone_number varchar(64) null comment '手机号', gender tinyint(1) default 0 null comment '0 未知 1 男 2 女 ' )
对应的实体为:
package cn.felord.r2dbc.config; import lombok.Data; /** * @author felord.cn */ @Data public class ClientUser { private String userId; private String username; private String phoneNumber; private Integer gender; }
然后我们编写一个Webflux的反应式接口:
package cn.felord.r2dbc.config; import org.springframework.data.r2dbc.core.DatabaseClient; import org.springframework.web.bind.annotation.GetMapping; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RestController; import reactor.core.publisher.Flux; import reactor.core.publisher.Mono; import javax.annotation.Resource; /** * The type User controller. * * @author felord.cn * @since 17 :07 */ @RestController @RequestMapping("/user") public class UserController { @Resource private DatabaseClient databaseClient; /** * 查询 * * @return 返回Flux序列 包含所有的ClientUser */ @GetMapping("/get") public Flux<ClientUser> clientUserFlux() { return databaseClient.execute("select * from client_user").as(ClientUser.class) .fetch() .all(); } /** * 响应式写入. * * @return Mono对象包含更新成功的条数 */ @GetMapping("/add") public Mono<Integer> insert() { ClientUser clientUser = new ClientUser(); clientUser.setUserId("34345514644"); clientUser.setUsername("felord.cn"); clientUser.setPhoneNumber("3456121"); clientUser.setGender(1); return databaseClient.insert().into(ClientUser.class) .using(clientUser) .fetch().rowsUpdated(); } }
调用接口就能获取到期望的数据结果。
5. 总结
乍一看R2DBC并没有想象中的那么难,但是间接的需要了解Flux
、Mono
等抽象概念。同时目前来说如果不和Webflux框架配合也没有使用场景。就本文的MySQL而言,R2DBC驱动还是社区维护(不得不说PgSQL就做的很好)。
然而需要你看清的是反应式才是未来。如果你要抓住未来就需要现在就了解一些相关的知识。这让我想起五年前刚刚接触Spring Boot的感觉。另外这里有一份Spring官方关于R2DBC的PPT,也是让你更好了解R2DBC的权威资料。可以关注:码农小胖哥 回复r2dbc获取。
关注公众号:Felordcn获取更多资讯
低调大师中文资讯倾力打造互联网数据资讯、行业资源、电子商务、移动互联网、网络营销平台。
持续更新报道IT业界、互联网、市场资讯、驱动更新,是最及时权威的产业资讯及硬件资讯报道平台。
转载内容版权归作者及来源网站所有,本站原创内容转载请注明来源。
- 上一篇
【开源狂欢节】限量领取CKA考试8折优惠码-Linux Foundation开源软件大学
Linux Foundation开源软件大学年中会员福利大放送 ~限量领取考试8折优惠码~ 助力程序员在逆境中不断提升,让你在职场更进一步 随着开源技术的热度持续攀升,越来越多的国内开发者开始对开源知识进行了解、学习、使用,并积极地回馈开源事业。学习和使用开源技术已经成为互联网技术人才的必备技能,对于企业而言,利用开源技术提升企业技术实力也已成为众多大中型科技企业的共识。 Linux Foundation开源软件大学为助力开源技术专业人才技能提升,提供丰富的培训课程体系和Linux基金会官方认证,为广大企业培养优秀的软件人才。 逆境中,互联网人需要警醒 据Linux Foundation开源软件大学数据统计:全国5月份有30w+的程序员招聘需求,其中一线城市占比18w+,超50%;招聘企业中95%对学历要求为本科,加分项是拥有某些专业领域的证书,而经过数据对比,拥有一项证书或技能认证的人群占统计数据17%,而通过招聘岗位薪资来看,拥有含金量高的技能证书能影响程序员薪资的幅度是:3000-10000之间。 但从数据看来,却仅有不到20%的人能在求职过程中,利用自己含金量高证书给自己加薪。...
- 下一篇
小师妹学JVM之:JIT中的PrintCompilation
简介 上篇文章我们讲到了JIT中的LogCompilation,将编译的日志都收集起来,存到日志文件里面,并且详细的解释了LogCompilation日志文件中的内容定义。今天我们再和小师妹一起学习LogCompilation的姊妹篇PrintCompilation,看看都有什么妙用吧。 PrintCompilation 小师妹:F师兄,上次你给讲的LogCompilation实在是太复杂了,生成的日志文件又多,完全看不了,我其实只是想知道有哪些方法被编译成了机器码,有没有什么更加简单的办法呢? 真理的大海,让未发现的一切事物躺卧在我的眼前,任我去探寻- 牛顿(英国) 当然有的,那就给你介绍一下LogCompilation的妹妹PrintCompilation,为什么是妹妹呢?因为PrintCompilation输出的日志要比LogCompilation少太多了。 老规矩,上上我们的JMH运行代码,文章中使用的代码链接都会在文末注明,这里使用图片的原因只是为了方便读者阅读代码: 这里和上次的LogCompilation不同的是,我们使用:-XX:+PrintCompilation参数。...
相关文章
文章评论
共有0条评论来说两句吧...
文章二维码
点击排行
-
Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- CentOS8编译安装MySQL8.0.19
- Docker快速安装Oracle11G,搭建oracle11g学习环境
- SpringBoot2配置默认Tomcat设置,开启更多高级功能
- MySQL8.0.19开启GTID主从同步CentOS8
- CentOS7,8上快速安装Gitea,搭建Git服务器
- Jdk安装(Linux,MacOS,Windows),包含三大操作系统的最全安装
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
推荐阅读
最新文章
- Docker使用Oracle官方镜像安装(12C,18C,19C)
- Springboot2将连接池hikari替换为druid,体验最强大的数据库连接池
- Eclipse初始化配置,告别卡顿、闪退、编译时间过长
- SpringBoot2编写第一个Controller,响应你的http请求并返回结果
- Linux系统CentOS6、CentOS7手动修改IP地址
- CentOS7设置SWAP分区,小内存服务器的救世主
- CentOS7编译安装Gcc9.2.0,解决mysql等软件编译问题
- CentOS7,8上快速安装Gitea,搭建Git服务器
- CentOS8编译安装MySQL8.0.19
- SpringBoot2整合Redis,开启缓存,提高访问速度