您好,登录后才能下订单哦!
本篇内容介绍了“Java任务调度框架Quartz怎么使用”的有关知识,在实际案例的操作过程中,不少人都会遇到这样的困境,接下来就让小编带领大家学习一下如何处理这些情况吧!希望大家仔细阅读,能够学有所成!
Quartz相较于Timer, Quartz增加了很多功能:
持久性作业 - 就是保持调度定时的状态;
作业管理 - 对调度作业进行有效的管理;
<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.3.2</version> </dependency> <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz-jobs</artifactId> <version>2.3.2</version> </dependency>
任务:将任务类执行 10 次,每次间隔 3 秒。
package com.sugar.quartz.utils; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import java.text.SimpleDateFormat; import java.util.Date; /** * 功能描述: 任务 * * @author XiaoNianXin * @date 2021/12/13 20:52 */ public class HelloJob implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { // 获取当前时间,并格式化 Date date = new Date(); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String dateSrting = format.format(date); // 业务功能模拟 System.out.println("开始备份数据库,时间:" + dateSrting); } }
package com.sugar.quartz.utils; import org.quartz.*; import org.quartz.impl.StdSchedulerFactory; /** * 功能描述: 定时器配置 * * @author XiaoNianXin * @date 2021/12/13 21:08 */ public class HelloSchedulerDemo { public static void main(String[] args) throws SchedulerException { // 1、调度器 - 从工厂获取调度实例 Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); // 2、任务实例 - 执行的任务对象 JobDetail job = JobBuilder.newJob(HelloJob.class) .withIdentity("job1", "group1") // 任务名称,组名称 .build(); // 3、触发器 - 控制执行次数和执行时间 Trigger trigger = TriggerBuilder.newTrigger() .withIdentity("trigger1", "group1") // 同上 .startNow() // 立刻启动 .withSchedule(SimpleScheduleBuilder.simpleSchedule(). withIntervalInSeconds(3). withRepeatCount(10)) // 循环10次,每次间隔3s .build(); // 调度器关联触发器,并启动 scheduler.scheduleJob(job,trigger); scheduler.start(); } }
Job
:基于反射的任务调度接口,所有任务类都要实现该接口,在接口的 execute 里编写自己的业务逻辑。
Job 生命周期
:每次执行 Job,在 execute 方法前会创建新的 Job实例,调用后实例被释放,再被GC回收。
JobDetail
:封装 Job,给 Job 实例提供许多属性。
JobDetail 属性
:name、group、jobClass、jobDataMap。
下文将 JobExecutionContext 简称为 JEC
JEC
:当调度器调用 Job 时,会将 JEC 传递给 Job 的 execute 方法。
JEC 作用
:Job 通过 JEC 获取运行环境信息,以及 Job 信息。
下文将 JobDataMap 简称为 JDM
JDM
:任务调度时,JDM 存储在 JEC 中,方便获取。
JDM 优点
:实现 Map 接口,可以存取任何可序列化对象,Job 执行时会将参数传给 JDM。
HelloSchedulerDemo:
package com.sugar.quartz.utils; import org.quartz.*; import org.quartz.impl.StdSchedulerFactory; /** * 功能描述: 定时器配置 * * @author XiaoNianXin * @date 2021/12/13 21:08 */ public class HelloSchedulerDemo { public static void main(String[] args) throws SchedulerException { // 1、调度器 - 从工厂获取调度实例 Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); // 2、任务实例 - 执行的任务对象 JobDetail job = JobBuilder.newJob(HelloJob.class) .withIdentity("job1", "group1") // 任务名称,组名称 .usingJobData("msg","JDM使用 - Detail") // JDM 传递参数 .build(); // 3、触发器 - 控制执行次数和执行时间 Trigger trigger = TriggerBuilder.newTrigger() .withIdentity("trigger1", "group1") // 同上 .startNow() // 立刻启动 .withSchedule(SimpleScheduleBuilder.simpleSchedule(). withIntervalInSeconds(3). withRepeatCount(10)) // 循环10次,每次间隔3s .usingJobData("msg","JDM使用 - Trigger") .build(); // 调度器关联触发器,并启动 scheduler.scheduleJob(job,trigger); scheduler.start(); } }
HelloJob:
package com.sugar.quartz.utils; import org.quartz.Job; import org.quartz.JobDataMap; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import java.text.SimpleDateFormat; import java.util.Date; /** * 功能描述: 定时业务功能 * * @author XiaoNianXin * @date 2021/12/13 20:52 */ public class HelloJob implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { // 获取当前时间,并格式化 Date date = new Date(); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String dateSrting = format.format(date); // 获取 JDM JobDataMap Detail_JDM = context.getJobDetail().getJobDataMap(); JobDataMap Trigger_JDM = context.getTrigger().getJobDataMap(); String detail_jdmString = Detail_JDM.getString("msg"); String trigger_jdmString = Trigger_JDM.getString("msg"); System.out.println("---------------------------------------------------"); System.out.println("detail_jdmString = " + detail_jdmString); System.out.println("trigger_jdmString = " + trigger_jdmString); // 业务功能模拟 System.out.println("开始备份数据库,时间:" + dateSrting); // 其他内容 System.out.println("Job 运行时间:" + context.getJobRunTime()); System.out.println("Job 当前运行时间:" + context.getFireTime()); System.out.println("Job 下次运行时间:" + context.getNextFireTime()); System.out.println("---------------------------------------------------"); } }
HelloJob:
// 实例化时自动绑定 JDM key对应的值 private String msg; public void setMsg(String msg) { this.msg = msg; } // 获取 JDM System.out.println(Trigger JDM : " + msg);
问题:上文中 JobDetail 和 Trigger 中的 JDM 的 key 均为 "msg",那此 msg 是哪一个?
E.g:遇到同名key,Trigger 会覆盖 JobDetail 的值,所以 msg 为 Trigger JDM 的值。
有状态 Job:多次调用 Job 期间,公用同一个 JDM。
有状态 Job:多次调用 Job 期间,每次新建一个新的 JDM。
预期:无状态 count 输出永远为 1,有状态 count 输出累加。
HelloSchedulerDemo:
// JobDeatil 添加一个 JDM,用做计数器 .usingJobData("count",0)
无状态 HelloJob:
package com.sugar.quartz.utils; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import java.text.SimpleDateFormat; import java.util.Date; /** * 功能描述: 任务类 * * @author XiaoNianXin * @date 2021/12/13 20:52 */ public class HelloJob implements Job { // 实例化时自动绑定 JDM key对应的值 private String msg; private Integer count; public void setMsg(String msg) { this.msg = msg; } public void setCount(Integer count) { this.count = count; } @Override public void execute(JobExecutionContext context) throws JobExecutionException { // 获取当前时间,并格式化 Date date = new Date(); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String dateSrting = format.format(date); // 获取 JDM System.out.println("---------------------------------------------------"); System.out.println("Trigger JDM : " + msg); System.out.println("Count : " + count); // 更新 JobDetail JDM 的 count count++; context.getJobDetail().getJobDataMap().put("count",count); // 业务功能模拟 System.out.println("开始备份数据库,时间:" + dateSrting); // 其他内容 System.out.println("Job 运行时间:" + context.getJobRunTime()); System.out.println("Job 当前运行时间:" + context.getFireTime()); System.out.println("Job 下次运行时间:" + context.getNextFireTime()); System.out.println("---------------------------------------------------"); } }
有状态 HelloJob:
// 任务类加上下面注解,多次调用 Job,会持久化 Job,JDM 的数据会被保存,供下次使用 @PersistJobDataAfterExecution
Trigger 常用
:SimpleTrigger
、CronTrigger
。
JobKey
:Job 实例标识,触发器触发时,执行 JobKey 对应任务。
StartTime
:第一次触发时间。
EndTime
:终止触发时间。
HelloSchedulerTriggerDemo:
package com.sugar.quartz.utils; import org.quartz.*; import org.quartz.impl.StdSchedulerFactory; import java.util.Date; /** * 功能描述: 定时器配置2 * * @author XiaoNianXin * @date 2021/12/13 21:08 */ public class HelloSchedulerTriggerDemo { public static void main(String[] args) throws SchedulerException { // 任务开始时间推迟 3 s,结束时间推迟 10 s Date startData = new Date(); startData.setTime(startData.getTime() + 3000); Date endData = new Date(); endData.setTime(endData.getTime() + 10000); // 1、调度器 - 从工厂获取调度实例 Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); // 2、任务实例 - 执行的任务对象 JobDetail job = JobBuilder.newJob(helloJobTrigger.class) .withIdentity("job1", "group1") // 任务名称,组名称 .usingJobData("msg","JDM使用 - Detail") // JDM 传递参数 .build(); // 3、触发器 - 控制执行次数和执行时间 Trigger trigger = TriggerBuilder.newTrigger() .withIdentity("trigger1", "group1") // 同上 .startNow() // 立刻启动 .startAt(startData) .endAt(endData) .build(); // 调度器关联触发器,并启动 scheduler.scheduleJob(job,trigger); scheduler.start(); } }
helloJobTrigger:
package com.sugar.quartz.utils; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.quartz.PersistJobDataAfterExecution; import java.text.SimpleDateFormat; import java.util.Date; /** * 功能描述: 任务类2 * * @author XiaoNianXin * @date 2021/12/13 20:52 */ @PersistJobDataAfterExecution public class helloJobTrigger implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { // 获取当前时间,并格式化 Date date = new Date(); SimpleDateFormat format = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); String dateSrting = format.format(date); // 业务功能模拟 System.out.println("---------------------------------------------------"); System.out.println("开始备份数据库,时间:" + dateSrting); // 获取 JobKey,StartTime,EndTime System.out.println("JobKey : " + context.getTrigger().getJobKey()); System.out.println("StartTime : " + format.format(context.getTrigger().getStartTime())); System.out.println("EndTime : " + format.format(context.getTrigger().getEndTime())); System.out.println("---------------------------------------------------"); } } // 运行结果 --------------------------------------------------- 开始备份数据库,时间:2021-12-13 23:25:06 JobKey : group1.job1 StartTime : 2021-12-13 23:25:06 EndTime : 2021-12-13 23:25:13 ---------------------------------------------------
下文将 SimpleTripper 简称为 ST
ST
:特定时间范围启动/结束,且以一个时间间隔重复 n 次 Job 所设计。
ST 属性:开始时间、结束时间、重复次数和时间间隔。
ST 提示:指定了结束时间,那么结束时间优先级 > 重复次数。
“Java任务调度框架Quartz怎么使用”的内容就介绍到这里了,感谢大家的阅读。如果想了解更多行业相关的知识可以关注亿速云网站,小编将为大家输出更多高质量的实用文章!
免责声明:本站发布的内容(图片、视频和文字)以原创、转载和分享为主,文章观点不代表本网站立场,如果涉及侵权请联系站长邮箱:is@yisu.com进行举报,并提供相关证据,一经查实,将立刻删除涉嫌侵权内容。