WebFlux 新增加的几种方法，以及SSE模式等响应式编程

Author: zhangtao

SpringWebFluxDemo/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>
+    <parent>
+        <groupId>org.springframework.boot</groupId>
+        <artifactId>spring-boot-starter-parent</artifactId>
+        <version>2.1.3.RELEASE</version>
+        <relativePath/> <!-- lookup parent from repository -->
+    </parent>
+    <groupId>com.github.xiaour</groupId>
+    <artifactId>flux</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>SpringWebFluxDemo</name>
+    <description>Demo project for Spring Boot</description>
+
+    <properties>
+        <java.version>1.8</java.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-web</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-webflux</artifactId>
+        </dependency>
+
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

SpringWebFluxDemo/src/main/java/com/github/xiaour/flux/SpringWebFluxDemoApplication.java

@@ -0,0 +1,13 @@
+package com.github.xiaour.flux;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class SpringWebFluxDemoApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(SpringWebFluxDemoApplication.class, args);
+    }
+
+}

SpringWebFluxDemo/src/main/java/com/github/xiaour/flux/controller/HelloWorlController.java

@@ -0,0 +1,24 @@
+package com.github.xiaour.flux.controller;
+
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Mono;
+
+/**
+ * @Author: [email protected]
+ * @Date: 2019-02-27 16:26
+ * @version: v1.0
+ * @Description: 入门案例
+ */
+
+@RestController
+@RequestMapping("/")
+public class HelloWorlController {
+
+        @GetMapping("hello")
+        public Mono<String> hello(){
+            return Mono.just("hello World!");
+        }
+
+}

SpringWebFluxDemo/src/main/java/com/github/xiaour/flux/controller/SSEController.java

@@ -0,0 +1,34 @@
+package com.github.xiaour.flux.controller;
+
+import io.netty.util.internal.ThreadLocalRandom;
+import org.springframework.http.codec.ServerSentEvent;
+import org.springframework.web.bind.annotation.GetMapping;
+import org.springframework.web.bind.annotation.RequestMapping;
+import org.springframework.web.bind.annotation.RestController;
+import reactor.core.publisher.Flux;
+import reactor.util.function.Tuples;
+
+import java.time.Duration;
+
+/**
+ * @Author: [email protected]
+ * @Date: 2019-02-27 16:37
+ * @version: v1.0
+ * @Description: 服务器推送接口
+ */
+@RestController
+@RequestMapping("/sse")
+public class SSEController {
+
+    @GetMapping("/randomNumbers")
+    public Flux<ServerSentEvent<Integer>> randomNumbers() {
+        return Flux.interval(Duration.ofSeconds(2))
+                .map(seq -> Tuples.of(seq, ThreadLocalRandom.current().nextInt()))
+                .map(data -> ServerSentEvent.<Integer>builder()
+                        .event("random")
+                        .id(Long.toString(data.getT1()))
+                        .data(data.getT2())
+                        .build());
+    }
+
+}

SpringWebFluxDemo/src/main/java/com/github/xiaour/flux/controller/UserController.java

@@ -0,0 +1,53 @@
+package com.github.xiaour.flux.controller;
+
+import com.github.xiaour.flux.entity.User;
+import com.github.xiaour.flux.service.UserService;
+import org.springframework.beans.factory.annotation.Autowired;
+import org.springframework.web.bind.annotation.*;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import java.util.Objects;
+
+/**
+ * @Author: [email protected]
+ * @Date: 2019-02-27 16:33
+ * @version: v1.0
+ * @Description: 用户管理接口
+ */
+@RestController
+@RequestMapping("/user")
+public class UserController {
+
+    @Autowired
+    private UserService userService;
+
+
+    @GetMapping("")
+    public Flux<User> list() {
+        return userService.list();
+    }
+
+    @GetMapping("/{id}")
+    public Mono<User> getById(@PathVariable("id") final String id) {
+        return this.userService.getById(id);
+    }
+
+    @PostMapping("")
+    public Mono<User> create(@RequestBody final User user) {
+        return this.userService.createOrUpdate(user);
+    }
+
+    @PutMapping("/{id}")
+    public Mono<User>  update(@PathVariable("id") final String id, @RequestBody final User user) {
+        Objects.requireNonNull(user);
+        user.setId(id);
+        return this.userService.createOrUpdate(user);
+    }
+
+    @DeleteMapping("/{id}")
+    public Mono<User>  delete(@PathVariable("id") final String id) {
+        return this.userService.delete(id);
+    }
+
+}

SpringWebFluxDemo/src/main/java/com/github/xiaour/flux/entity/User.java

@@ -0,0 +1,40 @@
+package com.github.xiaour.flux.entity;
+
+/**
+ * @Author: [email protected]
+ * @Date: 2019-02-27 16:31
+ * @version: v1.0
+ * @Description:
+ */
+public class User {
+
+    private String id;
+
+    private String name;
+
+    private Integer age;
+
+    public String getId() {
+        return id;
+    }
+
+    public void setId(String id) {
+        this.id = id;
+    }
+
+    public String getName() {
+        return name;
+    }
+
+    public void setName(String name) {
+        this.name = name;
+    }
+
+    public Integer getAge() {
+        return age;
+    }
+
+    public void setAge(Integer age) {
+        this.age = age;
+    }
+}

SpringWebFluxDemo/src/main/java/com/github/xiaour/flux/service/UserService.java

@@ -0,0 +1,44 @@
+package com.github.xiaour.flux.service;
+
+import com.github.xiaour.flux.entity.User;
+import org.springframework.stereotype.Service;
+import reactor.core.publisher.Flux;
+import reactor.core.publisher.Mono;
+
+import java.util.Map;
+import java.util.concurrent.ConcurrentHashMap;
+
+/**
+ * @Author: [email protected]
+ * @Date: 2019-02-27 16:30
+ * @version: v1.0
+ * @Description:
+ */
+@Service
+public class UserService {
+
+    private final Map<String, User> data = new ConcurrentHashMap<>();
+
+    public  Flux<User> list() {
+        return Flux.fromIterable(this.data.values());
+    }
+
+    public Flux<User> getById(final Flux<String> ids) {
+        return ids.flatMap(id -> Mono.justOrEmpty(this.data.get(id)));
+    }
+
+    public Mono<User> getById(final String id) {
+        return Mono.justOrEmpty(this.data.get(id));
+    }
+
+    public Mono<User> createOrUpdate(final User user) {
+        this.data.put(user.getId(), user);
+        return Mono.just(user);
+    }
+
+    public Mono<User> delete(final String id) {
+        return Mono.justOrEmpty(this.data.remove(id));
+    }
+
+
+}

SpringWebFluxDemo/src/main/resources/application.properties

@@ -0,0 +1 @@
+