1、添加maven依赖
<dependency><groupId>org.springframework.retry</groupId><artifactId>spring-retry</artifactId></dependency><dependency><!--如果其他的依赖已经引入了,可以不加--><groupId>org.aspectj</groupId><artifactId>aspectjweaver</artifactId></dependency>
2、在启动类新增@EnableRetry注解
3、在需要执行的方法上新增@Retryable注解
@Retryable(maxAttempts = 3,retryFor ={RuntimeException.class},noRetryFor = {NullPointerException.class},recover ="recover",backoff = @Backoff(delay = 2000,multiplier = 1.5))public String retryTest(){System.out.println("测试调用");throw new RuntimeException("RPC调用异常");//return "OK";}@Recoverpublic String recover(RuntimeException e){System.out.println("recover-->记日志到数据库 或者调用其余的方法");return "OK";}
4、参数解释
4.1 maxAttempts重试次数
4.2 retryFor对哪些异常进行重试
4.3 noRetryFor对哪些异常不重试
4.4 recover,当重试耗尽时,RetryOperations可以将控制传递给另一个回调,即RecoveryCallback。Spring-Retry还提供了@Recover注解,用于@Retryable重试失败后处理方法。如果不需要回调方法,可以直接不写回调方法,那么实现的效果是,重试次数完了后,如果还是没成功没符合业务判断,就抛出异常。注:回调函数与原始重试函数的返回值必须一致
4.5 backoff:重试等待策略,默认使用@Backoff,@Backoff的value默认为1000L,我们设置为2000; 以毫秒为单位的延迟(默认 1000),multiplier(指定延迟倍数)默认为0,表示固定暂停1秒后进行重试,如果把multiplier设置为1.5,则第一次重试为2秒,第二次为3秒,第三次为4.5秒。