Spring WebFlux：从Mono中提取值

Question

Mono<Account> account = webClientBuilder.build().get().uri("http://account-service/user/accounts/{userId}/",userId)
.retrieve().bodyToMono(Account.class);


//productId is a path variable on method
Mono<Product> product =this.productService.findById(productId);

block()/blockfirst（）/blocklast（）正在阻塞，线程反应器-http-nio-2不支持这一点

//Causes Error
Double accountBalance = account.map(a->a.getBalance()).block():

Double productPrice = product.map(p->p.getPrice()).block();

///Find difference, send response accordingly....

这是正确的方法吗？还有另一种更好的方法来实现这一点？我也在想一些类似的事情：

Mono<Double> accountBalance = account.map(a->a.getBalance()):

Mono<Double> productPrice = product.map(p->p.getPrice());

Mono<Double> res = accountBalance.zipWith(productPrice,(b,p)-> b-p);

//Something after this.....

Answer 1

你不能在主反应器线程上使用块法。这是被禁止的。block在其他线程上发布mono时可能会起作用，但这不是一种情况。

基本上你的方法与压缩两个单声道是正确的。您可以创建一些helper方法来对它们进行计算。在您的情况下，它可能看起来像：

public boolean isAccountBalanceGreater(Account acc, Product prd) {
   return acc.getBalance() >= prd.getPrice();
}

然后，在单流中，您可以传递方法引用，使其更具可读性。

Mono<Boolean> result = account.zipWith(productPrice, this::isAccountBalanceGreater)

return account.zipWith(productPrice, this::createResponse);

...

ResponseEntity createResponse(Account acc, Product prd) {
   int responseCode = isAccountBalanceGreater(acc, prd) ? 200 : 500;
   return ResponseEntity.status(responseCode).body(prd);
}