精讲RestTemplate第8篇-请求失败自动重试机制

原创
08/15 12:03
阅读数 6.1K

本文是精讲RestTemplate第8篇,前篇的blog访问地址如下:

在上一节我们为大家介绍了,当RestTemplate发起远程请求异常时的自定义处理方法,我们可以通过自定义的方式解析出HTTP Status Code状态码,然后根据状态码和业务需求决定程序下一步该如何处理。 本节为大家介绍另外一种通用的异常的处理机制:那就是自动重试。也就是说,在RestTemplate发送请求得到非200状态结果的时候,间隔一定的时间再次发送n次请求。n次请求都失败之后,最后抛出HttpClientErrorException。 在开始本节代码之前,将上一节的RestTemplate自定义异常处理的代码注释掉,否则自动重试机制不会生效。如下(参考上一节代码):

//restTemplate.setErrorHandler(new MyRestErrorHandler());

一、Spring Retry配置生效

通过maven坐标引入spring-retry,spring-retry的实现依赖于面向切面编程,所以引入aspectjweaver。以下配置过程都是基于Spring Boot应用。

<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
    <version>1.2.5.RELEASE</version>
</dependency>
<dependency>
   <groupId>org.aspectj</groupId>
   <artifactId>aspectjweaver</artifactId>
</dependency>

在Spring Boot 应用入口启动类,也就是配置类的上面加上@SpringRetry注解,表示让重试机制生效。

二、使用案例

[@Service](https://my.oschina.net/service)
public class RetryService {


  [@Resource](https://my.oschina.net/u/929718)
  private RestTemplate restTemplate;

  private static final DateTimeFormatter DATE_TIME_FORMATTER = DateTimeFormatter.ofPattern("yyyy-MM-dd HH:mm:ss");


  @Retryable(value = RestClientException.class, maxAttempts = 3,
          backoff = @Backoff(delay = 5000L,multiplier = 2))
  public HttpStatus testEntity() {
    System.out.println("发起远程API请求:" + DATE_TIME_FORMATTER.format(LocalDateTime.now()));
    
    String url = "http://jsonplaceholder.typicode.com/postss/1";
    ResponseEntity<String> responseEntity
            = restTemplate.getForEntity(url, String.class);

    return responseEntity.getStatusCode(); // 获取响应码
  }


}
  • @Retryable注解的方法在发生异常时会重试,参数说明:
    • value:当指定异常发生时会进行重试 ,HttpClientErrorException是RestClientException的子类。
    • include:和value一样,默认空。如果 exclude也为空时,所有异常都重试 
    • exclude:指定异常不重试,默认空。如果 include也为空时,所有异常都重试 
    • maxAttemps:最大重试次数,默认3 
    • backoff:重试等待策略,默认空
  • @Backoff注解为重试等待的策略,参数说明:
    • delay:指定重试的延时时间,默认为1000毫秒
    • multiplier:指定延迟的倍数,比如设置delay=5000,multiplier=2时,第一次重试为5秒后,第二次为10(5x2)秒,第三次为20(10x2)秒。

写一个测试的RetryController 对RetryService 的testEntity方法进行调用

@RestController
public class RetryController {
 
    @Resource
    private RetryService retryService;
 
    @GetMapping("/retry")
    public HttpStatus test() {
        return retryService.testEntity();
    }
}

三、测试结果

http://localhost:8080/retry 发起请求,结果如下:

从结果可以看出:

  • 第一次请求失败之后,延迟5秒后重试
  • 第二次请求失败之后,延迟10秒后重试
  • 第三次请求失败之后,抛出异常

欢迎关注我的博客,里面有很多精品合集

  • 本文转载注明出处(必须带连接,不能只转文字):字母哥博客

觉得对您有帮助的话,帮我点赞、分享!您的支持是我不竭的创作动力! 。另外,笔者最近一段时间输出了如下的精品内容,期待您的关注。

展开阅读全文
打赏
0
11 收藏
分享
加载中
精讲RestTemplate第9篇-如何通过HTTP Basic Auth认证,已经发布:http://www.zimug.com/java/spring/%e7%b2%be%e8%ae%b2resttemplate%e7%ac%ac9%e7%af%87-%e5%a6%82%e4%bd%95%e9%80%9a%e8%bf%87http-basic-auth%e8%ae%a4%e8%af%81/.html
08/16 14:24
回复
举报
更多评论
打赏
1 评论
11 收藏
0
分享
返回顶部
顶部