diff --git a/spring/webflux/webclient.md b/spring/webflux/webclient.md index 59af3fb..bd840f7 100644 --- a/spring/webflux/webclient.md +++ b/spring/webflux/webclient.md @@ -94,3 +94,58 @@ public WebClient webClient() { return WebClient.builder().clientConnector(connector).build(); } ``` +#### timeout +如果要设置connection timeout,示例如下: +```java +import io.netty.channel.ChannelOption; + +HttpClient httpClient = HttpClient.create() + .option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 10000); + +WebClient webClient = WebClient.builder() + .clientConnector(new ReactorClientHttpConnector(httpClient)) + .build(); +``` +如果要配置read/write timeout,可以按照如下示例进行配置: +```java +import io.netty.handler.timeout.ReadTimeoutHandler; +import io.netty.handler.timeout.WriteTimeoutHandler; + +HttpClient httpClient = HttpClient.create() + .doOnConnected(conn -> conn + .addHandlerLast(new ReadTimeoutHandler(10)) + .addHandlerLast(new WriteTimeoutHandler(10))); + +// Create WebClient... +``` +为所有请求配置response timeout: +```java +HttpClient httpClient = HttpClient.create() + .responseTimeout(Duration.ofSeconds(2)); + +// Create WebClient... +``` + +为指定的请求配置response timeout: +```java +WebClient.create().get() + .uri("https://example.org/path") + .httpRequest(httpRequest -> { + HttpClientRequest reactorRequest = httpRequest.getNativeRequest(); + reactorRequest.responseTimeout(Duration.ofSeconds(2)); + }) + .retrieve() + .bodyToMono(String.class); +``` + +### 各个超时含义 +再restTemplate等阻塞api中,各个超时的含义如下所示: + +#### readTimeout +会为serverSocket(和server进行通信的socket)设置`SocketOptions.SO_SOCKET`,单位为ms。 + +当`SO_SOCKET`被设置为正数值时,对`socket关联的inputstream`阻塞式调用,将最多阻塞该指定时长。如果调用超时,那么将会抛出`java. net. SocketTimeoutException`,但是socket仍然有效。 + +#### connectTimeout +以ms为单位指定一个超时时长,当与服务端建立连接时,如果超过该时长后连接仍未建立,那么将会抛出`java.net.SocketTimeoutException`异常。 +