Quartz任务调度框架_IT分享知识网

大家好，欢迎来到IT知识分享网。

文章目录

前言
一、介绍
二、使用步骤
三、基本实现原理

前言

最近跟的一个系统需要实时监控主机的应用进程以及存储空间等，实时生成告警提醒，这就需要在规定的时间去触发消息提醒功能，在这里主要也是用到了Quartz来调度任务的。

一、介绍

驱动流程：比如在确定时间后根据任务完成情况触发一个警告并通知
系统维护：在具体时间点调度一个数据从数据库转到xml文件中
在应用中提供消息提醒服务

二、使用步骤

1.创建maven工程，添加依赖

下载quartz的jar包，导入依赖

<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.3.2</version> </dependency>

2.创建任务

代码如下（示例）：

public class MyJob implements Job { 
      private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"); public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { 
      //执行任务的逻辑 String time = sdf.format(new Date()); System.out.println("~~~~~"+time); } }

3.启动任务

使用任务调度器Scheduler进行任务管理

启动任务
暂停任务
继续任务
停止任务

package com.qfedu.job; import org.quartz.*; import org.quartz.impl.StdSchedulerFactory; import java.util.Date; public class QuartzTest { 
      public static void main(String[] args) { 
      try { 
      //1.创建Quartz的任务调度器 Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); //2.创建触发器：定义了任务调度的时机（延时、循环、定时...） // simpleScheduleBuilder对象表示任务的触发规则 SimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.simpleSchedule() .withIntervalInSeconds(3) .withRepeatCount(10); SimpleTrigger trigger = TriggerBuilder.newTrigger() .withIdentity("trigger1", "group1")// withIdentity 设置trigger唯一表示 .startAt(new Date(System.currentTimeMillis() + 5000))// startAt 设置首 次触发时间 .withSchedule(simpleScheduleBuilder)// withSchedule 设置触发器的触发规则 .build(); // 通过TriggerBuilder对象，构造Trigger对象 //3.创建任务(JobDetail 用于封装具体的任务) JobDetail job = JobBuilder.newJob(MyJob.class).build(); //将任务及触发器，绑定到任务调度 scheduler.scheduleJob(job,trigger); //启动任务 scheduler.start() } catch (SchedulerException e) { 
      e.printStackTrace(); } } }

三、基本实现原理

scheduler：任务调度器（执行调度的控制器）
trigger：触发器，用于定义任务调度时间规则
job：任务，即被调度的任务

1. Scheduler任务调度器

Scheduler任务调度器由SchedulerFactory 工厂创建，主要提供了以下两种工厂实现：

DirectSchedulerFactory（使用较麻烦，需要进行编码配置）
StdSchedulerFactory（✔）

Scheduler 主要有三种：

RemoteMBeanScheduler
RemoteScheduler
StdScheduler（✔）
创建任务调度器

Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();

2. Triggers触发器

DateIntervalTrigger 日期周期的规则的触发器
NthIncludedDayTrigger 排除指定时间周期和日期的触发器

2.1 SimpleTrigger

延时任务：当用户提交订单之后启动任务，延时30min检查订单状态，如果未支付则取消订单
释放库存
循环任务：每个指定的时间周期执行一次任务，任务可以循环（可以无限循环、可以循环指
定的次数、还可以循环执行到指定的时间点）
定时任务：在指定的时间点调度执行任务
规则：
重复次数，可以是0、正整数，以及常量SimpleTrigger.REPEAT_INDEFINITELY
重复的间隔，必须是0，或者long型的正数，表示毫秒。注意，如果重复间隔为0，trigger将会以重
复次数并发执行(或者以scheduler可以处理的近似并发数)。
endTime属性的值会覆盖设置重复次数的属性值；比如，你可以创建一个trigger，在终止时间之前
每隔10秒执行一次，你不需要去计算在开始时间和终止时间之间的重复次数，只需要设置终止时间
并将重复次数设置为REPEAT_INDEFINITELY。

//指定时间触发，每隔10秒执行一次，重复10次： SimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.simpleSchedule() .withIntervalInSeconds(10) .withRepeatCount(10); SimpleTrigger trigger = (SimpleTrigger) TriggerBuilder.newTrigger() .withIdentity("trigger3", "group1") .startAt(myTimeToStartFiring) //指定触发的时间 .withSchedule(simpleScheduleBuilder) //指定触发器的时间规则 .forJob(myJob) .build();

2.2 CronTirgger

使用cron表达式定义触发任务的时间规则，通常比SimpleTrigger更有用，如果需要基于日历的概念而不是按照SimpleTrigger的精确指定间隔进行重新启动的作业启动计划。使用CronTrigger可以指时间表，例如“每周五中午”或“每个工作日和上午9:30”，甚至“每周一至周五上午9:00至10点之间每5分钟”和1月份的星期五“。和SimpleTrigger一样，CronTrigger有一个startTime，它指定何时生效，以及一个（可选的）endTime，用于指定何时停止计划。

// 通过cron表达式定义触发任务的时间规则 CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0/3 * * * * ?"); //触发器 CronTrigger cronTrigger = (CronTrigger) TriggerBuilder.newTrigger() .withIdentity("cronTrigger1","group1") .startAt( DateBuilder.futureDate(5, DateBuilder.IntervalUnit.SECOND) )//设置首次执行任务的时间 .withSchedule( cronScheduleBuilder ) //将时间规则设置给触发器 .endAt(DateBuilder.dateOf(22,0,0) ) //设置任务终止的时间 .build();

简单介绍一下Cron表达式：
由七个子表达式组成的字符串（最后一个年份可省略）

Seconds Minutes Hours Day-of-Month Month Day-of-Week Year 秒 分 时 日期 月份 星期几 年份 //示例 #每5分钟就会触发一次 “0 0/5 * * *？” #每5分钟触发一次，分钟后10秒（即上午10时10分，上午10:05:10等）。 “10 0/5 * * *？”

3. Misfire策略

Misfire当已经绑定到调度器Scheduler的触发器及任务在执行的过程中，因Scheduler出现故障停止了、或者线程池中没有充足的线程执行到期的任务，从而导致Trigger触发周期到了但是任务没有执行的情况。
对于所有类型的Trigger，Quartz都为其指定了默认的定义其恢复之后的执行策略——MISFIRE_INSTRUCTION_SMART_POLICY（立即执行misfire的任务，然后继续按计划往后执行）

SimpleTrigger的Misfire策略

#当资源可用时立即执行所有misfire的任务，执行到设置的endTime剩余的周期次数 MISFIRE_INSTRUCTION_FIRE_NOW #不会判断misfire，当资源可用时立即执行所有misfire的任务，然后按照原计划执行 MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY #立即执行第一次misfire任务，修改startTime为当前时间，按照原来的时间间隔执行下一次任务（总次数不变） MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_EXISTING_REPEAT_COUNT # 立即执行第一次misfire任务，修改startTime为当前时间，按照原来的时间间隔执行下一次任务（剩下的任务） MISFIRE_INSTRUCTION_RESCHEDULE_NOW_WITH_REMAINING_REPEAT_COUNT # 不会立即执行任务，等到下一次计划时间到达时开始执行，忽略已经发生的misfire任务 MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_EXISTING_COUNT # 不会立即执行任务，等到下一次计划时间到达时开始执行，忽略已经发生的misfire任务 MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_REMAINING_COUNT //示例 SimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.simpleSchedule() .withIntervalInSeconds(3).repeatForever() //.withMisfireHandlingInstructionFireNow() //.withMisfireHandlingInstructionIgnoreMisfires() //.withMisfireHandlingInstructionNextWithExistingCount() //.withMisfireHandlingInstructionNextWithRemainingCount() //.withMisfireHandlingInstructionNowWithExistingCount() .withMisfireHandlingInstructionNowWithRemainingCount(); SimpleTrigger trigger = TriggerBuilder.newTrigger() .withIdentity("trigger1","group1") .withSchedule(simpleScheduleBuilder) .build();

CronTrigger的Misfire策略

# 立即执行所有的misfire任务，然后继续按计划执行 MISFIRE_INSTRUCTION_IGNORE_MISFIRE_POLICY # 发生的misfire的任务都会被忽略，从当前时间按照原计划执行 MISFIRE_INSTRUCTION_DO_NOTHING #立即执行第一个发生misfire的任务，忽略其他misfire的任务，然后按照原计划继续执行 MISFIRE_INSTRUCTION_FIRE_ONCE_NOW //示例 CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder .cronSchedule("0 0 12 ? * MON#1 2022") //.withMisfireHandlingInstructionIgnoreMisfires() //.withMisfireHandlingInstructionDoNothing() .withMisfireHandlingInstructionFireAndProceed(); CronTrigger cronTrigger = (CronTrigger) TriggerBuilder.newTrigger() .withIdentity("cronTrigger1","group1") .withSchedule( cronScheduleBuilder ) .build();

4 任务Job

4.1 Job

Job表示被调度的任务，在任务调度的业务开发中，quartz提供了Job接口，我们自定义执行任务类实现此Job接口，在execute方法中完成业务的执行。

两种类型的Job:无状态的和有状态的
有状态的job不能被并行执行，只有上一次触发的任务被执行完之后才能触发下一次执行。
两种属性：volatility 和 durability
其中 volatility 表示任务是否被持久化到数据库存储，而 durability 表示在没有 trigger 关联的时候任务是否被保留。两者都是在值为 true 的时候任务被持久化或保留。

4.2 JobDetail

用于封装Job实例所包含的属性

//创建任务(JobDetail 用于封装具体的任务) JobDetail job = JobBuilder.newJob(MyJob.class) .withIdentity("job1","group1") //设置任务的标识 .build();

4.3 JobDataMap

包含不限量的（序列化的）数据对象，在job实例执行的时候，可以使用其中的数据。

//将job加入到scheduler之前，在构建Trigger、JobDetail时，可以将数据放入JobDataMap //1.创建Quartz的任务调度器 Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); //2.创建触发器 SimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.simpleSchedule() .withIntervalInSeconds(3) .withRepeatCount(10) .withMisfireHandlingInstructionNextWithRemainingCount(); SimpleTrigger trigger = TriggerBuilder.newTrigger() .withIdentity("trigger1", "group1") .withSchedule(simpleScheduleBuilder) .usingJobData("key1","value1") //设置Trigger参数 .build(); //3.创建任务(JobDetail 用于封装具体的任务) JobDetail job = JobBuilder.newJob(MyJob.class) .withIdentity("job1","group1") .usingJobData("key2","value2") //设置JobDetail参数 .build(); scheduler.scheduleJob(job,trigger); scheduler.start();

//在Job执行过程中，可以从JobDataMap中取出数据 public class MyJob implements Job { 
      private SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd hh:mm:ss"); public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { 
      //执行任务的逻辑 // 通过execute方法的JobExecutionContext参数获取触发器、JobDetail绑定的参数 // 1.获取trigger中传递的参数 JobDataMap jobDataMap1 = jobExecutionContext.getTrigger().getJobDataMap(); String value1 = (String) jobDataMap1.get("key1"); // 2.获取JobDetail中传递的参数 JobDataMap jobDataMap2 = jobExecutionContext.getJobDetail().getJobDataMap(); String value2 = (String) jobDataMap2.get("key2"); String time = sdf.format(new Date()); System.out.println("~~~~~"+time+"\t"+value1+"\t"+value2); } }

免责声明：本站所有文章内容,图片，视频等均是来源于用户投稿和互联网及文摘转载整编而成，不代表本站观点，不承担相关法律责任。其著作权各归其原作者或其出版社所有。如发现本站有涉嫌抄袭侵权/违法违规的内容,侵犯到您的权益，请在线联系站长,一经查实,本站将立刻删除。本文来自网络,若有侵权，请联系删除，如若转载，请注明出处：https://haidsoft.com/115307.html

Quartz任务调度框架