我使用带有 webflux 的 Spring Boot 2.1.1.RELEASE。
依赖关系如下:
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-webflux</artifactId>
</dependency>
Run Code Online (Sandbox Code Playgroud)
这是控制器,我使用 Hooks.onOperatorDebug(); 正如 reactor 的文档所说,它可以打开调试模式。
@RestController
public class TestController {
@GetMapping("/test")
public Mono test(String a) {
Hooks.onOperatorDebug();
return Mono.just("test1")
.map(t -> t + "test2")
.zipWith(Mono.error(() -> new IllegalArgumentException("error")));
}
@PostMapping("/test")
public Mono post(@RequestBody Req req) {
return Mono.just(req);
}
}
class Req {
private String a;
private String b;
public String getA() {
return a;
}
public void setA(String a) {
this.a = a;
}
public String getB() …Run Code Online (Sandbox Code Playgroud)