Spring Boot 2 快速教程：WebFlux 集成 Mongodb（四）

時間 2019-12-05

標籤 spring boot 快速教程 webflux 集成 mongodb 欄目 Spring 简体版

原文原文鏈接

摘要: 原創出處 https://www.bysocket.com 「公衆號：泥瓦匠BYSocket 」歡迎關注和轉載，保留摘要，謝謝！

這是泥瓦匠的第104篇原創css

文章工程：
* JDK 1.8
* Maven 3.5.2
* Spring Boot 2.1.3.RELEASE
* 工程名：springboot-webflux-4-thymeleaf
* 工程地址：見文末java

1、前言

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

什麼是 MongoDB ?nginx

官網：https://www.mongodb.com/git

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

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

因爲操做方便，本文用 Docker 啓動一個 MognoDB 服務。若是 Docker 不會安裝的，請參考此文：Docker 安裝與基本操做 https://www.jianshu.com/p/f272726db9c5算法

Docker 安裝 MognoDB 並啓動以下：spring

一、建立掛載目錄sql

docker volume create mongo_data_db docker volume create mongo_data_configdb

二、啓動 MognoDB

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

三、初始化管理員帳號

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

四、測試連通性

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()

2、結構

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

目錄核心以下

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

3、新增 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 了。

4、對象

修改 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 ，數據訪問對象一一映射到數據存儲。

5、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();

5.1 源碼層面

ReactiveCrudRepository 抽象在 reactive 包，如圖：

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

6、處理器類 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); } }

7、運行工程

一個 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

7.1 鏈接 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()

8、總結

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

系列教程目錄

《01：WebFlux 系列教程大綱》
《02：WebFlux 快速入門實踐》
《03：WebFlux Web CRUD 實踐》
《04：WebFlux 整合 Mongodb》
《05：WebFlux 整合 Thymeleaf》
《06：WebFlux 中 Thymeleaf 和 Mongodb 實踐》
《07：WebFlux 整合 Redis》
《08：WebFlux 中 Redis 實現緩存》
《09：WebFlux 中 WebSocket 實現通訊》
《10：WebFlux 集成測試及部署》
《11：WebFlux 實戰圖書管理系統》

代碼示例

本文示例讀者能夠經過查看下面倉庫的中的模塊工程名: 2-x-spring-boot-webflux-handling-errors：

若是您對這些感興趣，歡迎 star、follow、收藏、轉發給予支持！

參考資料

Spring Boot 2.x WebFlux 系列：https://www.bysocket.com/archives/2290
spring.io 官方文檔

如下專題教程也許您會有興趣

《程序兵法：算法與數據結構》 https://www.bysocket.com/archives/2314/algorithm
《Spring Boot 2.x 系列教程》
https://www.bysocket.com/springboot
《Java 核心系列教程》
https://www.bysocket.com/archives/2100

（關注微信公衆號，領取 Java 精選乾貨學習資料）（添加我微信：bysocket01。加入純技術交流羣，成長技術）

相關標籤/搜索

每日一句

每一个你不满意的现在，都有一个你没有努力的曾经。