1. 简介
三月份已经介绍过 ,它是一种异步的、非阻塞的关系式数据库连接规范。尽管一些 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
来自 “ ITPUB博客 ” ，链接：https://blog.itpub.net/69975884/viewspace-2700117/ ，如需转载，请注明出处，否则将追究法律责任。
