📖 학습 자료 : https://adjh54.tistory.com/170

문제 상황

• 거래 단계 변경
  • 거래 단계를 ‘제작 완료(PRODUCTION_COMPLETED)’로 변경 후, 7일 뒤 자동으로 ‘거래 완료(COMPLETED)’로 단계로 변경하는 로직이 필요함
• 월 단위 자재 정보(단가 및 재고) 데이터 생성
  • 월 단위 자재 분석 데이터 조회 시, 해당 월의 자재 정보 데이터가 필요함 → 데이터가 존재하지 않는 상태에서 조회 시, 자재 정보 데이터의 부재로 인한 예외 발생 → 스케줄러를 통해 매월 초, 이번 달에 필요한 자재 정보 데이터를 자동 생성하는 로직이 필요함

Quartz를 사용한 이유

• 복잡한 스케줄링 : Quartz는 복잡한 스케줄링 요구사항을 쉽게 구현할 수 있도록 한다.
• 지속성 지원 : 스케줄링 작업 데이터를 DB에 저장하여 애플리케이션을 재시동 하여도 지속적인 스케줄링 지원이 가능하다.
• 유연한 트리거 옵션 : 정확한 타이밍으로 작업을 실행할 수 있다. 또한, 동적으로 작업 실행 시점을 설정할 수 있다.

Quartz vs Spring Batch

Quartz 를 활용한 스케줄링 생성 및 삭제

• 스케줄링 생성 및 삭제 서비스 코드

@RequiredArgsConstructor
@Service
public class ScheduleService {

    private final SchedulerFactoryBean schedulerFactoryBean;

		// 스케줄링 생성 로직
    private void addJob(JobRequest jobRequest, Class<? extends Job> jobClass) {
				// Job 을 실행시키는 Trigger 생성
        Trigger trigger = JobUtil.createTrigger(jobRequest);
        
        // Job 생성을 위한 JobDetail 객체 생성
        JobDetail jobDetail = JobUtil.createJob(jobRequest, jobClass);

        try {
		        // Job 스케줄링 수행
            schedulerFactoryBean.getScheduler().scheduleJob(jobDetail, trigger);
        } catch (SchedulerException e) {
            throw new CustomCommonException(CommonErrorCode.INTERNAL_SERVER_ERROR);
        }
    }
    
}

• JobRequest DTO 및 JobType Enum

@Builder
public record JobRequest (
        String name,
        String group,
        JobType jobType,
        Date startAt
) {
}

public enum JobType {
    ONE_TIME,
    MONTHLY
}

• Trigger 생성 및 Job 생성을 위한 JobUtil 클래스

public class JobUtil {

    private JobUtil() {
    }

    public static Trigger createTrigger(JobRequest jobRequest) {
        TriggerKey triggerKey = TriggerKey.triggerKey(jobRequest.name(), jobRequest.group());

				// JobType 에 따른 Trigger의 스케줄 설정
				// 한번만 실행
        if (jobRequest.jobType().equals(JobType.ONE_TIME)) {
            return TriggerBuilder.newTrigger()
                    .withIdentity(triggerKey)
                    .startAt(jobRequest.startAt())
                    .build();
        // 월 단위 실행
        } else {
            return TriggerBuilder.newTrigger()
                    .withIdentity(triggerKey)
                    .withSchedule(CronScheduleBuilder.cronSchedule("0 0 0 1 * ?")) // 매월 1일 실행
                    .startNow()
                    .build();
        }
    }

    public static JobDetail createJob(JobRequest jobRequest, Class<? extends Job> jobClass) {
        JobKey jobKey = JobKey.jobKey(jobRequest.name(), jobRequest.group());

        JobDetail job = JobBuilder.newJob(jobClass)
                .withIdentity(jobKey)
                .build();

        return job;
    }

}

스케줄링 작업을 위한 Job 클래스

• 거래 단계 변경을 위한 Job → Job Interface 를 구현한다.

@RequiredArgsConstructor
@Component
public class ChangeStageToCompletedJob implements Job {

    private final OrderService orderService;
    private final FactoryOrderService factoryOrderService;
    private final FactoryOrderEmailService factoryOrderEmailService;

    @Override
    public void execute(JobExecutionContext context) {
        Long orderId = Long.valueOf(context.getJobDetail().getKey().getName());

        Order order = orderService.getOrderById(orderId);

        if (!order.enableChangeStageToCompleted()) {
            return;
        }

        factoryOrderService.changeStageToCompleted(orderId);

        factoryOrderEmailService.sendEmailForChangeStageToCompleted(orderId);
    }
}