WebClient reactor.core.Exceptions$ErrorCallbackNotImplemented

Question

所以我有以下代码可以对远程机器执行 GET：

webClient.get()
            .uri(myUri)
            .accept(MediaType.APPLICATION_JSON)
            .retrieve()
            .bodyToMono(String.class)
            .subscribe(text -> {
                LOG.info(text);
            });

我得到这个异常，没问题，我期待它，但很难找到任何文档如何处理这些错误：

reactor.core.Exceptions$ErrorCallbackNotImplemented: java.net.UnknownHostException

Answer 1

要处理这些异常，您需要添加以下内容，使其适应您的情况（在我的情况下，如果我收到 unkownHostException，我只需记录一个请求的服务不存在的警告：

webClient.get()
            .uri(myUri)
            .accept(MediaType.APPLICATION_JSON)
            .retrieve()
            .bodyToMono(String.class)
            .onErrorResume(e -> {
                if (e instanceof UnknownHostException) {
                    LOG.warn("Failed to get myStuff, desired service not present");
                } else {
                    LOG.error("Failed to get myStuff");
                }
                return Mono.just("Encountered an exception");
            })
            .subscribe(text -> {
                LOG.info(text);
            });

您处理错误，并将某些内容发送到下一步。我真的希望有一种方法可以停下来，并且不会将任何东西传递到管道中。