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

 更新时间:2016年03月07日 08:52:23   投稿:goldensun  
这篇文章主要介绍了Java的作业调度类库Quartz基本使用指南,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:

20163791859291.png (271×235)

数据表字段解释:

  • 表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静态代码块作用及执行顺序解析

    Java静态代码块作用及执行顺序解析

    这篇文章主要介绍了Java静态代码块作用及执行顺序解析,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友可以参考下
    2020-04-04
  • Java 生成带Logo和文字的二维码

    Java 生成带Logo和文字的二维码

    这篇文章主要介绍了Java 生成带Logo和文字的二维码的方法,帮助大家更好的理解和学习使用Java,感兴趣的朋友可以了解下
    2021-04-04
  • java直接插入排序示例

    java直接插入排序示例

    这篇文章主要介绍了java直接插入排序示例,插入排序的比较次数仍然是n的平方,但在一般情况下,它要比冒泡排序快一倍,比选择排序还要快一点。它常常被用在复杂排序算法的最后阶段,比如快速排序。
    2014-05-05
  • Java数据类型分类与基本数据类型转换

    Java数据类型分类与基本数据类型转换

    这篇文章主要介绍了Java数据类型分类与基本数据类型转换,Java的数据类型主要分为两类,基本数据类型、引用数据类型,下文详细介绍,感兴趣的朋友可以参考一下
    2022-07-07
  • jpa使用注解生成表时无外键问题及解决

    jpa使用注解生成表时无外键问题及解决

    这篇文章主要介绍了jpa使用注解生成表时无外键问题及解决方案,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-06-06
  • idea SpringBoot+Gradle环境配置到项目打包

    idea SpringBoot+Gradle环境配置到项目打包

    Gradle是一个基于Java应用的项目自动化构建工具,本文介绍了在IDEA中创建Spring Boot Gradle项目,项目配置包括init.gradle和settings.gradle,感兴趣的可以了解一下
    2024-11-11
  • Java中import导入的用法说明

    Java中import导入的用法说明

    这篇文章主要介绍了Java中import导入的用法说明,具有很好的参考价值,希望对大家有所帮助。如有错误或未考虑完全的地方,望不吝赐教
    2022-06-06
  • 使用XML配置c3p0数据库连接池

    使用XML配置c3p0数据库连接池

    这篇文章主要为大家详细介绍了使用XML配置c3p0数据库连接池,具有一定的参考价值,感兴趣的小伙伴们可以参考一下
    2019-08-08
  • Java实现的生成二维码统计扫描次数并转发到某个地址功能详解

    Java实现的生成二维码统计扫描次数并转发到某个地址功能详解

    这篇文章主要介绍了Java实现的生成二维码统计扫描次数并转发到某个地址功能,可实现生成带统计功能的二维码,涉及java二维码的生成、参数传递、解析等相关操作技巧,需要的朋友可以参考下
    2018-07-07
  • 使用maven创建普通项目命令行程序详解

    使用maven创建普通项目命令行程序详解

    大部分使用maven创建的是web项目,这里使用maven创建一个命令行程序,目的是让大家了解maven特点和使用方式,有需要的朋友可以借鉴参考下
    2021-10-10

最新评论