//定义相关配置@Configuration@EnableSchedulingpublic class QuartzConfig {@Autowiredprivate SpringJobFactory springJobFactory;//读取quartz的属性文件(自己的工程存在dev或者test及其他配置文件,到哪个台读取指定名称的配置文件)@Value("${config}")private String configName;@Bean("schedulerFactoryBean")public SchedulerFactoryBean schedulerFactoryBean(@Qualifier("quartzProperties") Properties properties) throws SchedulerException {SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();schedulerFactoryBean.setQuartzProperties(properties);schedulerFactoryBean.setJobFactory(springJobFactory);schedulerFactoryBean.setWaitForJobsToCompleteOnShutdown(true);return schedulerFactoryBean;}@Beanpublic Properties quartzProperties() throws IOException {PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();propertiesFactoryBean.setLocation(new ClassPathResource(configName));propertiesFactoryBean.afterPropertiesSet();return propertiesFactoryBean.getObject();}}定义quartz的任务工厂(由于quartz与spring都有自己的所属的容器)@Componentpublic class SpringJobFactory extends AdaptableJobFactory {@Autowiredprivate AutowireCapableBeanFactory capableBeanFactory;@Overrideprotected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {Object jobInstance = super.createJobInstance(bundle);capableBeanFactory.autowireBean(jobInstance);return jobInstance;}}复制代码
quartz.properties的配置详情#ThreadPool 线程池属性org.quartz.threadPool.class=org.quartz.simpl.SimpleThreadPoolorg.quartz.threadPool.threadCount=15org.quartz.threadPool.threadPriority=5# Configure JobStore#使用数据库作为quartz的持久化org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTXorg.quartz.jobStore.driverDelegateClass=org.quartz.impl.jdbcjobstore.StdJDBCDelegateorg.quartz.jobStore.tablePrefix=QRTZ_org.quartz.jobStore.dataSource=myDS#容忍任务遗漏时间org.quartz.jobStore.misfireThreshold=5000org.quartz.dataSource.myDS.driver=com.mysql.jdbc.Driverorg.quartz.dataSource.myDS.URL=jdbc:mysql://local:3306/quartz?useSSL=false&characterEncoding=utf-8&serverTimezone=Hongkong&autoReconnect=trueorg.quartz.dataSource.myDS.user=rootorg.quartz.dataSource.myDS.password=rootorg.quartz.dataSource.myDS.test-while-idle=trueorg.quartz.dataSource.myDS.test-on-borrow=trueorg.quartz.dataSource.myDS.test-on-return=trueorg.quartz.dataSource.myDS.time-between-eviction-runs-millis=300000org.quartz.dataSource.myDS.validation-query=select 1#config pluignorg.quartz.plugin.triggHistory.class=org.quartz.plugins.history.LoggingTriggerHistoryPluginorg.quartz.plugin.triggHistory.triggerFiredMessage=Trigger {1}.{0} fired job {6}.{5} at: {4, date, HH:mm:ss MM/dd/yyyy}org.quartz.plugin.triggHistory.triggerCompleteMessage=Trigger {1}.{0} completed firing job {6}.{5} at {4, date, HH:mm:ss MM/dd/yyyy} with resulting trigger instruction code: {9}org.quartz.plugin.shutdownhook.class=org.quartz.plugins.management.ShutdownHookPluginorg.quartz.plugin.shutdownhook.cleanShutdown=true复制代码
接着实现Job接口定义自己的任务
将业务逻辑定义在execute方法中就行了
@Component//避免并发执行(重要注解)@DisallowConcurrentExecutionpublic class SchedulerJob implements Job 以下是quartz基于数据库持久化的相关sql复制代码
-- ------------------------------ Table structure for qrtz_blob_triggers-- ----------------------------DROP TABLE IF EXISTS `qrtz_blob_triggers`;CREATE TABLE `qrtz_blob_triggers` (`SCHED_NAME` varchar(80) NOT NULL,`TRIGGER_NAME` varchar(100) NOT NULL,`TRIGGER_GROUP` varchar(100) NOT NULL,`BLOB_DATA` blob,PRIMARY KEY (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`),CONSTRAINT `qrtz_blob_triggers_ibfk_1` FOREIGN KEY (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`) REFERENCES `qrtz_triggers` (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Table structure for qrtz_calendars-- ----------------------------DROP TABLE IF EXISTS `qrtz_calendars`;CREATE TABLE `qrtz_calendars` (`SCHED_NAME` varchar(80) NOT NULL,`CALENDAR_NAME` varchar(100) NOT NULL,`CALENDAR` blob NOT NULL,PRIMARY KEY (`SCHED_NAME`,`CALENDAR_NAME`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Table structure for qrtz_cron_triggers-- ----------------------------DROP TABLE IF EXISTS `qrtz_cron_triggers`;CREATE TABLE `qrtz_cron_triggers` (`SCHED_NAME` varchar(80) NOT NULL,`TRIGGER_NAME` varchar(100) NOT NULL,`TRIGGER_GROUP` varchar(100) NOT NULL,`CRON_EXPRESSION` varchar(100) NOT NULL,`TIME_ZONE_ID` varchar(80) DEFAULT NULL,PRIMARY KEY (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`),CONSTRAINT `qrtz_cron_triggers_ibfk_1` FOREIGN KEY (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`) REFERENCES `qrtz_triggers` (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Table structure for qrtz_fired_triggers-- ----------------------------DROP TABLE IF EXISTS `qrtz_fired_triggers`;CREATE TABLE `qrtz_fired_triggers` (`SCHED_NAME` varchar(80) NOT NULL,`ENTRY_ID` varchar(95) NOT NULL,`TRIGGER_NAME` varchar(100) NOT NULL,`TRIGGER_GROUP` varchar(100) NOT NULL,`INSTANCE_NAME` varchar(100) NOT NULL,`FIRED_TIME` bigint(13) NOT NULL,`SCHED_TIME` bigint(13) NOT NULL,`PRIORITY` int(11) NOT NULL,`STATE` varchar(16) NOT NULL,`JOB_NAME` varchar(100) DEFAULT NULL,`JOB_GROUP` varchar(100) DEFAULT NULL,`IS_NONCONCURRENT` varchar(1) DEFAULT NULL,`REQUESTS_RECOVERY` varchar(1) DEFAULT NULL,PRIMARY KEY (`SCHED_NAME`,`ENTRY_ID`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Table structure for qrtz_job_details-- ----------------------------DROP TABLE IF EXISTS `qrtz_job_details`;CREATE TABLE `qrtz_job_details` (`SCHED_NAME` varchar(80) NOT NULL,`JOB_NAME` varchar(100) NOT NULL,`JOB_GROUP` varchar(100) NOT NULL,`DESCRIPTION` varchar(100) DEFAULT NULL,`JOB_CLASS_NAME` varchar(100) 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,PRIMARY KEY (`SCHED_NAME`,`JOB_NAME`,`JOB_GROUP`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Table structure for qrtz_locks-- ----------------------------DROP TABLE IF EXISTS `qrtz_locks`;CREATE TABLE `qrtz_locks` (`SCHED_NAME` varchar(80) NOT NULL,`LOCK_NAME` varchar(40) NOT NULL,PRIMARY KEY (`SCHED_NAME`,`LOCK_NAME`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Table structure for qrtz_paused_trigger_grps-- ----------------------------DROP TABLE IF EXISTS `qrtz_paused_trigger_grps`;CREATE TABLE `qrtz_paused_trigger_grps` (`SCHED_NAME` varchar(80) NOT NULL,`TRIGGER_GROUP` varchar(100) NOT NULL,PRIMARY KEY (`SCHED_NAME`,`TRIGGER_GROUP`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Table structure for qrtz_scheduler_state-- ----------------------------DROP TABLE IF EXISTS `qrtz_scheduler_state`;CREATE TABLE `qrtz_scheduler_state` (`SCHED_NAME` varchar(80) NOT NULL,`INSTANCE_NAME` varchar(100) NOT NULL,`LAST_CHECKIN_TIME` bigint(13) NOT NULL,`CHECKIN_INTERVAL` bigint(13) NOT NULL,PRIMARY KEY (`SCHED_NAME`,`INSTANCE_NAME`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Table structure for qrtz_simple_triggers-- ----------------------------DROP TABLE IF EXISTS `qrtz_simple_triggers`;CREATE TABLE `qrtz_simple_triggers` (`SCHED_NAME` varchar(80) NOT NULL,`TRIGGER_NAME` varchar(100) NOT NULL,`TRIGGER_GROUP` varchar(100) 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`),CONSTRAINT `qrtz_simple_triggers_ibfk_1` FOREIGN KEY (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`) REFERENCES `qrtz_triggers` (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Table structure for qrtz_simprop_triggers-- ----------------------------DROP TABLE IF EXISTS `qrtz_simprop_triggers`;CREATE TABLE `qrtz_simprop_triggers` (`SCHED_NAME` varchar(80) NOT NULL,`TRIGGER_NAME` varchar(100) NOT NULL,`TRIGGER_GROUP` varchar(100) NOT NULL,`STR_PROP_1` varchar(120) DEFAULT NULL,`STR_PROP_2` varchar(120) DEFAULT NULL,`STR_PROP_3` varchar(120) DEFAULT NULL,`INT_PROP_1` int(11) DEFAULT NULL,`INT_PROP_2` int(11) DEFAULT NULL,`LONG_PROP_1` bigint(20) DEFAULT NULL,`LONG_PROP_2` bigint(20) DEFAULT NULL,`DEC_PROP_1` decimal(13,4) DEFAULT NULL,`DEC_PROP_2` decimal(13,4) DEFAULT NULL,`BOOL_PROP_1` varchar(1) DEFAULT NULL,`BOOL_PROP_2` varchar(1) DEFAULT NULL,PRIMARY KEY (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`),CONSTRAINT `qrtz_simprop_triggers_ibfk_1` FOREIGN KEY (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`) REFERENCES `qrtz_triggers` (`SCHED_NAME`, `TRIGGER_NAME`, `TRIGGER_GROUP`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;-- ------------------------------ Table structure for qrtz_triggers-- ----------------------------DROP TABLE IF EXISTS `qrtz_triggers`;CREATE TABLE `qrtz_triggers` (`SCHED_NAME` varchar(80) NOT NULL,`TRIGGER_NAME` varchar(100) NOT NULL,`TRIGGER_GROUP` varchar(100) NOT NULL,`JOB_NAME` varchar(100) NOT NULL,`JOB_GROUP` varchar(100) NOT NULL,`DESCRIPTION` varchar(100) DEFAULT NULL,`NEXT_FIRE_TIME` bigint(13) DEFAULT NULL,`PREV_FIRE_TIME` bigint(13) DEFAULT NULL,`PRIORITY` int(11) DEFAULT NULL,`TRIGGER_STATE` varchar(16) NOT NULL,`TRIGGER_TYPE` varchar(8) NOT NULL,`START_TIME` bigint(13) NOT NULL,`END_TIME` bigint(13) DEFAULT NULL,`CALENDAR_NAME` varchar(100) DEFAULT NULL,`MISFIRE_INSTR` smallint(2) DEFAULT NULL,`JOB_DATA` blob,PRIMARY KEY (`SCHED_NAME`,`TRIGGER_NAME`,`TRIGGER_GROUP`),KEY `SCHED_NAME` (`SCHED_NAME`,`JOB_NAME`,`JOB_GROUP`),CONSTRAINT `qrtz_triggers_ibfk_1` FOREIGN KEY (`SCHED_NAME`, `JOB_NAME`, `JOB_GROUP`) REFERENCES `qrtz_job_details` (`SCHED_NAME`, `JOB_NAME`, `JOB_GROUP`)) ENGINE=InnoDB DEFAULT CHARSET=utf8;复制代码
