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

這是泥瓦匠的第105篇原創(chuàng)

文章工程：

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

前言

本小章節(jié)，主要還是總結下上面兩講的操作，并實現下復雜查詢的小案例。那么沒裝 MongoDB 的可以進行下面的安裝流程。

Docker 安裝 MognoDB 并啟動如下：

1、創(chuàng)建掛載目錄

docker volume create mongo_data_db
docker volume create mongo_data_configdb

2、啟動 MognoDB

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

3、初始化管理員賬號

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

# 創(chuàng)建最高權限用戶
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()

如果已經安裝后，只要重啟即可。

查看已有的鏡像

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

復雜查詢語句實現也很簡單，只要依照接口實現規(guī)范，即可實現對應 mysql 的 where 查詢語句。這里findByxxx ，xxx 可以映射任何字段，包括主鍵等。

接口的命名是遵循規(guī)范的。常用命名規(guī)則如下：

  • 關鍵字 ：： 方法命名
  • 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 層渲染。繼續(xù)修改下控制器類 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> 或者 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 工程就開發(fā)完畢了，下面運行工程驗證下。使用 IDEA 右側工具欄，點擊 Maven Project Tab ，點擊使用下 Maven 插件的 install 命令。或者使用命令行的形式，在工程根目錄下，執(zhí)行 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 中執(zhí)行 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 工具，開發(fā)必備。進行下面操作：

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

打開瀏覽器，訪問 http://localhost:8080/city/getByName?cityName=杭州，可以看到如圖的響應：

繼續(xù)訪問 http://localhost:8080/city/page/list , 發(fā)現沒有值，那么按照上一講插入幾條數據即可有值，如圖：

總結

這里，初步實現了一個簡單的整合，具體復雜的案例我們在綜合案例中實現，會很酷炫很適合。下面整合 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 實戰(zhàn)圖書管理系統(tǒng)》

代碼示例

本文示例讀者可以通過查看下面?zhèn)}庫的中的模塊工程名: 2-x-spring-boot-webflux-handling-errors：

如果您對這些感興趣，歡迎 star、follow、收藏、轉發(fā)給予支持！

參考資料

?著作權歸作者所有,轉載或內容合作請聯(lián)系作者
【社區(qū)內容提示】社區(qū)部分內容疑似由AI輔助生成，瀏覽時請結合常識與多方信息審慎甄別。
平臺聲明：文章內容（如有圖片或視頻亦包括在內）由作者上傳并發(fā)布，文章內容僅代表作者本人觀點，簡書系信息發(fā)布平臺，僅提供信息存儲服務。

相關閱讀更多精彩內容

友情鏈接更多精彩內容