From 86aedc590e5298919782f39cac62a2416ea81f4c Mon Sep 17 00:00:00 2001
From: liqiangqiang <liqiangqiang@youzan.com>
Date: Tue, 17 Apr 2018 21:16:34 +0800
Subject: [PATCH] =?UTF-8?q?WebFlux=20=E6=95=B4=E5=90=88=20Thymeleaf?=
MIME-Version: 1.0
Content-Type: text/plain; charset=UTF-8
Content-Transfer-Encoding: 8bit

---
 springboot-webflux-4-thymeleaf/pom.xml        | 48 +++++++++++++++
 .../org/spring/springboot/Application.java    | 19 ++++++
 .../spring/springboot/dao/CityRepository.java | 43 +++++++++++++
 .../org/spring/springboot/domain/City.java    | 60 +++++++++++++++++++
 .../springboot/handler/CityHandler.java       | 39 ++++++++++++
 .../controller/CityWebFluxController.java     | 58 ++++++++++++++++++
 .../src/main/resources/application.properties |  0
 .../main/resources/templates/cityList.html    | 38 ++++++++++++
 8 files changed, 305 insertions(+)
 create mode 100755 springboot-webflux-4-thymeleaf/pom.xml
 create mode 100644 springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/Application.java
 create mode 100644 springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/dao/CityRepository.java
 create mode 100644 springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/domain/City.java
 create mode 100644 springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/handler/CityHandler.java
 create mode 100644 springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/webflux/controller/CityWebFluxController.java
 create mode 100644 springboot-webflux-4-thymeleaf/src/main/resources/application.properties
 create mode 100644 springboot-webflux-4-thymeleaf/src/main/resources/templates/cityList.html

diff --git a/springboot-webflux-4-thymeleaf/pom.xml b/springboot-webflux-4-thymeleaf/pom.xml
new file mode 100755
index 0000000..2c437ce
--- /dev/null
+++ b/springboot-webflux-4-thymeleaf/pom.xml
@@ -0,0 +1,48 @@
+<?xml version="1.0" encoding="UTF-8"?>
+<project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
+         xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
+  <modelVersion>4.0.0</modelVersion>
+
+  <groupId>springboot</groupId>
+  <artifactId>springboot-webflux-4-thymeleaf</artifactId>
+  <version>0.0.1-SNAPSHOT</version>
+  <name>springboot-webflux-4-thymeleaf :: Spring Boot WebFlux 整合 Thymeleaf</name>
+
+  <!-- Spring Boot 启动父依赖 -->
+  <parent>
+    <groupId>org.springframework.boot</groupId>
+    <artifactId>spring-boot-starter-parent</artifactId>
+    <version>2.0.1.RELEASE</version>
+  </parent>
+
+  <dependencies>
+
+    <!-- Spring Boot Web Flux 依赖 -->
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-webflux</artifactId>
+    </dependency>
+
+    <!-- 模板引擎 Thymeleaf 依赖 -->
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-thymeleaf</artifactId>
+    </dependency>
+
+
+    <!-- Spring Boot Test 依赖 -->
+    <dependency>
+      <groupId>org.springframework.boot</groupId>
+      <artifactId>spring-boot-starter-test</artifactId>
+      <scope>test</scope>
+    </dependency>
+
+    <!-- Junit -->
+    <dependency>
+      <groupId>junit</groupId>
+      <artifactId>junit</artifactId>
+      <version>4.12</version>
+    </dependency>
+  </dependencies>
+
+</project>
diff --git a/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/Application.java b/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/Application.java
new file mode 100644
index 0000000..467400e
--- /dev/null
+++ b/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/Application.java
@@ -0,0 +1,19 @@
+package org.spring.springboot;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * Spring Boot 应用启动类
+ *
+ */
+// Spring Boot 应用的标识
+@SpringBootApplication
+public class Application {
+
+    public static void main(String[] args) {
+        // 程序启动入口
+        // 启动嵌入式的 Tomcat 并初始化 Spring 环境及其各 Spring 组件
+        SpringApplication.run(Application.class,args);
+    }
+}
diff --git a/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/dao/CityRepository.java b/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/dao/CityRepository.java
new file mode 100644
index 0000000..9ea9e9e
--- /dev/null
+++ b/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/dao/CityRepository.java
@@ -0,0 +1,43 @@
+package org.spring.springboot.dao;
+
+import org.spring.springboot.domain.City;
+import org.springframework.stereotype.Repository;
+
+import java.util.Collection;
+import java.util.concurrent.ConcurrentHashMap;
+import java.util.concurrent.ConcurrentMap;
+import java.util.concurrent.atomic.AtomicLong;
+
+@Repository
+public class CityRepository {
+
+    private ConcurrentMap<Long, City> repository = new ConcurrentHashMap<>();
+
+    private static final AtomicLong idGenerator = new AtomicLong(0);
+
+    public Long save(City city) {
+        Long id = idGenerator.incrementAndGet();
+        city.setId(id);
+        repository.put(id, city);
+        return id;
+    }
+
+    public Collection<City> findAll() {
+        return repository.values();
+    }
+
+
+    public City findCityById(Long id) {
+        return repository.get(id);
+    }
+
+    public Long updateCity(City city) {
+        repository.put(city.getId(), city);
+        return city.getId();
+    }
+
+    public Long deleteCity(Long id) {
+        repository.remove(id);
+        return id;
+    }
+}
diff --git a/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/domain/City.java b/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/domain/City.java
new file mode 100644
index 0000000..fa3b410
--- /dev/null
+++ b/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/domain/City.java
@@ -0,0 +1,60 @@
+package org.spring.springboot.domain;
+
+/**
+ * 城市实体类
+ *
+ */
+public class City {
+
+    /**
+     * 城市编号
+     */
+    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;
+    }
+}
diff --git a/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/handler/CityHandler.java b/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/handler/CityHandler.java
new file mode 100644
index 0000000..08e91f2
--- /dev/null
+++ b/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/handler/CityHandler.java
@@ -0,0 +1,39 @@
+package org.spring.springboot.handler;
+
+import org.spring.springboot.dao.CityRepository;
+import org.spring.springboot.domain.City;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Component;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Component
+public class CityHandler {
+
+    private final CityRepository cityRepository;
+
+    @Autowired
+    public CityHandler(CityRepository cityRepository) {
+        this.cityRepository = cityRepository;
+    }
+
+    public Mono<Long> save(City city) {
+        return Mono.create(cityMonoSink -> cityMonoSink.success(cityRepository.save(city)));
+    }
+
+    public Mono<City> findCityById(Long id) {
+        return Mono.justOrEmpty(cityRepository.findCityById(id));
+    }
+
+    public Flux<City> findAllCity() {
+        return Flux.fromIterable(cityRepository.findAll());
+    }
+
+    public Mono<Long> modifyCity(City city) {
+        return Mono.create(cityMonoSink -> cityMonoSink.success(cityRepository.updateCity(city)));
+    }
+
+    public Mono<Long> deleteCity(Long id) {
+        return Mono.create(cityMonoSink -> cityMonoSink.success(cityRepository.deleteCity(id)));
+    }
+}
diff --git a/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/webflux/controller/CityWebFluxController.java b/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/webflux/controller/CityWebFluxController.java
new file mode 100644
index 0000000..a0bb558
--- /dev/null
+++ b/springboot-webflux-4-thymeleaf/src/main/java/org/spring/springboot/webflux/controller/CityWebFluxController.java
@@ -0,0 +1,58 @@
+package org.spring.springboot.webflux.controller;
+
+import org.spring.springboot.domain.City;
+import org.spring.springboot.handler.CityHandler;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.stereotype.Controller;
+import org.springframework.ui.Model;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+@Controller
+@RequestMapping(value = "/city")
+public class CityWebFluxController {
+
+    @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<Long> saveCity(@RequestBody City city) {
+        return cityHandler.save(city);
+    }
+
+    @PutMapping()
+    @ResponseBody
+    public Mono<Long> 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";
+
+    @GetMapping("/page/list")
+    public String listPage(final Model model) {
+        final Flux<City> cityFluxList = cityHandler.findAllCity();
+        model.addAttribute("cityList", cityFluxList);
+        return CITY_LIST_PATH_NAME;
+    }
+
+}
diff --git a/springboot-webflux-4-thymeleaf/src/main/resources/application.properties b/springboot-webflux-4-thymeleaf/src/main/resources/application.properties
new file mode 100644
index 0000000..e69de29
diff --git a/springboot-webflux-4-thymeleaf/src/main/resources/templates/cityList.html b/springboot-webflux-4-thymeleaf/src/main/resources/templates/cityList.html
new file mode 100644
index 0000000..3245b7e
--- /dev/null
+++ b/springboot-webflux-4-thymeleaf/src/main/resources/templates/cityList.html
@@ -0,0 +1,38 @@
+<!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>