Spring Retry教程(2)-注解方式的实现

    org.springframework.retry
    spring-retry
    1.2.5.RELEASE



    org.springframework
    spring-aspects
    5.2.8.RELEASE

@Configuration
@EnableRetry
public class AppConfig { ... }

或

@SpringBootApplication
@EnableRetry
public class Application

• value：指定处理的异常类，默认为空
• include：指定处理的异常类，默认为空，当include和exclude为空时，默认所有异常
• exclude：指定哪些异常不处理，默认空
• maxAttempts：最大重试次数。默认3次

补偿策略处理的是两次重试之间的时间间隔问题。

• delay：指定等待时间，没有设置的话默认为1000ms
• maxDelay：最大重试时间，没有设置默认为3000ms
• multiplier：下一次调用时间的乘数
• random：随机等待时间，默认值为false

@Service
public class SpringRetryService{
    private static final Logger LOGGER = LoggerFactory.getLogger(SpringRetryService.class);

    @Retryable(value = {Exception.class},exclude={}, maxAttempts = 5, backoff =@Backoff(value = 1000,multiplier = 2))
    public void testRetry() throws Exception {
        boolean result = false;
        SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        try {
            LOGGER.info("重试方法被调用，当前时间是" + sdf.format(new Date()));
            int i = 9 / 0;
        } catch (Exception e) {
            throw new Exception("重试之后，还是失败了！", e);
        }
    }
    @Recover
    public void testRecovery(Exception e) {
        
        LOGGER.warn("重试5次依旧失败了！"+e.getMessage());
    }
}

@RestController
@RequestMapping("/springRetry")
public class SpringRetryController {
    private static final Logger LOG = LoggerFactory.getLogger(SpringRetryController.class);
    @Autowired
    private SpringRetryService pringRetryService;
    @RequestMapping("/testSpringRetry")
    public String testSpringRetry() {
        LOG.info("invoke method testSpringRetry! ");
        try {
            pringRetryService.testRetry();
        } catch (Exception e) {
            LOG.error("重试失败了", e);
        }
        return " retry success";
    }
}