本文是精讲响应式WebClient第6篇,前篇的blog访问地址如下:
在上一篇我们为大家介绍了WebClient的异常处理方法,我们可以对指定的异常进行处理,也可以分类处理400-499、500-599状态码的HTTP异常。 我们本节为大家介绍的实际上是另外一种异常处理机制:请求失败之后自动重试。当WebClient发起请求,没有得到正常的响应结果,它就会每隔一段时间再次发送请求,可以发送n次,这个n是我们自定义的。n次请求都失败了,最后再将异常抛出,可以通过我们上一节交给大家的方法进行异常处理。也就是针对连接超时异常、读写超时异常等,或者是HTTP响应结果为非正常状态码(不是200状态码段),都在自动重试机制的范畴内。
下面的代码是请求"http://jsonplaceholder.typicode.com" 网站的服务,该网站是一个免费提供HTTP请求测试的服务端网站,我们可以用它测试WebClient。需要注意的是:正常的GET方法请求地址是"/posts/1",我特意的把它写错成为"/postss/1",这样可以触发404资源无法找到的异常。
public class ReTryTest {
@Test
public void testRetry() {
WebClient webClient = WebClient.builder()
.baseUrl("http://jsonplaceholder.typicode.com")
.build();
Mono<String> mono = webClient
.get() //GET 请求
.uri("/postss/1") // 请求路径,注意为了制造异常,这里是错的
.retrieve() //获取请求结果
.bodyToMono(String.class) //用Mono接收单个非集合对象数据
.doOnError(Exception.class, err -> { //处理异常
System.out.println(LocalDateTime.now() + "---发生错误:" +err.getMessage() );
})
.retry(3);
System.out.println("=====" + mono.block());
}
}
下面是doOnError中打印的控制台输出内容,一共打印了4次。(一次失败 + 三次重试失败)
上面的请求重试方法,请求失败之后立即重试,在很短的时间内就完成了3次重试。如果这是在生产环境下,可能你的服务端因为资源紧张造成请求响应超时等异常,这种重试机制无疑会让本就不堪重负的服务端雪上加霜。我们下面交给大家一种为重试设置时间间隔的方法:
.retryBackoff(3, Duration.ofSeconds(5));
源码如下:
上面的retryBackoff方法虽然已经一定程度上缓解了请求重试导致的服务端的压力,但是它还是不分场景的不断重试。
所以说Webclient已经在源码中,将retryBackoff()标记为废弃,建议使用retryWhen()代替它。retryWhen()可以指定针对某些异常进行重试,其他异常不做重试。
为了使用retryWhen(),需要引入下面的包
<dependency>
<groupId>io.projectreactor.addons</groupId>
<artifactId>reactor-extra</artifactId>
</dependency>
为了能够制造请求超时的异常场景,我们给连接超时设置为5毫秒,即:让所有请求一定会超时。(没有任何请求能在5毫秒内完成网络连接)
//认为设置请求超时时间为5毫秒,也就是请求一定会超时,一定会抛出ConnectTimeoutException
TcpClient tcpClient = TcpClient
.create()
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5); //5毫秒
WebClient webClient = WebClient.builder()
.baseUrl("http://jsonplaceholder.typicode.com")
.clientConnector(new ReactorClientHttpConnector(HttpClient.from(tcpClient)))
.build();
用Retry对象定义请求重试的条件,也就是retryWhen的when
Retry<?> retry = Retry.onlyIf(x -> x.exception() instanceof ConnectTimeoutException)
.retryMax(3) // 重试3次
.backoff(Backoff.exponential(Duration.ofSeconds(5),Duration.ofSeconds(60),2,true));
Mono<String> mono = webClient
.get() //GET 请求
.uri("/posts/1") // 请求路径,这里的请求路径是正确的
.retrieve()
.bodyToMono(String.class)
.retryWhen(retry); //满足Retry条件进行重试
System.out.println("=====" + mono.block());
Retry.onlyIf(x -> x.exception() instanceof ConnectTimeoutException)
表示只有针对ConnectTimeoutException连接超市异常才进行请求重试,这里使用了java8的Predicate语法backOff表示重试的时间间隔
喜欢 (0)or分享 (0)