spring webflux 示例

Author: YunaiV

lab-27/lab-27-webflux-01/src/main/java/cn/iocoder/springboot/lab27/springwebflux/controller/UserController.java

@@ -3,6 +3,7 @@
 import cn.iocoder.springboot.lab27.springwebflux.dto.UserAddDTO;
 import cn.iocoder.springboot.lab27.springwebflux.dto.UserUpdateDTO;
 import cn.iocoder.springboot.lab27.springwebflux.vo.UserVO;
+import org.reactivestreams.Publisher;
 import org.springframework.web.bind.annotation.*;
 import reactor.core.publisher.Flux;
 import reactor.core.publisher.Mono;
@@ -55,7 +56,7 @@ public Mono<UserVO> get(@RequestParam("id") Integer id) {
      * @return 添加成功的用户编号
      */
     @PostMapping("add")
-    public Mono<Integer> add(UserAddDTO addDTO) {
+    public Mono<Integer> add(@RequestBody Publisher<UserAddDTO> addDTO) {
         // 插入用户记录，返回编号
         Integer returnId = UUID.randomUUID().hashCode();
         // 返回用户编号
@@ -69,7 +70,7 @@ public Mono<Integer> add(UserAddDTO addDTO) {
      * @return 是否修改成功
      */
     @PostMapping("/update")
-    public Mono<Boolean> update(UserUpdateDTO updateDTO) {
+    public Mono<Boolean> update(@RequestBody Publisher<UserUpdateDTO> updateDTO) {
         // 更新用户记录
         Boolean success = true;
         // 返回更新是否成功

lab-27/lab-27-webflux-01/src/main/java/cn/iocoder/springboot/lab27/springwebflux/config/WebFluxRouteConfiguration.java renamed to lab-27/lab-27-webflux-01/src/main/java/cn/iocoder/springboot/lab27/springwebflux/controller/UserRouter.java

@@ -1,8 +1,8 @@
-package cn.iocoder.springboot.lab27.springwebflux.config;
+package cn.iocoder.springboot.lab27.springwebflux.controller;
 
 import cn.iocoder.springboot.lab27.springwebflux.vo.UserVO;
 import org.springframework.context.annotation.Bean;
-import org.springframework.context.annotation.Configuration;
+import org.springframework.stereotype.Component;
 import org.springframework.util.StringUtils;
 import org.springframework.web.reactive.function.server.*;
 import reactor.core.publisher.Mono;
@@ -15,8 +15,8 @@
 import static org.springframework.web.reactive.function.server.RouterFunctions.route;
 import static org.springframework.web.reactive.function.server.ServerResponse.ok;
 
-@Configuration
-public class WebFluxRouteConfiguration {
+@Component
+public class UserRouter {
 
     @Bean
     public RouterFunction<ServerResponse> userListRouterFunction() {