Spring中使用quartz

時間 2019-11-06

標籤 spring 使用 quartz 欄目 Spring 简体版

原文原文鏈接

1.Quartz基礎java

quartz對任務調度核心領域問題驚醒了高度抽象，提出了調度器，任務，和觸發器這三個核心概念，並在org.quartz經過接口和類對核心概念進行描述。mysql

Scheduler接口: quartz的執行線程，它根據Trigger決定調度時刻，根據JobDetail的說明實例化並運行Jobweb

JobDetail類: 可持久化的任務描述信息。任務雖然分組，可是僅用做管理標示，任務之間並沒有實質性關聯, 例如沒法定義job chain。spring

Trigger類:任務的調度策略。這裏的特色是調度策略與任務描述分開，調度策略和任務描述均可以分別在Scheduler註冊，而後再關聯起來。JobDetail與Trigger的關係是一對多。sql

JobDataMap: 將任務的運行時可持久化狀態信息從JobDetail類中分離出來數據庫

Job接口: 任務的執行代碼併發

StatefulJob接口: 無狀態任務對應的JobDataMap能夠認爲是隻讀的,而有狀態的任務在屢次執行過程當中保留對JobDataMap所做的修改,一個後果是有狀態任務沒法被併發執行。oracle

JobExecutionException類: 能夠經過JobExecutionException調整調度程序的下一步動做app

Calendar接口: 用於從trigger的調度計劃中排除某些時間段，例如假期等。ide

ThreadPool:

2.使用SimpleTrigger與CronTrigger：

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
/**
 * Created by Dou on 2014/12/1 0001.
 */
public class SimpleTriggerAndCornTriggerRunner {
    public static void main(String[] args) {
        try {
            /**
             * quartz jar 2.2.1版本寫法
             */
            //建立jobDeail實例，綁定Job實現類
            //指明job的名稱，組名，以及綁定的類 jar包版本爲2.2.1
            JobDetail jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job1_2", "jGroup1").build();
            //使用simpleTrigger規則  jar包版本爲2.2.1
            Trigger simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger1_1","tgroup1").startNow()
                    .withSchedule(SimpleScheduleBuilder.simpleSchedule()
                            .withIntervalInSeconds(2) //時間價格
                            .withRepeatCount(4)       //重複次數（將執行5次）
                    )
                    .build();
            //使用CornTrigger規則  jar包版本爲2.2.1
            Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1_2","tgroup1")
                    .withSchedule(CronScheduleBuilder.cronSchedule("0/3 * * * * ？"))
                    .startNow()
                    .build();
            /**
             * quartz jar 1.8.4版本寫法
             */
//            JobDetail jobDetail = new JobDetail("job1_1", "jgroup1",SimpleJob.class);
//              //使用CornTrigger規則 1.8.4版本寫法
//            SimpleTrigger simpleTrigger = new SimpleTrigger("trigger1_1","tgroup1");
//            simpleTrigger.setStartTime(new Date());
//              simpleTrigger.setRepeatInterval(2000);
//              simpleTrigger.setRepeatCount(100);
              //使用CornTrigger規則 1.8.4版本寫法
/*            CronTrigger cronTrigger = new CronTrigger("trigger1_2", "tgroup1");
              CronExpression cexp = new CronExpression("0/5 * * * * ?");
              cronTrigger.setCronExpression(cexp);*/
            /**
             * quartz jar 1.8.4版本寫法end
             */
        
            SchedulerFactory schedulerFactory =new StdSchedulerFactory();
            Scheduler scheduler = null;
            //經過schedulerFActory得到一個調度器
            scheduler = schedulerFactory.getScheduler();
            //把做業和觸發器註冊到任務調度中
            scheduler.scheduleJob(jobDetail,simpleTrigger);
            //啓動調度
            scheduler.start();
            //1.8.4版本 使用corntrigger方式看本例的時候須要經過(Thread.currentThread().sleep();)方式讓主線程睡眠一段時間，
            //使用調度器能夠繼續執行任務調度的工做。不然在調度器啓動後，由於主線程立刻推出去，
            //寄生於主線程的調度器也將關閉，調度器中的任務都將相應銷燬，致使看不清實際的運行效
            //果。
            //能夠經過單元測試的時候讓主線程睡眠一段時間，使用下面的方式。
            //
/*            try {
                // wait 30 seconds to show jobs
                Thread.sleep(30L * 1000L);
                // executing...
            } catch (Exception e) {
            }
            scheduler.shutdown(true);*/
        }catch (Exception e){
        }
    }
}

所需job類：

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import java.text.SimpleDateFormat;
import java.util.Date;
/**
 * Created by Dou on 2014/11/28 0028.
 */
/*
<!-- 若是在spring中使用MethodInvokingJobDetailFactoryBean 業務類註冊job時候不用實現job接口 在spring3.x.x版本後可用 -->
 */
public class SimpleJob implements Job {
    @Override
    public void execute(JobExecutionContext jobEC) throws JobExecutionException {
        System.out.println(" Time is: "+( new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())));
    }
    public void doWork(){
        System.out.println(" Time is: "+( new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())));
    }
}
public class MyService { 不實現Job接口的job
    public void test(){
        System.out.println("Hello!");
    }
}

quart與spring:

web.xml:
 <context-param>
   <param-name>contextConfigLocation</param-name>
   <param-value>
         classpath*:/applicationContext-main.xml,classpath*:/applicationContext-quartz.xml
       </param-value>
</context-param>
applicationContext-quartz.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"
       xmlns:p="http://www.springframework.org/schema/p"
       xsi:schemaLocation="http://www.springframework.org/schema/beans http://www.springframework.org/schema/beans/spring-beans-4.0.xsd"
       default-lazy-init="true">
    <!-- 啓動觸發器 -->
    <bean name="scheduler" lazy-init="false" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
        <property name="triggers">
            <list>
                <ref bean="myJobTrigger" />
                <ref bean="simpleTrigger" />
            </list>
        </property>
        <property name="startupDelay" value="30" />  <!--單位：秒-->
        <property name="configLocation" value="classpath:/quartz.properties" />
    </bean>
    <!-- 調度配置 -->
    <!-- 調度配置cronTrigger -->
    <bean id="myJobTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean"
         p:startDelay="1000" >  <!--單位：毫秒-->
        <property name="jobDataAsMap">
            <map>
                <entry key="count" value="10" />
            </map>
        </property>
        <property name="jobDetail">
            <ref bean="myJobDetail" />
        </property>
        <property name="cronExpression">
            <value>0/3 * * * * ?</value>
        </property>
    </bean>
    <!-- 調度配置simpleTrigger -->
    <bean id="simpleTrigger" class="org.springframework.scheduling.quartz.SimpleTriggerFactoryBean"
          p:jobDetail-ref="myJobDetail" p:startDelay="1000" p:repeatInterval="2000"
          p:repeatCount="100">
        <property name="jobDataAsMap">
            <map>
                <entry key="count" value="10" />
            </map>
        </property>
    </bean>
    
    <!-- job配置 -->
    <!-- 使用MethodInvokingJobDetailFactoryBean 業務類不用實現job接口 在spring3.x.x版本後可用 -->
    <bean id="myJobDetail" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean">
        <property name="targetObject">
            <ref bean="myService" />
        </property>
        <property name="targetMethod">
            <value>test</value>
        </property>
        <property name="concurrent">  <!-- 指定任務類型是否與狀態 false：有狀態，有狀態的任務不能併發執行-->
            <value>false</value>
        </property>
    </bean>
    <bean id="myJob" class="com.dou.app.quartz.SimpleJob"/>
    <bean id="myService" class="com.dou.app.quartz.MyService"/>
<!-- quartz.jar.1.x 版本寫法 -->
    <!--<bean name="jobDetail" class="org.springframework.scheduling.quartz.JobDetailBean"-->
          <!--p:jobClass="com.dou.app.quartz.SimpleJob"-->
          <!--p:applicationContextJobDataKey="applicationContext">-->
        <!--<property name="jobDataAsMap">-->
            <!--<map>-->
                <!--<entry key="size" value="10" />-->
            <!--</map>-->
        <!--</property>-->
    <!--</bean>-->
    <!--<bean id="scheduler"-->
          <!--class="org.springframework.scheduling.quartz.SchedulerFactoryBean">-->
        <!--<property name="triggers">-->
            <!--<list>-->
                <!--<ref bean="simpleTrigger" />-->
            <!--</list>-->
        <!--</property>-->
        <!--<property name="schedulerContextAsMap">-->
            <!--<map>-->
                <!--<entry key="timeout" value="30" />-->
            <!--</map>-->
        <!--</property>-->
        <!--<property name="quartzProperties">-->
            <!--<props>-->
                <!--<prop key="org.quartz.threadPool.class">-->
                    <!--org.quartz.simpl.SimpleThreadPool-->
                <!--</prop>-->
                <!--<prop key="org.quartz.threadPool.threadCount">10</prop>-->
            <!--</props>-->
        <!--</property>-->
    <!--</bean>-->
</beans>

quartz.properties:

#集羣的配置，這裏不使用集羣
#org.quartz.scheduler.instanceName = DefaultQuartzScheduler
#配置調度器的線程池
org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool
org.quartz.threadPool.threadCount = 10
org.quartz.threadPool.threadPriority = 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread = true
# Using RAMJobStore
## if using RAMJobStore, please be sure that you comment out the following
## - org.quartz.jobStore.tablePrefix, 
## - org.quartz.jobStore.driverDelegateClass, 
## - org.quartz.jobStore.dataSource
#配置任務調度現場數據保存機制
# RAMJobStore：將信息保存在RAM中
org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore
# Using JobStoreTX 將調度現場數據保存在數據庫中
## Be sure to run the appropriate script(under docs/dbTables) first to create tables
#org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
# Configuring JDBCJobStore with the Table Prefix 設定數據庫表前綴
#org.quartz.jobStore.tablePrefix = QRTZ_
# Using DriverDelegate
#org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
#org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.oracle.OracleDelegate
#org.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.HSQLDBDelegate
# Using datasource 設置數據源名稱
#org.quartz.jobStore.dataSource = qzDS
# Define the datasource to use
##Mysql
#org.quartz.dataSource.qzDS.driver = com.mysql.jdbc.Driver
#org.quartz.dataSource.qzDS.URL = jdbc:mysql://192.168.3.128:3306/manager?useUnicode=true&characterEncoding=utf-8
#org.quartz.dataSource.qzDS.user = root
#org.quartz.dataSource.qzDS.password = 1234
#org.quartz.dataSource.qzDS.maxConnections = 30
#Oracle
#org.quartz.dataSource.qzDS.driver = oracle.jdbc.driver.OracleDriver
#org.quartz.dataSource.qzDS.URL = jdbc:oracle:thin:@localhost:1521:ora9i
#org.quartz.dataSource.qzDS.user = stamen
#org.quartz.dataSource.qzDS.password = abc
#org.quartz.dataSource.qzDS.maxConnections = 30