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

Question

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

仅仅在得到的单声道（或通量）上使用Mono#timeout(Duration)方法就够了吗？还是这会导致可能的内存/连接泄漏？

提前道谢！

（Spring5WebFlux的答案是如何在Webclient上设置超时的，但不起作用！）

Answer 1

从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();