1、說明

1. quartz可以通過jdbc直連連接到MYSQL數據庫，讀取配置在數據庫里的job初始化信息，并且把job通過java序列化到數據庫里，這樣就使得每個job信息得到了持久化，即使在jvm或者容器掛掉的情況下，也能通過數據庫感知到其他job的狀態和信息。
2. quartz集群各節點之間是通過同一個數據庫實例(準確的說是同一個數據庫實例的同一套表)來感知彼此的。

2、數據庫表的創建

創建quartz要用的數據庫表，此sql文件在：quartz-2.2.3\docs\dbTables。此文件夾下有各個數據庫的sql文件，mysql選擇tables_mysql.sql。總共有11張表。

• QRTZ_CALENDARS 以 Blob 類型存儲 Quartz 的 Calendar 信息
• QRTZ_CRON_TRIGGERS 存儲 Cron Trigger，包括 Cron表達式和時區信息
• QRTZ_FIRED_TRIGGERS 存儲與已觸發的 Trigger 相關的狀態信息，以及相聯 Job的執行信息
• QRTZ_PAUSED_TRIGGER_GRPS 存儲已暫停的 Trigger 組的信息
• QRTZ_SCHEDULER_STATE 存儲少量的有關 Scheduler 的狀態信息，和別的 Scheduler實例(假如是用于一個集群中)
• QRTZ_LOCKS 存儲程序的悲觀鎖的信息(假如使用了悲觀鎖)
• QRTZ_JOB_DETAILS 存儲每一個已配置的 Job 的詳細信息
• QRTZ_JOB_LISTENERS 存儲有關已配置的 JobListener 的信息
• QRTZ_SIMPLE_TRIGGERS 存儲簡單的Trigger，包括重復次數，間隔，以及已觸的次數
• QRTZ_BLOG_TRIGGERS Trigger 作為 Blob 類型存儲(用于 Quartz 用戶用 JDBC創建他們自己定制的 Trigger 類型，JobStore 并不知道如何存儲實例的時候)
• QRTZ_TRIGGER_LISTENERS 存儲已配置的 TriggerListener 的信息
• QRTZ_TRIGGERS 存儲已配置的 Trigger 的信息

3、 quartz.properties的配置

調度標識名 集群中每一個實例都必須使用相同的名稱
org.quartz.scheduler.instanceName = MyScheduler
線程數量
org.quartz.threadPool.threadCount = 10
線程優先級
org.quartz.threadPool.threadPriority = 5
數據保存方式為持久化
org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX
數據庫平臺
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
表的前綴
org.quartz.jobStore.tablePrefix = QRTZ_
庫的別名
org.quartz.jobStore.dataSource = myDS
Cluster開啟集群
org.quartz.jobStore.isClustered = true
ID設置為自動獲取 每一個必須不同
org.quartz.scheduler.instanceId = AUTO
org.quartz.dataSource.myDS.driver = com.mysql.jdbc.Driver
org.quartz.dataSource.myDS.URL = jdbc:mysql://localhost:3306/hms?characterEncoding=utf-8
org.quartz.dataSource.myDS.user = root
org.quartz.dataSource.myDS.password = 123456
org.quartz.dataSource.myDS.maxConnections = 5</pre> 
  
4.創建任務
 
  
package com.lidong.dubbo.core.util.quartz;

import java.io.Serializable;
import java.text.SimpleDateFormat;
import java.util.Date;
import org.quartz.DisallowConcurrentExecution;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.PersistJobDataAfterExecution;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean;
import org.springframework.scheduling.quartz.QuartzJobBean;
/**

@項目名稱:lidong-dubbo
@類名:SpringQtz
@類的描述: 作業類的調度
@作者:lidong
@創建時間:2017/2/8 下午5:41
@公司:chni
@QQ:1561281670
@郵箱:lidong1665@163.com
*/

public class SpringQtz extends QuartzJobBean{

static Logger  logger = LoggerFactory.getLogger(SpringQtz.class);

private static int counter = 0;

@Override
protected void executeInternal(JobExecutionContext jobExecutionContext) throws JobExecutionException {
    long ms = System.currentTimeMillis();
    logger.error(" SpringQtz start  執行");
    logger.info("-------"+new SimpleDateFormat("yyyy-MM-dd hh:mm:ss").format(new Date(ms))+"  "+"(" + counter++ + ")");
}


}</pre> 
  
5.spring-quartz.xml的配置
 
  
<?xml version="1.0" encoding="UTF-8"?>
<beans xmlns="
        http://www.springframework.org/schema/beans

        ;
    <!-- 定義調用對象和調用對象的方法 -->
    <bean id="SpringQtzJobDetail"
        class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
        <property name="jobClass"  value="com.lidong.dubbo.core.util.quartz.SpringQtz"/>
        <property name="durability" value="true"/>


    <property name="group" value="job_work"/>
    <property name="name" value="job_work_name"/>
</bean>
<bean id="SpringQtzJobDetail1"
    class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass" value="com.lidong.dubbo.core.util.quartz.SpringQtzDemo"/>
    <property name="durability" value="true"/>

    <property name="group" value="job_work1"/>
    <property name="name" value="job_work_name1"/>
</bean>


<!-- ======================== 調度觸發器 ======================== -->
<bean id="CronTriggerBean"
    class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="SpringQtzJobDetail"></property>
    <!-- cron表達式 -->
    <property name="cronExpression" value="0/20 * * * * ?"></property>
</bean>

<bean id="CronTriggerBean1"
    class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="SpringQtzJobDetail1"></property>
    <!-- cron表達式 -->
    <property name="cronExpression" value="0/30 * * * * ?"></property>
</bean>

<!-- ======================== 調度工廠 ======================== -->
<bean id="SpringJobSchedulerFactoryBean"
    class="org.springframework.scheduling.quartz.SchedulerFactoryBean">

    <property name="dataSource">
        <ref bean="dataSource"/>
    </property>
    <property name="applicationContextSchedulerContextKey" value="applicationContext" />
    <property name="configLocation" value="classpath:config/quartz.properties"/>
    <!--啟動時更新己存在的Job，這樣就不用每次修改targetObject后刪除qrtz_job_details表對應記錄了-->
    <property name="overwriteExistingJobs" value="true"/>
    <property name="triggers">
        <list>
            <ref bean="CronTriggerBean" />
            <ref bean="CronTriggerBean1" />
        </list>
    </property>
    <property name="jobDetails">
        <list>
            <ref bean="SpringQtzJobDetail" />
            <ref bean="SpringQtzJobDetail1" />
        </list>
    </property>
</bean>

</beans></pre> 
  
6. 分別部署到兩臺Tomcat服務器查看效果
 
  
第1個tomcat的結果：
 
  
 
  
第2個omcat的結果：
 
  
 
  
可以看到。任務不會重復執行。
 
  
 
 
  
來自：http://blog.csdn.net/u010046908/article/details/56015388