快捷導(dǎo)航

Java的作業(yè)調(diào)度類庫Quartz基本使用指南

更新時(shí)間：2016年03月07日 08:52:23 投稿：goldensun

這篇文章主要介紹了Java的作業(yè)調(diào)度類庫Quartz基本使用指南,Quartz能夠讓類按照指定的計(jì)劃順序執(zhí)行,需要的朋友可以參考下

一、常用接口：
1、Job接口：該接口只有一個(gè)方法

void execute(JobExecutionContext context)

開發(fā)者實(shí)現(xiàn)該接口定義需要執(zhí)行的任務(wù)。JobExecutionContext類提供調(diào)度上下文的各種信息

2、JobDetail：用于描敘Job實(shí)現(xiàn)類及其他的一些靜態(tài)信息

3、Trigger：描敘觸發(fā)Job執(zhí)行的時(shí)間觸發(fā)規(guī)則

4、Calendar：定義了一個(gè)關(guān)聯(lián)Trigger可能(或者不可能)觸發(fā)的時(shí)間空間。它沒有定義觸發(fā)的真實(shí)時(shí)間，而是用在在普通的Schedule需要限制Trigger觸發(fā)的時(shí)候。大部分Calendar包含默認(rèn)所有的時(shí)間，并且用戶去排除部分時(shí)間。

5、Scheduler：運(yùn)行容器，使用SchedulerFactory創(chuàng)建Scheduler實(shí)例

二、代碼示例：

1、使用Quartz，需要實(shí)現(xiàn)Job接口；

public class TestJob implements Job {
 public void execute(JobExecutionContext context) throws JobExecutionException {
 System.out.println("Hello World! - " + new Date());
 //do more...
 }
}

2、調(diào)度【比較簡(jiǎn)單，直接看代碼就可以了】

public class quartzTest {
 public static void main(String args[]) throws SchedulerException, ParseException {
 JobDetail jobDetail= JobBuilder.newJob(TestJob.class)
  .withIdentity("testJob_1","group_1")
  .build();
 
 Trigger trigger= TriggerBuilder
  .newTrigger()
  .withIdentity("trigger_1","group_1")
  .startNow()
  .withSchedule(SimpleScheduleBuilder.simpleSchedule()
   .withIntervalInSeconds(10) //時(shí)間間隔
   .withRepeatCount(5) //重復(fù)次數(shù)(將執(zhí)行6次)
   )
  .build();
 SchedulerFactory sf = new StdSchedulerFactory();
 Scheduler sched = sf.getScheduler();
 
 sched.scheduleJob(jobDetail,trigger);
 
 sched.start();
 
 }
}

這里使用的是2.2.1版本，參考官方文檔的示例。看到一些參考書使用的版本比較老，所以會(huì)有一些出入，很多方法都被棄用了，所以還是直接看文檔比較實(shí)在，Quartz的官方網(wǎng)站地址是：http://www.quartz-scheduler.org/

三、Quartz2.2.1配置文件示例

# Default Properties file for use by StdSchedulerFactory
# to create a Quartz Scheduler Instance, if a different
# properties file is not explicitly specified.
#
 
#集群配置
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: 10
org.quartz.threadPool.threadPriority: 5
org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true
 
org.quartz.jobStore.misfireThreshold: 60000
 
#============================================================================
# Configure JobStore
#============================================================================
 
#默認(rèn)配置，數(shù)據(jù)保存到內(nèi)存
#org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore
#持久化配置
org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties:true
#數(shù)據(jù)庫表前綴
org.quartz.jobStore.tablePrefix:qrtz_
org.quartz.jobStore.dataSource:qzDS
 
#============================================================================
# Configure Datasources
#============================================================================
#JDBC驅(qū)動(dòng)
org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver
org.quartz.dataSource.qzDS.URL:jdbc:mysql://localhost:3306/quartzdb
org.quartz.dataSource.qzDS.user:root
org.quartz.dataSource.qzDS.password:123456
org.quartz.dataSource.qzDS.maxConnection:10

四、數(shù)據(jù)庫相關(guān)
持久化須事先在相應(yīng)數(shù)據(jù)庫創(chuàng)建Quartz的數(shù)據(jù)表，在Quartz發(fā)布包里面的docs/dbTables有對(duì)應(yīng)不同數(shù)據(jù)庫的SQL腳本

例如，這里使用的是MYSQL：

20163791859291.png (271×235)

數(shù)據(jù)表字段解釋：

表qrtz_job_details: 保存job詳細(xì)信息,該表需要用戶根據(jù)實(shí)際情況初始化
job_name:集群中job的名字,該名字用戶自己可以隨意定制,無強(qiáng)行要求
job_group:集群中job的所屬組的名字,該名字用戶自己隨意定制,無強(qiáng)行要求
job_class_name:實(shí)現(xiàn)類的完全包名,quartz就是根據(jù)這個(gè)路徑到classpath找到該job類
is_durable:是否持久化,把該屬性設(shè)置為1，quartz會(huì)把job持久化到數(shù)據(jù)庫中
job_data:一個(gè)blob字段，存放持久化job對(duì)象
表qrtz_triggers: 保存trigger信息
trigger_name: trigger的名字,該名字用戶自己可以隨意定制,無強(qiáng)行要求
trigger_group:trigger所屬組的名字,該名字用戶自己隨意定制,無強(qiáng)行要求
job_name: qrtz_job_details表job_name的外鍵
job_group: qrtz_job_details表job_group的外鍵
trigger_state:當(dāng)前trigger狀態(tài)，設(shè)置為ACQUIRED,如果設(shè)置為WAITING,則job不會(huì)觸發(fā)
trigger_cron:觸發(fā)器類型,使用cron表達(dá)式
表qrtz_cron_triggers:存儲(chǔ)cron表達(dá)式表
trigger_name: qrtz_triggers表trigger_name的外鍵
trigger_group: qrtz_triggers表trigger_group的外鍵
cron_expression:cron表達(dá)式
表qrtz_scheduler_state:存儲(chǔ)集群中note實(shí)例信息，quartz會(huì)定時(shí)讀取該表的信息判斷集群中每個(gè)實(shí)例的當(dāng)前狀態(tài)
instance_name:之前配置文件中org.quartz.scheduler.instanceId配置的名字，就會(huì)寫入該字段，如果設(shè)置為AUTO,quartz會(huì)根據(jù)物理機(jī)名和當(dāng)前時(shí)間產(chǎn)生一個(gè)名字
last_checkin_time:上次檢查時(shí)間
checkin_interval:檢查間隔時(shí)間