Spring webflux：webClient put调用

Question

@GetMapping("/account/{userId}/product/{productId}")
    public Mono<ResponseEntity<Product>> checkAccount(@PathVariable("userId") int userId,@PathVariable("productId") int productId){



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


    Mono<Product> product = this.ps.findById(productId);

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


    Mono<ResponseEntity<Product>> p = result.zipWith(product,this::getResponse);

    return p;

    }



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




    public ResponseEntity<Product> getResponse(boolean result,Product prod){
        if(result) {

            return ResponseEntity.accepted().body(prod);
        }else {
            return ResponseEntity.badRequest().body(prod);
        }
    }

@PutMapping("/account/update/{accountId}")
    public Mono<ResponseEntity<Account>> updateAccount(@PathVariable("accountId") int accountId, @RequestBody Account account) {


      return as.findById(accountId)
              .flatMap(oldAcc->{
                  oldAcc.setAccountId(account.getAccountId());
                  oldAcc.setAccountId(account.getAccountId());
                    oldAcc.setOwner(account.getOwner());
                    oldAcc.setPin(account.getPin());
                    oldAcc.setBalance(account.getBalance());
                    oldAcc.setUserId(account.getUserId());
                    return ar.save(oldAcc);
              }).map(a -> ResponseEntity.ok(a))
                .defaultIfEmpty(ResponseEntity.notFound().build());


    }

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

               double newBuyerBalance  =acc.getBalance() - prd.getPrice();

                Account newOwnerAcc = new Account(acc.getAccountId(),acc.getOwner(),acc.getPin(),newBuyerBalance,acc.getUserId());


                this.ps.removeProduct(prd.getProductId());


  webClientBuilder.build().put().uri("http://account-service/account/update/{accountId}",acc.getAccountId()).body(newOwnerAcc,Account.class).exchange();



              return true;
           }
           return false;
        }

Answer 1

您必须将反应代码视为事件链或回调。因此，在其他事情完成后，你需要回应你想要做的事情。

return webClientBuilder.build()
          .put().uri("http://account-service/account/update/{accountId}",
                         acc.getAccountId())
                         .body(newOwnerAcc,Account.class)
                         .exchange()
                         .thenReturn(true); // if you really need to return a boolean

在反应世界中，返回布尔值通常在语义上不正确。避免if-else语句是非常常见的

一种方法是返回一个单字 来标记某件事情已经完成，并触发链接到它上的某件事情。

public Mono<Void> isAccountBalanceGreater(Account acc, Product prd) {
    return webclient.put()
                    .uri( ... )
                    .retrieve()
                    .bodyToMono(Void.class)
                    .doOnError( // handle error )
 }

// How to call for example
isAccountBalanceGreater(foo, bar)
    .doOnSuccess( ... )
    .doOnError( ... )