[java] Quartz Scheduler의 작업 재시도 기능

16 Nov 2023

java

Quartz Scheduler는 Java 기반의 오픈 소스 작업 스케줄링 프레임워크입니다. 작업을 예약하고 실행하기 위해 많이 사용되며, 내장된 기능 중 하나는 작업 재시도 기능입니다. 이 기능을 사용하면 작업이 실패할 경우 자동으로 재시도할 수 있습니다.

작업 재시도 설정하기

작업을 재시도하려면, Quartz Scheduler의 Job 클래스를 작성하고 해당 클래스에 @DisallowConcurrentExecution 어노테이션을 추가해야 합니다. 그리고 재시도 가능한 작업은 JobExecutionContext 객체에서 getRefireCount() 메소드를 사용하여 현재 재시도 횟수를 알 수 있습니다.

import org.quartz.*;

@DisallowConcurrentExecution
public class MyJob implements Job {

    public void execute(JobExecutionContext context) throws JobExecutionException {
        
        int retryCount = context.getRefireCount();
        
        if (retryCount < 3) {
            // 작업 실행
        } else {
            // 최대 재시도 횟수 초과
        }
    }
}

위의 예제에서는 작업이 최대 3번의 재시도를 시도하고, 그 이상인 경우에는 최대 재시도 횟수를 초과한 것으로 처리합니다.

재시도 간격 설정하기

작업 재시도 간격을 설정하려면, Quartz Scheduler의 Trigger 클래스를 사용해야 합니다. SimpleTrigger 클래스를 사용하여 간단한 방식으로 설정할 수 있습니다. withIntervalInSeconds() 메소드를 사용하여 재시도 간격을 초 단위로 설정합니다.

import org.quartz.*;

public class MyJobScheduler {

    public static void main(String[] args) throws Exception {
        
        JobDetail job = JobBuilder.newJob(MyJob.class)
                .withIdentity("myJob")
                .build();
        
        Trigger trigger = TriggerBuilder.newTrigger()
                .withIdentity("myTrigger")
                .withSchedule(SimpleScheduleBuilder.simpleSchedule()
                        .withIntervalInSeconds(30)
                        .repeatForever())
                .build();
        
        Scheduler scheduler = new StdSchedulerFactory().getScheduler();
        scheduler.start();
        scheduler.scheduleJob(job, trigger);
    }
}

위의 예제에서는 작업을 30초 간격으로 반복하여 실행하도록 설정했습니다. 작업이 실패하면 30초 후에 재시도됩니다.

그 외 재시도 설정 옵션

Quartz Scheduler에서는 작업 재시도에 대한 다양한 설정 옵션을 제공합니다. 아래는 몇 가지 예시입니다.

withMisfireHandlingInstructionIgnoreMisfires(): 작업이 예정된 시간에 실행되지 못한 경우 놓친 작업을 무시합니다.
withMisfireHandlingInstructionNowWithExistingCount(): 작업이 예정된 시간에 실행되지 못한 경우 놓친 작업을 즉시 실행합니다.

자세한 내용은 Quartz Scheduler 공식 문서를 참조하시기 바랍니다.