当前位置:首页 > Web开发 > 正文

#Java#Spring#WebFlux#WebClient#Post#传参#Body# WebClient如何通过B

2024-03-31 Web开发

#Java#Spring#WebFlux#WebClient#Post#传参#Body#

WebClient如何通过Body以Post方法传参

视频讲解: https://www.bilibili.com/video/av82795780/

技术图片

WebfluxServerApplication.java

package com.example.webfluxserver; import lombok.extern.log4j.Log4j2; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RestController; import reactor.core.publisher.Mono; @Log4j2 @SpringBootApplication public class WebfluxServerApplication extends BaseApplication { public static void main(String[] args) { SpringApplication.run(WebfluxServerApplication.class, args); } @RestController class EmployeeController { @PostMapping(value = "save") public Mono<Boolean> save(@RequestBody Mono<Employee> employeeMono) { Mono<Boolean> employeeMono1 = employeeMono.flatMap(employee -> { employee.setName(employee.getName() + " had updated"); //save... return Mono.just(Boolean.TRUE); }); return employeeMono1; } } }

WebfluxConsumerApplication.java

package com.example.webfluxserver; import lombok.extern.log4j.Log4j2; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.web.bind.annotation.PostMapping; import org.springframework.web.bind.annotation.RequestBody; import org.springframework.web.bind.annotation.RestController; import reactor.core.publisher.Mono; @Log4j2 @SpringBootApplication public class WebfluxServerApplication extends BaseApplication { public static void main(String[] args) { SpringApplication.run(WebfluxServerApplication.class, args); } @RestController class EmployeeController { @PostMapping(value = "save") public Mono<Boolean> save(@RequestBody Mono<Employee> employeeMono) { Mono<Boolean> employeeMono1 = employeeMono.flatMap(employee -> { employee.setName(employee.getName() + " had updated"); //save... return Mono.just(Boolean.TRUE); }); return employeeMono1; } } }

公家号,,对峙每天3分钟视频学习

技术图片

WebFlux系列(七)WebClient Post传参

温馨提示: 本文由Jm博客推荐,转载请保留链接: https://www.jmwww.net/file/web/31682.html