傳統的 Spring方式集成，由于任務信息全部配置在 xml文件中，如果需要操作任務或者修改任務運行頻率，只能重新編譯、打包、部署、重啟，如果有緊急問題需要處理，會浪費很多的時間。

有沒有可以動態調度任務的方法？比如停止一個 Job？啟動一個 Job？修改 Job的觸發頻率？

讀取配置文件、寫入配置文件、重啟 Scheduler或重啟應用明顯是不可取的。

對于這種頻繁變更并且需要實時生效的配置信息，我們可以放到哪里？ZK、Redis、DB tables。

并且，我們可以提供一個界面，實現對數據表的輕松操作。?

配置管理

這里我們用最簡單的數據庫的實現。

問題?
1：建一張什么樣的表？參考 JobDetail的屬性。?

CREATE TABLE `sys_job` (?`id` int(11) NOT NULL AUTO_INCREMENT COMMENT 'ID',?`job_name` varchar(512) NOT NULL COMMENT '任務名稱 ',?`job_group` varchar(512) NOT NULL COMMENT '任務組名 ',?`job_cron` varchar(512) NOT NULL COMMENT '時間表達式 ',?`job_class_path` varchar(1024) NOT NULL COMMENT '類路徑 ,全類型 ',?`job_data_map` varchar(1024) DEFAULT NULL COMMENT '傳遞 map參數 ',?`job_status` int(2) NOT NULL COMMENT '狀態 :1啟用 0停用 ',?`job_describe` varchar(1024) DEFAULT NULL COMMENT '任務功能描述 ',?PRIMARY KEY (`id`)? ) ENGINE=InnoDB AUTO_INCREMENT=25 DEFAULT CHARSET=utf8;?

數據操作與任務調度

操作數據表非常簡單，SSM增刪改查。

但是在修改了表的數據之后，怎么讓調度器知道呢？

調度器的接口：Scheduler

在我們的需求中，我們需要做的事情：
1、新增一個任務
2、刪除一個任務
3、啟動、停止一個任務
4、修改任務的信息（包括調度規律）

因此可以把相關的操作封裝到一個工具類中。

public class SchedulerUtil {private static Logger logger = LoggerFactory.getLogger(SchedulerUtil.class);/*** 新增定時任務* @param jobClassName 類路徑* @param jobName 任務名稱* @param jobGroupName 組別* @param cronExpression Cron表達式* @param jobDataMap 需要傳遞的參數* @throws Exception*/public static void addJob(String jobClassName,String jobName, String jobGroupName, String cronExpression,String jobDataMap) throws Exception {// 通過SchedulerFactory獲取一個調度器實例SchedulerFactory sf = new StdSchedulerFactory();Scheduler scheduler = sf.getScheduler();// 啟動調度器scheduler.start();// 構建job信息JobDetail jobDetail = JobBuilder.newJob(getClass(jobClassName).getClass()).withIdentity(jobName, jobGroupName).build();// JobDataMap用于傳遞任務運行時的參數，比如定時發送郵件，可以用json形式存儲收件人等等信息if (StringUtils.isNotEmpty(jobDataMap)) {JSONObject jb = JSONObject.parseObject(jobDataMap);Map<String, Object> dataMap =(Map<String, Object>) jb.get("data");for (Map.Entry<String, Object> m:dataMap.entrySet()) {jobDetail.getJobDataMap().put(m.getKey(),m.getValue());}}// 表達式調度構建器(即任務執行的時間)CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);// 按新的cronExpression表達式構建一個新的triggerCronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroupName).withSchedule(scheduleBuilder).startNow().build();try {scheduler.scheduleJob(jobDetail, trigger);} catch (SchedulerException e) {logger.info("創建定時任務失敗" + e);throw new Exception("創建定時任務失敗");}}/*** 停用一個定時任務* @param jobName 任務名稱* @param jobGroupName 組別* @throws Exception*/public static void jobPause(String jobName, String jobGroupName) throws Exception {// 通過SchedulerFactory獲取一個調度器實例SchedulerFactory sf = new StdSchedulerFactory();Scheduler scheduler = sf.getScheduler();scheduler.pauseJob(JobKey.jobKey(jobName, jobGroupName));}/*** 啟用一個定時任務* @param jobName 任務名稱* @param jobGroupName 組別* @throws Exception*/public static void jobresume(String jobName, String jobGroupName) throws Exception {// 通過SchedulerFactory獲取一個調度器實例SchedulerFactory sf = new StdSchedulerFactory();Scheduler scheduler = sf.getScheduler();scheduler.resumeJob(JobKey.jobKey(jobName, jobGroupName));}/*** 刪除一個定時任務* @param jobName 任務名稱* @param jobGroupName 組別* @throws Exception*/public static void jobdelete(String jobName, String jobGroupName) throws Exception {// 通過SchedulerFactory獲取一個調度器實例SchedulerFactory sf = new StdSchedulerFactory();Scheduler scheduler = sf.getScheduler();scheduler.pauseTrigger(TriggerKey.triggerKey(jobName, jobGroupName));scheduler.unscheduleJob(TriggerKey.triggerKey(jobName, jobGroupName));scheduler.deleteJob(JobKey.jobKey(jobName, jobGroupName));}/*** 更新定時任務表達式* @param jobName 任務名稱* @param jobGroupName 組別* @param cronExpression Cron表達式* @throws Exception*/public static void jobReschedule(String jobName, String jobGroupName, String cronExpression) throws Exception {try {SchedulerFactory schedulerFactory = new StdSchedulerFactory();Scheduler scheduler = schedulerFactory.getScheduler();TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroupName);// 表達式調度構建器CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);// 按新的cronExpression表達式重新構建triggertrigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).startNow().build();// 按新的trigger重新設置job執行scheduler.rescheduleJob(triggerKey, trigger);} catch (SchedulerException e) {System.out.println("更新定時任務失敗" + e);throw new Exception("更新定時任務失敗");}}/*** 檢查Job是否存在* @throws Exception*/public static Boolean isResume(String jobName, String jobGroupName) throws Exception {SchedulerFactory sf = new StdSchedulerFactory();Scheduler scheduler = sf.getScheduler();TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroupName);Boolean state = scheduler.checkExists(triggerKey);return state;}/*** 暫停所有任務* @throws Exception*/public static void pauseAlljob() throws Exception {SchedulerFactory sf = new StdSchedulerFactory();Scheduler scheduler = sf.getScheduler();scheduler.pauseAll();}/*** 喚醒所有任務* @throws Exception*/public static void resumeAlljob() throws Exception {SchedulerFactory sf = new StdSchedulerFactory();Scheduler sched = sf.getScheduler();sched.resumeAll();}/*** 獲取Job實例* @param classname* @return* @throws Exception*/public static BaseJob getClass(String classname) throws Exception {try {Class<?> c = Class.forName(classname);return (BaseJob) c.newInstance();} catch (Exception e) {throw new Exception("類["+classname+"]不存在！");}}}

?

總結

以上是生活随笔為你收集整理的springboot-quartz工程动态调度的实现的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。