前些天发现了一个巨牛的人工智能学习网站,通俗易懂,风趣幽默,忍不住分享一下给大家。点击跳转到教程。

Quartz API核心接口有:

  • Scheduler – 与scheduler交互的主要API;
  • Job – 你通过scheduler执行任务,你的任务类需要实现的接口;
  • JobDetail – 定义Job的实例;
  • Trigger – 触发Job的执行;
  • JobBuilder – 定义和创建JobDetail实例的接口;
  • TriggerBuilder – 定义和创建Trigger实例的接口;

本文工程免费下载

一、Job

在上一节中,Job中定义了实际的业务逻辑,而JobDetail包含Job相关的配置信息。在Quartz中,每次Scheduler执行Job时,在调用其execute()方法之前,它需要先根据JobDetail提供的Job类型创建一个Job class的实例,在任务执行完以后,Job class的实例会被丢弃,Jvm的垃圾回收器会将它们回收。因此编写Job的具体实现时,需要注意:

(1) 它必须具有一个无参数的构造函数;

(2) 它不应该有静态数据类型,因为每次Job执行完以后便被回收,因此在多次执行时静态数据没法被维护。

在JobDetail中有这么一个成员JobDataMap,JobDataMap是Java Map接口的具体实现,并添加了一些便利的方法用于存储与读取原生类型数据,里面包含了当Job实例运行时,你希望提供给它的所有数据对象。

可以借助JobDataMap为Job实例提供属性/配置,可以通过它来追踪Job的执行状态等等。对于第一种情况,可以在创建Job时,添加JobDataMap数据,在Job的execute()中获取数据,第二种,则可以在Listener中通过获取JobDataMap中存储的状态数据追踪Job的执行状态。

一个实现了Job接口的Java类就能够被调度器执行。接口如下:

  1. packageorg.quartz;
  2. publicinterface Job {
  3. public void execute(JobExecutionContext context) throwsJobExecutionException;
  4. }

很简的,当Job的trigger触发时,Job的execute(..)方法就会被调度器调用。被传递到这个方法里来的JobExecutionContext对象提供了带有job运行时的信息:执行它的调度器句柄、触发它的触发器句柄、job的JobDetail对象和一些其他的项。JobDetail对象是Job在被加到调度器里时所创建的,它包含有很多的Job属性设置,和JobDataMap一样,可以用来存储job实例时的一些状态信息。

比如如下任务类

[java] view plain copy
  1. <code class="language-java">package com.mucfc;
  2. import java.util.Date;
  3. import org.apache.commons.logging.Log;
  4. import org.apache.commons.logging.LogFactory;
  5. import org.quartz.Job;
  6. import org.quartz.JobDetail;
  7. import org.quartz.JobExecutionContext;
  8. import org.quartz.JobExecutionException;
  9. public class NewJob implements Job{
  10. static Log logger = LogFactory.getLog(NewJob.class);
  11. @Override
  12. public void execute(JobExecutionContext context) throws JobExecutionException {
  13. System.err.println("Hello!  NewJob is executing."+new Date() );
  14. //取得job详情
  15. JobDetail jobDetail = context.getJobDetail();
  16. // 取得job名称
  17. String jobName = jobDetail.getClass().getName();
  18. logger.info("Name: " + jobDetail.getClass().getSimpleName());
  19. //取得job的类
  20. logger.info("Job Class: " + jobDetail.getJobClass());
  21. //取得job开始时间
  22. logger.info(jobName + " fired at " + context.getFireTime());
  23. logger.info("Next fire time " + context.getNextFireTime());
  24. }
  25. }
  26. </code>

当 Scheduler 调用一个 Job,一个 JobexecutionContext 传递给 execute() 方法。JobExecutionContext 对象让 Job 能访问 Quartz 运行时候环境和 Job 本身的明细数据。这就类似于在 Java Web 应用中的 servlet 访问 ServletContext 那样。通过 JobExecutionContext,Job 可访问到所处环境的所有信息,包括注册到 Scheduler 上与该 Job 相关联的 JobDetail 和 Triiger。

二、JobDetail

JobDetail实例是通过JobBuilder类创建的

可以通过导入该类下的所有静态方法

       import static org.quartz.JobBuilder.*;

然后是创建:

  1. 创建一个JobDetail实例
  2. JobDetail jobDetail = newJob(NewJob.class).withIdentity("job1_1", "jGroup1").build();

如果不导入静态包:

那么就要用:

  1. 创建一个JobDetail实例
  2. obDetail jobDetail = JobBuilder.newJob(NewJob.class).withIdentity("job1_1", "jGroup1").build();

对于部署在 Scheduler 上的每一个 Job 只创建了一个 JobDetail 实例。JobDetail 是作为 Job 实例进行定义的。注意到在代码 中不是把 Job 对象注册到 Scheduler;实际注册的是一个 JobDetail 实例。

  1. public void startSchedule() {
  2. try {
  3. // 1、创建一个JobDetail实例,指定Quartz
  4. JobDetail jobDetail = JobBuilder.newJob(NewJob.class) // 任务执行类
  5. .withIdentity("job1_1", "jGroup1")// 任务名,任务组
  6. .build();
  7. //2、创建Trigger
  8. SimpleScheduleBuilder builder=SimpleScheduleBuilder.simpleSchedule()
  9. .withIntervalInSeconds(5) //设置间隔执行时间
  10. .repeatSecondlyForTotalCount(5);//设置执行次数
  11. Trigger trigger=TriggerBuilder.newTrigger().withIdentity(
  12. "trigger1_1","tGroup1").startNow().withSchedule(builder).build();
  13. //3、创建Scheduler
  14. Scheduler scheduler=StdSchedulerFactory.getDefaultScheduler();
  15. //4、调度执行
  16. scheduler.scheduleJob(jobDetail, trigger);
  17. scheduler.start();
  18. } catch (SchedulerException e) {
  19. e.printStackTrace();
  20. }
  21. }

结果:

从上面的代码中可以看JobDetail 被加到 Scheduler 中了,而不是 job。Job 类是作为 JobDetail 的一部份,但是它直到 Scheduler 准备要执行它的时候才会被实例化的。

直到执行时才会创建 Job 实例

Job 的实例要到该执行它们的时候才会实例化出来。每次 Job 被执行,一个新的 Job 实例会被创建。其中暗含的意思就是你的 Job 不必担心线程安全性,因为同一时刻仅有一个线程去执行给定 Job 类的实例,甚至是并发执行同一 Job 也是如此。

可以看到,我们传给scheduler一个JobDetail实例,因为我们在创建JobDetail时,将要执行的job的类名传给了JobDetail,所以scheduler就知道了要执行何种类型的job;每次当scheduler执行job时,在调用其execute(…)方法之前会创建该类的一个新的实例;执行完毕,对该实例的引用就被丢弃了,实例会被垃圾回收;这种执行策略带来的一个后果是,job必须有一个无参的构造函数(当使用默认的JobFactory时);另一个后果是,在job类中,不应该定义有状态的数据属性,因为在job的多次执行中,这些属性的值不会保留。

那么如何给job实例增加属性或配置呢?如何在job的多次执行中,跟踪job的状态呢?答案就是:JobDataMap,JobDetail对象的一部分。

三、JobDataMap

JobDataMap中可以包含不限量的(序列化的)数据对象,在job实例执行的时候,可以使用其中的数据;JobDataMap是Java Map接口的一个实现,额外增加了一些便于存取基本类型的数据的方法。

将job加入到scheduler之前,在构建JobDetail时,可以将数据放入JobDataMap,如下示例:

  1. package com.mucfc;
  2. import org.quartz.Job;
  3. import org.quartz.JobDataMap;
  4. import org.quartz.JobExecutionContext;
  5. import org.quartz.JobExecutionException;
  6. import org.quartz.JobKey;
  7. public class NewJob2 implements Job{
  8. @Override
  9. public void execute(JobExecutionContext context) throws JobExecutionException {
  10. JobKey key = context.getJobDetail().getKey();
  11. JobDataMap dataMap = context.getJobDetail().getJobDataMap();
  12. String jobSays = dataMap.getString("jobSays");
  13. float myFloatValue = dataMap.getFloat("myFloatValue");
  14. System.out.println("Instance " + key + " of DumbJob says: " + jobSays + ", and val is: " + myFloatValue);
  15. }
  16. }

在job的执行过程中,可以从JobDataMap中取出数据,如下示例:

  1. package com.mucfc;
  2. import org.quartz.JobBuilder;
  3. import org.quartz.JobDetail;
  4. import org.quartz.Scheduler;
  5. import org.quartz.SchedulerException;
  6. import org.quartz.SimpleScheduleBuilder;
  7. import org.quartz.Trigger;
  8. import org.quartz.TriggerBuilder;
  9. import org.quartz.impl.StdSchedulerFactory;
  10. public class Test {
  11. public void startSchedule() {
  12. try {
  13. // 1、创建一个JobDetail实例,指定Quartz
  14. JobDetail jobDetail = JobBuilder.newJob(NewJob.class) // 任务执行类
  15. .withIdentity("job1_1", "jGroup1")// 任务名,任务组
  16. .build();
  17. JobDetail jobDetail2 = JobBuilder.newJob(NewJob2.class)
  18. .withIdentity("job1_2", "jGroup1")
  19. .usingJobData("jobSays", "Hello World!")
  20. .usingJobData("myFloatValue", 3.141f)
  21. .build();
  22. //2、创建Trigger
  23. SimpleScheduleBuilder builder=SimpleScheduleBuilder.simpleSchedule()
  24. .withIntervalInSeconds(5) //设置间隔执行时间
  25. .repeatSecondlyForTotalCount(5);//设置执行次数
  26. Trigger trigger=TriggerBuilder.newTrigger().withIdentity(
  27. "trigger1_1","tGroup1").startNow().withSchedule(builder).build();
  28. //3、创建Scheduler
  29. Scheduler scheduler=StdSchedulerFactory.getDefaultScheduler();
  30. //4、调度执行
  31. scheduler.scheduleJob(jobDetail2, trigger);
  32. scheduler.start();
  33. } catch (SchedulerException e) {
  34. e.printStackTrace();
  35. }
  36. }
  37. public static void main(String[] args) {
  38. Test test=new Test();
  39. test.startSchedule();
  40. }
  41. }

结果:

四、 Trigger

Trigger对象是用来触发执行Job的。当调度一个job时,我们实例一个触发器然后调整它的属性来满足job执行的条件。触发器也有一个和它相关的JobDataMap,它是用来给被触发器触发的job传参数的。Quartz有一些不同的触发器类型,不过,用得最多的是SimpleTrigger和CronTrigger。

如果我们需要在给定时刻执行一次job或者在给定时刻触发job随后间断一定时间不停的执行的话,SimpleTrigger是个简单的解决办法;如果我们想基于类似日历调度的触发job的话,比如说,在每个星期五的中午或者在每个月第10天的10:15触发job时,CronTrigger是很有用的。

为什么用jobs和triggers呢?很多任务调度器并没有任务和触发器的概念,一些任务调度器简单定义一个“job”为在一个执行时间伴随一些小任务标示,其他的更像Quartz里job和trigger对象的联合体。在开发Quartz时,开发者们决定,在调度时间表和在这上面运行的工作应该分开。这是很有用的。

例如,job能够独立于触发器被创建和储存在任务调度器里,并且,很多的触发器能够与同一个job关联起来。这个松耦合的另一个好处就是在与jobs关联的触发器终止后,我们能够再次配置保留在调度器里的jobs,这样的话,我们能够再次调度这些jobs而不需要重新定义他们。我们也可以在不重新定义一个关联到job的触发器的情况下,修改或替代它。

当Jobs和triggers被注册到Quartz的调度器里时,他们就有了唯一标示符。他们也可以被放到“groups”里,Groups是用来组织分类jobs和triggers的,以便今后的维护。在一个组里的job和trigger的名字必须是唯一的,换句话说,一个job和trigger的全名为他们的名字加上组名。如果把组名置为”null”,系统会自动给它置为Scheduler.DEFAULT_GROUP

Scheduler在使用之前需要实例化。一般通过SchedulerFactory来创建一个实例。有些用户将factory的实例保存在JNDI中,但直接初始化,然后使用该实例也许更简单(见下面的示例)。

scheduler实例化后,可以启动(start)、暂停(stand-by)、停止(shutdown)。注意:scheduler被停止后,除非重新实例化,否则不能重新启动;只有当scheduler启动后,即使处于暂停状态也不行,trigger才会被触发(job才会被执行)。

五、SimpleTrigger的介绍

正如其名所示,SimpleTrigger对于设置和使用是最为简单的一种 QuartzTrigger。它是为那种需要在特定的日期/时间启动,且以一个可能的间隔时间重复执行 n 次的 Job 所设计的。
我们前面已经在一个简单的Quartz的例子里使用过了SimpleTrigger,我们通过

  1. SimpleScheduleBuilder builder=SimpleScheduleBuilder.simpleSchedule()
  2. //设置间隔执行时间
  3. .withIntervalInSeconds(5)
  4. //设置执行次数
  5. .withRepeatCount(4);
  1. Trigger trigger=TriggerBuilder.newTrigger().withIdentity(
  2. "trigger1_1","tGroup1").startNow().withSchedule(builder).build();

或者无限执行

  1. SimpleScheduleBuilder builder=SimpleScheduleBuilder.simpleSchedule()
  2. //设置间隔执行时间
  3. .withIntervalInSeconds(5)
  4. //设置执行次数
  5. .repeatForever();
  6. Trigger trigger=TriggerBuilder.newTrigger().withIdentity(
  7. "trigger1_1","tGroup1").startNow().withSchedule(builder).build();

对于Quartz而言,它还不能满足我们的触发情况,所以它仅仅是用于一些简单的触发情况;

六、CronTrigger

CronTrigger 允许设定非常复杂的触发时间表。然而有时也许不得不使用两个或多个 SimpleTrigger来满足你的触发需求,这时候,你仅仅需要一个 CronTrigger 实例就够了。顾名思义,CronTrigger 是基于 Unix类似于 cron 的表达式。例如,你也许有一个 Job,要它在星期一和星期五的上午 8:00-9:00间每五分钟执行一次。假如你试图用 SimpleTrigger 来实现,你或许要为这个 Job 配置多个Trigger。然而,你可以使用如下的表达式来产生一个遵照这个时间表触发的 Trigger;
比如:

  1. // 创建Trigger
  2. CronScheduleBuilder builder2 = CronScheduleBuilder.cronSchedule("0 0/5 8 * * *");//8:00-8:55,每隔5分钟执行
  3. /**
  4. builder2 = CronScheduleBuilder.dailyAtHourAndMinute(12, 30);
  5. **/
  6. Trigger trigger=TriggerBuilder.newTrigger().withIdentity("trigger1_1","tGroup1").startNow().withSchedule(builder2).build();

因为 CronTrigger内建的如此强的灵活性,也与生俱来可用于创建几乎无所限制的表达式,且因为支持unix的cron表达式,则做为企业应用,我们的操作系统一般也都以unxi操作系统为主,所以掌握CronTrigger的使用费用有必要,我们将在后面对CronTrigger 进行详细的介绍。cron 表达式的格式见下一节。

七、Job与Trigger的关系

大家都知道,一个作业,比较重要的三个要素就是Schduler,jobDetail,Trigger;而Trigger对于job而言就好比一个驱动器;没有触发器来定时驱动作业,作业就无法运行;对于Job而言,一个job可以对应多个Trigger,但对于Trigger而言,一个Trigger只能对应一个job;所以一个Trigger 只能被指派给一个 Job;如果你需要一个更复杂的触发计划,你可以创建多个 Trigger 并指派它们给同一个 Job。Scheduler 是基于配置在 Job上的 Trigger 来决定正确的执行计划的,下面就是为同一个 JobDetail 使用多个Trigger;

转自:http://blog.csdn.net/evankaka

本文工程免费下载

【Quartz】深入Job、JobDetail、JobDataMap、Trigger相关推荐

  1. 第四节: Quartz.Net五大构件之Trigger通用用法(常用方法、优先级、与job关联等)

    一. 简介 1. 几个类型: ①:TriggerBuilder:用来创建ITrigger实例 ②:ITrigger:触发器实例 2.常用的几个方法 ①.StartNow:Trigger马上触发. ②. ...

  2. 处理quartz 异常 Couldn‘t retrieve trigger: No record found for selection of Trigger with key:

    处理quartz 异常 Couldn't retrieve trigger: No record found for selection of Trigger with key: 参考文章: (1)处 ...

  3. Corg.quartz.JobPersistenceException: Couldn‘t retrieve trigger

    项目场景: 提示:这里简述项目相关背景: 例如:项目场景:示例:通过蓝牙芯片(HC-05)与手机 APP 通信,每隔 5s 传输一批传感器数据(不是很大) 问题描述: 启动项目之前修改了路径,调整了位 ...

  4. 任务定时器报错:org.quartz.JobPersistenceException: Couldn't retrieve trigger: invalid stream header: C2ACED

    定时器在项目启动时,就会初始化并执行,代码没有检查出来任何问题,启动就报错如下: Error starting ApplicationContext. To display the condition ...

  5. org.quartz.JobPersistenceException: Couldn‘t store trigger ‘DEFAULT.MT_vqhsgkj1lrr8‘ for ‘?,?‘

    Couldn't store trigger 'DEFAULT.MT_vqhsgkj1lrr8' 错误信息 解决办法 错误信息 org.quartz.JobPersistenceException: ...

  6. java quartz Scheduler 操作JobDetail

    scheduler可以看成是一个容器,对JobDetail进行增删改查 //增 sched.addJob(job,false);// false表示不替换,ture表示替换,既更新;另外一般使用 比较 ...

  7. 第五节: Quartz.Net五大构件之Trigger的四大触发类

    一. WithSimpleSchedule(ISimpleTrigger) 1. 用途:时.分.秒上的轮询(和timer类似),实际开发中,该场景占绝大多数. 2. 轮询的种类:永远轮询和限定次数轮询 ...

  8. 定时任务Quartz

    目录 Quartz框架 SpringBoot整合Quartz 一般job类都要加上这两个注解 Quartz集群 注意事项 Quartz框架 Quartz三大组件JobDetail,Trigger,Sc ...

  9. quarts任务调度快速上手

    了解Quartz体系结构 Quartz对任务调度的领域问题进行了高度的抽象,提出了调度器.任务和触发器这3个核心的概念,并在org.quartz通过接口和类对重要的这些核心概念进行描述: ●Job:是 ...

最新文章

  1. 逻辑运算符''取某值
  2. 强监管下 协议支付会是互金平台救命稻草?(协议支付是代扣协议的升级版)
  3. 文件服务器的配置与管理(3) 共享文件夹的创建与使用
  4. Java黑皮书课后题第10章:**10.9(Course类)如下改写Course类
  5. RTX5 | STM32H743+CubeMX+RTX5+两路FDCAN驱动+CANopen协议
  6. C语言获取某个文件中一行内容中指定字符串后的值
  7. linux环境 jenkins +allure生成测试报告
  8. url没有参数名怎么直接带参数_用30行Python爬虫带你看PLMM(划掉,喵星人)
  9. PhotoshopCS5中将单位修改成百分比
  10. java 折线_用Java绘制简单的折线图
  11. 如何为复杂页面实现过渡页面
  12. DCGAN-深度卷积生成对抗网络-转置卷积
  13. 关于boostrap的modal隐藏问题(前端框架)
  14. spss数据预处理步骤_Spss的数据预处理
  15. 小波变换matlab代码,matlab小波变换代码
  16. html5在线聊天一对一,纯js网页在线聊天对话插件(原创)
  17. CSS媒体查询(@media)全面解析
  18. Qt之定制个性化系统托盘菜单(仿360安全卫士)
  19. 程序员面试常见的10个问题,非常实用的面试技巧,收藏一下
  20. 《人类简史》笔记二——一场永远的革命

热门文章

  1. SharePoint 2007 and 2010 的服务器场的端口
  2. 一步步编写操作系统 57 门、调用门与RPL序 2
  3. 接口和抽象类是否继承了Object
  4. 内存参数 计算_Spark统一内存管理的实现
  5. 【LeetCode-SQL每日一练】—— 196. 删除重复的电子邮箱
  6. 【CodeForces - 1197C】Array Splitting(水题)
  7. 【牛客 - 21302】被3整除的子序列(线性dp)
  8. 【HDU - 1540】 Tunnel Warfare (线段树进阶操作 区间合并+ 单点更新+ 最长覆盖区间查询 )
  9. 《TCP/IP详解》学习笔记(二):数据链路层
  10. 用OpenSSL编写SSL,TLS程序