摘要：在配置下上面啟動(dòng)的配置數(shù)據(jù)庫(kù)名為賬號(hào)密碼也為。突出點(diǎn)是，即非阻塞的。四對(duì)象修改包里面的城市實(shí)體對(duì)象類。修改城市對(duì)象，代碼如下城市實(shí)體類城市編號(hào)省份編號(hào)城市名稱描述注解標(biāo)記對(duì)應(yīng)庫(kù)表的主鍵或者唯一標(biāo)識(shí)符。
摘要: 原創(chuàng)出處 https://www.bysocket.com 「公眾號(hào)：泥瓦匠BYSocket 」歡迎關(guān)注和轉(zhuǎn)載，保留摘要，謝謝！
這是泥瓦匠的第104篇原創(chuàng)
文章工程：
JDK 1.8
Maven 3.5.2
Spring Boot 2.1.3.RELEASE
工程名：springboot-webflux-4-thymeleaf
工程地址：見文末
一、前言
上一講用 Map 數(shù)據(jù)結(jié)構(gòu)內(nèi)存式存儲(chǔ)了數(shù)據(jù)。這樣數(shù)據(jù)就不會(huì)持久化，本文我們用 MongoDB 來(lái)實(shí)現(xiàn) WebFlux 對(duì)數(shù)據(jù)源的操作。
什么是 MongoDB ?
官網(wǎng)：https://www.mongodb.com/
MongoDB 是一個(gè)基于分布式文件存儲(chǔ)的數(shù)據(jù)庫(kù)，由 C++ 語(yǔ)言編寫，旨在為 WEB 應(yīng)用提供可擴(kuò)展的高性能數(shù)據(jù)存儲(chǔ)解決方案。
MongoDB 是一個(gè)介于關(guān)系數(shù)據(jù)庫(kù)和非關(guān)系數(shù)據(jù)庫(kù)之間的產(chǎn)品，是非關(guān)系數(shù)據(jù)庫(kù)當(dāng)中功能最豐富，最像關(guān)系數(shù)據(jù)庫(kù)的。
由于操作方便，本文用 Docker 啟動(dòng)一個(gè) MognoDB 服務(wù)。如果 Docker 不會(huì)安裝的，請(qǐng)參考此文：Docker 安裝與基本操作 https://www.jianshu.com/p/f27...
Docker 安裝 MognoDB 并啟動(dòng)如下：
1、創(chuàng)建掛載目錄
docker volume create mongo_data_db
docker volume create mongo_data_configdb
2、啟動(dòng) MognoDB
docker run -d
--name mongo
-v mongo_data_configdb:/data/configdb
-v mongo_data_db:/data/db
-p 27017:27017
mongo
--auth
3、初始化管理員賬號(hào)
docker exec -it mongo mongo admin
// 容器名 // mongo命令 數(shù)據(jù)庫(kù)名
# 創(chuàng)建最高權(quán)限用戶
db.createUser({ user: "admin", pwd: "admin", roles: [ { role: "root", db: "admin" } ] });
4、測(cè)試連通性
docker run -it --rm --link mongo:mongo mongo mongo -u admin -p admin --authenticationDatabase admin mongo/admin
MognoDB 基本操作：
類似 MySQL 命令，顯示庫(kù)列表：
show dbs
使用某數(shù)據(jù)庫(kù)
use admin
顯示表列表
show collections
如果存在 city 表，格式化顯示 city 表內(nèi)容
db.city.find().pretty()
二、結(jié)構(gòu)
類似上面講的工程搭建，新建一個(gè)工程編寫此案例。工程如圖：
[圖片上傳失敗...(image-df7c3f-1558613654501)]
目錄核心如下
pom.xml maven 配置
application.properties 配置文件
dao 數(shù)據(jù)訪問層，本文要點(diǎn)
三、新增 POM 依賴與配置
在 pom.xml 配置新的依賴：
org.springframework.boot
spring-boot-starter-data-mongodb-reactive
類似配了 MySQL 和 JDBC 驅(qū)動(dòng)，肯定得去配置數(shù)據(jù)庫(kù)。在 application.properties 配置下上面啟動(dòng)的 MongoDB 配置：
數(shù)據(jù)庫(kù)名為 admin、賬號(hào)密碼也為 admin。
spring.data.mongodb.host=localhost
spring.data.mongodb.database=admin
spring.data.mongodb.port=27017
spring.data.mongodb.username=admin
spring.data.mongodb.password=admin
這就一個(gè)巨大的問題了，為啥不用我們常用的 MySQL 數(shù)據(jù)庫(kù)呢？
答案是 Spring Data Reactive Repositories 目前支持 Mongo、Cassandra、Redis、Couchbase。不支持 MySQL ，那究竟為啥呢？那就說(shuō)明下 JDBC 和 Spring Data 的關(guān)系。
Spring Data Reactive Repositories 突出點(diǎn)是 Reactive，即非阻塞的。區(qū)別如下：
基于 JDBC 實(shí)現(xiàn)的 Spring Data ，比如 Spring Data JPA 是阻塞的。原理是基于阻塞 IO 模型
消耗每個(gè)調(diào)用數(shù)據(jù)庫(kù)的線程（Connection）
事務(wù)只能在一個(gè) java.sql.Connection 使用，即一個(gè)事務(wù)一個(gè)操作。
那如何異步非阻塞封裝下 JDBC 的思想也不新鮮，Scala 庫(kù) Slick 3 就實(shí)現(xiàn)了。簡(jiǎn)單的實(shí)現(xiàn)原理如下：
一個(gè)事務(wù)多個(gè)操作，那么共享一個(gè) java.sql.Connection ?？梢允褂猛该魇聞?wù)管理，利用回調(diào)編程模型去傳遞
保持有限的空閑連接
最后，我堅(jiān)信非阻塞 JDBC 很快就會(huì)出現(xiàn)的。這樣我們就開心的調(diào)用 MySQL 了。
四、對(duì)象
修改 org.spring.springboot.domain 包里面的城市實(shí)體對(duì)象類。修改城市（City）對(duì)象 City，代碼如下：
import org.springframework.data.annotation.Id;
/**
* 城市實(shí)體類
*
*/
public class City {
/**
* 城市編號(hào)
*/
@Id
private Long id;
/**
* 省份編號(hào)
*/
private Long provinceId;
/**
* 城市名稱
*/
private String cityName;
/**
* 描述
*/
private String description;
public Long getId() {
return id;
}
public void setId(Long id) {
this.id = id;
}
public Long getProvinceId() {
return provinceId;
}
public void setProvinceId(Long provinceId) {
this.provinceId = provinceId;
}
public String getCityName() {
return cityName;
}
public void setCityName(String cityName) {
this.cityName = cityName;
}
public String getDescription() {
return description;
}
public void setDescription(String description) {
this.description = description;
}
}
@Id 注解標(biāo)記對(duì)應(yīng)庫(kù)表的主鍵或者唯一標(biāo)識(shí)符。因?yàn)檫@個(gè)是我們的 DO ，數(shù)據(jù)訪問對(duì)象一一映射到數(shù)據(jù)存儲(chǔ)。
五、MongoDB 數(shù)據(jù)訪問層 CityRepository
修改 CityRepository 類，代碼如下：
import org.spring.springboot.domain.City;
import org.springframework.data.mongodb.repository.ReactiveMongoRepository;
import org.springframework.stereotype.Repository;
@Repository
public interface CityRepository extends ReactiveMongoRepository {
}
CityRepository 接口只要繼承 ReactiveMongoRepository 類即可。默認(rèn)會(huì)提供很多實(shí)現(xiàn)，比如 CRUD 和列表查詢參數(shù)相關(guān)的實(shí)現(xiàn)。ReactiveMongoRepository 接口默認(rèn)實(shí)現(xiàn)了如下：
Mono insert(S var1);
Flux insert(Iterable var1);
Flux insert(Publisher var1);
Flux findAll(Example var1);
Flux findAll(Example var1, Sort var2);
如圖，ReactiveMongoRepository 的集成類 ReactiveSortingRepository、ReactiveCrudRepository 實(shí)現(xiàn)了很多常用的接口：
[圖片上傳失敗...(image-d465a3-1558613654501)]
ReactiveCrudRepository 接口如圖所示：
[圖片上傳失敗...(image-5aa4b4-1558613654501)]
另外可以看出，接口的命名是遵循規(guī)范的。常用命名規(guī)則如下：
關(guān)鍵字 ：： 方法命名
And ：： findByNameAndPwd
Or ：： findByNameOrSex
Is ：： findById
Between ：： findByIdBetween
Like ：： findByNameLike
NotLike ：： findByNameNotLike
OrderBy ：： findByIdOrderByXDesc
Not ：： findByNameNot
常用案例，代碼如下：
Flux findByLastname(String lastname);
@Query("{ "firstname": ?0, "lastname": ?1}")
Mono findByFirstnameAndLastname(String firstname, String lastname);
// Accept parameter inside a reactive type for deferred execution
Flux findByLastname(Mono lastname);
Mono findByFirstnameAndLastname(Mono firstname, String lastname);
@Tailable // Use a tailable cursor
Flux findWithTailableCursorBy();
5.1 源碼層面
ReactiveCrudRepository 抽象在 reactive 包，如圖：
[圖片上傳失敗...(image-9c90fc-1558613654501)]
這里我們可以看出，支持了 reactive 還支持了 RxJava。對(duì)應(yīng)老的 CrudRepository 新增了 ReactiveCrudRepository 接口及各種存儲(chǔ)實(shí)現(xiàn)。
六、處理器類 Handler 和控制器類 Controller
修改下 Handler ，代碼如下：
@Component
public class CityHandler {
private final CityRepository cityRepository;
@Autowired
public CityHandler(CityRepository cityRepository) {
this.cityRepository = cityRepository;
}
public Mono save(City city) {
return cityRepository.save(city);
}
public Mono findCityById(Long id) {
return cityRepository.findById(id);
}
public Flux findAllCity() {
return cityRepository.findAll();
}
public Mono modifyCity(City city) {
return cityRepository.save(city);
}
public Mono deleteCity(Long id) {
cityRepository.deleteById(id);
return Mono.create(cityMonoSink -> cityMonoSink.success(id));
}
}
不要對(duì) Mono 、Flux 陌生，把他當(dāng)成對(duì)象即可。繼續(xù)修改下控制器類 Controller ，代碼如下：
@RestController
@RequestMapping(value = "/city")
public class CityWebFluxController {
@Autowired
private CityHandler cityHandler;
@GetMapping(value = "/{id}")
public Mono findCityById(@PathVariable("id") Long id) {
return cityHandler.findCityById(id);
}
@GetMapping()
public Flux findAllCity() {
return cityHandler.findAllCity();
}
@PostMapping()
public Mono saveCity(@RequestBody City city) {
return cityHandler.save(city);
}
@PutMapping()
public Mono modifyCity(@RequestBody City city) {
return cityHandler.modifyCity(city);
}
@DeleteMapping(value = "/{id}")
public Mono deleteCity(@PathVariable("id") Long id) {
return cityHandler.deleteCity(id);
}
}
七、運(yùn)行工程
一個(gè) CRUD 的 Spring Boot Webflux 工程就開發(fā)完畢了，下面運(yùn)行工程驗(yàn)證下。使用 IDEA 右側(cè)工具欄，點(diǎn)擊 Maven Project Tab ，點(diǎn)擊使用下 Maven 插件的 install 命令?；蛘呤褂妹钚械男问?，在工程根目錄下，執(zhí)行 Maven 清理和安裝工程的指令：
cd springboot-webflux-3-mongodb
mvn clean install
在控制臺(tái)中看到成功的輸出：
... 省略
[INFO] ------------------------------------------------------------------------
[INFO] BUILD SUCCESS
[INFO] ------------------------------------------------------------------------
[INFO] Total time: 01:30 min
[INFO] Finished at: 2017-10-15T10:00:54+08:00
[INFO] Final Memory: 31M/174M
[INFO] ------------------------------------------------------------------------
在 IDEA 中執(zhí)行 Application 類啟動(dòng)，任意正常模式或者 Debug 模式?？梢栽诳刂婆_(tái)看到成功運(yùn)行的輸出：
... 省略
2018-04-10 08:43:39.932 INFO 2052 --- [ctor-http-nio-1] r.ipc.netty.tcp.BlockingNettyContext : Started HttpServer on /0:0:0:0:0:0:0:0:8080
2018-04-10 08:43:39.935 INFO 2052 --- [ main] o.s.b.web.embedded.netty.NettyWebServer : Netty started on port(s): 8080
2018-04-10 08:43:39.960 INFO 2052 --- [ main] org.spring.springboot.Application : Started Application in 6.547 seconds (JVM running for 9.851)
打開 POST MAN 工具，開發(fā)必備。進(jìn)行下面操作：
新增城市信息 POST http://127.0.0.1:8080/city
7.1 連接 MongoDB , 驗(yàn)證數(shù)據(jù)
連接 MongoDB
docker run -it --rm --link mongo:mongo mongo mongo -u admin -p admin --authenticationDatabase admin mongo/admin
顯示庫(kù)列表：
show dbs
使用某數(shù)據(jù)庫(kù)
use admin
顯示表列表
show collections
如果存在 city 表，格式化顯示 city 表內(nèi)容：
db.city.find().pretty()
八、總結(jié)
這里，探討了 Spring WebFlux 的如何整合 MongoDB 。整合其他存儲(chǔ) Cassandra、Redis、Couchbase，就大同小異了。下面，我們能會(huì)整合 Thymeleaf，更好的頁(yè)面展示給大家。順便讓大家學(xué)習(xí)下 Thymeleaf 的基本用法。
系列教程目錄
《01：WebFlux 系列教程大綱》
《02：WebFlux 快速入門實(shí)踐》
《03：WebFlux Web CRUD 實(shí)踐》
《04：WebFlux 整合 Mongodb》
《05：WebFlux 整合 Thymeleaf》
《06：WebFlux 中 Thymeleaf 和 Mongodb 實(shí)踐》
《07：WebFlux 整合 Redis》
《08：WebFlux 中 Redis 實(shí)現(xiàn)緩存》
《09：WebFlux 中 WebSocket 實(shí)現(xiàn)通信》
《10：WebFlux 集成測(cè)試及部署》
《11：WebFlux 實(shí)戰(zhàn)圖書管理系統(tǒng)》
代碼示例
本文示例讀者可以通過(guò)查看下面?zhèn)}庫(kù)的中的模塊工程名: 2-x-spring-boot-webflux-handling-errors：
Github：https://github.com/JeffLi1993/springboot-learning-example
Gitee：https://gitee.com/jeff1993/springboot-learning-example
如果您對(duì)這些感興趣，歡迎 star、follow、收藏、轉(zhuǎn)發(fā)給予支持！
參考資料
Spring Boot 2.x WebFlux 系列：https://www.bysocket.com/arch...
spring.io 官方文檔
以下專題教程也許您會(huì)有興趣
《程序兵法：算法與數(shù)據(jù)結(jié)構(gòu)》 https://www.bysocket.com/arch...
《Spring Boot 2.x 系列教程》
https://www.bysocket.com/spri...
《Java 核心系列教程》
https://www.bysocket.com/arch...
