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

一、常用接口：
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:检查间隔时间

以上是小编为您精心准备的的内容，在的博客、问答、公众号、人物、课程等栏目也有的相关内容，欢迎继续使用右上角搜索按钮进行搜索java
quartz
quartz作业调度框架、quartz 调度spark作业、任务调度 quartz、quartz分布式任务调度、quartz 分布式调度，以便于您获取更多的相关知识。

时间： 2024-04-10 03:44:46

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

举例讲解Java的JSON类库GSON的基本用法_java

GSON这个Java类库可以把Java对象转换成JSON,也可以把JSON字符串转换成一个相等的Java对象.Gson支持任意复杂Java对象包括没有源代码的对象. 其他的json解析库还有json-lib:Jackson:com.alibaba.fastjson 小编还是喜欢Google的Gson. 一.使用场景:java对象和json字符串的相互转换:日志输出. 例如: Logger logger = Logger.getLogger(CommonAction.class); Gson g

Java的Socket通讯基础编程完全指南_java

什么是Socket网络上的两个程序通过一个双向的通讯连接实现数据的交换,这个双向链路的一端称为一个Socket.Socket通常用来实现客户方和服务方的连接.Socket是TCP/IP协议的一个十分流行的编程界面,一个Socket由一个IP地址和一个端口号唯一确定. 但是,Socket所支持的协议种类也不光TCP/IP一种,因此两者之间是没有必然联系的.在Java环境下,Socket编程主要是指基于TCP/IP协议的网络编程. Socket通讯的过程Server端Listen(监听)某个端口是否

求教，如何用eclipse看java的标准类库的源码？===求助

问题描述 求教,如何用eclipse看java的标准类库的源码?===求助 求教,如何用eclipse看java的标准类库的源码?百度上搜到的办法不好用===求助 解决方案 首先把src.zip关联到Eclipse中,操作参考http://www.360doc.com/content/14/0117/14/15109633_345953972.shtml 然后用到什么库函数中的类,直接选中按F3查看源码就可以了. 解决方案二: 使用java反编译工具(jadclipse),很爽啊.http://

求高手解答 java.lang.ClassCastException: org.quartz.simpl.SimpleThreadPool

问题描述 使用quartz的时候,启动程序就抛出如下异常,不知道问题出在那,求解决...严重:Spring容器初始化过程中出现异常[wrzs_core]org.springframework.beans.factory.BeanCreationException:Errorcreatingbeanwithname'getScheduling':Invocationofinitmethodfailed;nestedexceptionisorg.quartz.SchedulerException:T

Thumbnailator v0.3.2发布 Java缩略图生成类库

Thumbnailator是一个Java缩略图生成类库.利用其提供的简单API,两三行代码就能够从现有图片生成缩略图.支持根据一个目录批量生成缩略图. 在Java制作缩略图可以是一个相当艰巨的任务.学习如何使用图像I/O API的,Java 2D API的,图像处理,图像 缩放技术,但不要害怕!Thumbnailator将使此操作 成为可能.Thumbnailator的流畅接口可以被用来执行相当 复杂的缩略图在一个简单的步骤处理任务.&http://www.aliyun.com/zixun/ag

实例讲解Java编程中数组反射的使用方法_java

什么是反射"反射(Reflection)能够让运行于JVM中的程序检测和修改运行时的行为."这个概念常常会和内省(Introspection)混淆,以下是这两个术语在Wikipedia中的解释: 内省用于在运行时检测某个对象的类型和其包含的属性: 反射用于在运行时检测和修改某个对象的结构及其行为. 从它们的定义可以看出,内省是反射的一个子集.有些语言支持内省,但并不支持反射,如C++. 内省示例:instanceof 运算符用于检测某个对象是否属于特定的类. if (obj insta

Java常用的一些多媒体文件基本操作方法简介_java

播放幻灯片和动画 用实例说明播放幻灯片和动画的方法. [例]小应用程序先将幻灯片读入数组在存储,单击鼠标变换幻灯片,逐张显示. import java.applet.*import java.awt.*; import java.awt.event.*; public class Example7_7 extends Applet implements MouseListener{ final int number = 50; //假定幻灯片有50张 int count = 0; Image[]

在Java SE上使用Headless模式的超级指南_java

 这篇文章介绍怎样在标准Java(Java SE,也称作J2SE)平台上用Headless模式. Headless模式是在缺少显示屏.键盘或者鼠标时的系统配置.听起来不可思议,但事实上你可以在这中模式下完成不同的操作,甚至是用图形数据也可以. 哪里才能用到此模式呢?想想你的应用不停的生成一张图片,比如,当用户每次登陆系统是都要生成一张认证图片.当创建图片时,你得应用既不需要显示器也不需要键盘.让我们假设一下,现在你的应用有个主架构或者专有服务器,但这个服务没有显示器,键盘或者鼠标.理想的决定是用

Apache Camel的Java编程入门指南_java

 Apache Camel是一个非常实用的规则引擎库,能够用来处理来自于不同源的事件和信息.你可以在使用不同的协议比如VM,HTTP,FTP,JMS甚至是文件系统中来传递消息,并且让你的操作逻辑和传递逻辑保持分离,这能够让你更专注于消息的内容. 在这篇文章中,我将提供一个Java语言(非Groovy)的Apache Camel入门演示. 首先创建一个Maven项目的pom.xml.   <?xml version="1.0" encoding="UTF-8"?