Spring WebFlux webclient句柄

Question

我正在使用Spring WebFlux webclient进行REST调用。我将连接超时配置为3000毫秒，相应地：

WebClient webClient = WebClient.builder()
    .clientConnector(new ReactorClientHttpConnector(options -> options
        .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 3000)))
    .build();

return webClient.get()
    .uri("http://localhost:8081/resource")
    .retrieve()
    .onStatus(HttpStatus::isError, clientResponse -> {
        // Some logging..
        return Mono.empty();
    })
    .bodyToMono(MyPojo.class);

onstatus方法将为每个400/500响应代码返回一个空的mono。如何对连接超时甚至读/写超时进行相同的操作。目前，它只是抛出一个io.netty.channel.ConnectTimeoutException，而onstatus不处理该异常

Answer 1

Reactor为此提供了多个onerror***运算符：

return webClient.get()
    .uri("http://localhost:8081/resource")
    .retrieve()
    .onErrorResume(ex -> Mono.empty())
    .onStatus(HttpStatus::isError, clientResponse -> {
        // Some logging..
        return Mono.empty();
    })
    .bodyToMono(MyPojo.class);