日日操夜夜添-日日操影院-日日草夜夜操-日日干干-精品一区二区三区波多野结衣-精品一区二区三区高清免费不卡

本文介紹了當(dāng)我們使用RetryTemplate時(shí)，Spring重試不起作用嗎？的處理方法，對(duì)大家解決問(wèn)題具有一定的參考價(jià)值，需要的朋友們下面隨著小編來(lái)一起學(xué)習(xí)吧！

問(wèn)題描述

我通過(guò)引用from the following course開(kāi)發(fā)了一個(gè)重試機(jī)制。下面是我在Spring Batch中開(kāi)發(fā)的代碼，在這個(gè)代碼中@Recover方法沒(méi)有被調(diào)用。我在這里做錯(cuò)了什么？

@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("===============");
    }
}

推薦答案

您正在以編程方式使用retryTemplate，因此需要提供RecoveryCallback作為第二個(gè)參數(shù)：

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

如果要使用使用注釋的聲明方式，則需要用@Retryable注釋可重試方法，用@Recover注釋恢復(fù)方法。

您可以在主頁(yè)中找到每種方法的示例：https://github.com/spring-projects/spring-retry#quick-start

這篇關(guān)于當(dāng)我們使用RetryTemplate時(shí)，Spring重試不起作用嗎？的文章就介紹到這了，希望我們推薦的答案對(duì)大家有所幫助，