Spring 3整合Quartz 2實現定時任務三：動態暫停 恢復 修改和刪除任務

前面我們已經完成了spring 3和quartz 2的整合以及動態添加定時任務，我們接着來完善它，使之能支持更多的操作，例如暫停、恢復、修改等。

在動態添加定時任務中其實已經涉及到了其中的一些代碼，這里我們再來細化的理一理。先來看一下我們初步要實現的目標效果圖，這里我們只在內存中操作，並沒有把quartz的任何信息保存到數據庫，即使用的是RAMJobStore，當然如果你有需要，可以實現成JDBCJobStore，那樣任務信息將會更全面，貌似還有專門的監控工具，不過本人沒有用過：

如上圖，我們要先列出計划中的定時任務以及正在執行中的定時任務，這里的正在執行中指的是任務已經觸發線程還沒執行完的情況。比如每天2點執行一個數據導入操作，這個操作執行時間需要5分鍾，在這5分鍾之內這個任務才是運行中的任務。當任務正常時可以使用暫停按鈕，任務暫停時可以使用恢復按鈕。

trigger各狀態說明：

None：Trigger已經完成，且不會在執行，或者找不到該觸發器，或者Trigger已經被刪除 NORMAL:正常狀態 PAUSED：暫停狀態 COMPLETE：觸發器完成，但是任務可能還正在執行中 BLOCKED：線程阻塞狀態 ERROR：出現錯誤

計划中的任務

指那些已經添加到quartz調度器的任務，因為quartz並沒有直接提供這樣的查詢接口，所以我們需要結合JobKey和Trigger來實現，核心代碼：

1. Scheduler scheduler = schedulerFactoryBean.getScheduler();
2. GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup();
3. Set<JobKey> jobKeys = scheduler.getJobKeys(matcher);
4. List<ScheduleJob> jobList = new ArrayList<ScheduleJob>();
5. for (JobKey jobKey : jobKeys) {
6. List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);
7. for (Trigger trigger : triggers) {
8. ScheduleJob job = new ScheduleJob();
9. job.setJobName(jobKey.getName());
10. job.setJobGroup(jobKey.getGroup());
11. job.setDesc("觸發器:" + trigger.getKey());
12. Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
13. job.setJobStatus(triggerState.name());
14. if (trigger instanceof CronTrigger) {
15. CronTrigger cronTrigger = (CronTrigger) trigger;
16. String cronExpression = cronTrigger.getCronExpression();
17. job.setCronExpression(cronExpression);
18. }
19. jobList.add(job);
20. }
21. }

上面代碼中的jobList就是我們需要的計划中的任務列表，需要注意一個job可能會有多個trigger的情況，在下面講到的立即運行一次任務的時候，會生成一個臨時的trigger也會出現在這。這里把一個Job有多個trigger的情況看成是多個任務。我們前面包括在實際項目中一般用到的都是CronTrigger ，所以這里我們着重處理了下CronTrigger的情況。

運行中的任務

實現和計划中的任務類似，核心代碼：

1. Scheduler scheduler = schedulerFactoryBean.getScheduler();
2. List<JobExecutionContext> executingJobs = scheduler.getCurrentlyExecutingJobs();
3. List<ScheduleJob> jobList = new ArrayList<ScheduleJob>(executingJobs.size());
4. for (JobExecutionContext executingJob : executingJobs) {
5. ScheduleJob job = new ScheduleJob();
6. JobDetail jobDetail = executingJob.getJobDetail();
7. JobKey jobKey = jobDetail.getKey();
8. Trigger trigger = executingJob.getTrigger();
9. job.setJobName(jobKey.getName());
10. job.setJobGroup(jobKey.getGroup());
11. job.setDesc("觸發器:" + trigger.getKey());
12. Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());
13. job.setJobStatus(triggerState.name());
14. if (trigger instanceof CronTrigger) {
15. CronTrigger cronTrigger = (CronTrigger) trigger;
16. String cronExpression = cronTrigger.getCronExpression();
17. job.setCronExpression(cronExpression);
18. }
19. jobList.add(job);
20. }

暫停任務

這個比較簡單，核心代碼：

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

恢復任務

和暫停任務相對，核心代碼：

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

刪除任務

刪除任務后，所對應的trigger也將被刪除

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

立即運行任務

這里的立即運行，只會運行一次，方便測試時用。quartz是通過臨時生成一個trigger的方式來實現的，這個trigger將在本次任務運行完成之后自動刪除。trigger的key是隨機生成的，例如：DEFAULT.MT_4k9fd10jcn9mg。在我的測試中，前面的DEFAULT.MT是固定的，后面部分才隨機生成。

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

更新任務的時間表達式

更新之后，任務將立即按新的時間表達式執行：

1. Scheduler scheduler = schedulerFactoryBean.getScheduler();
2. TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getJobName(),
3. scheduleJob.getJobGroup());
4. //獲取trigger，即在spring配置文件中定義的 bean id="myTrigger"
5. CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
6. //表達式調度構建器
7. CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob
8. .getCronExpression());
9. //按新的cronExpression表達式重新構建trigger
10. trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)
11. .withSchedule(scheduleBuilder).build();
12. //按新的trigger重新設置job執行
13. scheduler.rescheduleJob(triggerKey, trigger);

到這里，我們的spring3 整合quartz 2的定時任務功能終於是告一段落了，對常用的一些功能進行了實現，相信可以滿足一般項目的需求了。