为 Spring Web 客户端添加异常处理程序

Question

我将此代码用于 REST API 请求。

WebClient.Builder builder = WebClient.builder().baseUrl(gatewayUrl);
ClientHttpConnector httpConnector = new ReactorClientHttpConnector(opt -> opt.sslContext(sslContext));
builder.clientConnector(httpConnector);

如何添加连接异常处理程序？我想实现一些自定义逻辑？这个功能容易实现吗？

Answer 1

如果我在由于 SSL 凭据而导致连接失败的情况下理解您的问题，那么您应该会在 REST 响应中看到连接异常本身。 您可以通过在WebClient.ResponseSpec#onStatus 上获得的Flux 结果处理该异常。 #onStatus 的文档说：

注册一个自定义错误函数，当给定 HttpStatus 谓词适用。函数返回的异常 将从bodyToMono(Class) 和bodyToFlux(Class) 返回。经过 默认情况下，错误处理程序是抛出一个 WebClientResponseException 当响应状态码为 4xx 或 5xx。

看看this example：

Mono<Person> result = client.get()
            .uri("/persons/{id}", id).accept(MediaType.APPLICATION_JSON)
            .retrieve()
            .onStatus(HttpStatus::is4xxServerError, response -> ...) // This is in the docs there but is wrong/fatfingered, should be is4xxClientError
            .onStatus(HttpStatus::is5xxServerError, response -> ...)
            .bodyToMono(Person.class);

对于您的问题，连接错误应该在调用后自行显现，您可以自定义它在反应管道中的传播方式：

Mono<Person> result = client.get()
            .uri("/persons/{id}", id).accept(MediaType.APPLICATION_JSON)
            .retrieve()
            .onStatus(HttpStatus::is4xxClientError, response -> {
                 ... Code that looks at the response more closely...
                 return Mono.error(new MyCustomConnectionException());
             })
            .bodyToMono(Person.class);

希望对您有所帮助。