【优化技术专题】「温故而知新」基于 Quartz 系列的任务调度框架的动态化任务实现分析

李浩宇/Alex

关注

发布于: 2 小时前

【优化技术专题】「温故而知新」基于Quartz系列的任务调度框架的动态化任务实现分析

不提 XXLJOB 或者其他的调度框架，就看我接触的第一个任务调度框架 Quartz(温故而知新)

Quartz 的动态暂停恢复修改和删除任务

实现动态添加定时任务，先来看一下我们初步要实现的目标效果图，这里我们只在内存中操作，并没有把 quartz 的任何信息保存到数据库，即使用的是 RAMJobStore，

当然如果你有需要，可以实现成 JDBCJobStore，那样任务信息将会更全面。

例如，我们要先列出计划中的定时任务以及正在执行中的定时任务，这里的正在执行中指的是任务已经触发线程还没执行完的情况。

比如每天 2 点执行一个数据导入操作，这个操作执行时间需要 5 分钟，在这 5 分钟之内这个任务才是运行中的任务。
当任务正常时可以使用暂停按钮，任务暂停时可以使用恢复按钮。

trigger 各状态说明：

None：Trigger 已经完成且不会在执行，或找不到该触发器，或 Trigger 已经被删除.
NORMAL：正常状态
PAUSED：暂停状态
COMPLETE：触发器完成，但是任务可能还正在执行中
BLOCKED：线程阻塞状态
ERROR：出现错误

定时任务运行工厂类

任务运行入口，即 Job 实现类，在这里我把它看作工厂类：

/** * 定时任务运行工厂类 *  * User: liyd * Date: 14-1-3 * Time: 上午10:11 */public class QuartzJobFactory implements Job {     @Override    public void execute(JobExecutionContext context) throws JobExecutionException {        System.out.println("任务成功运行");        ScheduleJob scheduleJob = (ScheduleJob)context.getMergedJobDataMap().get("scheduleJob");        System.out.println("任务名称 = [" + scheduleJob.getJobName() + "]");    }  }

复制代码

这里我们实现的是无状态的 Job，如果要实现有状态的 Job 在以前是实现 StatefulJob 接口，在我使用的 quartz 2.2.1 中，StatefulJob 接口已经不推荐使用了，换成了注解的方式，只需要给你实现的 Job 类加上注解 @DisallowConcurrentExecution 即可实现有状态：

/*** 定时任务运行工厂类* <p/>* User: liyd* Date: 14-1-3* Time: 上午10:11*/@DisallowConcurrentExecutionpublic class QuartzJobFactory implements Job {...}

复制代码

创建任务

既然要动态的创建任务，我们的任务信息当然要保存在某个地方了，这里我们新建一个保存任务信息对应的实体类：

/** * 计划任务信息 * User: liyd * Date: 14-1-3 * Time: 上午10:24 */public class ScheduleJob {    /** 任务id */    private String jobId;    /** 任务名称 */    private String jobName;    /** 任务分组 */    private String jobGroup;    /** 任务状态 0禁用 1启用 2删除*/    private String jobStatus;    /** 任务运行时间表达式 */    private String cronExpression;    /** 任务描述 */    private String desc;    getter and setter ....}

复制代码

接下来我们创建测试数据，实际应用中该数据可以保存在数据库等地方，我们把任务的分组名+任务名作为任务的唯一 key，和 quartz 中的实现方式一致：

/** 计划任务map */private static Map<String, ScheduleJob> jobMap = new HashMap<String, ScheduleJob>();static {    for (int i = 0; i < 5; i++) {        ScheduleJob job = new ScheduleJob();        job.setJobId("10001" + i);        job.setJobName("data_import" + i);        job.setJobGroup("dataWork");        job.setJobStatus("1");        job.setCronExpression("0/5 * * * * ?");        job.setDesc("数据导入任务");        addJob(job);    }} /** * 添加任务 * @param scheduleJob */public static void addJob(ScheduleJob scheduleJob) {    jobMap.put(scheduleJob.getJobGroup() + "_" + scheduleJob.getJobName(), scheduleJob);}

复制代码

有了调度工厂，有了任务运行入口实现类，有了任务信息，接下来就是创建我们的定时任务了，在这里我把它设计成一个 Job 对应一个 trigger，两者的分组及名称相同，方便管理，条理也比较清晰，在创建任务时如果不存在新建一个，如果已经存在则更新任务，主要代码如下：

schedulerFactoryBean 由 spring 创建注入

Scheduler scheduler = schedulerFactoryBean.getScheduler(); //这里获取任务信息数据List<ScheduleJob> jobList = DataWorkContext.getAllJob();for (ScheduleJob job : jobList) {    TriggerKey T = TriggerKey.triggerKey(job.getJobName(), job.getJobGroup());    //获取trigger，即在spring配置文件中定义的 bean id="myTrigger"    CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);    //不存在，创建一个    if (null == trigger) {        JobDetail jobDetail = JobBuilder.newJob(QuartzJobFactory.class)            .withIdentity(job.getJobName(), job.getJobGroup()).build();        jobDetail.getJobDataMap().put("scheduleJob", job);        //表达式调度构建器        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job            .getCronExpression());        //按新的cronExpression表达式构建一个新的trigger        trigger = TriggerBuilder.newTrigger().withIdentity(job.getJobName(), job.getJobGroup()).withSchedule(scheduleBuilder).build();        scheduler.scheduleJob(jobDetail, trigger);    } else {        // Trigger已存在，那么更新相应的定时设置        //表达式调度构建器        CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job            .getCronExpression());        //按新的cronExpression表达式重新构建trigger        trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)            .withSchedule(scheduleBuilder).build();        //按新的trigger重新设置job执行        scheduler.rescheduleJob(triggerKey, trigger);    }}

复制代码

如此，可以说已经完成了我们的动态任务创建，大功告成了。有了上面的代码，添加和修改任务是不是也会了，顺道解决了？
上面我们创建的 5 个测试任务，都是 5 秒执行一次，都将调用 QuartzJobFactory 的 execute 方法，但是传入的任务信息参数不同，execute 方法中的如下代码就是得到具体的任务信息，包括任务分组和任务名：

ScheduleJob scheduleJob = (ScheduleJob)context.getMergedJobDataMap().get("scheduleJob");

复制代码

有了任务分组和任务名即确定了该任务的唯一性，接下来需要什么操作实现起来是不是就很容易了？
以后需要添加新的定时任务只需要在任务信息列表中加入记录即可，然后在 execute 方法中通过判断任务分组和任务名来实现你具体的操作。
以上已经初始实现了我们需要的功能，增加和修改也已经可以通过源代码举一反三出来，但是我们在实际开发的时候需要进行测试，如果一个任务是 1 个小时运行一次的，测试起来是不是很不方便？当然你可以修改任务的运行时间表达式，但相信这不是最好的方法，接下来我们就要实现在不对当前任务信息做任何修改的情况下触发任务，并且该触发只会运行一次作测试用。

计划中的任务

**主要是已经添加到 quartz 调度器的任务，因为 quartz 并没有直接提供这样的查询接口，所以我们需要结合 JobKey 和 Trigger 来实现，核心代码： **

  Scheduler scheduler = schedulerFactoryBean.getScheduler();   GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup();   Set<JobKey> jobKeys = scheduler.getJobKeys(matcher);   List<ScheduleJob> jobList = new ArrayList<ScheduleJob>();   for (JobKey jobKey : jobKeys) {      List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);      for (Trigger trigger : triggers) {        ScheduleJob job = new ScheduleJob();       job.setJobName(jobKey.getName());       job.setJobGroup(jobKey.getGroup());       job.setDesc("触发器:" + trigger.getKey());       Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());       job.setJobStatus(triggerState.name());       if (trigger instanceof CronTrigger) {          CronTrigger cronTrigger = (CronTrigger) trigger;          String cronExpression = cronTrigger.getCronExpression();          job.setCronExpression(cronExpression);        }        jobList.add(job);    } }

复制代码

jobList 就是我们需要的计划中的任务列表，需要注意一个 job 可能会有多个 trigger 的情况，在下面讲到的立即运行一次任务的时候，会生成一个临时的 trigger 也会出现在这。
这里把一个 Job 有多个 trigger 的情况看成是多个任务。包括在实际项目中一般用到的都是 CronTrigger ，所以这里我们着重处理了下 CronTrigger 的情况。

运行中的任务

实现和计划中的任务类似，核心代码：

Scheduler scheduler = schedulerFactoryBean.getScheduler(); List<JobExecutionContext> executingJobs = scheduler.getCurrentlyExecutingJobs(); List<ScheduleJob> jobList = new ArrayList<ScheduleJob>(executingJobs.size()); for (JobExecutionContext executingJob : executingJobs) {    ScheduleJob job = new ScheduleJob();    JobDetail jobDetail = executingJob.getJobDetail();    JobKey jobKey = jobDetail.getKey();    Trigger trigger = executingJob.getTrigger();    job.setJobName(jobKey.getName());    job.setJobGroup(jobKey.getGroup());    job.setDesc("触发器:" + trigger.getKey());    Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());    job.setJobStatus(triggerState.name());    if (trigger instanceof CronTrigger) {      CronTrigger cronTrigger = (CronTrigger) trigger;      String cronExpression = cronTrigger.getCronExpression();      job.setCronExpression(cronExpression);    }    jobList.add(job); }

复制代码

暂停任务机制

比较简单，核心代码：

Scheduler scheduler = schedulerFactoryBean.getScheduler(); JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup()); scheduler.pauseJob(jobKey);

复制代码

恢复任务

暂停任务相对，核心代码：

Scheduler scheduler = schedulerFactoryBean.getScheduler(); JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup()); scheduler.resumeJob(jobKey);

复制代码

删除任务

删除任务后，所对应的 trigger 也将被删除

Scheduler scheduler = schedulerFactoryBean.getScheduler(); JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup()); scheduler.deleteJob(jobKey);

复制代码

立即运行任务

这里的立即运行，只会运行一次，方便测试时用。quartz 是通过临时生成一个 trigger 的方式来实现的，这个 trigger 将在本次任务运行完成之后自动删除。
trigger 的 key 是随机生成的，例如：DEFAULT.MT_4k9fd10jcn9mg。
在我的测试中，前面的 DEFAULT.MT 是固定的，后面部分才随机生成。

Scheduler scheduler = schedulerFactoryBean.getScheduler(); JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup()); scheduler.triggerJob(jobKey);

复制代码

更新任务的时间表达式

更新之后，任务将立即按新的时间表达式执行：

Scheduler scheduler = schedulerFactoryBean.getScheduler();   TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getJobName(),  scheduleJob.getJobGroup());   //获取trigger，即在spring配置文件中定义的 bean id="myTrigger" CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);   //表达式调度构建器 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob  .getCronExpression());   //按新的cronExpression表达式重新构建trigger trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)  .withSchedule(scheduleBuilder).build();   //按新的trigger重新设置job执行 scheduler.rescheduleJob(triggerKey, trigger);

复制代码

cronExpression 表达式：

字段允许值允许的特殊字符
秒 0-59 , - * /
分 0-59 , - * /
小时 0-23 , - * /
日期 1-31 , - * ? / L W C
月份 1-12 或者 JAN-DEC , - * /
星期 1-7 或者 SUN-SAT , - * ? / L C #
年（可选）留空, 1970-2099 , - * /
特殊字符意义
* 表示所有值；
? 表示未说明的值，即不关心它为何值；
- 表示一个指定的范围；
, 表示附加一个可能值；
/ 符号前表示开始时间，符号后表示每次递增的值；
L W C
L("last") ("last") "L" 用在 day-of-month 字段意思是 "这个月最后一天"；用在 day-of-week 字段, 它简单意思是 "7" or "SAT"。如果在 day-of-week 字段里和数字联合使用，它的意思就是 "这个月的最后一个星期几"
例如： "6L" means "这个月的最后一个星期五". 当我们用“L”时，不指明一个列表值或者范围是很重要的，不然的话，我们会得到一些意想不到的结果。
W("weekday") 只能用在 day-of-month 字段。用来描叙最接近指定天的工作日（周一到周五）。
例如：在 day-of-month 字段用“15W”指“最接近这个月第 15 天的工作日”，即如果这个月第 15 天是周六，那么触发器将会在这个月第 14 天即周五触发；如果这个月第 15 天是周日，那么触发器将会在这个月第 16 天即周一触发；如果这个月第 15 天是周二，那么就在触发器这天触发。
注意一点：这个用法只会在当前月计算值，不会越过当前月。“W”字符仅能在 day- of-month 指明一天，不能是一个范围或列表。也可以用“LW”来指定这个月的最后一个工作日。
# 只能用在 day-of-week 字段。用来指定这个月的第几个周几。例：在 day-of-week 字段用"6#3"指这个月第 3 个周五（6 指周五，3 指第 3 个）。如果指定的日期不存在，触发器就不会触发。
C 指和 calendar 联系后计算过的值。
例：在 day-of-month 字段用“5C”指在这个月第 5 天或之后包括 calendar 的第一天；在 day-of-week 字段用“1C”指在这周日或之后包括 calendar 的第一天。

- 星期的简写：- 周一 MON- 周二 TUE- 周三 WED- 周四 THU- 周五 FRI- 周六 SAT- 周日 SUN

在 MONTH 和 Day Of Week 字段里对字母大小写不敏感

表达式意义
每天中午 12 点触发
"0 0 12 * * ?"
每天上午 10:15 触发
"0 15 10 ? * *"
"0 15 10 * * ?"
"0 15 10 * * ? *" （此处最后一项年是可选的）
2005 年的每天上午 10:15 触发
"0 15 10 * * ? 2005"
每天下午 2 点到下午 2:59 期间的每 1 分钟触发
"0 * 14 * * ?"
每天下午 2 点到下午 2:55 期间的每 5 分钟触发
"0 0/5 14 * * ?"
每天下午 2 点到 2:55 期间和下午 6 点到 6:55 期间的每 5 分钟触发
"0 0/5 14,18 * * ?"
每天下午 2 点到下午 2:05 期间的每 1 分钟触发
"0 0-5 14 * * ?"
每年三月的星期三的下午 2:10 和 2:44 触发
"0 10,44 14 ? 3 WED" / "0 10,44 14 ? 3 WED * "
周一至周五的上午 10:15 触发
"0 15 10 ? * MON-FRI" / "0 15 10 ? * MON-FRI * "
每月 15 日上午 10:15 触发
"0 15 10 15 * ?"
每月最后一日的上午 10:15 触发
"0 15 10 L * ?"
每月的最后一个星期五上午 10:15 触发
"0 15 10 ? * 6L"
2002 年至 2005 年的每月的最后一个星期五上午 10:15 触发
"0 15 10 ? * 6L 2002-2005"
每月的第三个星期五上午 10:15 触发
"0 15 10 ? * 6#3"
每两个小时
0 */2 * * *

发布于: 2 小时前阅读数: 4

原文链接:【http://xie.infoq.cn/article/254acb1178f4c8bba72750211】。文章转载请联系作者。

李浩宇/Alex

关注

🏆 2021年InfoQ写作平台-签约作者 🏆 2020.03.25 加入

👑【酷爱计算机技术、醉心开发编程、喜爱健身运动、热衷悬疑推理的”极客狂人“】 🏅 【Java技术领域，MySQL技术领域，APM全链路追踪技术及微服务、分布式方向的技术体系等】 “任何足够先进的技术都是魔法“

发布

暂无评论

创作场景

【优化技术专题】「温故而知新」基于 Quartz 系列的任务调度框架的动态化任务实现分析

Quartz 的动态暂停 恢复 修改和删除任务

trigger 各状态说明：

定时任务运行工厂类

创建任务

schedulerFactoryBean 由 spring 创建注入

计划中的任务

运行中的任务

暂停任务机制

恢复任务

删除任务

立即运行任务

更新任务的时间表达式

cronExpression 表达式：

李浩宇/Alex

评论

Quartz 的动态暂停恢复修改和删除任务