前面的内容讲解了用 Map 数据结构内存式存储了数据，这样数据就不会持久化，本文我们用 MongoDB 来实现 WebFlux 对数据源的操作。

关于MongoDB，见官网。

MongoDB 是一个基于分布式文件存储的数据库，由 C++ 语言编写，旨在为 Web 应用提供可扩展的高性能数据存储解决方案。

MongoDB 是一个介于关系数据库和非关系数据库之间的产品，是非关系数据库当中功能最丰富，最像关系数据库。

关于MongoDB的安装和操作，详见官方文档，或者自行搜索。

下面开始构建项目：

项目需要的组件很简单，一个wen和一个mongodb组件。生成项目并下载，可以自行查看pom中有哪些依赖。

下面构建项目所需要的类和目录，创建好后如下：

使用MySQL数据库要在配置文件中配置数据源，使用MongoDB当然也要配置，在application.properties 配置下上面启动的 MongoDB 配置：

这就一个巨大的问题了，为啥不用我们常用的 MySQL 数据库呢？

答案是 Spring Data Reactive Repositories 目前支持 Mongo、Cassandra、Redis、Couchbase。不支持 MySQL，那究竟为啥呢？那就说明下 JDBC 和 Spring Data 的关系。

Spring Data Reactive Repositories 突出点是 Reactive，即非阻塞的。区别如下：

1    基于 JDBC 实现的 Spring Data，比如 Spring Data JPA 是阻塞的。原理是基于阻塞 IO 模型 消耗每个调用数据库的线程（Connection）。

2    事务只能在一个 java.sql.Connection 使用，即一个事务一个操作。

那如何异步非阻塞封装下 JDBC 的思想也不新鲜，Scala 库 Slick 3 就实现了。简单的实现原理如下：

1    一个事务多个操作，那么共享一个 java.sql.Connection，可以使用透明事务管理，利用回调编程模型去传递。

2    保持有限的空闲连接。

我坚信非阻塞 JDBC 很快就会出现的，这样我们就开心的调用 MySQL 了！！！

下面来查看类的内容。City对象类内容如下：

@Id 注解标记对应库表的主键或者唯一标识符。因为这个是我们的 DO，数据访问对象一一映射到数据存储。

MongoDB 数据访问层 CityRepository：

CityRepository 接口只要继承 ReactiveMongoRepository 类即可，默认会提供很多实现，比如 CRUD 和列表查询参数相关的实现。ReactiveMongoRepository 接口默认实现了如下：

如图，ReactiveMongoRepository 的集成类 ReactiveSortingRepository、ReactiveCrudRepository 实现了很多常用的接口：

ReactiveCrudRepository 接口如图所示：

另外可以看出，接口的命名是遵循规范的，常用命名规则如下：

常用案例，代码如下：

源码层面

ReactiveCrudRepository 抽象在 reactive 包，如图：

这里我们可以看出，支持了 Reactive 还支持了 RxJava。对应老的 CrudRepository 新增了 ReactiveCrudRepository 接口及各种存储实现。

处理器类 Handler 和控制器类 Controller：

不要对 Mono、Flux 陌生，把它当成对象即可。

继续修改控制器类 Controller，代码如下：

运行工程

一个 CRUD 的 Spring Boot WebFlux 工程就开发完毕了，下面运行工程验证下。在 IDEA 中执行 Application 类启动，任意正常模式或者 Debug 模式，可以在控制台看到成功运行的输出：

打开Postman进行接口测试，新增城市信息 POST http://127.0.0.1:8003/city：

连接数据库，可以看到成功添加：

其它接口操作略。。。

总结

这里探讨了 Spring WebFlux 的如何整合 MongoDB，整合其他存储 Cassandra、Redis、Couchbase 就大同小异了。

原文：https://gitbook.cn/gitchat/column/5acda6f6d7966c5ae1086f2b/topic/5acda9f9d7966c5ae108705c

代码：https://gitee.com/blueses/springboot-webflux