获取 Mono 的结果，以便将其传递到 Jpa 存储库或其他非反应式类

Question

我想知道从 Mono（或 Flux）获取对象以传递到非反应性方法（如 Jpa 存储库）的适当方法是什么。

这是我这样做的方式：

@Service
public class ReactiveAccountService {

    //AccountService's methods take non-mono/non-flux objects as arguments
    private AccountService accountService;

    public ReactiveAccountService(AccountService accountService) {
        this.accountService = accountService;
    }

    public Mono<Void> signUp(Mono<Account> accountMono) {
        //Account is a Jpa entity
        accountMono.subscribe(account -> accountService.signUp(account));
        return Mono.empty();
    }

}

这怎么改善？有人能建议一下吗？

Answer 1

更好的方法是这样的：

public Mono<Void> signUp(Mono<Account> accountMono) {
    //Account is a Jpa entity
    return accountMono.flatMap(account -> {
                  accountService.signUp(account);
                  return Mono.empty();
              });
}

通过这种方式，您可以遵循反应式流的要求，并且不会使用阻止代码来打扰执行流。另外，根据Spring WebFlux的要求，您不会订阅自己的代码，而是将所有内容都交给容器，该容器是该Mono的发起者