本文是精讲响应式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)用来设置写数据超时时长,单位是毫秒
//初始化一个WebClientprivate 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服务端测试的网站。

@Testpublic 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 客户端申请没有失去返回值,而是持续把异样对外抛出。如果咱们目前的需要是,不管申请成功失败,都给客户端一个返回值,该怎么做?也就是说咱们须要在申请产生异样的时候,给出默认返回值。

@Testpublic 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深入浅出系列》