Quartz實(shí)現(xiàn)動(dòng)態(tài)定時(shí)任務(wù)

參考資料：http://www.cnblogs.com/soundcode/p/6599952.html

一跨嘉、說明

???? 由于最近工作要實(shí)現(xiàn)定時(shí)任務(wù)的執(zhí)行，而且要求定時(shí)周期是不固定的怀挠，所以就用到了quartz來實(shí)現(xiàn)這個(gè)功能；

???? spring3.1以下的版本必須使用quartz1.x系列术奖，3.1以上的版本才支持quartz 2.x腰奋，不然會(huì)出錯(cuò)。至于原因阳谍，則是spring對(duì)于quartz的支持實(shí)現(xiàn)蛀柴，org.springframework.scheduling.quartz.CronTriggerBean繼承了org.quartz.CronTrigger，在quartz1.x系列中org.quartz.CronTrigger是個(gè)類矫夯，而在quartz2.x系列中org.quartz.CronTrigger變成了接口鸽疾，從而造成無法用spring的方式配置quartz的觸發(fā)器（trigger）。

???? 我使用的quartz版本是2.2.1 训貌。

???? 最終實(shí)現(xiàn)的功能：

????? 1）項(xiàng)目啟動(dòng)時(shí)制肮，可執(zhí)行的定時(shí)任務(wù)啟動(dòng)，按時(shí)執(zhí)行相應(yīng)的邏輯；

???? 2）? 可添加新任務(wù)弄企，刪除任務(wù)超燃，更新任務(wù)，暫停任務(wù)拘领，恢復(fù)任務(wù) 意乓；

二、添加quartz包

??? 我使用Gradle構(gòu)建項(xiàng)目约素，加包時(shí)只需下面一行即可：

?? compile "org.quartz-scheduler:quartz:2.2.1"

三届良、配置及使用

????? 1. ?配置任務(wù)調(diào)度器（對(duì)應(yīng)的文件名為quartz-task.xml）??

?xml?version="1.0"?encoding="UTF-8"?>

<beans?xmlns="http://www.springframework.org/schema/beans"?xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance"

?xsi:schemaLocation="http://www.springframework.org/schema/beans?http://www.springframework.org/schema/beans/spring-beans-3.0.xsd"

?default-lazy-init="false">

????<bean?name="schedulerFactoryBean"?class="org.springframework.scheduling.quartz.SchedulerFactoryBean">?

???????

????????<property?name="applicationContextSchedulerContextKey">????

????????????<value>applicationContextvalue>????

????????property>???

????bean>??

????

????<bean?id="loadTask"?class="com.quartz.LoadTask"?init-method="initTask"?/>

beans>

??? 2. 服務(wù)器啟動(dòng)時(shí)加載，在web.xml文件里配置

<context-param>

??<param-name>contextConfigLocationparam-name>

??<param-value>classpath:quartz-task.xmlparam-value>

?context-param>

?? 3. 加載可執(zhí)行任務(wù)的類LoadTask.java

?publicclassLoadTask?{

?publicvoidinitTask()?throwsException?{

??Scheduler?scheduler?=?schedulerFactoryBean.getScheduler();

??//?可執(zhí)行的任務(wù)列表

??Collection<Task>?taskList?=?taskService.findTask();

??for(Task?task?:?taskList)?{

???//?任務(wù)名稱和任務(wù)組設(shè)置規(guī)則：

???//?名稱：task_1?..

???//?組?：group_1?..

???TriggerKey?triggerKey?=?TriggerKey.triggerKey(

?????"task_"+?task.getId(),?"group_"+?task.getId());

???CronTrigger?trigger?=?(CronTrigger)?scheduler

?????.getTrigger(triggerKey);

???//?不存在圣猎，創(chuàng)建一個(gè)

???if(null==?trigger)?{

????JobDetail?jobDetail?=?JobBuilder

??????.newJob(QuartzJobFactory.class)

??????.withIdentity("task_"+?task.getId(),

????????"group_"+?task.getId()).build();

????jobDetail.getJobDataMap().put("scheduleJob",?task);

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

????CronScheduleBuilder?scheduleBuilder?=?CronScheduleBuilder

??????.cronSchedule(getCronExpression());

????//?按新的表達(dá)式構(gòu)建一個(gè)新的trigger

????trigger?=?TriggerBuilder

??????.newTrigger()

??????.withIdentity("task_"+?task.getId(),

????????"group_"+?task.getId())

??????.withSchedule(scheduleBuilder).build();

????scheduler.scheduleJob(jobDetail,?trigger);

???}?else{

????//?trigger已存在士葫，則更新相應(yīng)的定時(shí)設(shè)置

????CronScheduleBuilder?scheduleBuilder?=?CronScheduleBuilder

??????.cronSchedule(taskService.getCronExpression());

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

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

??????.withSchedule(scheduleBuilder).build();

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

????scheduler.rescheduleJob(triggerKey,?trigger);

???}

??}

?@Autowired

?privateSchedulerFactoryBean?schedulerFactoryBean;

?@Autowired

?privateTaskService?taskService;

}

?? 4. 調(diào)度任務(wù)的入口

?publicclassQuartzTaskFactory?implementsJob?{

?@Override

?publicvoidexecute(JobExecutionContext?context)

???throwsJobExecutionException?{

??//?TODO?Auto-generated?method?stub

??try{

???System.out.println("任務(wù)運(yùn)行...");

???Task?task?=?(Task)?context.getMergedJobDataMap().get(

?????"scheduleJob");

???System.out.println("任務(wù)名稱:?["+?task.getTaskName()?+?"]");

???//在這里執(zhí)行你的任務(wù)...

???}?catch(Exception?e)?{

???e.printStackTrace();

??}

}

?? 5. 暫停任務(wù)