Spring Boot WebFlux-03——WebFlux 整合 MongoDB

前言

上一課的內容講解了用 Map 數據結構內存式存儲了數據，這樣數據就不會持久化，本文咱們用 MongoDB 來實現 WebFlux 對數據源的操做。css

什麼是 MongoDB？詳見官網。java

MongoDB 是一個基於分佈式文件存儲的數據庫，由 C++ 語言編寫，旨在爲 Web 應用提供可擴展的高性能數據存儲解決方案。react

MongoDB 是一個介於關係數據庫和非關係數據庫之間的產品，是非關係數據庫當中功能最豐富，最像關係數據庫。nginx

因爲操做方便，本文用 Docker 啓動一個 MognoDB 服務。若是 Docker 不會安裝，請參考此文：Docker 安裝與基本操做。web

Docker 安裝 MognoDB 並啓動以下。spring

（1）建立掛載目錄：sql

docker volume create mongo_data_db docker volume create mongo_data_configdb

（2）啓動 MognoDB：mongodb

docker run -d \ --name mongo \ -v mongo_data_configdb:/data/configdb \ -v mongo_data_db:/data/db \ -p 27017:27017 \ mongo \ --auth

（3）初始化管理員帳號：docker

docker exec -it mongo mongo admin // 容器名 // mongo命令 數據庫名 # 建立最高權限用戶 db.createUser({ user: 'admin', pwd: 'admin', roles: [ { role: "root", db: "admin" } ] });

（4）測試連通性：數據庫

docker run -it --rm --link mongo:mongo mongo mongo -u admin -p admin --authenticationDatabase admin mongo/admin

MognoDB 基本操做

相似 MySQL 命令，顯示庫列表：

show dbs

使用某數據庫：

use admin

顯示錶列表：

show collections

若是存在 city 表，格式化顯示 city 表內容：

db.city.find().pretty()

結構

相似上面講的工程搭建，新建一個工程編寫此案例。工程如圖：

目錄核心以下：

pom.xml maven 配置；
application.properties 配置文件；
dao 數據訪問層，本文要點。

新增 POM 依賴與配置

在 pom.xml 配置新的依賴：

<!-- Spring Boot 響應式 MongoDB 依賴 --> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-data-mongodb-reactive</artifactId> </dependency>

相似配了 MySQL 和 JDBC 驅動，確定得去配置數據庫。在 application.properties 配置下上面啓動的 MongoDB 配置：

數據庫名爲 admin，帳號密碼也爲 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

這就一個巨大的問題了，爲啥不用咱們經常使用的 MySQL 數據庫呢？

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

Spring Data Reactive Repositories 突出點是 Reactive，即非阻塞的。區別以下：

基於 JDBC 實現的 Spring Data，好比 Spring Data JPA 是阻塞的。原理是基於阻塞 IO 模型消耗每一個調用數據庫的線程（Connection）。
事務只能在一個 java.sql.Connection 使用，即一個事務一個操做。

那如何異步非阻塞封裝下 JDBC 的思想也不新鮮，Scala 庫 Slick 3 就實現了。簡單的實現原理以下：

一個事務多個操做，那麼共享一個 java.sql.Connection，可使用透明事務管理，利用回調編程模型去傳遞。
保持有限的空閒鏈接。

最後，我堅信非阻塞 JDBC 很快就會出現的，這樣咱們就開心的調用 MySQL 了。

對象

修改 org.spring.springboot.domain 包裏面的城市實體對象類。修改城市（City）對象 City，代碼以下：

import org.springframework.data.annotation.Id; /** * 城市實體類 * */ public class City { /** * 城市編號 */ @Id private Long id; /** * 省份編號 */ 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 註解標記對應庫表的主鍵或者惟一標識符。由於這個是咱們的 DO，數據訪問對象一一映射到數據存儲。

MongoDB 數據訪問層 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<City, Long> { }

CityRepository 接口只要繼承 ReactiveMongoRepository 類便可，默認會提供不少實現，好比 CRUD 和列表查詢參數相關的實現。ReactiveMongoRepository 接口默認實現了以下：

<S extends T> Mono<S> insert(S var1); <S extends T> Flux<S> insert(Iterable<S> var1); <S extends T> Flux<S> insert(Publisher<S> var1); <S extends T> Flux<S> findAll(Example<S> var1); <S extends T> Flux<S> findAll(Example<S> var1, Sort var2);

如圖，ReactiveMongoRepository 的集成類 ReactiveSortingRepository、ReactiveCrudRepository 實現了不少經常使用的接口：

ReactiveCrudRepository 接口如圖所示：

另外能夠看出，接口的命名是遵循規範的，經常使用命名規則以下：

關鍵字	方法命名
And	findByNameAndPwd
Or	findByNameOrSex
Is	findById
Between	findByIdBetween
Like	findByNameLike
NotLike	findByNameNotLike
OrderBy	findByIdOrderByXDesc
Not	findByNameNot

經常使用案例，代碼以下：

Flux<Person> findByLastname(String lastname); @Query("{ 'firstname': ?0, 'lastname': ?1}") Mono<Person> findByFirstnameAndLastname(String firstname, String lastname); // Accept parameter inside a reactive type for deferred execution Flux<Person> findByLastname(Mono<String> lastname); Mono<Person> findByFirstnameAndLastname(Mono<String> firstname, String lastname); @Tailable // Use a tailable cursor Flux<Person> findWithTailableCursorBy();

源碼層面

ReactiveCrudRepository 抽象在 reactive 包，如圖：

這裏咱們能夠看出，支持了 Reactive 還支持了 RxJava。對應老的 CrudRepository 新增了 ReactiveCrudRepository 接口及各類存儲實現。

處理器類 Handler 和控制器類 Controller

修改下 Handler，代碼以下：

@Component public class CityHandler { private final CityRepository cityRepository; @Autowired public CityHandler(CityRepository cityRepository) { this.cityRepository = cityRepository; } public Mono<City> save(City city) { return cityRepository.save(city); } public Mono<City> findCityById(Long id) { return cityRepository.findById(id); } public Flux<City> findAllCity() { return cityRepository.findAll(); } public Mono<City> modifyCity(City city) { return cityRepository.save(city); } public Mono<Long> deleteCity(Long id) { cityRepository.deleteById(id); return Mono.create(cityMonoSink -> cityMonoSink.success(id)); } }

不要對 Mono、Flux 陌生，把它當成對象便可。繼續修改控制器類 Controller，代碼以下：

@RestController @RequestMapping(value = "/city") public class CityWebFluxController { @Autowired private CityHandler cityHandler; @GetMapping(value = "/{id}") public Mono<City> findCityById(@PathVariable("id") Long id) { return cityHandler.findCityById(id); } @GetMapping() public Flux<City> findAllCity() { return cityHandler.findAllCity(); } @PostMapping() public Mono<City> saveCity(@RequestBody City city) { return cityHandler.save(city); } @PutMapping() public Mono<City> modifyCity(@RequestBody City city) { return cityHandler.modifyCity(city); } @DeleteMapping(value = "/{id}") public Mono<Long> deleteCity(@PathVariable("id") Long id) { return cityHandler.deleteCity(id); } }

運行工程

一個 CRUD 的 Spring Boot WebFlux 工程就開發完畢了，下面運行工程驗證下。使用 IDEA 右側工具欄，單擊 Maven Project Tab 選項，點擊使用 Maven 插件的 install 命令。或者使用命令行的形式，在工程根目錄下，執行 Maven 清理和安裝工程的指令：

cd springboot-webflux-3-mongodb mvn clean install

在控制檯中看到成功的輸出：

... 省略
[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 中執行 Application 類啓動，任意正常模式或者 Debug 模式，能夠在控制檯看到成功運行的輸出：

... 省略
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 工具，開發必備。進行下面操做。

新增城市信息 POST http://127.0.0.1:8080/city。

鏈接 MongoDB，驗證數據

鏈接 MongoDB：

docker run -it --rm --link mongo:mongo mongo mongo -u admin -p admin --authenticationDatabase admin mongo/admin

顯示庫列表：

show dbs

使用某數據庫：

use admin

顯示錶列表：

show collections

若是存在 city 表，格式化顯示 city 表內容：

db.city.find().pretty()

總結

這裏探討了 Spring WebFlux 的如何整合 MongoDB，整合其餘存儲 Cassandra、Redis、Couchbase 就大同小異了。下面，咱們已經能夠整合 Thymeleaf，更好的頁面展現給你們，順便讓你們學習下 Thymeleaf 的基本用法。