使用 Spring Webflux Reactive WebClient 设置连接超时答案

【问题标题】：Set connection timeout using Spring Webflux Reactive WebClient使用 Spring Webflux Reactive WebClient 设置连接超时
【发布时间】：2018-06-14 06:15:30
【问题描述】：

为（默认）WebClient 设置（连接）超时的正确方法是什么？

只对生成的 Mono（或 Flux）使用 Mono#timeout(Duration) 方法就足够了吗？还是这会导致可能的内存/连接泄漏？

提前致谢！

（Spring 5 webflux how to set a timeout on Webclient 的回答无效！）

【问题讨论】：

Spring 5 webflux how to set a timeout on Webclient的可能重复
我知道你提到的那个帖子；即使是接受的答案也不起作用（而且非常丑陋）。

标签： spring spring-webflux

【解决方案1】：

目前，WebClient 不提供该选项作为顶级配置选项。您必须在底层 HTTP 客户端库中进行配置。

所以另一个问题的答案是正确的。但在您的情况下，您可能需要更改连接超时，而不是套接字超时（或两者）。

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

【讨论】：

【解决方案2】：

从 Reactor Netty 0.8 和 Spring Framework 5.1 开始，您可以设置连接、读取和写入超时，如下所示：

TcpClient tcpClient = TcpClient.create()
                 .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 1000) // Connection Timeout
                 .doOnConnected(connection ->
                         connection.addHandlerLast(new ReadTimeoutHandler(10)) // Read Timeout
                                   .addHandlerLast(new WriteTimeoutHandler(10))); // Write Timeout
WebClient webClient = WebClient.builder()
    .clientConnector(new ReactorClientHttpConnector(HttpClient.from(tcpClient)))
    .build();

【讨论】：