## 一、前言 在項目開發過程當中，某些定時任務，可能在運行一段時間之后，就不需要了，或者需要修改下定時任務的執行時間等等。 需要在代碼當中進行修改然后重新打包發布，很麻煩。使用Quartz來實現的話不需要重新修改代碼而達到要求。 ## 二、原理 1. 使用quartz提供的API完成配置任務的增刪改查 2. 將任務的配置保存在數據庫中 ## 三、配置 application.yml 在上一節中已經引入了maven依賴包,這里不再重復。直接spring屬性下面加入quartz配置信息 ~~~ spring: datasource: url: jdbc:mysql://192.168.161.3:3306/testdb?useUnicode=true&characterEncoding=utf-8&useSSL=false username: test password: 4rfv$RFV driver-class-name: com.mysql.jdbc.Driver quartz: job-store-type: JDBC #數據庫存儲quartz任務配置 jdbc: initialize-schema: NEVER #自動初始化表結構，第一次啟動的時候這里寫always ~~~ > 但可能是版本bug，有的時候自動建表不會生效，自己去quartz-scheduler-x.x.x.jar里面找一下建表sql腳本：classpath:org/quartz/impl/jdbcjobstore/tables\_@@platform@@.sql，然后執行。  ## 四、動態配置代碼實現 第一步 創建一個定時任務相關實體類用于保存定時任務相關信息到數據庫當中 ~~~ @Data public class QuartzBean { /** 任務id */ private String id; /** 任務名稱 */ private String jobName; /** 任務執行類 */ private String jobClass; /** 任務狀態 啟動還是暫停*/ private Integer status; /** 任務運行時間表達式 */ private String cronExpression; } ~~~ 第二步 創建定時任務暫停，修改，啟動，單次啟動工具類 ~~~ public class QuartzUtils { /** * 創建定時任務 定時任務創建之后默認啟動狀態 * @param scheduler 調度器 * @param quartzBean 定時任務信息類 */ @SuppressWarnings("unchecked") public static void createScheduleJob(Scheduler scheduler, QuartzBean quartzBean) throws ClassNotFoundException, SchedulerException { //獲取到定時任務的執行類 必須是類的絕對路徑名稱 //定時任務類需要是job類的具體實現 QuartzJobBean是job的抽象類。 Class<? extends Job> jobClass = (Class<? extends Job>) Class.forName(quartzBean.getJobClass()); // 構建定時任務信息 JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(quartzBean.getJobName()).build(); // 設置定時任務執行方式 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(quartzBean.getCronExpression()); // 構建觸發器trigger CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(quartzBean.getJobName()).withSchedule(scheduleBuilder).build(); scheduler.scheduleJob(jobDetail, trigger); } /** * 根據任務名稱暫停定時任務 * @param scheduler 調度器 * @param jobName 定時任務名稱 */ public static void pauseScheduleJob(Scheduler scheduler, String jobName) throws SchedulerException { JobKey jobKey = JobKey.jobKey(jobName); scheduler.pauseJob(jobKey); } /** * 根據任務名稱恢復定時任務 * @param scheduler 調度器 * @param jobName 定時任務名稱 */ public static void resumeScheduleJob(Scheduler scheduler, String jobName) throws SchedulerException { JobKey jobKey = JobKey.jobKey(jobName); scheduler.resumeJob(jobKey); } /** * 根據任務名稱立即運行一次定時任務 * @param scheduler 調度器 * @param jobName 定時任務名稱 */ public static void runOnce(Scheduler scheduler, String jobName) throws SchedulerException { JobKey jobKey = JobKey.jobKey(jobName); scheduler.triggerJob(jobKey); } /** * 更新定時任務 * @param scheduler 調度器 * @param quartzBean 定時任務信息類 */ public static void updateScheduleJob(Scheduler scheduler, QuartzBean quartzBean) throws SchedulerException { //獲取到對應任務的觸發器 TriggerKey triggerKey = TriggerKey.triggerKey(quartzBean.getJobName()); //設置定時任務執行方式 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(quartzBean.getCronExpression()); //重新構建任務的觸發器trigger CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey); trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build(); //重置對應的job scheduler.rescheduleJob(triggerKey, trigger); } /** * 根據定時任務名稱從調度器當中刪除定時任務 * @param scheduler 調度器 * @param jobName 定時任務名稱 */ public static void deleteScheduleJob(Scheduler scheduler, String jobName) throws SchedulerException { JobKey jobKey = JobKey.jobKey(jobName); scheduler.deleteJob(jobKey); } } ~~~ ~~~ @Controller @RequestMapping("/quartz/job/") public class QuartzController { //注入任務調度 @Resource private Scheduler scheduler; @PostMapping("/create") @ResponseBody public String createJob(@RequestBody QuartzBean quartzBean) throws SchedulerException, ClassNotFoundException { QuartzUtils.createScheduleJob(scheduler,quartzBean); return "已創建任務";//這里return不是生產級別代碼，測試簡單寫一下 } @PostMapping("/pause") @ResponseBody public String pauseJob(String jobName) throws SchedulerException { QuartzUtils.pauseScheduleJob (scheduler,jobName); return "已暫停成功";//這里return不是生產級別代碼，測試簡單寫一下 } @PostMapping("/run") @ResponseBody public String runOnce(String jobName) throws SchedulerException { QuartzUtils.runOnce (scheduler,jobName); return "運行任務" + jobName + "成功";//這里return不是生產級別代碼，測試簡單寫一下 } @PostMapping("/resume") @ResponseBody public String resume(String jobName) throws SchedulerException { QuartzUtils.resumeScheduleJob(scheduler,jobName); return "恢復定時任務成功：" + jobName; } @PostMapping("/update") @ResponseBody public String update(@RequestBody QuartzBean quartzBean) throws SchedulerException { QuartzUtils.updateScheduleJob(scheduler,quartzBean); return "更新定時任務調度信息成功"; } } ~~~