共计 3676 个字符，预计需要花费 10 分钟才能阅读完成。
本文是精讲响应式 WebClient 第 5 篇，前篇的 blog 拜访地址如下：
- 精讲响应式 webclient 第 1 篇 - 响应式非阻塞 IO 与根底用法
- 精讲响应式 WebClient 第 2 篇 -GET 申请阻塞与非阻塞调用办法详解
- 精讲响应式 WebClient 第 3 篇 -POST、DELETE、PUT 办法应用
- 精讲响应式 WebClient 第 4 篇 - 文件上传与下载
本文来为大家介绍一下，当 WebClient 申请产生异样的时候，该如何解决。为了解说异样解决，咱们须要先制作出异样，所以咱们先为大家介绍：申请超时时长的设置。
一、申请超时时长的设置
要想模仿超时异样，咱们首先要晓得超时时长的失常配置渠道是怎么样的。如下文代码所示：
ChannelOption.CONNECT_TIMEOUT_MILLIS用来设置连贯超时时长, 单位是毫秒ReadTimeoutHandler(5000, TimeUnit.MILLISECONDS)用来设置读数据超时时长, 单位是毫秒WriteTimeoutHandler(5000, TimeUnit.MILLISECONDS)用来设置写数据超时时长, 单位是毫秒
// 初始化一个 WebClient
private WebClient getWebClient(){
TcpClient tcpClient = TcpClient
.create()
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5000)
.doOnConnected(connection -> {connection.addHandlerLast(new ReadTimeoutHandler(5000, TimeUnit.MILLISECONDS));
connection.addHandlerLast(new WriteTimeoutHandler(5000, TimeUnit.MILLISECONDS));
});
return WebClient.builder()
.baseUrl("http://jsonplaceholder.typicode.com")
.clientConnector(new ReactorClientHttpConnector(HttpClient.from(tcpClient)))
.build();}当咱们把连贯超时时长设置为 5(毫秒)的时候，则连贯必定会超时。轻易发送一个申请，超时之后会抛出 ConnectTimeoutException
当咱们把读数据超市时长设置为 5(毫秒)的时候，则数据读操作必定会超时。轻易发送一个申请，超时之后会抛出 ReadTimeoutException
二、解决特定的异样
上面咱们就以 ConnectTimeoutException 为例，进行异样解决
// 制作异样，将超时工夫设置为 5 毫秒
.option(ChannelOption.CONNECT_TIMEOUT_MILLIS, 5)而后执行上面的 GET 申请，上文 WebClient 的 baseurl 为：”http://jsonplaceholder.typicode.com”，该网站是一个收费提供 HTTP 服务端测试的网站。
@Test
public void testSimple() throws Exception {Mono<String> mono = getWebClient()
.get() // 发送 GET 申请
.uri("/posts/1") // 服务申请门路，基于 baseurl
.retrieve() // 获取响应体
.bodyToMono(String.class) // 响应数据类型转换
// 进行异样解决
.doOnError(ConnectTimeoutException.class, err -> {System.out.println("产生谬误：" +err.getMessage() );
});
System.out.println(mono.block());
}上文中的 doOnError 是咱们本节为大家介绍的异样解决办法，用于解决 ConnectTimeoutException，输入后果如下：
从输入后果上看：一：异样失去解决，因为看到了 System.out 打印日志。二是异样依然被抛出了，没有失去返回值。
三、申请异样给出默认返回值
从第二大节中的代码及控制台输入，能够看出 HTTP 客户端申请没有失去返回值，而是持续把异样对外抛出。如果咱们目前的需要是，不管申请成功失败，都给客户端一个返回值，该怎么做？也就是说咱们须要在申请产生异样的时候，给出默认返回值。
@Test
public void testReturn() throws Exception {Mono<String> mono = getWebClient()
.get() // 发送 GET 申请
.uri("/posts/1") // 服务申请门路，基于 baseurl
.retrieve() // 获取响应体
.bodyToMono(String.class) // 响应数据类型转换
.doOnError(ConnectTimeoutException.class, err -> {System.out.println("产生谬误：" +err.getMessage() );
})
.onErrorReturn("申请产生异样，请查看！");
System.out.println(mono.block());
}应用 onErrorReturn(); 给出申请的默认返回值，输入后果如下：
能够看到申请测试用例胜利 pass 了，因为咱们给出了异样解决的默认返回值，没有把异样持续抛出。
四、分类异样解决
下面的异样解决办法，只能解决指定的某种异样：ConnectTimeoutException。如果说咱们想让异样解决绝对通用一些该怎么办？有的小伙伴可能会想到拦挡异样的父类 Exception，当然这也是一种方法。
.doOnError(Exception.class, err -> {System.out.println("产生谬误：" +err.getMessage() );
});咱们上面为大家介绍一种，针对 HTTP 响应异样解决更敌对的一种形式。通常来说，异样能够分为两种：
- 一种是客户端输出或拜访异样，比方：拜访的资源不存在 404，没有权限拜访资源 403，输出的数据不合乎格局等等。这种异样通常是用户拜访了不该拜访的资源，或者输出了不该输出的数据导致的。通常用 HTTP 状态码示意在 400-499 范畴内。
- 另一种是服务端外部谬误，比方：500 服务外部谬误、502 网关谬误等等。这种异样通常和用户没什么关系，是 IT 基础设施或者编程导致的异样。
所以咱们只须要针对下面的两类异样进行解决即可。如下文代码所示：
- e.is4xxClientError()示意的是 400-499 状态码段的异样
- e.is5xxClientError()示意的是 500-599 状态码段的异样
public void testSimple2() throws Exception {Mono<String> mono = getWebClient()
.get() // 发送 GET 申请
.uri("/postss/1") // 服务申请门路，基于 baseurl
.retrieve() // 获取响应体
.onStatus(e -> e.is4xxClientError(), resp -> {System.out.println("产生客户端输出谬误：" + resp.statusCode().value() + " "
+ resp.statusCode().getReasonPhrase());
return Mono.error(new RuntimeException("申请失败"));
})
.onStatus(e -> e.is5xxServerError(), resp -> {System.out.println("产生服务端谬误：" + resp.statusCode().value() + " "
+ resp.statusCode().getReasonPhrase());
return Mono.error(new RuntimeException("服务器异样"));
})
.bodyToMono(String.class); // 响应数据类型转换
System.out.println(mono.block());
}当初咱们将申请地址由正确的 ”/posts/1″，改成谬误的 ”/postss/1″，所以当咱们拜访服务端的时候，服务端并不存在这个资源。异样解决的输入后果如下：
欢送关注我的博客，外面有很多精品合集
- 本文转载注明出处（必须带连贯，不能只转文字）：字母哥博客。
感觉对您有帮忙的话，帮我点赞、分享！您的反对是我不竭的创作能源！。另外，笔者最近一段时间输入了如下的精品内容，期待您的关注。
- 《手摸手教你学 Spring Boot2.0》
- 《Spring Security-JWT-OAuth2 一本通》
- 《实战前后端拆散 RBAC 权限管理系统》
- 《实战 SpringCloud 微服务从青铜到王者》
- 《VUE 深入浅出系列》
