“添加”似乎在 WebFlux 中工作，但似乎必须有一个“更可接受的方式”

Question

WebFlux、反应式和处理程序的新手。

我能够从 ServerRequest 获取 Mono 并处理包含的 POJO 以将新元组添加到数据库。但是，似乎应该有一种“更好”或“更容易接受”的方式来编写这段代码。

如果对 AccountRequestHandler 中的代码提供任何帮助/输入，我们将不胜感激，尤其是对建议更改背后的基本原理的解释。

路由器实现（精简为仅“POST”）...

@Configuration
public class AccountRequestRouter {

    @Bean
    public RouterFunction<ServerResponse> route(AccountRequestHandler requestHandler) {
        return nest(path("/v2"),
                   nest(accept(APPLICATION_JSON),
                      .andRoute(RequestPredicates.POST("/accounts"), requestHandler::addAccount)
                       ));
    }
}

处理程序实现... 我实际执行添加，然后分别创建 ServerResponse 的代码是我关注的内容。这似乎很“笨拙”，特别是因为 AccountService.addAccount() 在完成时返回一个 Mono。

@Component
public class AccountRequestHandler {

    @Autowired
    private mil.navy.ccop.service.accounts.account.AccountService accountService;

    public Mono<ServerResponse> addAccount(ServerRequest request) {
        return request.bodyToMono(Account.class).flatMap(account -> {
                                                                        accountService.addAccount(account);
                                                                        return ServerResponse.ok().build();
                                                                    })
                                                .switchIfEmpty(ServerResponse.badRequest()
                                                                             .contentType(APPLICATION_JSON)
                                                                             .build(Mono.empty()));
    }
}

AccountService 实现（再次精简）...

@Service
class AccountService {

    @Autowired
    private AccountRepository accounts;

    public AccountService() {
    }

    public Mono<Void> addAccount(Account account) {
        Account proxy;

        // make sure that accountId is set to support auto-generation of synthetic key value
        proxy = new Account(-1, account.getShortName(), account.getLongName(), account.getDescription());
        accounts.save(proxy);
        return Mono.empty();
    }
}

感谢所有帮助提升这种编程风格的人......

Answer 1

首先，您有 2 个 addAccount，这可能有点令人困惑。

其次，您也在编写什么样的“存储库”？如果它是一个 sql 存储库，则需要将其正确包装在 Mono.fromCallable() 中，否则它将阻塞 Reactive 线程池，并且性能会非常差。

是的，还有其他的做事方式。很多人倾向于在flatmap 或map 中做事，当然这里完全可以做事，但是对于语义，我会说它不太好。

map 和 flatmap 通常用于对单声道的内部值执行某种计算，然后返回相同的或新的值或单声道内的类型​​。

我会这样重写。

在这里返回无效：

public void addAccount(Account account) {
    Account proxy;

    // make sure that accountId is set to support auto-generation of synthetic key value
    proxy = new Account(-1, account.getShortName(), account.getLongName(), account.getDescription());
    accounts.save(proxy);
}

这里：

public Mono<ServerResponse> addAccount(ServerRequest request) {
    return request.bodyToMono(Account.class)
                .doOnSuccess(account -> {
                            accountService.addAccount(account);
                }).then(ServerResponse.ok().build())
                  .switchIfEmpty(ServerResponse.badRequest()
                                      .contentType(APPLICATION_JSON)
                                      .build());
}

有许多不同的doOn 方法可用于消费和对事物产生“副作用”。比如doOnSuccess、doOnError、doOnCancel等等等等。

您还拥有then 和thenReturn，它们只会返回您放入其中的任何内容。 Then 返回您放入的任何 Mono。 thenReturn 将您放入其中的任何值包装到 Mono 中并返回它。