如何在web客户端检索中处理404

Question

我是spring-webclient的新手，我已经编写了一个通用方法，可以用来在我的应用程序中使用rest api：

public <T> List<T> get(URI url, Class<T> responseType) {
return  WebClient.builder().build().get().uri(url)
.header("Authorization", "Basic " + principal)
.retrieve().bodyToFlux(responseType).collectList().block();
}

我想返回一个空列表，如果消费了rest api返回404。

有人能建议如何做到这一点吗？

Answer 1

默认情况下，retrieve方法对任何4xx&5xx错误

默认情况下，4xx和5xx响应会导致WebClientResponseException。

您可以使用onErrorResume

webClient.get()
.uri(url)
.retrieve()
.header("Authorization", "Basic " + principal)
.bodyToFlux(Account.class)
.onErrorResume(WebClientResponseException.class,
ex -> ex.getRawStatusCode() == 404 ? Flux.empty() : Mono.error(ex))
.collectList().block();

Answer 2

您也可以使用onStatus，它允许您过滤想要的异常

public <T> List<T> get(URI url, Class<T> responseType) {
return  WebClient.builder().build().get().uri(url)
.header("Authorization", "Basic " + principal)
.retrieve()
.onStatus(HttpStatus::is4xxClientError, this::handleErrors)
.bodyToFlux(responseType)
.collectList().block();
}
private Mono<Throwable> handleErrors(ClientResponse response ){
return response.bodyToMono(String.class).flatMap(body -> {
log.error("LOg errror");
return Mono.error(new Exception());
});
}

Answer 3

从Spring WebFlux 5.3开始，他们添加了交换方法，允许您轻松处理不同的响应，如下所示：

public <T> List<T> get(URI url, Class<T> responseType) {
return WebClient.builder().build().get().uri(url)
.header("Authorization", "Basic " + principal)
.exchangeToFlux(clientResponse -> {
if (clientResponse.statusCode().equals(HttpStatus.NOT_FOUND)) {
return Flux.empty();
} else {
return clientResponse.bodyToFlux(responseType);
}
})
.collectList()
.block();
}