Spring4.0.6 +Quartz 2.2.1動態新增、修改、刪除、關閉定時任務（可結合資料庫以及空指標異常問題的解決）
阿新 • • 發佈：2018-12-02
不懂定時器的可以閱讀這位作者的文章：Quartz 2.2 的實現原理和執行過程：http://blog.csdn.net/xlxxcc/article/details/52104463
spring配置
<!-- 定時器 --> <!-- 這個類用來做需要完成的業務--> <bean id="initalJob" class="com.shanreal.scheduler.IntialQuartzJob"></bean> <!-- 定時任務 --> <!-- 定義呼叫物件和呼叫物件的方法，這個配置和普通的一樣的,id是JobDetail的名字 --> <bean id="jobtask" class="org.springframework.scheduling.quartz.MethodInvokingJobDetailFactoryBean"> <!-- 呼叫的類 --> <property name="targetObject" ref="initalJob"/> <!-- 呼叫類中的方法 --> <property name="targetMethod" value="initial" /> <!-- 是否併發 --> <property name ="concurrent" value ="false" /> </bean> <!-- 定義觸發時間 ，這邊就不同了，這裡必須將時間設定成無限長，因為我們要去讀取資料庫的時間來做為定時器的觸發時間--> <bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean "> <property name="jobDetail" ref="jobtask" /> <!-- cron表示式 --> <property name="cronExpression" value="0 0/2 * * * ?" /> </bean> <!-- 總管理類 如果將lazy-init='false'那麼容器啟動就會執行排程程式 --> <bean id="startQuertz" lazy-init="true" autowire="no" class="org.springframework.scheduling.quartz.SchedulerFactoryBean"> <property name="jobFactory" ref="jobFactory" /> <property name="triggers"> <list> <ref bean="cronTrigger" /> </list> </property> </bean> <!--這個類是用來設定觸發時間的， startJobs方法啟動排程容器，然後按照上面觸發器每隔1s執行所配置的myJob2.doSomething()方法 --> <bean id="quartzManager" class="com.shanreal.scheduler.QuartzManager" lazy-init="false" init-method="startJobs" > <!--這個物件一定要注入，這樣類才能進行管理，還有在型別要用get set方法，不然會報錯。--> <property name="scheduler" ref="startQuertz" /> </bean>
QuartzManager.java 動態新增、修改和刪除定時任務管理類
import org.quartz.CronScheduleBuilder; import org.quartz.CronTrigger; import org.quartz.JobBuilder; import org.quartz.JobDetail; import org.quartz.JobKey; import org.quartz.Scheduler; import org.quartz.Trigger; import org.quartz.TriggerBuilder; import org.quartz.TriggerKey; public class QuartzManager { private Scheduler scheduler; /** * @Description: 新增一個定時任務 * * @param jobName 任務名 * @param jobGroupName 任務組名 * @param triggerName 觸發器名 * @param triggerGroupName 觸發器組名 * @param jobClass 任務 * @param cron 時間設定，參考quartz說明文件 */ @SuppressWarnings({ "unchecked", "rawtypes" }) public void addJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName, Class jobClass, String cron) { try { // 任務名，任務組，任務執行類 JobDetail jobDetail= JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build(); // 觸發器 TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger(); // 觸發器名,觸發器組 triggerBuilder.withIdentity(triggerName, triggerGroupName); triggerBuilder.startNow(); // 觸發器時間設定 triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron)); // 建立Trigger物件 CronTrigger trigger = (CronTrigger) triggerBuilder.build(); // 排程容器設定JobDetail和Trigger scheduler.scheduleJob(jobDetail, trigger); // 啟動 if (!scheduler.isShutdown()) { scheduler.start(); } } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description: 修改一個任務的觸發時間 * * @param jobName * @param jobGroupName * @param triggerName 觸發器名 * @param triggerGroupName 觸發器組名 * @param cron 時間設定，參考quartz說明文件 */ public void modifyJobTime(String jobName, String jobGroupName, String triggerName, String triggerGroupName, String cron) { try { TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName); CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); if (trigger == null) { return; } String oldTime = trigger.getCronExpression(); if (!oldTime.equalsIgnoreCase(cron)) { /** 方式一 ：呼叫 rescheduleJob 開始 */ // 觸發器 TriggerBuilder<Trigger> triggerBuilder = TriggerBuilder.newTrigger(); // 觸發器名,觸發器組 triggerBuilder.withIdentity(triggerName, triggerGroupName); triggerBuilder.startNow(); // 觸發器時間設定 triggerBuilder.withSchedule(CronScheduleBuilder.cronSchedule(cron)); // 建立Trigger物件 trigger = (CronTrigger) triggerBuilder.build(); // 方式一 ：修改一個任務的觸發時間 scheduler.rescheduleJob(triggerKey, trigger); /** 方式一 ：呼叫 rescheduleJob 結束 */ /** 方式二：先刪除，然後在建立一個新的Job */ //JobDetail jobDetail = scheduler.getJobDetail(JobKey.jobKey(jobName, jobGroupName)); //Class<? extends Job> jobClass = jobDetail.getJobClass(); //removeJob(jobName, jobGroupName, triggerName, triggerGroupName); //addJob(jobName, jobGroupName, triggerName, triggerGroupName, jobClass, cron); /** 方式二 ：先刪除，然後在建立一個新的Job */ } } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description: 移除一個任務 * * @param jobName * @param jobGroupName * @param triggerName * @param triggerGroupName */ public void removeJob(String jobName, String jobGroupName, String triggerName, String triggerGroupName) { try { TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroupName); scheduler.pauseTrigger(triggerKey);// 停止觸發器 scheduler.unscheduleJob(triggerKey);// 移除觸發器 scheduler.deleteJob(JobKey.jobKey(jobName, jobGroupName));// 刪除任務 } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description:啟動所有定時任務 */ public void startJobs() { try { scheduler.start(); } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description:關閉所有定時任務 */ public void shutdownJobs() { try { if (!scheduler.isShutdown()) { scheduler.shutdown(); } } catch (Exception e) { throw new RuntimeException(e); } } public Scheduler getScheduler() { return scheduler; } public void setScheduler(Scheduler scheduler) { this.scheduler = scheduler; } }
IntialQuartzJob：初始化定時器
@Component
public class IntialQuartzJob {
public void initial(){
System.out.println("----------初始化定時器操作---------");
//這裡可以寫初始執行的定時器方法
}
}JobFactory:用於處理異常（一定要有這個，不然自定義的異常直接被job處理會造成程式報空指標異常）
import org.quartz.spi.TriggerFiredBundle; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.config.AutowireCapableBeanFactory; import org.springframework.scheduling.quartz.AdaptableJobFactory; import org.springframework.stereotype.Service; @Service("jobFactory") public class JobFactory extends AdaptableJobFactory { @Autowired private AutowireCapableBeanFactory capableBeanFactory; @Override protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception { Object jobInstance = super.createJobInstance(bundle); capableBeanFactory.autowireBean(jobInstance); return jobInstance; } }
IntialOtherQuartzJob：系統啟動時初始化新增定時器（可以從資料庫讀取資料）
import org.springframework.beans.factory.InitializingBean;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Component;
@Component
public class IntialOtherQuartzJob implements InitializingBean {
@Autowired
private QuartzManager quartzManager;
public void initialMethod() throws Exception {
System.out.println("--------bean:配置：初始化資料庫儲存的定時器配置--------");
}
@Override
public void afterPropertiesSet() throws Exception {
System.out.println("--------介面實現：初始化資料庫儲存的定時器配置--------");
quartzManager.addJob("班次下線","test","test","test",ClassesQuartzJob.class,"0 0 0/8 * * ?");
}關於系統啟動時初始化執行方法：https://blog.csdn.net/honghailiang888/article/details/73333821
手動測試：
public class Test {
public static String JOB_NAME = "動態任務排程";
public static String TRIGGER_NAME = "動態任務觸發器";
public static String JOB_GROUP_NAME = "XLXXCC_JOB_GROUP";
public static String TRIGGER_GROUP_NAME = "XLXXCC_JOB_GROUP";
public static void main(String[] args) {
try {
System.out.println("【系統啟動】開始(每1秒輸出一次)...");
QuartzManager.addJob(JOB_NAME, JOB_GROUP_NAME, TRIGGER_NAME, TRIGGER_GROUP_NAME, MyJob.class, "0/1 * * * * ?");
Thread.sleep(5000);
System.out.println("【修改時間】開始(每5秒輸出一次)...");
QuartzManager.modifyJobTime(JOB_NAME, JOB_GROUP_NAME, TRIGGER_NAME, TRIGGER_GROUP_NAME, "0/5 * * * * ?");
Thread.sleep(6000);
System.out.println("【移除定時】開始...");
QuartzManager.removeJob(JOB_NAME, JOB_GROUP_NAME, TRIGGER_NAME, TRIGGER_GROUP_NAME);
System.out.println("【移除定時】成功");
} catch (Exception e) {
e.printStackTrace();
}
}
}
個人的資料庫和頁面沒有實現，由於保密原因，以後有機會再自己造資料新增吧。
這裡有個比較全面的，資料庫+頁面：https://blog.csdn.net/qq_21454973/article/details/81979660