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

Question

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

我能得到单声道

任何对Account tRequest estHandler中代码的帮助/输入都将不胜感激，尤其是解释建议更改背后的基本原理。

路由器实现（分解为仅“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)
                       ));
    }
}

处理程序实现...我真正做添加的代码，然后单独创建一个服务器响应，是我关注的。它看起来“笨拙”，尤其是因为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 repo，则需要将其正确包装在＜code＞Mono中。fromCallable（）否则它将阻塞＜code＞反应性

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

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

我会把它改写成这样。

在此返回void:

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等。

你也有然后然后返回，这将只返回你放入其中的任何东西。然后返回您放入其中的任何内容 Mono。然后返回将您放入其中的任何值包装到 Mono 中并返回它。