Spring webFlux DTO之间的差异

Question

我使用Spring boot反应式web流量作为restendpoint。

以下两者之间的区别是什么：

@PostMapping
public Mono someMethod(@RequestBody SomeDTO someDto){
.....

到

@PostMapping
public Mono someMethod(@RequestBody Mono<SomeDTO> someDTO) {
....

我不理解我的控制器方法在输入参数上的差异。我知道一个是pojo，另一个是mono，但从反应的角度来看，这意味着什么？

Answer 1

首先，一些背景。您正在使用1.4。WebFlux的注释控制器类。这些实现基于1.5。功能endpoint类。我建议直接使用功能endpoint。

从反应式POV中，您必须了解您需要创建反应式流。在Mono方法中，这是为您创建的，在某个DTO方法中，您可能应该使用Mono.just（某个DTO）来创建它。

在该语句中需要了解的是，创建语句将在构建阶段而不是反应语句的执行阶段执行。构建阶段不是异步执行的。

因此，考虑两个mono创建语句。

return Mono.just(Thread.sleep(1000));

和

return Mono.just(1000).map(Thread::sleep);

是的，我知道它不会因为中断的异常而编译，但是在第一种情况下，Mono直到1秒才会返回给客户端，然后在订阅时它什么也不会做。在第二种情况下，mono将立即返回给客户端，并在订阅后等待一秒钟。第二个是你正在努力争取的。

这对你意味着什么？考虑

return Mono.just(repo.save(someDto));

和

return someDto.map(repo::save);

在第一种情况下，如上所述，someDto将保存在回购中，然后mono将返回给客户，并且在订阅时不会执行任何操作。错误的在第二种情况下，mono将返回给客户端，线程释放回webflux框架以用于另一个请求，并且当客户端订阅返回的mono时，将保存someDto。你在努力什么。

通过以下方法正确处理第一个案例：

return Mono.just(someDto).map(repo::save);

这就是单声道。只需要（someDto）你自己，而在第二种情况下，webflux框架正在为你做这件事。

选择哪一个？如果你只是想在mono中封装一些数据并使用它，那么最好让框架为你做，或者使用功能endpoint。如果您打算出于其他原因创建单声道，然后在映射过程中使用someDto，请使用第一种情况。第二个原因是，IMHO是一个罕见的用例。

通常，在使用功能endpoint时，您最终会执行请求。bodyToMono（SomeDto.class）这相当于您的第二个案例，以及框架在第二个案例中为您做了什么。