精讲响应式WebClient第5篇-请求超时设置与异常处理
本文是精讲响应式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",所以当我们访问服务端的时候,服务端并不存在这个资源。异常处理的输出结果如下:
喜欢 (0)or分享 (0)
- php实现图形计算器
- Selenium2+python自动化73-定位的坑:class属性有空格
- 华中农业大学第五届程序设计大赛网络同步赛题解
- Java构造方法与析构方法实例剖析
- 5.训练模型之利用训练的模型识别物体
- KMP算法学习(详解)
- 查找算法的实现(C/C++实现)
- HDU 1495 非常可乐(数论,BFS)
- Selenium2+python自动化74-jquery定位
- 用php实现简单的自制计算器
- Selenium2+python自动化75-Chrome配置加载
- Selenium2+python自动化75-非input文件上传(SendKeys)
- python接口自动化11-post传data参数案例
- POJ 1321 棋盘问题(DFS板子题,简单搜索练习)
- HTML 教程
- HTML 简介
- html div 标签介绍
- html span 标签介绍
- html a 超链接标签
- HTML Br换行标签介绍
- HTML P段落标签介绍
- HTML br与p标签区别
- Html H 标题标签
- html px em pt长度单位
- HTML form 标签
- HTML radio 单选框
- HTML B 加粗标签
- HTML strong加粗粗体标签
- HTML em 强调标签
- HTML i 斜体标签
- HTML u下划线标签
- HTML s 删除线标签
- Html img 图片标签
- Html上标注sup与下标注sub标签
- HTML nobr 禁止换行标签
- HTML hr 水平线标签
- HTML label 标签
- HTML input 标签
- HTML textarea 标签
- HTML select下拉列表标签
- HTML checkbox 多选框
- HTML font color 标签
- HTML iframe 框架标签
- HTML Table 表格
- HTML dl dt dd 标签
- HTML ol li有序列表标签
- HTML ul li 无序列表标签
- HTML 注释
- CSS 教程
- CSS 简介
- CSS 语法
- CSS Id 和 Class选择器
- CSS 样式的创建
- CSS background 背景介绍
- CSS 文本样式
- CSS font 字体
- CSS A 链接
- CSS ul ol列表样式
- CSS TABLE 样式
- CSS 框模型
- CSS border 边框
- CSS Outlines 轮廓
- CSS 外边距 Margin
- CSS Padding 内边距
- CSS 分组和嵌套选择器
- CSS 尺寸 (Dimension)
- CSS Display 属性
- CSS Position 定位
- CSS Float 浮动
- CSS 水平对齐(Horizontal Align)
- CSS 组合选择符
- CSS 伪类
- CSS 伪元素
- CSS 导航栏
- CSS 下拉菜单
- CSS 图片廊
- CSS 图像透明/不透明
- CSS sprite 图像拼合技术
- CSS 媒体类型
- CSS 属性选择器
- CSS 实例