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

17次阅读

共计 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());

通过 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 发动申请，后果如下：

从后果能够看出：