feat：Spring Boot 整合 WebFlux 实现基本的 CURD。

Author: GitSuperDrew

springboot-webflux/.gitignore

@@ -0,0 +1,31 @@
+HELP.md
+target/
+!.mvn/wrapper/maven-wrapper.jar
+!**/src/main/**
+!**/src/test/**
+
+### STS ###
+.apt_generated
+.classpath
+.factorypath
+.project
+.settings
+.springBeans
+.sts4-cache
+
+### IntelliJ IDEA ###
+.idea
+*.iws
+*.iml
+*.ipr
+
+### NetBeans ###
+/nbproject/private/
+/nbbuild/
+/dist/
+/nbdist/
+/.nb-gradle/
+build/
+
+### VS Code ###
+.vscode/

springboot-webflux/README.md

@@ -0,0 +1,219 @@
+# 一、工程简介
+> Spring2.X新系列的框架搭建 >>> WebFlux + RESTFul风格。
+
+# 二、搭建步骤
+1. 引入核心依赖
+```xml
+<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.projectlombok</groupId>
+       <artifactId>lombok</artifactId>
+       <optional>true</optional>
+   </dependency>
+</dependencies>
+```
+2. 定义测试用的实体类`User.java`
+```java
+@Data
+@Builder
+@Accessors(chain = true)
+@NoArgsConstructor
+@AllArgsConstructor
+public class User {
+    private Long id;
+    private String username;
+    private String realName;
+    private String password;
+    private Integer age;
+    private String sex;
+}
+```
+3. 定义DAO层
+```java
+@Repository
+public class UserRepository {
+    /**
+     * 可以替换成 ORM框架（mybatis的*Mapper）
+     */
+    private ConcurrentMap<Long, User> repository = new ConcurrentHashMap<>();
+
+    private static final AtomicLong idGenerator = new AtomicLong(0);
+
+    public Long save(User user) {
+        Long id = idGenerator.incrementAndGet();
+        user.setId(id);
+        repository.put(id, user);
+        return id;
+    }
+
+    public Collection<User> findAll() {
+        return repository.values();
+    }
+
+    public User findUserById(Long id) {
+        return repository.get(id);
+    }
+
+    public Long updateUser(User user) {
+        repository.put(user.getId(), user);
+        return user.getId();
+    }
+
+    public Long deleteUser(Long id) {
+        repository.remove(id);
+        return id;
+    }
+}
+```
+4. 定义 Service层（即 *Handler）
+```java
+@Component
+public class UserHandler {
+
+    private final UserRepository userRepository;
+
+    @Autowired
+    public UserHandler(UserRepository userRepository) {
+        this.userRepository = userRepository;
+    }
+
+    public Mono<Long> save(User user) {
+        return Mono.create(userMonoSink -> userMonoSink.success(userRepository.save(user)));
+    }
+
+    public Mono<User> findUserById(Long id) {
+        return Mono.justOrEmpty(userRepository.findUserById(id));
+    }
+
+    public Flux<User> findAllUser() {
+        return Flux.fromIterable(userRepository.findAll());
+    }
+
+    public Mono<Long> modifyUser(User user) {
+        return Mono.create(userMonoSink -> userMonoSink.success(userRepository.updateUser(user)));
+    }
+
+    public Mono<Long> deleteUser(Long id) {
+        return Mono.create(userMonoSink -> userMonoSink.success(userRepository.deleteUser(id)));
+    }
+}
+```
+5. 控制层（`UserWebFluxController.java`）
+```java
+@RestController
+@RequestMapping(path = "/user")
+public class UserWebFluxController {
+
+    @Autowired
+    private UserHandler userHandler;
+
+    @GetMapping(path = "/{id}")
+    public Mono<User> findUserById(@PathVariable("id") Long id) {
+        return userHandler.findUserById(id);
+    }
+
+    @GetMapping()
+    public Flux<User> findAllUser() {
+        return userHandler.findAllUser();
+    }
+
+    @PostMapping()
+    public Mono<Long> saveUser(@RequestBody User user) {
+        return userHandler.save(user);
+    }
+
+    @PutMapping()
+    public Mono<Long> modifyUser(@RequestBody User user) {
+        return userHandler.modifyUser(user);
+    }
+
+    @DeleteMapping(path = "/{id}")
+    public Mono<Long> deleteUser(@PathVariable(value = "id") Long id) {
+        return userHandler.deleteUser(id);
+    }
+}
+```
+
+
+6. 测试步骤
+   1. POST 请求 → 新增
+      ```text
+      请求地址：http://localhost:8080/user
+      请求参数如下：（raw/json）
+      {
+           "username": "Drew",
+           "age": 25,
+           "sex": "男",
+           "realName": "杜鲁",
+           "password": 123
+       }
+      ```
+   2. PUT  请求 → 修改
+      ```text
+      请求地址：http://localhost:8080/user
+      请求参数如下：（raw/json）
+      {
+           "username": "DrewPlus",
+           "age": 23,
+           "sex": "男",
+           "realName": "杜鲁PLUS",
+           "password": 123
+       }
+      ```
+   3. GET  请求 👉 查询
+      ```text
+      (1)请求地址：http://localhost:8080/user/3
+      返回数据如下：
+      {
+           "id": 3,
+           "username": "Drew",
+           "realName": "杜鲁",
+           "password": "123",
+           "age": 25,
+           "sex": "男"
+       }
+      (2)请求所有：http://localhost:8080/user
+      返回数据如下：
+      [
+         {
+            "id": 1,
+            "username": "Drew Plus",
+            "realName": "杜鲁",
+            "password": "123",
+            "age": 25,
+            "sex": "男"
+         },
+         {
+            "id": 2,
+            "username": "Drew",
+            "realName": "杜鲁",
+            "password": "123",
+            "age": 25,
+            "sex": "男"
+         },
+         {
+            "id": 3,
+            "username": "Drew",
+            "realName": "杜鲁",
+            "password": "123",
+            "age": 25,
+            "sex": "男"
+         }
+      ]
+      ```
+   4. DELETE 请求 → 删除
+      ```text
+      请求地址：http://localhost:8080/user/1
+      返回数据：1 （即用户ID）
+      ```
+
+# 三、延伸阅读
+

springboot-webflux/pom.xml

@@ -0,0 +1,108 @@
+<?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 https://maven.apache.org/xsd/maven-4.0.0.xsd">
+    <modelVersion>4.0.0</modelVersion>
+    <groupId>edu.study.module</groupId>
+    <artifactId>springboot-webflux</artifactId>
+    <version>0.0.1-SNAPSHOT</version>
+    <name>springboot-webflux</name>
+    <description>RESTFul风格配合WebFlux project for Spring Boot</description>
+
+    <properties>
+        <java.version>1.8</java.version>
+        <project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
+        <project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
+        <spring-boot.version>2.3.7.RELEASE</spring-boot.version>
+    </properties>
+
+    <dependencies>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-data-rest</artifactId>
+        </dependency>
+        <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>com.alibaba</groupId>
+            <artifactId>fastjson</artifactId>
+            <version>1.2.72</version>
+        </dependency>
+        <dependency>
+            <groupId>org.apache.commons</groupId>
+            <artifactId>commons-lang3</artifactId>
+            <version>3.1</version>
+        </dependency>
+
+        <dependency>
+            <groupId>org.projectlombok</groupId>
+            <artifactId>lombok</artifactId>
+            <optional>true</optional>
+        </dependency>
+        <dependency>
+            <groupId>org.springframework.boot</groupId>
+            <artifactId>spring-boot-starter-test</artifactId>
+            <scope>test</scope>
+            <exclusions>
+                <exclusion>
+                    <groupId>org.junit.vintage</groupId>
+                    <artifactId>junit-vintage-engine</artifactId>
+                </exclusion>
+            </exclusions>
+        </dependency>
+        <dependency>
+            <groupId>io.projectreactor</groupId>
+            <artifactId>reactor-test</artifactId>
+            <scope>test</scope>
+        </dependency>
+    </dependencies>
+
+    <dependencyManagement>
+        <dependencies>
+            <dependency>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-dependencies</artifactId>
+                <version>${spring-boot.version}</version>
+                <type>pom</type>
+                <scope>import</scope>
+            </dependency>
+        </dependencies>
+    </dependencyManagement>
+
+    <build>
+        <plugins>
+            <plugin>
+                <groupId>org.apache.maven.plugins</groupId>
+                <artifactId>maven-compiler-plugin</artifactId>
+                <version>3.8.1</version>
+                <configuration>
+                    <source>1.8</source>
+                    <target>1.8</target>
+                    <encoding>UTF-8</encoding>
+                </configuration>
+            </plugin>
+            <plugin>
+                <groupId>org.springframework.boot</groupId>
+                <artifactId>spring-boot-maven-plugin</artifactId>
+                <version>2.3.7.RELEASE</version>
+                <configuration>
+                    <mainClass>edu.study.module.springbootwebflux.SpringbootWebfluxApplication</mainClass>
+                </configuration>
+                <executions>
+                    <execution>
+                        <id>repackage</id>
+                        <goals>
+                            <goal>repackage</goal>
+                        </goals>
+                    </execution>
+                </executions>
+            </plugin>
+        </plugins>
+    </build>
+
+</project>

springboot-webflux/src/main/java/edu/study/module/springbootwebflux/SpringbootWebfluxApplication.java

@@ -0,0 +1,13 @@
+package edu.study.module.springbootwebflux;
+
+import org.springframework.boot.SpringApplication;
+import org.springframework.boot.autoconfigure.SpringBootApplication;
+
+@SpringBootApplication
+public class SpringbootWebfluxApplication {
+
+    public static void main(String[] args) {
+        SpringApplication.run(SpringbootWebfluxApplication.class, args);
+    }
+
+}