doc: 阅读webflux文档

This commit is contained in:
asahi
2025-04-25 12:38:40 +08:00
parent 6a6dfd5bed
commit 521d591047

View File

@@ -94,3 +94,58 @@ public WebClient webClient() {
return WebClient.builder().clientConnector(connector).build(); 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`异常。