Quartz 임무 스케줄 링 실천

최근 에 작업 스케줄 러 를 쓰 고 있 습 니 다. 몇 초 마다 데이터 베 이 스 를 조회 하고 데 이 터 를 꺼 내 처리 해 야 합 니 다.Quartz 작업 스케줄 링 프레임 워 크 에 사 용 했 습 니 다.
기본 개념
Quartz 는 작업 (Job), 트리거 (Trigger), 스케줄 러 (Scheduler) 등 몇 가지 중요 한 대상 을 포함한다.
Job: 하나의 인터페이스 에 하나의 방법 만 있 습 니 다. void execute (). 우리 가 수행 해 야 할 임 무 는 이 인 터 페 이 스 를 실현 하고 execute 에서 우리 가 해 야 할 일 을 실현 해 야 합 니 다.
JobDetail: Quartz 에서 Job 을 실행 할 때마다 Job 인 스 턴 스 를 만들어 야 하기 때문에 실행 할 때 실례 화 할 수 있 도록 실현 클래스 를 직접 받 아들 이 고 설명 정보 가 필요 합 니 다. JobDetail 은 바로 이 일 을 하 는 것 입 니 다.JobDetail 을 만 드 는 방법 은 다음 과 같 습 니 다. JobBuilder builder = JobBuilder. newJob (SimpleJob. class);JobDetail jobDetail=builder.build(); JobBuilder 를 통 해 builder. withIdentity (name, group) 등 설명 을 설정 할 수 있 습 니 다 .
Trigger: 트리거 실행 시간 을 설명 하 는 추상 적 인 클래스 입 니 다. Simple Trigger 와 CronTrigger 라 는 두 가지 키 클래스 가 있 습 니 다. 한 번 만 터치 하거나 고정 시간 간격 으로 실행 하면 Simple Trigger 가 가장 적합 한 선택 입 니 다.한편, CronTrigger 는 Cron 표현 식 을 통 해 각종 복잡 한 시간 규칙 의 스케줄 링 방안 을 정의 할 수 있다. 예 를 들 어 아침 9 시 에 실행 되 고 월요일, 수요일, 금요일 오후 5 시 에 실행 되 는 등 이다.
Scheduler: quartz 스케줄 러 라 고 볼 수 있 습 니 다. 우 리 는 JobDetail 과 Trigger 를 Scheduler 에 등록 하여 스케줄 러 로 실행 합 니 다.
간단 한 예
quartz 를 직접 사용 하여 간단 한 예 를 실현 하 다.1. Simple Job 클래스 를 만 들 고 Job 인 터 페 이 스 를 실현 합 니 다.

public class SimpleJob implements Job{
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        System.out.println("     Job"+jobExecutionContext.getJobDetail().getDescription());
    }
}

2. SimpleJob 을 사용 하여 JobDetail 인 스 턴 스 를 만 듭 니 다.

        //    JobDetail  
        JobBuilder builder=JobBuilder.newJob(SimpleJob.class);
        builder.withIdentity("test","test");
        builder.withDescription("my test");
        JobDetail jobDetail=builder.build();

3. Trigger 를 만 듭 니 다. 여기 서 Simple Trigger 를 사용 하여 만 듭 니 다. 지금부터 1s 간격 으로 실 행 됩 니 다.

        //        ，1s     ，    
        Trigger trigger = TriggerBuilder.newTrigger().withSchedule(
                SimpleScheduleBuilder.simpleSchedule()
                        .withIntervalInSeconds(1)
                        .repeatForever()).
                startNow().build();

4. Scheduler 를 만 들 고 위 에서 만 든 Trigger 와 jobDetail 을 등록 하고 실행 하기 시작 합 니 다.

        try {
            //       
            SchedulerFactory schedulerFactory = new StdSchedulerFactory();
            Scheduler scheduler = schedulerFactory.getScheduler();
            //  jobDetail，trigger    
            scheduler.scheduleJob(jobDetail,trigger);
            //    
            scheduler.start();
        } catch (SchedulerException e) {
            e.printStackTrace();
        }

Spring 기반 예
1. 두 개의 Job 구현

public class MyJob {

    public void process(){
        System.out.println("  Job.."+Thread.currentThread().getId());
        try {
            Thread.sleep(1000000);
        } catch (InterruptedException e) {
            e.printStackTrace();
        }
    }

    public void process1(){
        System.out.println("  Job1.."+Thread.currentThread().getId());
    }
}

spring 설정

<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="http://www.springframework.org/schema/beans" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xmlns:p="http://www.springframework.org/schema/p" xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-3.0.xsd">

    <bean id="myJob" class="org.yywang.spring.MyJob"></bean>

    <bean id="myJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject">
            <ref bean="myJob"></ref>
        </property>
        <property name="targetMethod">
            <value>process</value>
        </property>
        <!--           。   false ，                          -->
        <property name="concurrent">
            <value>true</value>
        </property>

    </bean>

    <bean id="myJobDetail1" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject">
            <ref bean="myJob"></ref>
        </property>
        <property name="targetMethod">
            <value>process1</value>
        </property>
        <!--           。   false ，                          -->
        <property name="concurrent">
            <value>true</value>
        </property>

    </bean>

    <bean id="myTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail">
            <ref bean="myJobDetail"></ref>
        </property>
        <property name="cronExpression">
            <value>0/2 * * * * ?</value>
        </property>
    </bean>

    <bean id="myTrigger1" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
        <property name="jobDetail">
            <ref bean="myJobDetail1"></ref>
        </property>
        <property name="cronExpression">
            <value>0/5 * * * * ?</value>
        </property>
    </bean>

    <bean class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
               <ref bean="myTrigger"></ref>
                <ref bean="myTrigger1"></ref>
            </list>
        </property>
        <property name="autoStartup">
            <value>true</value>
        </property>
        <property name="configLocation" value="classpath:quartz.properties"/>
    </bean>
</beans>

quartz.properties

#============================================================================
#    Main Scheduler Properties
#============================================================================
org.quartz.scheduler.instanceName = DefaultQuartzScheduler
org.quartz.scheduler.rmi.export = false
org.quartz.scheduler.rmi.proxy = false
org.quartz.scheduler.wrapJobExecutionInUserTransaction = false

#============================================================================
#        
#============================================================================
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 5
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true

#============================================================================
#    JobStore
#============================================================================
org.quartz.jobStore.misfireThreshold = 60000

#   JobStore,              
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

#    JobStore
#org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.MSSQLDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.oracle.OracleDelegate

클 라 이언 트 가 spring 을 초기 화하 면 됩 니 다.

 new ClassPathXmlApplicationContext("classpath:spring_*.xml");

Cron 표현 식
다음 참조:http://liuzidong.iteye.com/blog/1119773 http://www.iteye.com/topic/582119 http://blog.itpub.net/183473/viewspace-434672
Other 이상 필요 한 Maven 설정

    <properties>
        <org.springframework.version>3.2.3.RELEASE</org.springframework.version>
    </properties>

        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.1.7</version>
        </dependency>
                <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context-support</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-context</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.springframework</groupId>
            <artifactId>spring-tx</artifactId>
            <version>${org.springframework.version}</version>
        </dependency>
        <dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.1.7</version>
        </dependency>

More
http://www.ibm.com/developerworks/cn/java/j-quartz/index.html http://www.blogjava.net/baoyaer/articles/155645.html http://www.blogjava.net/supercrsky/articles/199443.html