如何在Spring WebClient中设置和处理超时？

Question

Spring docs表示，需要手动为WebClient配置http客户机以设置超时:https://docs.Spring.io/Spring/docs/current/spring-framework-reference/web-reactive.html#webflux-client-builder-reactor-timeout。但是，由于WebClient返回反应单声道，所以可以（在API方面）应用.timeout方法。

有同样的效果吗？

此外，当使用.timeout方法时，需要reactor的timeoutexception。如果手动进行配置，流中会出现相同的错误吗？例如doonerror（timeoutexception.class,...）会工作吗？

Answer 1

我的发现

以特定于http客户端的方式设置超时将导致特定于http客户端的异常，即WebClient不包装异常：

@Test
void test() {
    var host = "localhost";
    var endpoint = "/test";
    var port = 8089;
    var timeout = Duration.ofSeconds(3);

    WireMockServer wireMockServer = new WireMockServer(wireMockConfig().port(8089));
    wireMockServer.start();
    WireMock.configureFor(host, wireMockServer.port());

    WireMock.stubFor(get(urlEqualTo(endpoint))
        .willReturn(aResponse().withFixedDelay((int) timeout.toMillis())));

    HttpClient httpClient = HttpClient.create()
        .tcpConfiguration(client ->
            client.doOnConnected(conn -> conn
                .addHandlerLast(new ReadTimeoutHandler((int) (timeout.toSeconds() / 2)))
                .addHandlerLast(new WriteTimeoutHandler((int) (timeout.toSeconds() / 2)))));

    WebClient webClient = WebClient.builder()
        .baseUrl(format("http://%s:%d", host, port))
        .clientConnector(new ReactorClientHttpConnector(httpClient)).build();

    webClient.get().uri(endpoint).retrieve().bodyToMono(Recommendation.class).block();
}

这将导致io.netty.handler.timeout.ReadTimeoutException。

.timeout(timeout.dividedby(2)).block()导致常规的timeoutexception(java.util.concurrent)，但是web客户机之后是否会关心连接仍然是一个悬而未决的问题（可能不会）。

我的解决方案是使用特定于http客户机的配置来确保以本机和正确的方式利用连接，同时添加新的处理程序，该处理程序将http客户机相关的异常包装成更通用的异常（或java.util.concurrent.TimeoutException)，这样WebClient客户机就不会依赖于提供程序异常。