Spring Boot 实现 WebFlux HTTP Restful 服务

springboot-webflux/pom.xml

@@ -0,0 +1,59 @@
+<?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</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>springboot-webflux :: Spring Boot 实现 WebFlux HTTP Restful 服务</name>
+
+    <!-- Spring Boot 启动父依赖 -->
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.0.0.M3</version>
+    </parent>
+
+    <properties>
+        <mybatis-spring-boot>1.2.0</mybatis-spring-boot>
+        <mysql-connector>5.1.39</mysql-connector>
+    </properties>
+
+    <dependencies>
+
+        <!-- Spring Boot Web Flux 依赖 -->
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</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>
+
+
+
+    <repositories>
+        <repository>
+            <id>spring-milestones</id>
+            <name>Spring Milestones</name>
+            <url>https://repo.spring.io/libs-milestone</url>
+            <snapshots>
+                <enabled>false</enabled>
+            </snapshots>
+        </repository>
+    </repositories>
+
+</project>

springboot-webflux/src/main/java/org/spring/springboot/Application.java

@@ -0,0 +1,20 @@
+package org.spring.springboot;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+/**
+ * Spring Boot 应用启动类
+ *
+ * Created by bysocket on 09/29/2017.
+ */
+// Spring Boot 应用的标识
+@SpringBootApplication
+public class Application {
+
+    public static void main(String[] args) {
+        // 程序启动入口
+        // 启动嵌入式的 Tomcat 并初始化 Spring 环境及其各 Spring 组件
+        SpringApplication.run(Application.class,args);
+    }
+}

springboot-webflux/src/main/java/org/spring/springboot/controller/CityRestController.java

@@ -0,0 +1,51 @@
+package org.spring.springboot.controller;
+
+import org.spring.springboot.domain.City;
+import org.spring.springboot.service.CityService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+/**
+ * 城市 Controller 实现 Restful HTTP 服务
+ * <p>
+ * Created by bysocket on 09/29/2017.
+ */
+@RestController
+@RequestMapping(value = "/city")
+public class CityRestController {
+
+    @Autowired
+    private CityService cityService;
+
+    @RequestMapping(value = "/{id}", method = RequestMethod.GET)
+    public Mono<City> findOneCity(@PathVariable("id") Long id) {
+        return Mono.create(cityMonoSink -> cityMonoSink.success(cityService.findCityById(id)));
+    }
+
+    @RequestMapping(method = RequestMethod.GET)
+    public Flux<City> findAllCity() {
+        return Flux.create(cityFluxSink -> {
+            cityService.findAllCity().forEach(city -> {
+                cityFluxSink.next(city);
+            });
+            cityFluxSink.complete();
+        });
+    }
+
+    @RequestMapping(method = RequestMethod.POST)
+    public Mono<Long> createCity(@RequestBody City city) {
+        return Mono.create(cityMonoSink -> cityMonoSink.success(cityService.saveCity(city)));
+    }
+
+    @RequestMapping(method = RequestMethod.PUT)
+    public Mono<Long> modifyCity(@RequestBody City city) {
+        return Mono.create(cityMonoSink -> cityMonoSink.success(cityService.updateCity(city)));
+    }
+
+    @RequestMapping(value = "/{id}", method = RequestMethod.DELETE)
+    public Mono<Long> modifyCity(@PathVariable("id") Long id) {
+        return Mono.create(cityMonoSink -> cityMonoSink.success(cityService.deleteCity(id)));
+    }
+}

springboot-webflux/src/main/java/org/spring/springboot/domain/City.java

@@ -0,0 +1,61 @@
+package org.spring.springboot.domain;
+
+/**
+ * 城市实体类
+ *
+ * Created by bysocket on 09/29/2017.
+ */
+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;
+    }
+}

springboot-webflux/src/main/java/org/spring/springboot/service/CityService.java

@@ -0,0 +1,52 @@
+package org.spring.springboot.service;
+
+import org.spring.springboot.domain.City;
+
+import java.util.List;
+
+/**
+ * 城市业务逻辑接口类
+ *
+ * Created by bysocket on 09/29/2017.
+ */
+public interface CityService {
+
+    /**
+     * 获取城市信息列表
+     *
+     * @return
+     */
+    List<City> findAllCity();
+
+    /**
+     * 根据城市 ID,查询城市信息
+     *
+     * @param id
+     * @return
+     */
+    City findCityById(Long id);
+
+    /**
+     * 新增城市信息
+     *
+     * @param city
+     * @return
+     */
+    Long saveCity(City city);
+
+    /**
+     * 更新城市信息
+     *
+     * @param city
+     * @return
+     */
+    Long updateCity(City city);
+
+    /**
+     * 根据城市 ID,删除城市信息
+     *
+     * @param id
+     * @return
+     */
+    Long deleteCity(Long id);
+}

springboot-webflux/src/main/java/org/spring/springboot/service/impl/CityServiceImpl.java

@@ -0,0 +1,50 @@
+package org.spring.springboot.service.impl;
+
+import org.spring.springboot.domain.City;
+import org.spring.springboot.service.CityService;
+import org.springframework.stereotype.Service;
+
+import java.util.ArrayList;
+import java.util.HashMap;
+import java.util.List;
+import java.util.Map;
+
+/**
+ * 城市业务逻辑实现类
+ *
+ * Created by bysocket on 09/29/2017.
+ */
+@Service
+public class CityServiceImpl implements CityService {
+
+    // 模拟数据库，存储 City 信息
+    private static Map<Long, City> CITY_DB = new HashMap<>();
+
+    public List<City> findAllCity() {
+        return new ArrayList<>(CITY_DB.values());
+    }
+
+    public City findCityById(Long id) {
+        return CITY_DB.get(id);
+    }
+
+    @Override
+    public Long saveCity(City city) {
+        city.setId(CITY_DB.size() + 1L);
+        CITY_DB.put(city.getId(), city);
+        return city.getId();
+    }
+
+    @Override
+    public Long updateCity(City city) {
+        CITY_DB.put(city.getId(), city);
+        return city.getId();
+    }
+
+    @Override
+    public Long deleteCity(Long id) {
+        CITY_DB.remove(id);
+        return id;
+    }
+
+}