[java] Quartz Scheduler로 주기적인 데이터 갱신하기

16 Nov 2023

java

많은 애플리케이션에서는 주기적으로 데이터를 갱신해야 하는 경우가 있습니다. 이를 위해 Quartz Scheduler라는 자바 라이브러리를 사용할 수 있습니다. Quartz Scheduler는 스케줄링 작업을 관리하고 실행할 수 있는 강력한 도구입니다.

이번 예시에서는 Quartz Scheduler를 사용해 주기적으로 데이터를 갱신하는 방법을 살펴보겠습니다.

1. 의존성 추가하기

먼저, Maven이나 Gradle 프로젝트의 의존성 관리 파일에 Quartz Scheduler의 의존성을 추가해야 합니다.

Maven:

<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz</artifactId>
    <version>2.3.0</version>
</dependency>

Gradle:

implementation 'org.quartz-scheduler:quartz:2.3.0'

2. Job 클래스 작성하기

Quartz Scheduler에서 실행할 작업을 정의하기 위해 Job 클래스를 작성해야 합니다. 이 클래스는 Job 인터페이스를 구현해야 하며, execute() 메소드에서 실제 작업을 수행합니다.

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class DataUpdateJob implements Job {

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // 주기적으로 실행될 작업을 구현
        System.out.println("데이터를 갱신합니다.");
    }
}

3. 스케줄러 설정하기

Quartz Scheduler를 설정하고 작업을 스케줄링하기 위해 Scheduler 인스턴스를 생성해야 합니다. 스케줄러를 설정하는 방법은 매우 다양한데, 여기서는 간단한 예시로 SchedulerFactoryBean을 사용하겠습니다.

import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import org.springframework.scheduling.annotation.EnableScheduling;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;

@Configuration
@EnableScheduling
public class QuartzConfig {

    @Bean
    public SchedulerFactoryBean schedulerFactoryBean() {
        SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
        schedulerFactoryBean.setTriggers(trigger1(), trigger2(), ...); // 실행할 작업의 트리거 설정
        schedulerFactoryBean.setJobDetails(dataUpdateJobDetail()); // 실행할 작업 설정
        return schedulerFactoryBean;
    }

    @Bean
    public JobDetail dataUpdateJobDetail() {
        return JobBuilder.newJob(DataUpdateJob.class).build();
    }

    @Bean
    public Trigger trigger1() {
        return TriggerBuilder
                .newTrigger()
                .withSchedule(CronScheduleBuilder.cronSchedule("0 0/1 * 1/1 * ? *")) // 실행 주기 설정
                .build();
    }

    @Bean
    public Trigger trigger2() {
        return TriggerBuilder
                .newTrigger()
                .withSchedule(SimpleScheduleBuilder.repeatMinutelyForever(5)) // 실행 주기 설정
                .build();
    }
}

이 예시에서는 SchedulerFactoryBean을 사용해 스케줄러를 설정하고, Trigger를 사용해 실행 주기를 설정합니다. Trigger에는 다양한 실행 주기 설정 방법이 있으며, cron 표현식이나 간단한 주기적인 실행 등을 지원합니다.

4. 애플리케이션 실행하기

위에서 설정한 스케줄러를 실행하기 위해 애플리케이션을 실행합니다. 스케줄러는 설정된 주기에 따라 작업을 실행할 것입니다.

import org.springframework.boot.SpringApplication;
import org.springframework.boot.autoconfigure.SpringBootApplication;
import org.springframework.context.annotation.AnnotationConfigApplicationContext;

@SpringBootApplication
public class Application {

    public static void main(String[] args) {
        SpringApplication.run(Application.class, args);

        // 스프링 컨텍스트를 통해 스케줄러 빈을 가져옴
        AnnotationConfigApplicationContext context = new AnnotationConfigApplicationContext(QuartzConfig.class);
        Scheduler scheduler = context.getBean(Scheduler.class);

        // 스케줄러 시작
        scheduler.start();
    }
}

위의 예시에서는 Spring Boot를 사용해 Quartz Scheduler를 실행하고 있습니다. 적절한 Spring Boot 설정이 필요하며, @EnableScheduling 애노테이션을 사용해 스케줄링을 활성화합니다.

결론

Quartz Scheduler를 사용하면 주기적으로 데이터를 갱신하는 작업을 쉽게 관리할 수 있습니다. 위의 예시를 참고하여 자신의 애플리케이션에 맞게 설정하고 실행해보세요.

참고: