时间戳

首页 > 解决方案 > 当我们使用 RetryTemplate 时 Spring Retry 不起作用？

java - 当我们使用 RetryTemplate 时 Spring Retry 不起作用？

问题描述

我通过参考以下课程来开发重试机制。下面是我在 Spring Batch 中开发的代码，在这个代码@Recover方法中没有被调用。我在这里做错了什么？

@EnableRetry
@Configuration
public class RetryConfig {
    @Value("${retry.interval.in.seconds}")
    private long retryIntervalInSeconds;

    @Value("${max.attempts}")
    private int attempts;
    
    @Bean
    public RetryTemplate mdsRetryTemplate() {
        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
        retryPolicy.setMaxAttempts(attempts);

        FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
        backOffPolicy.setBackOffPeriod(1000 * retryIntervalInSeconds);
        
        RetryTemplate template = new RetryTemplate();
        template.setRetryPolicy(retryPolicy);
        template.setBackOffPolicy(backOffPolicy);
        return template;
    }
}

下面是控制器

@RestController
@Slf4j
public class BatchJobController {

    @Autowired
    private JobLauncher jobLauncher;

    @Autowired
    @Qualifier(value = "sampleAcctJob")
    private Job sampleAcctJob;


    @Autowired
    private RetryTemplate retryTemplate;

    @GetMapping(value = "/invoke-job")
    public String handle() throws Throwable {

        long diff = 0;
        JobExecution je= this.invokeJob();
        Date start = je.getCreateTime();
        Date end = je.getEndTime();

        diff = end.getTime() - start.getTime();

        return "All data has been loaded successfully.";
    }

    private JobExecution invokeJob() throws Throwable {
        // PDF Job
        JobParameters pdfParams = new JobParametersBuilder()
                .addString(".id", String.valueOf(System.currentTimeMillis()))
                .addDate("date", new Date()).toJobParameters();

        return retryTemplate.execute(retryContext  -> {
            JobExecution jobExecution = jobLauncher.run(sampleAcctJob, pdfParams);
            if(!jobExecution.getAllFailureExceptions().isEmpty()) {
                log.error("============== sampleAcctJob Job failed, retrying.... ================");
                throw jobExecution.getAllFailureExceptions().iterator().next();
            }
            logDetails(jobExecution);
            return jobExecution;
        });
    }

    private void logDetails(JobExecution jobExecution) {
        log.info("JOB_NAME = {}, JOB_STATUS = {}, START_TIME={}, END_TIME = {} ", 
                jobExecution.getJobInstance().getJobName(), 
                jobExecution.getStatus(),
                jobExecution.getStartTime(), 
                jobExecution.getEndTime());
    }
    
    @Recover
    private void recover() {
        System.out.println("===============");
    }
}

标签： javaspringspring-batchspring-retry

解决方案

您正在retryTemplate以编程方式使用 ，因此您需要提供RecoveryCallback第二个参数：

  retryTemplate.execute(new MyRetryCallback(), new MyRecoveryCallback());

如果你想使用使用注解的声明式方法，你需要用 .注解可重试方法@Retryable和用 .recovery 方法注解@Recover。

您可以在主页中找到每种方法的示例：https ://github.com/spring-projects/spring-retry#quick-start

推荐阅读