关于spring:精讲RestTemplate第8篇请求失败自动重试机制

70次阅读

共计 2678 个字符,预计需要花费 7 分钟才能阅读完成。

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

  • 精讲 RestTemplate 第 1 篇 - 在 Spring 或非 Spring 环境下如何应用
  • 精讲 RestTemplate 第 2 篇 - 多种底层 HTTP 客户端类库的切换
  • 精讲 RestTemplate 第 3 篇 -GET 申请应用办法详解
  • 精讲 RestTemplate 第 4 篇 -POST 申请办法应用详解
  • 精讲 RestTemplate 第 5 篇 -DELETE、PUT 等申请办法应用详解
  • 精讲 RestTemplate 第 6 篇 - 文件上传下载与大文件流式下载
  • 精讲 RestTemplate 第 7 篇 - 自定义申请失败异样解决

在上一节咱们为大家介绍了,当 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 注解,示意让重试机制失效。

二、应用案例

  • 写一个模仿的业务类 RetryService,在其外面注入 RestTemplate。RestTemplate 实例化 Bean 配置参考:《精讲 RestTemplate 第 1 篇 - 在 Spring 或非 Spring 环境下如何应用》和《精讲 RestTemplate 第 2 篇 - 多种底层 HTTP 客户端类库的切换》进行实现。
  • 将正确的申请服务地址由“/posts/1”改成“/postss/1”。服务不存在所以抛出 404 异样,是为了触发重试机制。
@Service
public class RetryService {


  @Resource
  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(5×2) 秒,第三次为 20(10×2) 秒。

写一个测试的 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 秒后重试
  • 第三次申请失败之后,抛出异样

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

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

感觉对您有帮忙的话,帮我点赞、分享!您的反对是我不竭的创作能源!。另外,笔者最近一段时间输入了如下的精品内容,期待您的关注。

  • 《手摸手教你学 Spring Boot2.0》
  • 《Spring Security-JWT-OAuth2 一本通》
  • 《实战前后端拆散 RBAC 权限管理系统》
  • 《实战 SpringCloud 微服务从青铜到王者》
  • 《VUE 深入浅出系列》

正文完
 0