摘要：二結(jié)構(gòu)這個工程會對城市進行管理實現(xiàn)操作。負責將持久層數(shù)據(jù)操作相關(guān)的封裝組織，完成新增查詢刪除等操作。原因是，直接使用和是非阻塞寫法，相當于回調(diào)方式。反應(yīng)了是的好處集合了非阻塞異步。其實是的一個補充。可以發(fā)布類型的元素。

摘要: 原創(chuàng)出處 https://www.bysocket.com 「公眾號：泥瓦匠BYSocket 」歡迎關(guān)注和轉(zhuǎn)載，保留摘要，謝謝！

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

文章工程：

JDK 1.8

Maven 3.5.2

Spring Boot 2.1.3.RELEASE

工程名：springboot-webflux-2-restful

工程地址：見文末

上一篇基于功能性端點去創(chuàng)建一個簡單服務(wù)，實現(xiàn)了 Hello 。這一篇用 Spring Boot WebFlux 的注解控制層技術(shù)創(chuàng)建一個 CRUD WebFlux 應(yīng)用，讓開發(fā)更方便。這里我們不對數(shù)據(jù)庫儲存進行訪問，因為后續(xù)會講到，而且這里主要是講一個完整的 WebFlux CRUD。

這個工程會對城市（City）進行管理實現(xiàn) CRUD 操作。該工程創(chuàng)建編寫后，得到下面的結(jié)構(gòu)，其目錄結(jié)構(gòu)如下：

├── pom.xml
├── src
│?? └── main
│??     ├── java
│??     │?? └── org
│??     │??     └── spring
│??     │??         └── springboot
│??     │??             ├── Application.java
│??     │??             ├── dao
│??     │??             │?? └── CityRepository.java
│??     │??             ├── domain
│??     │??             │?? └── City.java
│??     │??             ├── handler
│??     │??             │?? └── CityHandler.java
│??     │??             └── webflux
│??     │??                 └── controller
│??     │??                     └── CityWebFluxController.java
│??     └── resources
│??         └── application.properties
└── target

如目錄結(jié)構(gòu)，我們需要編寫的內(nèi)容按順序有：

對象

數(shù)據(jù)訪問層類 Repository

處理器類 Handler

控制器類 Controller

新建包 org.spring.springboot.domain ，作為編寫城市實體對象類。新建城市（City）對象 City，代碼如下：

/**
 * 城市實體類
 *
 */
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;
    }
}

城市包含了城市編號、省份編號、城市名稱和描述。具體開發(fā)中，會使用 Lombok 工具來消除冗長的 Java 代碼，尤其是 POJO 的 getter / setter 方法。具體查看 Lombok 官網(wǎng)地址：projectlombok.org。

新建包 org.spring.springboot.dao ，作為編寫城市數(shù)據(jù)訪問層類 Repository。新建 CityRepository，代碼如下：

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

@Repository 用于標注數(shù)據(jù)訪問組件，即 DAO 組件。實現(xiàn)代碼中使用名為 repository 的 Map 對象作為內(nèi)存數(shù)據(jù)存儲，并對對象具體實現(xiàn)了具體業(yè)務(wù)邏輯。CityRepository 負責將 Book 持久層（數(shù)據(jù)操作）相關(guān)的封裝組織，完成新增、查詢、刪除等操作。

這里不會涉及到數(shù)據(jù)存儲這塊，具體數(shù)據(jù)存儲會在后續(xù)介紹。

新建包 org.spring.springboot.handler ，作為編寫城市處理器類 CityHandler。新建 CityHandler，代碼如下：

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 save(City city) {
        return Mono.create(cityMonoSink -> cityMonoSink.success(cityRepository.save(city)));
    }

    public Mono findCityById(Long id) {
        return Mono.justOrEmpty(cityRepository.findCityById(id));
    }

    public Flux findAllCity() {
        return Flux.fromIterable(cityRepository.findAll());
    }

    public Mono modifyCity(City city) {
        return Mono.create(cityMonoSink -> cityMonoSink.success(cityRepository.updateCity(city)));
    }

    public Mono deleteCity(Long id) {
        return Mono.create(cityMonoSink -> cityMonoSink.success(cityRepository.deleteCity(id)));
    }
}

@Component 泛指組件，當組件不好歸類的時候，使用該注解進行標注。然后用 final 和 @Autowired 標注在構(gòu)造器注入 CityRepository Bean，代碼如下：

    private final CityRepository cityRepository;

    @Autowired
    public CityHandler(CityRepository cityRepository) {
        this.cityRepository = cityRepository;
    }

從返回值可以看出，Mono 和 Flux 適用于兩個場景，即：

Mono：實現(xiàn)發(fā)布者，并返回 0 或 1 個元素，即單對象

Flux：實現(xiàn)發(fā)布者，并返回 N 個元素，即 List 列表對象

有人會問，這為啥不直接返回對象，比如返回 City/Long/List。原因是，直接使用 Flux 和 Mono 是非阻塞寫法，相當于回調(diào)方式。利用函數(shù)式可以減少了回調(diào)，因此會看不到相關(guān)接口。反應(yīng)了是 WebFlux 的好處：集合了非阻塞 + 異步。

Mono 是什么？ 官方描述如下：A Reactive Streams Publisher with basic rx operators that completes successfully by emitting an element, or with an error.

Mono 是響應(yīng)流 Publisher ，即要么成功發(fā)布元素，要么錯誤。如圖所示：

Mono 常用的方法有：

Mono.create()：使用 MonoSink 來創(chuàng)建 Mono

Mono.justOrEmpty()：從一個 Optional 對象或 null 對象中創(chuàng)建 Mono。

Mono.error()：創(chuàng)建一個只包含錯誤消息的 Mono

Mono.never()：創(chuàng)建一個不包含任何消息通知的 Mono

Mono.delay()：在指定的延遲時間之后，創(chuàng)建一個 Mono，產(chǎn)生數(shù)字 0 作為唯一值

Flux 是什么？ 官方描述如下：A Reactive Streams Publisher with rx operators that emits 0 to N elements, and then completes (successfully or with an error).

Flux 是響應(yīng)流 Publisher ，即要么成功發(fā)布 0 到 N 個元素，要么錯誤。Flux 其實是 Mono 的一個補充。如圖所示：

所以要注意：如果知道 Publisher 是 0 或 1 個，則用 Mono。

Flux 最值得一提的是 fromIterable 方法。fromIterable(Iterable it) 可以發(fā)布 Iterable 類型的元素。當然，F(xiàn)lux 也包含了基礎(chǔ)的操作：map、merge、concat、flatMap、take，這里就不展開介紹了。

Spring Boot WebFlux 也可以使用自動配置加注解驅(qū)動的模式來進行開發(fā)。

新建包目錄 org.spring.springboot.webflux.controller ，并在目錄中創(chuàng)建名為 CityWebFluxController 來處理不同的 HTTP Restful 業(yè)務(wù)請求。代碼如下：

import org.spring.springboot.domain.City;
import org.spring.springboot.handler.CityHandler;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.*;
import reactor.core.publisher.Flux;
import reactor.core.publisher.Mono;

@RestController
@RequestMapping(value = "/city")
public class CityWebFluxController {

    @Autowired
    private CityHandler cityHandler;

    @GetMapping(value = "/{id}")
    public Mono findCityById(@PathVariable("id") Long id) {
        return cityHandler.findCityById(id);
    }

    @GetMapping()
    public Flux findAllCity() {
        return cityHandler.findAllCity();
    }

    @PostMapping()
    public Mono saveCity(@RequestBody City city) {
        return cityHandler.save(city);
    }

    @PutMapping()
    public Mono modifyCity(@RequestBody City city) {
        return cityHandler.modifyCity(city);
    }

    @DeleteMapping(value = "/{id}")
    public Mono deleteCity(@PathVariable("id") Long id) {
        return cityHandler.deleteCity(id);
    }
}

這里按照 REST 風格實現(xiàn)接口。那具體什么是 REST?

REST 是屬于 WEB 自身的一種架構(gòu)風格，是在 HTTP 1.1 規(guī)范下實現(xiàn)的。Representational State Transfer 全稱翻譯為表現(xiàn)層狀態(tài)轉(zhuǎn)化。Resource：資源。比如 newsfeed；Representational：表現(xiàn)形式，比如用JSON，富文本等；State Transfer：狀態(tài)變化。通過HTTP 動作實現(xiàn)。

理解 REST ,要明白五個關(guān)鍵要素：

資源（Resource）

資源的表述（Representation）

狀態(tài)轉(zhuǎn)移（State Transfer）

統(tǒng)一接口（Uniform Interface）

超文本驅(qū)動（Hypertext Driven）

6 個主要特性：

面向資源（Resource Oriented）

可尋址（Addressability）

連通性（Connectedness）

無狀態(tài)（Statelessness）

統(tǒng)一接口（Uniform Interface）

超文本驅(qū)動（Hypertext Driven）

具體這里就不一一展開，詳見 http://www.infoq.com/cn/artic...。

請求入?yún)ⅰilters、重定向、Conversion、formatting 等知識會和以前 MVC 的知識一樣，詳情見文檔：
https://docs.spring.io/spring...

一個 CRUD 的 Spring Boot Webflux 工程就開發(fā)完畢了，下面運行工程驗證下。使用 IDEA 右側(cè)工具欄，點擊 Maven Project Tab ，點擊使用下 Maven 插件的 install 命令。或者使用命令行的形式，在工程根目錄下，執(zhí)行 Maven 清理和安裝工程的指令：

cd springboot-webflux-2-restful
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

獲取城市信息列表 GET http://127.0.0.1:8080/city

其他接口就不演示了。

這里，探討了 Spring WebFlux 的一些功能，構(gòu)建沒有底層數(shù)據(jù)庫的基本 CRUD 工程。為了更好的展示了如何創(chuàng)建 Flux 流，以及如何對其進行操作。下面會講到如何操作數(shù)據(jù)存儲。

《01：WebFlux 系列教程大綱》

《02：WebFlux 快速入門實踐》

《03：WebFlux Web CRUD 實踐》

《04：WebFlux 整合 Mongodb》

《05：WebFlux 整合 Thymeleaf》

《06：WebFlux 中 Thymeleaf 和 Mongodb 實踐》

《07：WebFlux 整合 Redis》

《08：WebFlux 中 Redis 實現(xiàn)緩存》

《09：WebFlux 中 WebSocket 實現(xiàn)通信》

《10：WebFlux 集成測試及部署》

《11：WebFlux 實戰(zhàn)圖書管理系統(tǒng)》

本文示例讀者可以通過查看下面?zhèn)}庫的中的模塊工程名: 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、收藏、轉(zhuǎn)發(fā)給予支持！

Spring Boot 2.x WebFlux 系列：https://www.bysocket.com/arch...

spring.io 官方文檔

《Spring Boot 2.x 系列教程》 https://www.bysocket.com/spri...

《Java 核心系列教程》 https://www.bysocket.com/arch...