一、基本概念
Quartz核心的概念：scheduler任務調度、Job任務、Trigger觸發器、JobDetail任務細節。
scheduler任務調度：
是最核心的概念，需要把JobDetail和Trigger注冊到scheduler中，才可以執行。
Job任務：
其實Job是接口，其中只有一個execute方法：
Trigger觸發器
a)作用:它是來執行工作任務，在什么條件下觸發，什么時間執行，多久執行一次。
b)四大類型：SimpleTrigger，CronTirgger，DateIntervalTrigger， 和 NthIncludedDayTrigger。
SimpleTrigger 一般用於實現每隔一定時間執行任務，以及重復多少次，如每 2 小時執行一次，重復執行 5 次。SimpleTrigger 內部實現機制是通過計算間隔時間來計算下次的執行時間，這就導致其不適合調度定時的任務。例如我們想每天的 1：00AM 執行任務，如果使用 SimpleTrigger 的話間隔時間就是一天。注意這里就會有一個問題，即當有 misfired 的任務並且恢復執行時，該執行時間是隨機的（取決於何時執行 misfired 的任務，例如某天的 3：00PM）。這會導致之后每天的執行時間都會變成 3：00PM，而不是我們原來期望的 1：00AM。
CronTirgger 類似於 LINUX 上的任務調度命令 crontab，即利用一個包含 7 個字段的表達式來表示時間調度方式。例如，"0 15 10 * * ? *" 表示每天的 10：15AM 執行任務。對於涉及到星期和月份的調度，CronTirgger 是最適合的，甚至某些情況下是唯一選擇。例如，"0 10 14 ? 3 WED" 表示三月份的每個星期三的下午 14：10PM 執行任務。讀者可以在具體用到該 trigger 時再詳細了解每個字段的含義。
二、詳細實現案例
1、首先要在mysql里面建一個數據庫，這里起名：quartz_test，並導入以下sql內容
以下的sql為實現quartz集群必須要的表，quartz集群就是通過共享一個數據庫來實現的，不像redis那樣的集群，節點與節點需要通信；quartz集群的節點之間是不需要通信的。
DROP TABLE IF EXISTS QRTZ_FIRED_TRIGGERS; DROP TABLE IF EXISTS QRTZ_PAUSED_TRIGGER_GRPS; DROP TABLE IF EXISTS QRTZ_SCHEDULER_STATE; DROP TABLE IF EXISTS QRTZ_LOCKS; DROP TABLE IF EXISTS QRTZ_SIMPLE_TRIGGERS; DROP TABLE IF EXISTS QRTZ_SIMPROP_TRIGGERS; DROP TABLE IF EXISTS QRTZ_CRON_TRIGGERS; DROP TABLE IF EXISTS QRTZ_BLOB_TRIGGERS; DROP TABLE IF EXISTS QRTZ_TRIGGERS; DROP TABLE IF EXISTS QRTZ_JOB_DETAILS; DROP TABLE IF EXISTS QRTZ_CALENDARS; CREATE TABLE QRTZ_JOB_DETAILS( SCHED_NAME VARCHAR(120) NOT NULL, JOB_NAME VARCHAR(200) NOT NULL, JOB_GROUP VARCHAR(200) NOT NULL, DESCRIPTION VARCHAR(250) NULL, JOB_CLASS_NAME VARCHAR(250) NOT NULL, IS_DURABLE VARCHAR(1) NOT NULL, IS_NONCONCURRENT VARCHAR(1) NOT NULL, IS_UPDATE_DATA VARCHAR(1) NOT NULL, REQUESTS_RECOVERY VARCHAR(1) NOT NULL, JOB_DATA BLOB NULL, PRIMARY KEY (SCHED_NAME,JOB_NAME,JOB_GROUP)) ENGINE=InnoDB; CREATE TABLE QRTZ_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, JOB_NAME VARCHAR(200) NOT NULL, JOB_GROUP VARCHAR(200) NOT NULL, DESCRIPTION VARCHAR(250) NULL, NEXT_FIRE_TIME BIGINT(13) NULL, PREV_FIRE_TIME BIGINT(13) NULL, PRIORITY INTEGER NULL, TRIGGER_STATE VARCHAR(16) NOT NULL, TRIGGER_TYPE VARCHAR(8) NOT NULL, START_TIME BIGINT(13) NOT NULL, END_TIME BIGINT(13) NULL, CALENDAR_NAME VARCHAR(200) NULL, MISFIRE_INSTR SMALLINT(2) NULL, JOB_DATA BLOB NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), FOREIGN KEY (SCHED_NAME,JOB_NAME,JOB_GROUP) REFERENCES QRTZ_JOB_DETAILS(SCHED_NAME,JOB_NAME,JOB_GROUP)) ENGINE=InnoDB; CREATE TABLE QRTZ_SIMPLE_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, REPEAT_COUNT BIGINT(7) NOT NULL, REPEAT_INTERVAL BIGINT(12) NOT NULL, TIMES_TRIGGERED BIGINT(10) NOT NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)) ENGINE=InnoDB; CREATE TABLE QRTZ_CRON_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, CRON_EXPRESSION VARCHAR(120) NOT NULL, TIME_ZONE_ID VARCHAR(80), PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)) ENGINE=InnoDB; CREATE TABLE QRTZ_SIMPROP_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, STR_PROP_1 VARCHAR(512) NULL, STR_PROP_2 VARCHAR(512) NULL, STR_PROP_3 VARCHAR(512) NULL, INT_PROP_1 INT NULL, INT_PROP_2 INT NULL, LONG_PROP_1 BIGINT NULL, LONG_PROP_2 BIGINT NULL, DEC_PROP_1 NUMERIC(13,4) NULL, DEC_PROP_2 NUMERIC(13,4) NULL, BOOL_PROP_1 VARCHAR(1) NULL, BOOL_PROP_2 VARCHAR(1) NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)) ENGINE=InnoDB; CREATE TABLE QRTZ_BLOB_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, BLOB_DATA BLOB NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP), INDEX (SCHED_NAME,TRIGGER_NAME, TRIGGER_GROUP), FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP) REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)) ENGINE=InnoDB; CREATE TABLE QRTZ_CALENDARS ( SCHED_NAME VARCHAR(120) NOT NULL, CALENDAR_NAME VARCHAR(200) NOT NULL, CALENDAR BLOB NOT NULL, PRIMARY KEY (SCHED_NAME,CALENDAR_NAME)) ENGINE=InnoDB; CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS ( SCHED_NAME VARCHAR(120) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, PRIMARY KEY (SCHED_NAME,TRIGGER_GROUP)) ENGINE=InnoDB; CREATE TABLE QRTZ_FIRED_TRIGGERS ( SCHED_NAME VARCHAR(120) NOT NULL, ENTRY_ID VARCHAR(95) NOT NULL, TRIGGER_NAME VARCHAR(200) NOT NULL, TRIGGER_GROUP VARCHAR(200) NOT NULL, INSTANCE_NAME VARCHAR(200) NOT NULL, FIRED_TIME BIGINT(13) NOT NULL, SCHED_TIME BIGINT(13) NOT NULL, PRIORITY INTEGER NOT NULL, STATE VARCHAR(16) NOT NULL, JOB_NAME VARCHAR(200) NULL, JOB_GROUP VARCHAR(200) NULL, IS_NONCONCURRENT VARCHAR(1) NULL, REQUESTS_RECOVERY VARCHAR(1) NULL, PRIMARY KEY (SCHED_NAME,ENTRY_ID)) ENGINE=InnoDB; CREATE TABLE QRTZ_SCHEDULER_STATE ( SCHED_NAME VARCHAR(120) NOT NULL, INSTANCE_NAME VARCHAR(200) NOT NULL, LAST_CHECKIN_TIME BIGINT(13) NOT NULL, CHECKIN_INTERVAL BIGINT(13) NOT NULL, PRIMARY KEY (SCHED_NAME,INSTANCE_NAME)) ENGINE=InnoDB; CREATE TABLE QRTZ_LOCKS ( SCHED_NAME VARCHAR(120) NOT NULL, LOCK_NAME VARCHAR(40) NOT NULL, PRIMARY KEY (SCHED_NAME,LOCK_NAME)) ENGINE=InnoDB; CREATE INDEX IDX_QRTZ_J_REQ_RECOVERY ON QRTZ_JOB_DETAILS(SCHED_NAME,REQUESTS_RECOVERY); CREATE INDEX IDX_QRTZ_J_GRP ON QRTZ_JOB_DETAILS(SCHED_NAME,JOB_GROUP); CREATE INDEX IDX_QRTZ_T_J ON QRTZ_TRIGGERS(SCHED_NAME,JOB_NAME,JOB_GROUP); CREATE INDEX IDX_QRTZ_T_JG ON QRTZ_TRIGGERS(SCHED_NAME,JOB_GROUP); CREATE INDEX IDX_QRTZ_T_C ON QRTZ_TRIGGERS(SCHED_NAME,CALENDAR_NAME); CREATE INDEX IDX_QRTZ_T_G ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_GROUP); CREATE INDEX IDX_QRTZ_T_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_STATE); CREATE INDEX IDX_QRTZ_T_N_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP,TRIGGER_STATE); CREATE INDEX IDX_QRTZ_T_N_G_STATE ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_GROUP,TRIGGER_STATE); CREATE INDEX IDX_QRTZ_T_NEXT_FIRE_TIME ON QRTZ_TRIGGERS(SCHED_NAME,NEXT_FIRE_TIME); CREATE INDEX IDX_QRTZ_T_NFT_ST ON QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_STATE,NEXT_FIRE_TIME); CREATE INDEX IDX_QRTZ_T_NFT_MISFIRE ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME); CREATE INDEX IDX_QRTZ_T_NFT_ST_MISFIRE ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME,TRIGGER_STATE); CREATE INDEX IDX_QRTZ_T_NFT_ST_MISFIRE_GRP ON QRTZ_TRIGGERS(SCHED_NAME,MISFIRE_INSTR,NEXT_FIRE_TIME,TRIGGER_GROUP,TRIGGER_STATE); CREATE INDEX IDX_QRTZ_FT_TRIG_INST_NAME ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,INSTANCE_NAME); CREATE INDEX IDX_QRTZ_FT_INST_JOB_REQ_RCVRY ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,INSTANCE_NAME,REQUESTS_RECOVERY); CREATE INDEX IDX_QRTZ_FT_J_G ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,JOB_NAME,JOB_GROUP); CREATE INDEX IDX_QRTZ_FT_JG ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,JOB_GROUP); CREATE INDEX IDX_QRTZ_FT_T_G ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP); CREATE INDEX IDX_QRTZ_FT_TG ON QRTZ_FIRED_TRIGGERS(SCHED_NAME,TRIGGER_GROUP); commit;
2、創建maven項目，完整的工程結構如下圖
3、引入springboot和quartz的依賴
<?xml version="1.0" encoding="UTF-8"?> <project xmlns="http://maven.apache.org/POM/4.0.0" xmlns:xsi="http://www.w3.org/2001/XMLSchema-instance" xsi:schemaLocation="http://maven.apache.org/POM/4.0.0 http://maven.apache.org/xsd/maven-4.0.0.xsd"> <modelVersion>4.0.0</modelVersion> <groupId>com.springquartz.demo</groupId> <artifactId>spring-quartz</artifactId> <version>1.0-SNAPSHOT</version> <parent> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-parent</artifactId> <version>1.4.1.RELEASE</version> </parent> <dependencies> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-web</artifactId> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-tx</artifactId> <version>4.3.1.RELEASE</version> </dependency> <dependency> <groupId>mysql</groupId> <artifactId>mysql-connector-java</artifactId> <version>5.1.25</version> </dependency> <!--spring quartz依賴--> <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.2.3</version> </dependency> <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz-jobs</artifactId> <version>2.2.3</version> </dependency> <dependency> <groupId>org.springframework</groupId> <artifactId>spring-context-support</artifactId> <version>3.2.3.RELEASE</version> </dependency> </dependencies> </project>
注意：以上的依賴一個都不能少，少一個都運行不起來
4、添加application.yml（不是必須的），quartz.properties文件（必須要的）
application.yml
server:
port: 8084
context-path: /spring-quartz
quartz.properties
# Default Properties file for use by StdSchedulerFactory # to create a Quartz Scheduler Instance, if a different # properties file is not explicitly specified. # #默認或是自己改名字都行 org.quartz.scheduler.instanceName: DefaultQuartzScheduler #如果使用集群，instanceId必須唯一，設置成AUTO org.quartz.scheduler.instanceId = AUTO org.quartz.scheduler.rmi.export: false org.quartz.scheduler.rmi.proxy: false org.quartz.scheduler.wrapJobExecutionInUserTransaction: false org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool org.quartz.threadPool.threadCount: 10 org.quartz.threadPool.threadPriority: 5 org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true org.quartz.jobStore.misfireThreshold: 60000 #============================================================================ # Configure JobStore #============================================================================ # #org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore #存儲方式使用JobStoreTX，也就是數據庫 org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate #使用自己的配置文件 org.quartz.jobStore.useProperties:true #數據庫中quartz表的表名前綴 org.quartz.jobStore.tablePrefix:QRTZ_ org.quartz.jobStore.dataSource:qzDS #是否使用集群（如果項目只部署到 一台服務器，就不用了） org.quartz.jobStore.isClustered = true #============================================================================ # Configure Datasources #============================================================================ #配置數據源 org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver org.quartz.dataSource.qzDS.URL:jdbc:mysql://172.16.0.151:3306/quartz_test?useUnicode=true&characterEncoding=utf8 org.quartz.dataSource.qzDS.user:root org.quartz.dataSource.qzDS.password:huacloudhuacloud org.quartz.dataSource.qzDS.validationQuery=select 0 from dual
注意：如果部署的是quartz集群，必須加上以上紅色加粗的部分，如果只是單節點quartz可以不用加。
5、添加springboot啟動類
package com.springquartz; import org.springframework.boot.SpringApplication; import org.springframework.boot.autoconfigure.SpringBootApplication; import org.springframework.context.annotation.ComponentScan; /** * @author hzb * @date 2018/08/18 */ @SpringBootApplication @ComponentScan(basePackages = { "com.springquartz" }) public class Application { public static void main(String[] args) throws Exception { SpringApplication.run(Application.class, args); } }
6、創建job 實例工廠，解決spring注入問題，如果使用默認會導致spring的@Autowired 無法注入問題（很重要）
package com.springquartz.factory; import org.quartz.spi.TriggerFiredBundle; import org.springframework.beans.factory.config.AutowireCapableBeanFactory; import org.springframework.context.ApplicationContext; import org.springframework.context.ApplicationContextAware; import org.springframework.scheduling.quartz.SpringBeanJobFactory; import org.springframework.stereotype.Component; @Component public class MyJobFactory extends SpringBeanJobFactory implements ApplicationContextAware { private transient AutowireCapableBeanFactory beanFactory; @Override public void setApplicationContext(final ApplicationContext context) { beanFactory = context.getAutowireCapableBeanFactory(); } @Override protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception { final Object job = super.createJobInstance(bundle); beanFactory.autowireBean(job); return job; } }
7、quartz的初始化配置
package com.springquartz.config; import com.springquartz.factory.MyJobFactory; import org.quartz.Scheduler; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.beans.factory.config.PropertiesFactoryBean; import org.springframework.context.annotation.Bean; import org.springframework.context.annotation.Configuration; import org.springframework.core.io.ClassPathResource; import org.springframework.scheduling.quartz.SchedulerFactoryBean; import java.io.IOException; import java.util.Properties; /** * @author hzb * @date 2018/08/28 */ @Configuration public class SchedulerConfiguration { @Autowired private MyJobFactory myJobFactory; @Bean(name = "schedulerFactoryBean") public SchedulerFactoryBean schedulerFactoryBean() throws IOException { //獲取配置屬性 PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean(); propertiesFactoryBean.setLocation(new ClassPathResource("quartz.properties")); //在quartz.properties中的屬性被讀取並注入后再初始化對象 propertiesFactoryBean.afterPropertiesSet(); //創建SchedulerFactoryBean SchedulerFactoryBean factory = new SchedulerFactoryBean(); Properties pro = propertiesFactoryBean.getObject(); factory.setOverwriteExistingJobs(true); factory.setAutoStartup(true); factory.setQuartzProperties(pro); factory.setJobFactory(myJobFactory); return factory; } }
8、新建service接口和實現類
package com.springquartz.service; /** * @author hzb * @date 2018/08/28 */ public interface JobService { /** * 添加一個定時任務 * @param jobName * @param jobGroup */ void addCronJob(String jobName, String jobGroup); /** * 添加異步任務 * @param jobName * @param jobGroup */ void addAsyncJob(String jobName, String jobGroup); /** * 暫停任務 * @param jobName * @param jobGroup */ void pauseJob(String jobName, String jobGroup); /** * 恢復任務 * @param triggerName * @param triggerGroup */ void resumeJob(String triggerName, String triggerGroup); /** * 刪除job * @param jobName * @param jobGroup */ void deleteJob(String jobName, String jobGroup); }
package com.springquartz.service; import com.springquartz.job.AsyncJob; import com.springquartz.job.CronJob; import org.quartz.CronScheduleBuilder; import org.quartz.CronTrigger; import org.quartz.JobBuilder; import org.quartz.JobDataMap; import org.quartz.JobDetail; import org.quartz.JobKey; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.Trigger; import org.quartz.TriggerBuilder; import org.quartz.TriggerKey; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.scheduling.quartz.SchedulerFactoryBean; import org.springframework.stereotype.Service; import static org.quartz.SimpleScheduleBuilder.simpleSchedule; /** * @author hzb * @date 2018/08/28 */ @Service public class JobServiceImpl implements JobService { @SuppressWarnings("SpringJavaInjectionPointsAutowiringInspection") @Autowired private SchedulerFactoryBean schedulerFactoryBean; /** * 創建一個定時任務 * * @param jobName * @param jobGroup */ @Override public void addCronJob(String jobName, String jobGroup) { try { Scheduler scheduler = schedulerFactoryBean.getScheduler(); JobKey jobKey = JobKey.jobKey(jobName, jobGroup); JobDetail jobDetail = scheduler.getJobDetail(jobKey); if (jobDetail != null) { System.out.println("job:" + jobName + " 已存在"); } else { //構建job信息 jobDetail = JobBuilder.newJob(CronJob.class).withIdentity(jobName, jobGroup).build(); //用JopDataMap來傳遞數據 jobDetail.getJobDataMap().put("taskData", "hzb-cron-001"); //表達式調度構建器(即任務執行的時間,每5秒執行一次) CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("*/5 * * * * ?"); //按新的cronExpression表達式構建一個新的trigger CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName + "_trigger", jobGroup + "_trigger") .withSchedule(scheduleBuilder).build(); scheduler.scheduleJob(jobDetail, trigger); } } catch (Exception e) { e.printStackTrace(); } } @Override public void addAsyncJob(String jobName, String jobGroup) { try { Scheduler scheduler = schedulerFactoryBean.getScheduler(); JobKey jobKey = JobKey.jobKey(jobName, jobGroup); JobDetail jobDetail = scheduler.getJobDetail(jobKey); if (jobDetail != null) { System.out.println("job:" + jobName + " 已存在"); } else { //構建job信息,在用JobBuilder創建JobDetail的時候，有一個storeDurably()方法，可以在沒有觸發器指向任務的時候，將任務保存在隊列中了。然后就能手動觸發了 jobDetail = JobBuilder.newJob(AsyncJob.class).withIdentity(jobName, jobGroup).storeDurably().build(); jobDetail.getJobDataMap().put("asyncData","this is a async task"); Trigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName + "_trigger", jobGroup + "_trigger") //定義name/group .startNow()//一旦加入scheduler，立即生效 .withSchedule(simpleSchedule())//使用SimpleTrigger .build(); scheduler.scheduleJob(jobDetail, trigger); } } catch (Exception e) { e.printStackTrace(); } } @Override public void pauseJob(String jobName, String jobGroup) { try { Scheduler scheduler = schedulerFactoryBean.getScheduler(); TriggerKey triggerKey = TriggerKey.triggerKey(jobName + "_trigger", jobGroup + "_trigger"); scheduler.pauseTrigger(triggerKey); System.out.println("=========================pause job:" + jobName + " success========================"); } catch (SchedulerException e) { e.printStackTrace(); } } /** * 恢復任務 * * @param jobName * @param jobGroup */ @Override public void resumeJob(String jobName, String jobGroup) { try { Scheduler scheduler = schedulerFactoryBean.getScheduler(); TriggerKey triggerKey = TriggerKey.triggerKey(jobName + "_trigger", jobGroup + "_trigger"); scheduler.resumeTrigger(triggerKey); System.out.println("=========================resume job:" + jobName + " success========================"); } catch (SchedulerException e) { e.printStackTrace(); } } @Override public void deleteJob(String jobName, String jobGroup) { try { Scheduler scheduler = schedulerFactoryBean.getScheduler(); JobKey jobKey = JobKey.jobKey(jobName,jobGroup); scheduler.deleteJob(jobKey); System.out.println("=========================delete job:" + jobName + " success========================"); } catch (SchedulerException e) { e.printStackTrace(); } } }
9、新建controller
package com.springquartz.controller; import com.springquartz.service.JobService; import org.springframework.beans.factory.annotation.Autowired; import org.springframework.web.bind.annotation.RequestMapping; import org.springframework.web.bind.annotation.RequestMethod; import org.springframework.web.bind.annotation.RequestParam; import org.springframework.web.bind.annotation.RestController; /** * @author hzb * @date 2018/08/28 */ @RestController @RequestMapping("/quartztest") public class JobController { @Autowired private JobService jobService; /** * 創建cron任務 * @param jobName * @param jobGroup * @return */ @RequestMapping(value = "/cron",method = RequestMethod.POST) public String startCronJob(@RequestParam("jobName") String jobName, @RequestParam("jobGroup") String jobGroup){ jobService.addCronJob(jobName,jobGroup); return "create cron task success"; } /** * 創建異步任務 * @param jobName * @param jobGroup * @return */ @RequestMapping(value = "/async",method = RequestMethod.POST) public String startAsyncJob(@RequestParam("jobName") String jobName, @RequestParam("jobGroup") String jobGroup){ jobService.addAsyncJob(jobName,jobGroup); return "create async task success"; } /** * 暫停任務 * @param jobName * @param jobGroup * @return */ @RequestMapping(value = "/pause",method = RequestMethod.POST) public String pauseJob(@RequestParam("jobName") String jobName, @RequestParam("jobGroup") String jobGroup){ jobService.pauseJob(jobName,jobGroup); return "pause job success"; } /** * 恢復任務 * @param jobName * @param jobGroup * @return */ @RequestMapping(value = "/resume",method = RequestMethod.POST) public String resumeJob(@RequestParam("jobName") String jobName, @RequestParam("jobGroup") String jobGroup){ jobService.resumeJob(jobName,jobGroup); return "resume job success"; } /** * 刪除務 * @param jobName * @param jobGroup * @return */ @RequestMapping(value = "/delete",method = RequestMethod.PUT) public String deleteJob(@RequestParam("jobName") String jobName, @RequestParam("jobGroup") String jobGroup){ jobService.deleteJob(jobName,jobGroup); return "delete job success"; } }
10、新建job，這里的job僅僅只是打印信息，不做復雜的業務
package com.springquartz.job; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; /** * @author hzb * @date 2018/08/28 */ public class CronJob implements Job { @Override public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { System.out.println("=========================定時任務每5秒執行一次==============================="); System.out.println("jobName=====:"+jobExecutionContext.getJobDetail().getKey().getName()); System.out.println("jobGroup=====:"+jobExecutionContext.getJobDetail().getKey().getGroup()); System.out.println("taskData=====:"+jobExecutionContext.getJobDetail().getJobDataMap().get("taskData")); } }
package com.springquartz.job; import org.quartz.Job; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; /** * @author Administrator * @date 2018/08/28 */ public class AsyncJob implements Job { @Override public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException { System.out.println("========================立即執行的任務，只執行一次==============================="); System.out.println("jobName=====:"+jobExecutionContext.getJobDetail().getKey().getName()); System.out.println("jobGroup=====:"+jobExecutionContext.getJobDetail().getKey().getGroup()); System.out.println("taskData=====:"+jobExecutionContext.getJobDetail().getJobDataMap().get("asyncData")); } }
11、執行結果
啟動程序之后，這里用postman進行測試
a、創建一個cron任務
控制台打印：
2018-08-29 14:22:11.668 INFO 3284 --- [nio-8084-exec-1] o.s.web.servlet.DispatcherServlet : FrameworkServlet 'dispatcherServlet': initialization completed in 19 ms =========================定時任務每5秒執行一次=============================== jobName=====:cron1 jobGroup=====:cron-group1 taskData=====:hzb-cron-001 =========================定時任務每5秒執行一次=============================== jobName=====:cron1 jobGroup=====:cron-group1 taskData=====:hzb-cron-001 =========================定時任務每5秒執行一次=============================== jobName=====:cron1 jobGroup=====:cron-group1 taskData=====:hzb-cron-001 =========================定時任務每5秒執行一次===============================
b、暫停任務
控制台打印：
=========================定時任務每5秒執行一次=============================== jobName=====:cron1 jobGroup=====:cron-group1 taskData=====:hzb-cron-001 =========================定時任務每5秒執行一次=============================== jobName=====:cron1 jobGroup=====:cron-group1 taskData=====:hzb-cron-001 =========================pause job:cron1 success========================
可以看到剛才的5秒一次的定時任務不執行了
c、恢復任務
控制台打印：
=========================pause job:cron1 success======================== =========================resume job:cron1 success======================== =========================定時任務每5秒執行一次=============================== jobName=====:cron1 jobGroup=====:cron-group1 taskData=====:hzb-cron-001 =========================定時任務每5秒執行一次=============================== jobName=====:cron1 jobGroup=====:cron-group1 taskData=====:hzb-cron-001
d、刪除任務
控制台打印：
=========================定時任務每5秒執行一次=============================== jobName=====:cron1 jobGroup=====:cron-group1 taskData=====:hzb-cron-001 =========================定時任務每5秒執行一次=============================== jobName=====:cron1 jobGroup=====:cron-group1 taskData=====:hzb-cron-001 =========================delete job:cron1 success========================
二、擴展：cron表達式
cron表達式用於配置cronTrigger的實例。cron表達式實際上是由七個子表達式組成。這些表達式之間用空格分隔。
1.Seconds （秒）
2.Minutes（分）
3.Hours（小時）
4.Day-of-Month （天）
5.Month（月）
6.Day-of-Week （周）
7.Year（年）
例："0 0 12 ? * WED” 意思是：每個星期三的中午12點執行。
個別子表達式可以包含范圍或者列表。例如：上面例子中的WED可以換成"MON-FRI"，"MON,WED,FRI"，甚至"MON-WED,SAT"。
子表達式范圍：
1.Seconds (0~59)
2.Minutes (0~59)
3.Hours (0~23)
4.Day-of-Month (1~31,但是要注意有些月份沒有31天)
5.Month (0~11，或者"JAN, FEB, MAR, APR, MAY, JUN, JUL, AUG, SEP, OCT, NOV,DEC")
6.Day-of-Week (1~7,1=SUN 或者"SUN, MON, TUE, WED, THU, FRI, SAT”)
7.Year (1970~2099)
Cron表達式的格式：秒 分 時 日 月 周 年(可選)。
字段名 允許的值 允許的特殊字符
秒 0-59 , - * /
分 0-59 , - * /
小時 0-23 , - * /
日 1-31 , - * ? / L W C
月 1-12 or JAN-DEC , - * /
周幾 1-7 or SUN-SAT , - * ? / L C #
年(可選字段) empty 1970-2099 , - * /
字符含義：
* ：代表所有可能的值。因此，“*”在Month中表示每個月，在Day-of-Month中表示每天，在Hours表示每小時
- ：表示指定范圍。
, ：表示列出枚舉值。例如：在Minutes子表達式中，“5,20”表示在5分鍾和20分鍾觸發。
/ ：被用於指定增量。例如：在Minutes子表達式中，“0/15”表示從0分鍾開始，每15分鍾執行一次。"3/20"表示從第三分鍾開始，每20分鍾執行一次。和"3,23,43"（表示第3，23，43分鍾觸發）的含義一樣。
? ：用在Day-of-Month和Day-of-Week中，指“沒有具體的值”。當兩個子表達式其中一個被指定了值以后，為了避免沖突，需要將另外一個的值設為“?”。例如：想在每月20日觸發調度，不管20號是星期幾，只能用如下寫法：0 0 0 20 * ?，其中最后以為只能用“?”，而不能用“*”。
L ：用在day-of-month和day-of-week字串中。它是單詞“last”的縮寫。它在兩個子表達式中的含義是不同的。
在day-of-month中，“L”表示一個月的最后一天，一月31號，3月30號。
在day-of-week中，“L”表示一個星期的最后一天，也就是“7”或者“SAT”
如果“L”前有具體內容，它就有其他的含義了。例如：“6L”表示這個月的倒數第六天。“FRIL”表示這個月的最后一個星期五。
注意：在使用“L”參數時，不要指定列表或者范圍，這樣會出現問題。
W ：“Weekday”的縮寫。只能用在day-of-month字段。用來描敘最接近指定天的工作日（周一到周五）。例如：在day-of-month字段用“15W”指“最接近這個月第15天的工作日”，即如果這個月第15天是周六，那么觸發器將會在這個月第14天即周五觸發；如果這個月第15天是周日，那么觸發器將會在這個月第 16天即周一觸發；如果這個月第15天是周二，那么就在觸發器這天觸發。注意一點：這個用法只會在當前月計算值，不會越過當前月。“W”字符僅能在 day-of-month指明一天，不能是一個范圍或列表。也可以用“LW”來指定這個月的最后一個工作日，即最后一個星期五。
# ：只能用在day-of-week字段。用來指定這個月的第幾個周幾。例：在day-of-week字段用"6#3" or "FRI#3"指這個月第3個周五（6指周五，3指第3個）。如果指定的日期不存在，觸發器就不會觸發。
表達式例子：
0 * * * * ? 每1分鍾觸發一次
0 0 * * * ? 每天每1小時觸發一次
0 0 10 * * ? 每天10點觸發一次
0 * 14 * * ? 在每天下午2點到下午2:59期間的每1分鍾觸發
0 30 9 1 * ? 每月1號上午9點半
0 15 10 15 * ? 每月15日上午10:15觸發
*/5 * * * * ? 每隔5秒執行一次
0 */1 * * * ? 每隔1分鍾執行一次
0 0 5-15 * * ? 每天5-15點整點觸發
0 0/3 * * * ? 每三分鍾觸發一次
0 0-5 14 * * ? 在每天下午2點到下午2:05期間的每1分鍾觸發
0 0/5 14 * * ? 在每天下午2點到下午2:55期間的每5分鍾觸發
0 0/5 14,18 * * ? 在每天下午2點到2:55期間和下午6點到6:55期間的每5分鍾觸發
0 0/30 9-17 * * ? 朝九晚五工作時間內每半小時
0 0 10,14,16 * * ? 每天上午10點，下午2點，4點
0 0 12 ? * WED 表示每個星期三中午12點
0 0 17 ? * TUES,THUR,SAT 每周二、四、六下午五點
0 10,44 14 ? 3 WED 每年三月的星期三的下午2:10和2:44觸發
0 15 10 ? * MON-FRI 周一至周五的上午10:15觸發
0 0 23 L * ? 每月最后一天23點執行一次
0 15 10 L * ? 每月最后一日的上午10:15觸發
0 15 10 ? * 6L 每月的最后一個星期五上午10:15觸發
0 15 10 * * ? 2005 2005年的每天上午10:15觸發
0 15 10 ? * 6L 2002-2005 2002年至2005年的每月的最后一個星期五上午10:15觸發
0 15 10 ? * 6#3 每月的第三個星期五上午10:15觸發