如何在spring boot中动态更改@Scheduler cron表达式？

Question

我正在尝试在特定时间调用API。但有时api调用可能会失败，所以我制定了一个逻辑来检查api调用何时失败。

确认api调用失败后，我想将@Schedulercron表达式从当前cron表达式更改为15分钟后。

如何动态更改cron表达式？？

下面是我的API调用代码。

@Scheduled(cron="0 9 19 * * *", zone = "Asia/Seoul")
public void callAPi() throws InterruptedException {

    swrList = new ArrayList<>();
    List<GeoInfo> giList = gs.getGeoXY();
    
    for(GeoInfo gi : giList) {
        
        ShortWeatherReq swr = new ShortWeatherReq(APK.getApiKey(),"1",gi.getX(),gi.getY());
        swr.setBaseDate(); //현재 날짜로 baseDate를 설정하는 메소드를 호출
        swr.setNx(gi.getX()); //x좌표값 저장
        swr.setNy(gi.getY()); //y좌표값 저장
        
        swrList.add(swr); //list에 swr 추가
    }
    
    for(GeoInfo gi : giList) {
        
        ShortWeatherReq swr = new ShortWeatherReq(APK.getApiKey(),"2",gi.getX(),gi.getY());
        swr.setBaseDate(); //현재 날짜로 baseDate를 설정하는 메소드를 호출
        swr.setNx(gi.getX()); //x좌표값 저장
        swr.setNy(gi.getY()); //y좌표값 저장
        
        swrList.add(swr); //list에 swr 추가
    }
    
    //위 객체를 가지고 이제 API를 호출할수 있게 Service에게 전해줘야 함
    sws.setSwrList(swrList);
    
    temperList = sws.callSW(); // API 통신 Service 호출
    
    
    //Confirming API call failure

    if(temperList.isEmpty()) { //온도 리스트가 비어있다면 진입
        logger.warn("TemperList is empty");
        //이제 여기서 메일을 보내주는 서비스를 만들어서 메일 전송을 해줘야 함
        ms.sendErrorMail();
        logger.info("-------------------");
        
        logger.info("API Connection Fail");
    }else {
        logger.info("-------------------");
        
        logger.info("API ConnectionSuccess");
        
        logger.info("-------------------");
        
        //List에 담긴 온도 DB에 저장
        for(int i = 0;i<temperList.size();i++) {
            Temperature temp = temperList.get(i);
            ts.saveTemp(temp);
        }
        
        logger.info("DB Store Success");
    }
}

Answer 1

首先，您应该在应用程序类中激活Spring Retry。

@SpringBootApplication
@EnableScheduling
@EnableRetry
public class App {
    // something
}

然后，您需要将@Retryable添加到您作为@计划的使用的方法中。

@Scheduled(cron="0 9 19 * * *", zone = "Asia/Seoul")
// Add this line
@Retryable(maxAttempts = 3, backoff = @Backoff(delay = 1000), value={ApiCallException.class})
public void callAPi() throws InterruptedException {

    swrList = new ArrayList<>();
    List<GeoInfo> giList = gs.getGeoXY();
    
    for(GeoInfo gi : giList) {
        
        ShortWeatherReq swr = new ShortWeatherReq(APK.getApiKey(),"1",gi.getX(),gi.getY());
        swr.setBaseDate(); //현재 날짜로 baseDate를 설정하는 메소드를 호출
        swr.setNx(gi.getX()); //x좌표값 저장
        swr.setNy(gi.getY()); //y좌표값 저장
        
        swrList.add(swr); //list에 swr 추가
    }
    
    for(GeoInfo gi : giList) {
        
        ShortWeatherReq swr = new ShortWeatherReq(APK.getApiKey(),"2",gi.getX(),gi.getY());
        swr.setBaseDate(); //현재 날짜로 baseDate를 설정하는 메소드를 호출
        swr.setNx(gi.getX()); //x좌표값 저장
        swr.setNy(gi.getY()); //y좌표값 저장
        
        swrList.add(swr); //list에 swr 추가
    }
    
    //위 객체를 가지고 이제 API를 호출할수 있게 Service에게 전해줘야 함
    sws.setSwrList(swrList);
    
    temperList = sws.callSW(); // API 통신 Service 호출
    
    
    //Confirming API call failure

    if(temperList.isEmpty()) { //온도 리스트가 비어있다면 진입
        // Add this line
        throw new ApiCallException("API Connection Fail")
    }else {
        logger.info("-------------------");
        
        logger.info("API ConnectionSuccess");
        
        logger.info("-------------------");
        
        //List에 담긴 온도 DB에 저장
        for(int i = 0;i<temperList.size();i++) {
            Temperature temp = temperList.get(i);
            ts.saveTemp(temp);
        }
        
        logger.info("DB Store Success");
    }
}

这里是使用@Retryable注释设置backoff参数，以设置您想要的下一个运行时。在与BackOffPolicies相关的Spring Retry留档中，定义如下。

在短暂失败后重试时，在重试之前等待一段时间通常会有所帮助，因为通常失败是由某些问题引起的，而这些问题只能通过等待来解决。如果RetryCallback失败，RetryTemplate可以根据BackoffPolicy暂停执行。

您可以在此处找到有关Spring重试的详细信息。

虽然我的答案没有提供动态更改cron语句，但我希望它能解决你的问题。