spring-cloud-netflix - 在 Spring 5 WebClient 上设置请求特定读取超时的正确方法

Question

语境

我试图找到结合 Spring 5 的最佳方式 WebClient和 Hystrix .使用 Hystrix，我为 WebClient 完成的不同类型的请求设置了不同的超时时间。 .

当Hystrix达到超时，我还想确保 WebClient关闭其连接。以前使用时AsyncHttpClient ，这是通过设置 requestTimeout 来完成的在执行特定调用之前。但是，在 WebClient 上设置请求超时复杂得多，需要在ClientHttpConnector上完成根据 this answer .

Brian Cozel mentions最好共享相同的 ClientHttpConnector在整个应用程序中。但是，因为需要在 ClientHttpConnector 上设置请求特定的超时时间，这似乎不可能。

题

在 Spring 的 Reactive WebClient , 是否有设置请求特定超时的正确方法，但仍使用单个 ClientHttpConnector ?

Answer 1

您可以在客户端连接器上配置的超时操作非常低级:它们与套接字/连接超时有关。此配置无法在请求级别完成，因为连接可能会在连接池中共享和重用。

这个问题是关于响应超时的，因为您似乎关心每个请求获得响应的时间。

在这种情况下，您可以使用 timeout运算符(operator)基于每个请求:

Mono<UserData> result = this.webClient.get()
                .uri("/user")
                .accept(MediaType.APPLICATION_JSON)
                .retrieve()
                .bodyToMono(UserData.class)
                .timeout(Duration.ofSeconds(10));

超时操作符将抛出 TimeoutException在管线中;您可以使用 onError* 之一运算符来定义在这些情况下应该做什么。或者，您可以直接使用 timeout(Duration, Mono)提供回退的变体。