Java的作业调度类库Quartz基本使用指南

一、常用接口：
1、job接口：该接口只有一个方法

void execute(jobexecutioncontext context)

开发者实现该接口定义需要执行的任务。jobexecutioncontext类提供调度上下文的各种信息

2、jobdetail：用于描叙job实现类及其他的一些静态信息

3、trigger：描叙触发job执行的时间触发规则

4、calendar：定义了一个关联trigger可能(或者不可能)触发的时间空间。它没有定义触发的真实时间，而是用在在普通的schedule需要限制trigger触发的时候。大部分calendar包含默认所有的时间，并且用户去排除部分时间。

5、scheduler：运行容器，使用schedulerfactory创建scheduler实例

二、代码示例：

1、使用quartz，需要实现job接口；

public class testjob implements job {
 public void execute(jobexecutioncontext context) throws jobexecutionexception {
 system.out.println("hello world! - " + new date());
 //do more...
 }
}

2、调度【比较简单，直接看代码就可以了】

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) //时间间隔
   .withrepeatcount(5) //重复次数(将执行6次)
   )
  .build();
 schedulerfactory sf = new stdschedulerfactory();
 scheduler sched = sf.getscheduler();
 
 sched.schedulejob(jobdetail,trigger);
 
 sched.start();
 
 }
}

这里使用的是2.2.1版本，参考官方文档的示例。看到一些参考书使用的版本比较老，所以会有一些出入，很多方法都被弃用了，所以还是直接看文档比较实在，quartz的官方网站地址是：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
#============================================================================
 
#默认配置，数据保存到内存
#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
#数据库表前缀
org.quartz.jobstore.tableprefix:qrtz_
org.quartz.jobstore.datasource:qzds
 
#============================================================================
# configure datasources
#============================================================================
#jdbc驱动
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

四、数据库相关
持久化须事先在相应数据库创建quartz的数据表，在quartz发布包里面的docs/dbtables有对应不同数据库的sql脚本

例如，这里使用的是mysql：

数据表字段解释：

• 表qrtz_job_details: 保存job详细信息,该表需要用户根据实际情况初始化
• job_name:集群中job的名字,该名字用户自己可以随意定制,无强行要求
• job_group:集群中job的所属组的名字,该名字用户自己随意定制,无强行要求
• job_class_name:实现类的完全包名,quartz就是根据这个路径到classpath找到该job类
• is_durable:是否持久化,把该属性设置为1，quartz会把job持久化到数据库中
• job_data:一个blob字段，存放持久化job对象
• 表qrtz_triggers: 保存trigger信息
• trigger_name: trigger的名字,该名字用户自己可以随意定制,无强行要求
• trigger_group:trigger所属组的名字,该名字用户自己随意定制,无强行要求
• job_name: qrtz_job_details表job_name的外键
• job_group: qrtz_job_details表job_group的外键
• trigger_state:当前trigger状态，设置为acquired,如果设置为waiting,则job不会触发
• trigger_cron:触发器类型,使用cron表达式
• 表qrtz_cron_triggers:存储cron表达式表
• trigger_name: qrtz_triggers表trigger_name的外键
• trigger_group: qrtz_triggers表trigger_group的外键
• cron_expression:cron表达式
• 表qrtz_scheduler_state:存储集群中note实例信息，quartz会定时读取该表的信息判断集群中每个实例的当前状态
• instance_name:之前配置文件中org.quartz.scheduler.instanceid配置的名字，就会写入该字段，如果设置为auto,quartz会根据物理机名和当前时间产生一个名字
• last_checkin_time:上次检查时间
• checkin_interval:检查间隔时间