如何正确构造此webClient调用？

Question

我有一个目前看起来像这样的方法：

protected void doHealthCheck(Health.Builder builder) {
    try {
        VaultHealth vaultHealth = this.webClient
            .get()
            .exchange()
                .block()
                    .bodyToMono(VaultHealth.class)
                        .block();

        if (vaultHealth.isInitialized() && !vaultHealth.isSealed() && !vaultHealth.isStandby()) {
            builder.up();
            return;
        }
    }
    catch (Exception e) {
        builder.down();
        return;
    }

    builder.down();
}

我的理解是这是错误的。所以现在我正在考虑修复它，它应该是这样的：

        this.webClient
            .get()
            .exchange()
                .doOnSuccess(???)
                .doOnError(Health.Builder::down);

. doOn成功将返回一个客户响应，我需要在调用Health之前实际检查响应中的内容。构建器::。

如果我调用. fletMap（）而不是doOn成功，它会出现错误吗？或者我需要把它放在doOn成功中吗？如果我把它放在doOn成功中，似乎我需要做一个双重doOn成功（这不可能是正确的，是吗？）：

.doOnSuccess(x -> x.bodyToMono(VaultHealth.class).doOnSuccess(y -> if (y...) builder.up())

此外，我假设如果我这样重组它，我不需要try/catch，因为doOnError会处理它？

虽然这个特殊的方法在操作完成后执行操作是有意义的，但是在我需要返回对象的情况下呢？我的另一个理解是，我永远不应该使用。布洛克，对吗？

Answer 1

Mono::flatMap用于异步操作。对WebClient的调用是一种“异步”操作，因此您通常需要在WebClient::exchange方法之后使用Mono： flMap。不，您永远不应该在“WebFlux”应用程序中使用Mono::block。与其使用您拥有的，不如使用反应式方式：

    public void run(ApplicationArguments args) throws Exception {
        Health.Builder healthBuilder = new Health.Builder();
        healthBuilder.down();
        doHealthCheck(healthBuilder).onErrorReturn(healthBuilder).map(Health.Builder::build).subscribe(System.out::println);
    }
    protected Mono<Health.Builder> doHealthCheck( Health.Builder builder) {
        return webClient
            .get()
            .retrieve()
            .bodyToMono(VaultHealth.class)
            .map(vaultHealth->{
                if (vaultHealth.isInitialized() && !vaultHealth.isSealed() && !vaultHealth.isStandby())
                    builder.up();
                else 
                    builder.down();
                return builder;
            });
    }