WebFlux 整合 Thymeleaf 、 Mongodb 實踐 - Spring Boot（六）
這是泥瓦匠的第105篇原創
文章工程：
- JDK 1.8
- Maven 3.5.2
- Spring Boot 2.1.3.RELEASE
- 工程名：springboot-webflux-5-thymeleaf-mongodb
- 工程地址：見文末
前言
本小章節，主要還是總結下上面兩講的操作，並實現下複雜查詢的小案例。那麼沒裝 MongoDB 的可以進行下面的安裝流程。
Docker 安裝 MognoDB 並啟動如下：
1、建立掛載目錄
docker volume create mongo_data_db
docker volume create mongo_data_configdb2、啟動 MognoDB
docker run -d \
--name mongo \
-v mongo_data_configdb:/data/configdb \
-v mongo_data_db:/data/db \
-p 27017:27017 \
mongo \
--auth3、初始化管理員賬號
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/adminMognoDB 基本操作：
類似 MySQL 命令，顯示庫列表：
show dbs使用某資料庫
use admin顯示錶列表
show collections如果存在 city 表，格式化顯示 city 表內容
db.city.find().pretty()如果已經安裝後，只要重啟即可。
檢視已有的映象
docker images
然後 docker start mogno
結構
類似上面講的工程搭建，新建一個工程編寫此案例。工程如圖：
目錄核心如下
- pom.xml Maven依賴配置
- application.properties 配置檔案，配置 mongo 連線屬性配置
- dao 資料訪問層
- controller 展示層實現
新增 POM 依賴與配置
在 pom.xml 配置新的依賴：
<!-- Spring Boot 響應式 MongoDB 依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-data-mongodb-reactive</artifactId>
</dependency>
<!-- 模板引擎 Thymeleaf 依賴 -->
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-thymeleaf</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=adminMongoDB 資料訪問層 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> {
Mono<City> findByCityName(String cityName);
}
CityRepository 介面只要繼承 ReactiveMongoRepository 類即可。
這裡實現了通過城市名找出唯一的城市物件方法：
Mono<City> findByCityName(String cityName);複雜查詢語句實現也很簡單，只要依照介面實現規範，即可實現對應 mysql 的 where 查詢語句。這裡findByxxx ，xxx 可以對映任何欄位，包括主鍵等。
介面的命名是遵循規範的。常用命名規則如下：
- 關鍵字 ：： 方法命名
- And ：： findByNameAndPwd
- Or ：： findByNameOrSex
- Is ：： findById
- Between ：： findByIdBetween
- Like ：： findByNameLike
- NotLike ：： findByNameNotLike
- OrderBy ：： findByIdOrderByXDesc
- Not ：： findByNameNot
處理器類 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));
}
public Mono<City> getByCityName(String cityName) {
return cityRepository.findByCityName(cityName);
}
}新增對應的方法，直接返回 Mono 物件，不需要對 Mono 進行轉換，因為 Mono 本身是個物件，可以被 View 層渲染。繼續修改下控制器類 Controller ，程式碼如下：
@Autowired
private CityHandler cityHandler;
@GetMapping(value = "/{id}")
@ResponseBody
public Mono<City> findCityById(@PathVariable("id") Long id) {
return cityHandler.findCityById(id);
}
@GetMapping()
@ResponseBody
public Flux<City> findAllCity() {
return cityHandler.findAllCity();
}
@PostMapping()
@ResponseBody
public Mono<City> saveCity(@RequestBody City city) {
return cityHandler.save(city);
}
@PutMapping()
@ResponseBody
public Mono<City> modifyCity(@RequestBody City city) {
return cityHandler.modifyCity(city);
}
@DeleteMapping(value = "/{id}")
@ResponseBody
public Mono<Long> deleteCity(@PathVariable("id") Long id) {
return cityHandler.deleteCity(id);
}
private static final String CITY_LIST_PATH_NAME = "cityList";
private static final String CITY_PATH_NAME = "city";
@GetMapping("/page/list")
public String listPage(final Model model) {
final Flux<City> cityFluxList = cityHandler.findAllCity();
model.addAttribute("cityList", cityFluxList);
return CITY_LIST_PATH_NAME;
}
@GetMapping("/getByName")
public String getByCityName(final Model model,
@RequestParam("cityName") String cityName) {
final Mono<City> city = cityHandler.getByCityName(cityName);
model.addAttribute("city", city);
return CITY_PATH_NAME;
}新增 getByName 路徑，指向了新的頁面 city。使用 @RequestParam 接受 GET 請求入參，接受的引數為 cityName ，城市名稱。檢視返回值 Mono
Tymeleaf 檢視
然後編寫兩個檢視 city 和 cityList，程式碼分別如下：
city.html:
<!DOCTYPE html>
<html lang="zh-CN">
<head>
<meta charset="UTF-8"/>
<title>城市</title>
</head>
<body>
<div>
<table>
<legend>
<strong>城市單個查詢</strong>
</legend>
<tbody>
<td th:text="${city.id}"></td>
<td th:text="${city.provinceId}"></td>
<td th:text="${city.cityName}"></td>
<td th:text="${city.description}"></td>
</tbody>
</table>
</div>
</body>
</html>cityList.html:
<!DOCTYPE html>
<html lang="zh-CN">
<head>
<meta charset="UTF-8"/>
<title>城市列表</title>
</head>
<body>
<div>
<table>
<legend>
<strong>城市列表</strong>
</legend>
<thead>
<tr>
<th>城市編號</th>
<th>省份編號</th>
<th>名稱</th>
<th>描述</th>
</tr>
</thead>
<tbody>
<tr th:each="city : ${cityList}">
<td th:text="${city.id}"></td>
<td th:text="${city.provinceId}"></td>
<td th:text="${city.cityName}"></td>
<td th:text="${city.description}"></td>
</tr>
</tbody>
</table>
</div>
</body>
</html>執行工程
一個 CRUD 的 Spring Boot Webflux 工程就開發完畢了，下面執行工程驗證下。使用 IDEA 右側工具欄，點選 Maven Project Tab ，點選使用下 Maven 外掛的 install 命令。或者使用命令列的形式，在工程根目錄下，執行 Maven 清理和安裝工程的指令：
cd springboot-webflux-5-thymeleaf-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
開啟瀏覽器，訪問 http://localhost:8080/city/getByName?cityName=杭州，可以看到如圖的響應：
繼續訪問 http://localhost:8080/city/page/list , 發現沒有值，那麼按照上一講插入幾條資料即可有值，如圖：
總結
這裡，初步實現了一個簡單的整合，具體複雜的案例我們在綜合案例中實現，會很酷炫很適合。下面整合 Redis ，基於 Redis 可以實現常用的 快取、鎖 ，下一講，我們學習下如何整合 Reids 吧。
原始碼地址：https://github.com/JeffLi1993/springboot-learning-example
系列教程目錄
- 《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：
- Github：https://github.com/JeffLi1993/springboot-learning-example
- Gitee：https://gitee.com/jeff1993/springboot-learning-example
如果您對這些感興趣，歡迎 star、follow、收藏、轉發給予支援！
參考資料
- Spring Boot 2.x WebFlux 系列：https://www.bysocket.com/archives/2290
- spring.io 官方文件