WebFlux 集成 Thymeleaf 、 Mongodb 實踐 - Spring Boot（六）

時間 2019-11-15

標籤 webflux 集成 thymeleaf mongodb 實踐 spring boot 欄目 MongoDB 简体版

原文原文鏈接

這是泥瓦匠的第105篇原創html

文章工程：mysql

JDK 1.8
Maven 3.5.2
Spring Boot 2.1.3.RELEASE
工程名：springboot-webflux-5-thymeleaf-mongodb
工程地址：見文末

前言

本小章節，主要仍是總結下上面兩講的操做，並實現下複雜查詢的小案例。那麼沒裝 MongoDB 的能夠進行下面的安裝流程。react

Docker 安裝 MognoDB 並啓動以下：git

一、建立掛載目錄github

docker volume create mongo_data_db
docker volume create mongo_data_configdb複製代碼

二、啓動 MognoDBweb

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

三、初始化管理員帳號spring

docker exec -it mongo     mongo              admin
                        // 容器名   // mongo命令 數據庫名

# 建立最高權限用戶
db.createUser({ user: 'admin', pwd: 'admin', roles: [ { role: "root", db: "admin" } ] });複製代碼

四、測試連通性sql

docker run -it --rm --link mongo:mongo mongo mongo -u admin -p admin --authenticationDatabase admin mongo/admin複製代碼

MognoDB 基本操做：mongodb

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

show dbs複製代碼

使用某數據庫

use admin複製代碼

顯示錶列表

show collections複製代碼

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

db.city.find().pretty()複製代碼

若是已經安裝後，只要重啓便可。

查看已有的鏡像

docker images複製代碼

而後 docker start mogno 便可， mongo 是鏡像惟一名詞。

結構

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

目錄核心以下

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=admin複製代碼

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> {

    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 或者 String 都行。

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