前面我們已經(jīng)完成了spring 3和quartz 2的整合以及動(dòng)態(tài)添加定時(shí)任務(wù)，我們接著來(lái)完善它，使之能支持更多的操作，例如暫停、恢復(fù)、修改等。

在動(dòng)態(tài)添加定時(shí)任務(wù)中其實(shí)已經(jīng)涉及到了其中的一些代碼，這里我們?cè)賮?lái)細(xì)化的理一理。先來(lái)看一下我們初步要實(shí)現(xiàn)的目標(biāo)效果圖，這里我們只在內(nèi)存中操作，并沒(méi)有把quartz的任何信息保存到數(shù)據(jù)庫(kù)，即使用的是RAMJobStore，當(dāng)然如果你有需要，可以實(shí)現(xiàn)成JDBCJobStore，那樣任務(wù)信息將會(huì)更全面，貌似還有專(zhuān)門(mén)的監(jiān)控工具，不過(guò)本人沒(méi)有用過(guò)：

如上圖，我們要先列出計(jì)劃中的定時(shí)任務(wù)以及正在執(zhí)行中的定時(shí)任務(wù)，這里的正在執(zhí)行中指的是任務(wù)已經(jīng)觸發(fā)線(xiàn)程還沒(méi)執(zhí)行完的情況。比如每天2點(diǎn)執(zhí)行一個(gè)數(shù)據(jù)導(dǎo)入操作，這個(gè)操作執(zhí)行時(shí)間需要5分鐘，在這5分鐘之內(nèi)這個(gè)任務(wù)才是運(yùn)行中的任務(wù)。當(dāng)任務(wù)正常時(shí)可以使用暫停按鈕，任務(wù)暫停時(shí)可以使用恢復(fù)按鈕。

trigger各狀態(tài)說(shuō)明：

None：Trigger已經(jīng)完成，且不會(huì)在執(zhí)行，或者找不到該觸發(fā)器，或者Trigger已經(jīng)被刪除 NORMAL:正常狀態(tài) PAUSED：暫停狀態(tài) COMPLETE：觸發(fā)器完成，但是任務(wù)可能還正在執(zhí)行中 BLOCKED：線(xiàn)程阻塞狀態(tài) ERROR：出現(xiàn)錯(cuò)誤

計(jì)劃中的任務(wù)

指那些已經(jīng)添加到quartz調(diào)度器的任務(wù)，因?yàn)閝uartz并沒(méi)有直接提供這樣的查詢(xún)接口，所以我們需要結(jié)合JobKey和Trigger來(lái)實(shí)現(xiàn)，核心代碼：

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("觸發(fā)器:" + 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就是我們需要的計(jì)劃中的任務(wù)列表，需要注意一個(gè)job可能會(huì)有多個(gè)trigger的情況，在下面講到的立即運(yùn)行一次任務(wù)的時(shí)候，會(huì)生成一個(gè)臨時(shí)的trigger也會(huì)出現(xiàn)在這。這里把一個(gè)Job有多個(gè)trigger的情況看成是多個(gè)任務(wù)。我們前面包括在實(shí)際項(xiàng)目中一般用到的都是CronTrigger ，所以這里我們著重處理了下CronTrigger的情況。

運(yùn)行中的任務(wù)

實(shí)現(xiàn)和計(jì)劃中的任務(wù)類(lèi)似，核心代碼：

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("觸發(fā)器:" + 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);

}

暫停任務(wù)

這個(gè)比較簡(jiǎn)單，核心代碼：

Scheduler scheduler = schedulerFactoryBean.getScheduler();

JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());

scheduler.pauseJob(jobKey);

恢復(fù)任務(wù)

和暫停任務(wù)相對(duì)，核心代碼：

Scheduler scheduler = schedulerFactoryBean.getScheduler();

JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());

scheduler.resumeJob(jobKey);

刪除任務(wù)

刪除任務(wù)后，所對(duì)應(yīng)的trigger也將被刪除

Scheduler scheduler = schedulerFactoryBean.getScheduler();

JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());

scheduler.deleteJob(jobKey);

立即運(yùn)行任務(wù)

這里的立即運(yùn)行，只會(huì)運(yùn)行一次，方便測(cè)試時(shí)用。quartz是通過(guò)臨時(shí)生成一個(gè)trigger的方式來(lái)實(shí)現(xiàn)的，這個(gè)trigger將在本次任務(wù)運(yùn)行完成之后自動(dòng)刪除。trigger的key是隨機(jī)生成的，例如：DEFAULT.MT_4k9fd10jcn9mg。在我的測(cè)試中，前面的DEFAULT.MT是固定的，后面部分才隨機(jī)生成。

Scheduler scheduler = schedulerFactoryBean.getScheduler();

JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());

scheduler.triggerJob(jobKey);

更新任務(wù)的時(shí)間表達(dá)式

更新之后，任務(wù)將立即按新的時(shí)間表達(dá)式執(zhí)行：

Scheduler scheduler = schedulerFactoryBean.getScheduler();

TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getJobName(),

scheduleJob.getJobGroup());

//獲取trigger，即在spring配置文件中定義的 bean id="myTrigger"

CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);

//表達(dá)式調(diào)度構(gòu)建器

CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob

.getCronExpression());

//按新的cronExpression表達(dá)式重新構(gòu)建trigger

trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)

.withSchedule(scheduleBuilder).build();

//按新的trigger重新設(shè)置job執(zhí)行

scheduler.rescheduleJob(triggerKey, trigger);

到這里，我們的spring3 整合quartz 2的定時(shí)任務(wù)功能終于是告一段落了，對(duì)常用的一些功能進(jìn)行了實(shí)現(xiàn)，相信可以滿(mǎn)足一般項(xiàng)目的需求了。

總結(jié)

以上是生活随笔為你收集整理的Spring 3整合Quartz 2实现定时任务三：动态暂停 恢复 修改和删除任务的全部?jī)?nèi)容，希望文章能夠幫你解決所遇到的問(wèn)題。

如果覺(jué)得生活随笔網(wǎng)站內(nèi)容還不錯(cuò)，歡迎將生活随笔推薦給好友。