스케줄링이란 일정한 시간마다 특정한 업무를 수행하는 것이다. 오라클데이터베이스 같은 경우에는 dbms_job에서 지원하며 자바기반 환경에서는 quartz 를 많이 사용한다. 이번 예제에서는 Spring Framework3.,2와 quartz 1.8.6에서 간단히 스케줄링을 구현했다
:namespace prefix = o ns = "urn:schemas-microsoft-com:office:office" />
아래에서 태스크는 JOB에 기술되어 실행되는 일이다. JOB에 등록되는 것인데 헷갈리지 말자.
PSJ
Spring Framework3.2에서 아직 Quartz2.0 이상은 지원하지 않는 것 같다. 다음 같은 오류 발생!!
class org.springframework.scheduling.quartz.JobDetailBean has interface org.quartz.JobDetail as super class
따라하기
1. 간단히 스프링 프로젝트 하나 생성하자.
2. pom.xml
<project xmlns="http://maven.apache.org/POM/4.0.0"xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd">
<modelVersion>4.0.0</modelVersion>
<groupId>org.springframework.samples</groupId>
<artifactId>springquarts</artifactId>
<version>0.0.1-SNAPSHOT</version>
<properties>
<!-- Generic properties -->
<java.version>1.7</java.version>
<project.build.sourceEncoding>UTF-8</project.build.sourceEncoding>
<project.reporting.outputEncoding>UTF-8</project.reporting.outputEncoding>
<!-- Spring -->
<spring-framework.version>3.2.3.RELEASE</spring-framework.version>
<!-- Hibernate / JPA -->
<hibernate.version>4.2.1.Final</hibernate.version>
<!-- Logging -->
<logback.version>1.0.13</logback.version>
<slf4j.version>1.7.5</slf4j.version>
<!-- Test -->
<junit.version>4.11</junit.version>
</properties>
<dependencies>
<!-- QuartzJobBean in spring-context-support.jar -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context-support</artifactId>
<version>${spring-framework.version}</version>
</dependency>
<!-- Spring and Transactions -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-context</artifactId>
<version>${spring-framework.version}</version>
</dependency>
<!-- spring quarts에서 transaction이 필요 -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-tx</artifactId>
<version>${spring-framework.version}</version>
</dependency>
<!-- Quartz framework -->
<dependency>
<groupId>org.quartz-scheduler</groupId>
<artifactId>quartz</artifactId>
<version>2.1.7</version>
</dependency>
<!-- Logging with SLF4J & LogBack -->
<dependency>
<groupId>org.slf4j</groupId>
<artifactId>slf4j-api</artifactId>
<version>${slf4j.version}</version>
<scope>compile</scope>
</dependency>
<dependency>
<groupId>ch.qos.logback</groupId>
<artifactId>logback-classic</artifactId>
<version>${logback.version}</version>
<scope>runtime</scope>
</dependency>
<!-- Hibernate -->
<dependency>
<groupId>org.hibernate</groupId>
<artifactId>hibernate-entitymanager</artifactId>
<version>${hibernate.version}</version>
</dependency>
<!-- Test Artifacts -->
<dependency>
<groupId>org.springframework</groupId>
<artifactId>spring-test</artifactId>
<version>${spring-framework.version}</version>
<scope>test</scope>
</dependency>
<dependency>
<groupId>junit</groupId>
<artifactId>junit</artifactId>
<version>${junit.version}</version>
<scope>test</scope>
</dependency>
</dependencies>
</project>
3. 이번에는 실제 스케줄링 되면서 실행될 클래스 태스크 클래스와 실행메소드를 만들자.
package jobschedule.edu.onj;
/*
* 스케줄러에 걸어서 실행시킬 JOB
* 본 예제에서는 1초에 한번씩 실행됨
*/
public class RunTask {
public void myWork() {
System.out.println("오라클자바커뮤니티 스프링 스케줄러");
}
}
4. 쿼츠에서 실행될 JOB을 정의하자.(JOB에 TASK를 정의한다.)
두가지 방법이 있는데,,, (본 예제에서는 두 방법 모두 기술하여 테스트)
- MethodInvokingJobDetailFactoryBean을 이용하는 간단방법
<bean id="onjJob"
class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetObject" ref="runTask" />
<property name="targetMethod" value="mywork" />
</bean>
- QuartzJobBean을 상속한 클래스를 만들고 XML에서 쿼츠 JOB을 정의하는 방법
package jobschedule.edu.onj;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.scheduling.quartz.QuartzJobBean;
//QuartzJobBean은 복잡한 스케줄링에 적합한 유연한 스케줄러.
//상속받아서 스케줄러를 구현하자.
public class QuartzJob extends QuartzJobBean {
//실제 실행될 태스크
private RunTask runTask;
//실제 실행될 태스크를 setter 주입 받는다.
public void setRunTask(RunTask runTask) {
this.runTask = runTask;
}
//실행을 원하는 메소드를 CALL한다.
protected void executeInternal(JobExecutionContext context) throwsJobExecutionException {
runTask.myWork();
}
}
XML에서 다음과 같이 정의하면 된다.(XML은 아래에서 한번에 정리)
<!-- 실제스케줄링될 태스크(세터주입될)와 JOB을정의한 클래스등록 -->
<bean name="onjJob"class="org.springframework.scheduling.quartz.JobDetailBean">
<!-- JOB을 정의 -->
<property name="jobClass"value="jobschedule.edu.onj.QuartzJob" />
<!-- 실제스케줄링될 JOB-->
<property name="jobDataAsMap">
<map>
<entry key="runTask" value-ref="runTask" />
</map>
</property>
</bean>
5. Trigger 기술(정의한 JOB을 어떤 주기로 실행할 것인지 정의)
이 또한 두 가지 방법이 있는데 SimpleTrigger와 cronTrigger가 있다. SimpleTrigger는 작업의 주기를 repeatInterval 속성으로 정의하는 반면 cronTrigger는 Unix의 CronTab 설정하듯이 한다.
- SimpleTrigger
<!-- Simple Trigger, run every 1 seconds -->
<bean id="onjTrigger"
class="org.springframework.scheduling.quartz.SimpleTriggerBean">
<!-- 실행할 JOB -->
<property name="jobDetail" ref="onjJob" />
<!-- 1초에 한번씩 -->
<property name="repeatInterval" value="1000" />
<!-- 최초 시작시 1초후에 start -->
<property name="startDelay" value="1000" />
</bean>
- cronTrigger
<!-- 유닉스의 cron tab처럼 설정, 1초마다 -->
<bean id="cronTrigger"
class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail" ref="onjJob" />
<property name="cron__EXPRESSION__" value="0/1 * * * * ?" />
</bean>
6. 스케줄러 관리를 위한 Scheduler Factory를 정의
<!-- job 과 trigger 함께 기술 -->
<beanclass="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="jobDetails">
<list>
<ref bean="onjJob" />
</list>
</property>
<property name="triggers">
<list>
<ref bean="cronTrigger" /> <!-- cronTrigger로바꿔보라 -->
</list>
</property>
</bean>
7. 완성된 XML(springquartz.xml)
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans"
xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"
xsi:schemaLocation="http://www.springframework.org/schema/beans
http://www.springframework.org/schema/beans/spring-beans-3.2.xsd">
<!-- 실제 실행 될 태스크 -->
<bean id="runTask" class="jobschedule.edu.onj.RunTask" />
<!-- 실제스케줄링될 태스크(세터주입될)와 JOB을정의한 클래스등록 -->
<bean name="onjJob"class="org.springframework.scheduling.quartz.JobDetailBean">
<!-- JOB을 정의 -->
<property name="jobClass"value="jobschedule.edu.onj.QuartzJob" />
<!-- 실제스케줄링될 JOB-->
<property name="jobDataAsMap">
<map>
<entry key="runTask" value-ref="runTask" />
</map>
</property>
</bean>
<!--
위에서 정의한 JobDetailBean을 이용하여 스케줄링되는 JOB을 등록하는 방법이외,JOB을 등록하는 다른 방법
MethodInvokingJobDetailFactoryBean을 이용하는 간단한 방법, 스케줄링될클래스와 메소드 정의
<bean id="onjJob"
class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
<property name="targetObject" ref="runTask" />
<property name="targetMethod" value="mywork" />
</bean>
-->
<!-- Simple Trigger, run every 1 seconds -->
<bean id="onjTrigger"
class="org.springframework.scheduling.quartz.SimpleTriggerBean">
<!-- 실행할 JOB -->
<property name="jobDetail" ref="onjJob" />
<!-- 1초에 한번씩 -->
<property name="repeatInterval" value="1000" />
<!-- 최초 시작시 1초후에 start -->
<property name="startDelay" value="1000" />
</bean>
<!-- 유닉스의 cron tab처럼 설정, 1초마다 -->
<bean id="cronTrigger"
class="org.springframework.scheduling.quartz.CronTriggerBean">
<property name="jobDetail" ref="onjJob" />
<property name="cron__EXPRESSION__" value="0/1 * * * * ?" />
</bean>
<!-- job 과 trigger 함께 기술 -->
<beanclass="org.springframework.scheduling.quartz.SchedulerFactoryBean">
<property name="jobDetails">
<list>
<ref bean="onjJob" />
</list>
</property>
<property name="triggers">
<list>
<ref bean="cronTrigger" /> <!-- cronTrigger로바꿔보라 -->
</list>
</property>
</bean>
</beans>
8. TEST를 위한 Client Program
package jobschedule.edu.onj;
importorg.springframework.context.support.ClassPathXmlApplicationContext;
public class ScheuleMain {
public static void main(String[] args) {
new ClassPathXmlApplicationContext("springquartz.xml");
}
}
9. 결과
15:19:47.953 [main] INFO org.quartz.core.QuartzScheduler - Scheduler org.springframework.scheduling.quartz.SchedulerFactoryBean#0_$_NON_CLUSTERED started.
15:19:48.718 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-1] DEBUG org.quartz.core.JobRunShell - Calling execute on job DEFAULT.onjJob
오라클자바커뮤니티 스프링 스케줄러
15:19:48.937 [Timer-0] DEBUG org.quartz.utils.UpdateChecker - Checking for available updated version of Quartz...
15:19:49.718 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-2] DEBUG org.quartz.core.JobRunShell - Calling execute on job DEFAULT.onjJob
오라클자바커뮤니티 스프링 스케줄러
15:19:50.718 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-3] DEBUG org.quartz.core.JobRunShell - Calling execute on job DEFAULT.onjJob
오라클자바커뮤니티 스프링 스케줄러
15:19:51.718 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-4] DEBUG org.quartz.core.JobRunShell - Calling execute on job DEFAULT.onjJob
오라클자바커뮤니티 스프링 스케줄러
15:19:52.718 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-5] DEBUG org.quartz.core.JobRunShell - Calling execute on job DEFAULT.onjJob
오라클자바커뮤니티 스프링 스케줄러
15:19:53.718 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-6] DEBUG org.quartz.core.JobRunShell - Calling execute on job DEFAULT.onjJob
오라클자바커뮤니티 스프링 스케줄러
15:19:54.718 [org.springframework.scheduling.quartz.SchedulerFactoryBean#0_Worker-7] DEBUG org.quartz.core.JobRunShell - Calling execute on job DEFAULT.onjJob
