手机
当前位置:查字典教程网 >编程开发 >Java >Java的作业调度类库Quartz基本使用指南
Java的作业调度类库Quartz基本使用指南
摘要:一、常用接口:1、Job接口:该接口只有一个方法voidexecute(JobExecutionContextcontext)开发者实现该接...

一、常用接口:

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:

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

数据表字段解释:

表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:检查间隔时间

【Java的作业调度类库Quartz基本使用指南】相关文章:

Java线程中断的本质深入理解

java调用百度定位api服务获取地理位置示例

java中final与finally的使用介绍

java类中使用Jfreechart的简单实例

java中的枚举类型详细介绍

java不可逆加密算法之md5加密算法使用示例

java中的移位运算符心得总结

Java的关键字与保留字小结

java读取大文件简单实例

Java动态代理的应用详解

精品推荐
分类导航