01-Spring实现重试和降级机制

主要用于在模块调用中，出现失败、异常情况下，仍需要进行重复调用。并且在最终调用失败时，可以采用降级措施，返回一般结果。

1、重试机制

我们采用spring 提供的retry 插件，其原理采用aop机制，所以需要额外引入starter-aop包

1、依赖引入

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-aop</artifactId>
</dependency>
<dependency><groupId>org.springframework.retry</groupId><artifactId>spring-retry</artifactId>
</dependency>

2、在主启动类或者需要重试的方法所在的类上添加注解@EnableRetry

3、在需要重试的方法上增加注解 @Retryable，表示该方法需要重试。可以定义在接口的抽象方法上，也可以定义在实际的具体方法上。

public interface RetryService {/*** 指定异常CustomRetryException重试，重试最大次数为4（默认是3）,重试补偿机制间隔200毫秒* 还可以配置exclude,指定异常不重试，默认为空* @return result* @throws CustomRetryException 指定异常*/@Retryable(value = {CustomRetryException.class},maxAttempts = 4,backoff = @Backoff(200))String retry() throws CustomRetryException;
}

@Retryable注解参数说明：

maxAttempts :最大重试次数，默认为3，如果要设置的重试次数为3，可以不写；

value：抛出指定异常才会重试，支持多异常

include：和value一样，默认为空，当exclude也为空时，默认所以异常

exclude：指定不处理的异常

backoff：重试等待时间策略，默认使用@Backoff的value默认为1000L，我们设置为200L。

@Backoff注解中的参数说明：

value：隔多少毫秒后重试，默认为1000L；

delay：和value一样，但是默认为0；

multiplier（指定延迟倍数）默认为0，表示固定暂停1秒后进行重试，如果把multiplier设置为1.5，则第一次重试为2秒，第二次为3秒，第三次为4.5秒。

④可以同时在同一个类中使用@Recover来处理N次处理后都没有成功后需要处理的事情

可以在指定方法上标记@Recover来开启重试失败后调用的方法(注意,需跟重处理方法在同一个类中)

2、请求降级

使用@Recover实现降级措施

当重试到达指定次数时，被注解的方法将被回调，可以在该方法中进行日志处理。需要注意的是发生的异常和入参类型一致时才会回调。

@Retryable和@Recover修饰的方法要在同一个类中,且被@Retryable 标记的方法不能有返回值，这样Recover方法才会生效。

/*** value：抛出指定异常才会重试* include：和value一样，默认为空，当exclude也为空时，默认所有异常* exclude：指定不处理的异常* maxAttempts：最大重试次数，默认3次* backoff：重试等待策略，* 默认使用@Backoff，@Backoff的value默认为1000L，我们设置为2000； 以毫秒为单位的延迟（默认 1000）* multiplier（指定延迟倍数）默认为0，表示固定暂停1秒后进行重试，如果把multiplier设置为1.5，则第一次重试为2秒，第二次为3秒，第三次为4.5秒。* @param code* @return* @throws Exception*/@Override@Retryable(value = Exception.class,maxAttempts = 3,backoff = @Backoff(delay = 2000,multiplier = 1.5))public int testRetry(int code) throws Exception{System.out.println("test被调用,时间："+ LocalTime.now());if (code==0){throw new Exception("情况不对头！");}System.out.println("test被调用,情况对头了！");return 200;} /*** Spring-Retry还提供了@Recover注解，用于@Retryable重试失败后处理方法。* 如果不需要回调方法，可以直接不写回调方法，那么实现的效果是，重试次数完了后，如果还是没成功没符合业务判断，就抛出异常。* 可以看到传参里面写的是 Exception e，这个是作为回调的接头暗号（重试次数用完了，还是失败，我们抛出这个Exception e通知触发这个回调方法）。* 注意事项：* 方法的返回值必须与@Retryable方法一致* 方法的第一个参数，必须是Throwable类型的，建议是与@Retryable配置的异常一致，其他的参数，需要哪个参数，写进去就可以了（@Recover方法中有的）* 该回调方法与重试方法写在同一个实现类里面** 由于是基于AOP实现，所以不支持类里自调用方法* 如果重试失败需要给@Recover注解的方法做后续处理，那这个重试的方法不能有返回值，只能是void* 方法内不能使用try catch，只能往外抛异常* @Recover注解来开启重试失败后调用的方法(注意,需跟重处理方法在同一个类中)，此注解注释的方法参数一定要是@Retryable抛出的异常，否则无法识别，可以在该方法中进行日志处理。* @param e* @param code* @return*/@Recoverpublic int recover(Exception e, int code){System.out.println("回调方法执行！！！！");//记日志到数据库 或者调用其余的方法System.out.println("异常信息:"+e.getMessage());return 400;} 

3、 RetryTemplate

对每个方法上进行注解定义以及对应降低方法定义，过于繁琐。

spring 提供 retryTemplate 的bean对象，定义一个可重试、降级的代理对象。

RetryTemplate提供了RetryOperations的一种具体实现。它被认为是从中创建bean的良好做法。

1、定义retryTemplate对象

    @Bean@ConditionalOnMissingBeanpublic RetryTemplate retryTemplate(){final SimpleRetryPolicy simpleRetryPolicy = new SimpleRetryPolicy();simpleRetryPolicy.setMaxAttempts(4);
​final FixedBackOffPolicy fixedBackOffPolicy = new FixedBackOffPolicy();fixedBackOffPolicy.setBackOffPeriod(1000L);
​return RetryTemplate.builder().customPolicy(simpleRetryPolicy).customBackoff(fixedBackOffPolicy).retryOn(CustomRetryException.class).build();}

 2、使用retryTemplate

@Autowiredpivate RetryTemplate retryTemplate;
​@Testvoid retryWithoutAnnotation(){try {String message = retryTemplate.execute(x -> retryService.retryWithoutAnnotation());log.info("message = "+message);} catch (CustomRetryException e) {log.error("Error while executing test {}",e.getMessage());}}

3、RecoveryCallback 降级

execute时，可以选择输入RecoveryCallback回调，确定重试结束后，仍然出现异常的recovery行为。自定义方法如下：

@Slf4j
public class CustomRecoveryCallback implements RecoveryCallback<String> {
​@Overridepublic String recover(RetryContext retryContext) throws Exception {log.info("Default Retry service test,total retry {}",retryContext.getRetryCount());return "Error Class :: " + retryContext.getLastThrowable().getClass().getName();}
}

4、RetryListenerSupport生命周期控制

如果我们想在重试整个生命周期中，按照不同的阶段设置一些事件监听处理机制，那怎么办呢？设置自定义的RetryListenerSupport能帮助到我们。我们继承RetryListenerSupport，并重新Override close 、onError、open方法，这三个方法分别表示

• 所有重试结束时 close
• 每一次重试发生异常时 onError
• 重试正式开始前 open

@Slf4j
public class DefaultListenerSupport extends RetryListenerSupport {
​@Overridepublic <T, E extends Throwable> void close(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {log.info("DefaultListenerSupport close");super.close(context, callback, throwable);}
​@Overridepublic <T, E extends Throwable> void onError(RetryContext context, RetryCallback<T, E> callback, Throwable throwable) {log.info("DefaultListenerSupport onError");super.onError(context, callback, throwable);}
​@Overridepublic <T, E extends Throwable> boolean open(RetryContext context, RetryCallback<T, E> callback) {log.info("DefaultListenerSupport open");return super.open(context, callback);}
}

 并且在构造RetryTemaplate时候，设置withListener字段。

@Bean
@ConditionalOnMissingBean
public RetryListenerSupport retryListenerSupport(){return new DefaultListenerSupport();
}
​
@Bean
@ConditionalOnMissingBean
public RetryTemplate retryTemplate(RetryListenerSupport retryListenerSupport){
​...return RetryTemplate.builder().customPolicy(simpleRetryPolicy).customBackoff(fixedBackOffPolicy).withListener(retryListenerSupport).retryOn(CustomRetryException.class).build();
}