前言

Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目，完全由Java开发，可以用来执行定时任务，类似于java.util.Timer。但是相较于Timer， Quartz增加了很多功能：
持久性作业 - 就是保持调度定时的状态;
作业管理 - 对调度作业进行有效的管理;

本篇主要以应用搭建为主，知识体系参照另一篇博文
链接: Quartz 知识点汇总
.
架构图和知识点

1、引入QuartZ依赖

SpringBoot的依赖自行获取，这里不予提供

     <!-- quartz 依赖  没有规定版本的 可以用2.3.0--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId></dependency>

2、创建具体执行任务的JOB类


import lombok.extern.slf4j.Slf4j;
import org.quartz.*;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.stereotype.Component;import java.text.SimpleDateFormat;/*** @author Suqi* @version 1.0* @date 2021/8/11 8:58* @desc  简单的Job 任务类，executeInternal()用于执行具体的定任务业务逻辑**        所有的 任务JOB类都可以仿照该类进行编写*/
@Slf4j
@Component // 交由Spring管理
@DisallowConcurrentExecution // 保证多个推送在同一时间时，不并发执行
@PersistJobDataAfterExecution
public class PrintWordsJob extends QuartzJobBean {@Overrideprotected void executeInternal(JobExecutionContext context) throws JobExecutionException {JobKey jobKey = context.getJobDetail().getKey();System.out.println("工作任务名称：" +jobKey.getName() +"；    工作任务组：" +jobKey.getGroup());System.out.println("任务类名称（带包名）：" +context.getJobDetail().getJobClass().getName());System.out.println("任务类名称：" +context.getJobDetail().getJobClass().getSimpleName());System.out.println("当前任务执行时间：" +new SimpleDateFormat("E yyyy年-MM月-dd HH:mm:ss z").format(context.getFireTime()));
//        System.out.println("下一任务执行时间：" +new SimpleDateFormat("E yyyy年-MM月-dd HH:mm:ss z").format(context.getNextFireTime()));TriggerKey triggerKey = context.getTrigger().getKey();System.out.println("触发器名称：" +triggerKey.getName() +"；    触发器组：" +triggerKey.getGroup());Trigger trigger = context.getTrigger();if (trigger instanceof CronTrigger) {CronTrigger cronTrigger = (CronTrigger) trigger;System.out.println("触发器执行的Cron表达式：" +cronTrigger.getCronExpression());}if (trigger instanceof SimpleTrigger) {SimpleTrigger simpleTrigger = (SimpleTrigger) trigger;System.out.println("触发器执行的日历表达式：" +simpleTrigger.getDescription());}JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();String jobDataMessage = jobDataMap.getString("jobDetail1");System.out.println("任务参数消息值：" +jobDataMessage);JobDataMap triggerDataMap = context.getTrigger().getJobDataMap();String triggerDataMessage = triggerDataMap.getString("trigger1");System.out.println("触发器参数消息值：" +triggerDataMessage);System.out.println("=============================================================================");}
}

import org.quartz.*;
import org.quartz.impl.matchers.GroupMatcher;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.QuartzJobBean;
import org.springframework.stereotype.Service;import javax.annotation.PostConstruct;
import java.time.LocalDateTime;
import java.time.ZoneId;
import java.util.*;/*** @author Suqi* @version 1.0* @date 2021/8/11 9:40* @desc*/
@Service
public class QuartzService {@Autowiredprivate Scheduler scheduler;// Java自身注解，被@PostConstruct修饰的方法会在服务器加载Servlet的时候运行，并且只会被服务器执行一次 PostConstruct在构造函数之后执行，init（）方法之前执行。 Constructor(构造方法) -> @Autowired(依赖注入) -> @PostConstruct(注释的方法)@PostConstructpublic void startScheduler() {try {scheduler.start();} catch (SchedulerException e) {e.printStackTrace();}}/*** 增加一个job** @param jobClass     任务实现类* @param jobName      任务名称* @param jobGroupName 任务组名* @param jobTime      时间表达式 (这是每隔多少秒为一次任务)* @param jobTimes     运行的次数 （<0:表示不限次数）* @param jobData      参数*/public void addJob(Class<? extends QuartzJobBean> jobClass, String jobName, String jobGroupName, int jobTime,int jobTimes, Map jobData) {ZoneId zoneId = ZoneId.systemDefault();try {// 任务名称和组构成任务keyJobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build();// 设置job参数if (jobData != null && jobData.size() > 0) {jobDetail.getJobDataMap().putAll(jobData);}// 使用simpleTrigger规则Trigger trigger = null;if (jobTimes < 0) {trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroupName).withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(1).withIntervalInSeconds(jobTime)).startAt(Date.from(((LocalDateTime) jobData.get("startTime")).atZone(zoneId).toInstant())).endAt(Date.from(((LocalDateTime) jobData.get("planEndTime")).atZone(zoneId).toInstant())).build();} else {trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroupName).withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(1).withIntervalInSeconds(jobTime).withRepeatCount(jobTimes)).startAt(Date.from(((LocalDateTime) jobData.get("startTime")).atZone(zoneId).toInstant())).endAt(Date.from(((LocalDateTime) jobData.get("planEndTime")).atZone(zoneId).toInstant())).build();}scheduler.scheduleJob(jobDetail, trigger);} catch (SchedulerException e) {e.printStackTrace();}}/*** 增加一个job** @param jobClass     任务实现类* @param jobName      任务名称(建议唯一)* @param jobGroupName 任务组名* @param jobTime      时间表达式 （如：0/5 * * * * ? ）* @param jobData      参数*/public void addJob(Class<? extends QuartzJobBean> jobClass, String jobName, String jobGroupName, String jobTime, Map jobData) {try {// 创建jobDetail实例，绑定Job实现类// 指明job的名称，所在组的名称，以及绑定job类// 任务名称和组构成任务keyJobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(jobName, jobGroupName).build();// 设置job参数if (jobData != null && jobData.size() > 0) {jobDetail.getJobDataMap().putAll(jobData);}// 定义调度触发规则// 使用cornTrigger规则// 触发器keyTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroupName).startAt(DateBuilder.futureDate(1, DateBuilder.IntervalUnit.SECOND)).withSchedule(CronScheduleBuilder.cronSchedule(jobTime)).startNow().build();// 把作业和触发器注册到任务调度中scheduler.scheduleJob(jobDetail, trigger);} catch (Exception e) {e.printStackTrace();}}/*** 修改 一个job的 时间表达式** @param jobName* @param jobGroupName* @param jobTime*/public void updateJob(String jobName, String jobGroupName, String jobTime) {try {TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroupName);CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(CronScheduleBuilder.cronSchedule(jobTime)).build();// 重启触发器scheduler.rescheduleJob(triggerKey, trigger);} catch (SchedulerException e) {e.printStackTrace();}}public void updateJob(String jobName, String jobGroupName, int jobTime, int jobTimes, LocalDateTime startTime, LocalDateTime endTime) {ZoneId zoneId = ZoneId.systemDefault();TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroupName);try {SimpleTrigger trigger = (SimpleTrigger) scheduler.getTrigger(triggerKey);trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(1).withIntervalInSeconds(jobTime).withRepeatCount(jobTimes)).startAt(Date.from(startTime.atZone(zoneId).toInstant())).endAt(Date.from(endTime.atZone(zoneId).toInstant())).build();scheduler.rescheduleJob(triggerKey, trigger);} catch (SchedulerException e) {e.printStackTrace();}}/*** 删除任务一个job** @param jobName      任务名称* @param jobGroupName 任务组名*/public void deleteJob(String jobName, String jobGroupName) {try {scheduler.deleteJob(new JobKey(jobName, jobGroupName));} catch (Exception e) {e.printStackTrace();}}/*** 暂停一个job** @param jobName* @param jobGroupName*/public void pauseJob(String jobName, String jobGroupName) {try {JobKey jobKey = JobKey.jobKey(jobName, jobGroupName);scheduler.pauseJob(jobKey);} catch (SchedulerException e) {e.printStackTrace();}}/*** 恢复一个job** @param jobName* @param jobGroupName*/public void resumeJob(String jobName, String jobGroupName) {try {JobKey jobKey = JobKey.jobKey(jobName, jobGroupName);scheduler.resumeJob(jobKey);} catch (SchedulerException e) {e.printStackTrace();}}/*** 立即执行一个job** @param jobName* @param jobGroupName*/public void runAJobNow(String jobName, String jobGroupName) {try {JobKey jobKey = JobKey.jobKey(jobName, jobGroupName);scheduler.triggerJob(jobKey);} catch (SchedulerException e) {e.printStackTrace();}}/*** 判断是否已存在一个job** @param jobName* @param jobGroupName*/public boolean checkExistsJob(String jobName, String jobGroupName) {boolean check = false;try {JobKey jobKey = JobKey.jobKey(jobName, jobGroupName);check = scheduler.checkExists(jobKey);} catch (SchedulerException e) {e.printStackTrace();}return check;}/*** 获取所有计划中的任务列表** @return*/public List<Map<String, Object>> queryAllJob() {List<Map<String, Object>> jobList = null;try {GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup();Set<JobKey> jobKeys = scheduler.getJobKeys(matcher);jobList = new ArrayList<>();for (JobKey jobKey : jobKeys) {List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);for (Trigger trigger : triggers) {Map<String, Object> map = new HashMap<>();map.put("jobName", jobKey.getName());map.put("jobGroupName", jobKey.getGroup());map.put("description", "触发器:" + trigger.getKey());Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());map.put("jobStatus", triggerState.name());if (trigger instanceof CronTrigger) {CronTrigger cronTrigger = (CronTrigger) trigger;String cronExpression = cronTrigger.getCronExpression();map.put("jobTime", cronExpression);}jobList.add(map);}}} catch (SchedulerException e) {e.printStackTrace();}return jobList;}/*** 获取所有正在运行的job(占用着线程）** @return*/public List<Map<String, Object>> queryRunJob() {List<Map<String, Object>> jobList = null;try {List<JobExecutionContext> executingJobs = scheduler.getCurrentlyExecutingJobs();jobList = new ArrayList<Map<String, Object>>(executingJobs.size());for (JobExecutionContext executingJob : executingJobs) {Map<String, Object> map = new HashMap<String, Object>();JobDetail jobDetail = executingJob.getJobDetail();JobKey jobKey = jobDetail.getKey();Trigger trigger = executingJob.getTrigger();map.put("jobName", jobKey.getName());map.put("jobGroupName", jobKey.getGroup());map.put("description", "触发器:" + trigger.getKey());Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());map.put("jobStatus", triggerState.name());if (trigger instanceof CronTrigger) {CronTrigger cronTrigger = (CronTrigger) trigger;String cronExpression = cronTrigger.getCronExpression();map.put("jobTime", cronExpression);}jobList.add(map);}} catch (SchedulerException e) {e.printStackTrace();}return jobList;}
}

4、Controller层调度接口

注入我们封装好的quartzService，直接根据自身业务需求，传入具体的 Job.class（要执行的具体任务类）、任务名称、任务组名、以及任务定时的Cron表达式即可。

import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.web.bind.annotation.GetMapping;
import org.springframework.web.bind.annotation.RequestMapping;
import org.springframework.web.bind.annotation.RequestParam;
import org.springframework.web.bind.annotation.RestController;import java.util.Date;/*** @author Suqi* @version 1.0* @date 2022/9/19 10:25* @desc*/@Api(tags = "Quartz-测试类")
@RestController
@RequestMapping("/Quartz")
public class MySchedulerController {@AutowiredQuartzService quartzService;@GetMapping("addJobCorn")@ApiOperation(value = "简单添加一个定时通过corn")public void addJobCorn(@RequestParam(value = "jobName",required = true) String jobName,@RequestParam("jobGroupName") String jobGroupName,@RequestParam(value = "cron",defaultValue = "0/2 * * * * ? *") String cron){quartzService.addJob(PrintWordsJob.class,jobName,jobGroupName,cron,null);}@GetMapping("UpdateJobCorn")@ApiOperation(value = "修改一个定时通过corn")public void UpdateJobCorn(@RequestParam(value = "jobName",required = true) String jobName,@RequestParam("jobGroupName") String jobGroupName,@RequestParam("cron") String cron){quartzService.updateJob(jobName,jobGroupName,cron);}@GetMapping("pauseJob")@ApiOperation(value = "暂停一个定时通过corn")public void pauseJob(@RequestParam(value = "jobName",required = true) String jobName,@RequestParam("jobGroupName") String jobGroupName){quartzService.pauseJob(jobName,jobGroupName);}@GetMapping("checkExistsJob")@ApiOperation(value = "判断是否存在一个定时通过corn")public boolean checkExistsJob(@RequestParam(value = "jobName",required = true) String jobName,@RequestParam("jobGroupName") String jobGroupName){return quartzService.checkExistsJob(jobName,jobGroupName);}@GetMapping("resumeJob")@ApiOperation(value = "恢复一个定时通过corn")public void resumeJob(@RequestParam(value = "jobName",required = true) String jobName,@RequestParam("jobGroupName") String jobGroupName){quartzService.resumeJob(jobName,jobGroupName);}@GetMapping("deleteJob")@ApiOperation(value = "删除一个定时通过corn")public void deleteJob(@RequestParam(value = "jobName",required = true) String jobName,@RequestParam("jobGroupName") String jobGroupName){quartzService.deleteJob(jobName,jobGroupName);}@GetMapping("queryAllJob")@ApiOperation(value = "获取所有计划中的任务列表")public Object queryAllJob(){return quartzService.queryAllJob();}@GetMapping("queryRunJob")@ApiOperation(value = "获取所有正在运行的job")public Object queryRunJob(){return quartzService.queryRunJob();}public static void main(String[] args) throws SchedulerException {// 1、创建调度器SchedulerSchedulerFactory schedulerFactory = new StdSchedulerFactory();Scheduler scheduler = schedulerFactory.getScheduler();// 2、创建JobDetail实例，并与PrintWordsJob类绑定(Job执行内容)JobDetail jobDetail = JobBuilder.newJob(PrintWordsJob.class).usingJobData("jobDetail1", "这个Job用来测试的").withIdentity("job1", "group1").build();// 3、构建Trigger实例,每隔1s执行一次Date startDate = new Date();startDate.setTime(startDate.getTime() + 5000);Date endDate = new Date();endDate.setTime(startDate.getTime() + 10000);Trigger  cronTrigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "triggerGroup1").usingJobData("trigger1", "这是jobDetail1的trigger").startNow()//立即生效
//                .startAt(startDate)
//                .endAt(endDate).withSchedule(CronScheduleBuilder.cronSchedule("* * * * * ? *")).build();//4、执行scheduler.scheduleJob(jobDetail, cronTrigger);System.out.println("--------scheduler start ! ------------");scheduler.start();System.out.println("--------scheduler shutdown ! ------------");}}

常用的Cron语法 https://cron.qqe2.com/
0 0 12 * * ? #每天中午12点触发
0 15 10 ? * * #每天上午10:15触发
0 15 10 * ? * #每天上午10:15触发
0 15 10 * * ? #每天上午10:15触发
0 15 10 * * ? 2005 #2005年的每天上午10:15触发
0 * 14 * * ? #在每天下午2点到下午2:59期间的每1分钟触发
0 0/5 14 * * ? #在每天下午2点到下午2:55期间的每5分钟触发
0 0/5 14,18 * * ? #在每天下午2点到2:55期间和下午6点到6:55期间的每5分钟触发
0 0-5 14 * * ? #在每天下午2点到下午2:05期间的每1分钟触发
0 10,44 14 ? 3 WED #每年三月的星期三的下午2:10和2:44触发
0 15 10 ? * MON-FRI #周一至周五的上午10:15 触发
0 15 10 15 * ? #每月15日上午10:15 触发
0 15 10 L * ? #每月最后一日的上午10:15 触发
0 15 10 ? * 6L #每月的最后一个星期五上午10:15 触发
0 15 10 ? * 6L 2002-2005 #2002年至2005年的每月的最后一个星期五上午10:15触发
0 15 10 ? * 6#3 #每月的第三个星期五上午10:15触发

5、小结

在SpringBoot框架中，填好依赖，复制以上代码就可以快速搭建一个Quartz 服务，实际开发中可以根据个人的业务需求修改或创建标题二的JOB类，记得继承 extends QuartzJobBean，重写executeInternal( )方法即可。executeInternal( )内就是需要执行的具体业务逻辑。

补充====

缺失点：本demo 只是一个简易的服务大家，对于企业级别Quartz 的微服务搭建，还需要用到 Quartz 自带的数据库，配置好具体的线程数等信息，本文不进行深入。数据用于保存我们的任务和触发器等信息，MySQL的数据库表结构如下。

#
# In your Quartz properties file, you'll need to set
# org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
#
#
# By: Ron Cordell - roncordell
#  I didn't see this anywhere, so I thought I'd post it here. This is the script from Quartz to create the tables in a MySQL database, modified to use INNODB instead of MYISAM.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(190) NOT NULL,
JOB_GROUP VARCHAR(190) 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(190) NOT NULL,
TRIGGER_GROUP VARCHAR(190) NOT NULL,
JOB_NAME VARCHAR(190) NOT NULL,
JOB_GROUP VARCHAR(190) 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(190) 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(190) NOT NULL,
TRIGGER_GROUP VARCHAR(190) 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(190) NOT NULL,
TRIGGER_GROUP VARCHAR(190) 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(190) NOT NULL,TRIGGER_GROUP VARCHAR(190) 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(190) NOT NULL,
TRIGGER_GROUP VARCHAR(190) 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(190) 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(190) 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(190) NOT NULL,
TRIGGER_GROUP VARCHAR(190) NOT NULL,
INSTANCE_NAME VARCHAR(190) 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(190) NULL,
JOB_GROUP VARCHAR(190) 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(190) 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;

连接好数据库之后，还需要配置properties文件，Quartz框架会自动帮我们做好数据备份，记得配置在Spring管理层级下：

spring:datasource:driver-class-name: com.mysql.cj.jdbc.Driverurl: jdbc:mysql://xxxx:3306/qrcode?useUnicode=true&characterEncoding=UTF-8&useJDBCCompliantTimezoneShift=true&useLegacyDatetimeCode=false&serverTimezone=Asia/Shanghaiusername: rootpassword: xxxxxxxredis:host: xxxxxxxxpassword: xxxxxxport: 6379maxIdle: 16  #最大空闲数，数据库连接的最大空闲时间。超过空闲时间，数据库连接将被标记为不可用，然后被释放。设为0表示无限制。maxActive: 20 #连接池的最大数据库连接数。设为0表示无限制maxWait: 1000 #最大建立连接等待时间。如果超过此时间将接到异常。设为-1表示无限制。quartz:job-store-type: jdbc #数据库方式jdbc:initialize-schema: never #不初始化表结构properties:org:quartz:scheduler:instanceId: AUTO #默认主机名和时间戳生成实例ID,可以是任何字符串，但对于所有调度程序来说，必须是唯一的 对应qrtz_scheduler_state INSTANCE_NAME字段#instanceName: clusteredScheduler #quartzSchedulerjobStore:class: org.quartz.impl.jdbcjobstore.JobStoreTX #持久化配置driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate #我们仅为数据库制作了特定于数据库的代理useProperties: false #以指示JDBCJobStore将JobDataMaps中的所有值都作为字符串，因此可以作为名称 - 值对存储而不是在BLOB列中以其序列化形式存储更多复杂的对象。从长远来看，这是更安全的，因为您避免了将非String类序列化为BLOB的类版本问题。tablePrefix: QRTZ_  #数据库表前缀misfireThreshold: 60000 #在被认为“失火”之前，调度程序将“容忍”一个Triggers将其下一个启动时间通过的毫秒数。默认值（如果您在配置中未输入此属性）为60000（60秒）。clusterCheckinInterval: 5000 #设置此实例“检入”*与群集的其他实例的频率（以毫秒为单位）。影响检测失败实例的速度。isClustered: true #打开群集功能threadPool: #连接池class: org.quartz.simpl.SimpleThreadPoolthreadCount: 10threadPriority: 5threadsInheritContextClassLoaderOfInitializingThread: true

SpringBoot 快速整合 QuartZ相关推荐

使用spring-boot快速生成quartz所需的表
使用spring-boot快速生成quartz表的步骤: 之前创建quartz表,都是别人建好的,或者在网上找一些sql文件,执行创建,今天发现通过quartz可以快速生成 1.创建spring-bo ...
SpringBoot——快速整合EasyExcel实现Excel的上传下载
文章目录: 1.EasyExcel 2.Excel的上传(读Excel) 3.Excel的下载(写Excel) 4.结语 1.EasyExcel Hello,大家好啊,好久不见了,自工作之后真的很难腾 ...
SpringBoot中整合Quartz
场景项目搭建专栏: https://blog.csdn.net/BADAO_LIUMANG_QIZHI/column/info/35688 简介 Quartz是OpenSymphony开源组织在Jo ...
java xml快捷注释_详解SpringBoot 快速整合Mybatis（去XML化+注解进阶）
序言:使用MyBatis3提供的注解可以逐步取代XML,例如使用@Select注解直接编写SQL完成数据查询,使用@SelectProvider高级注解还可以编写动态SQL,以应对复杂的业务需求. 一 ...
Springboot快速整合通用Mapper
前言后端业务开发,每个表都要用到单表的增删改查等通用方法,而配置了通用Mapper可以极大的方便使用Mybatis单表的增删改查操作. 通用mapper配置 1.添加maven: <depen ...
Spring Boot定时任务-SpringBoot整合Quartz
如何通过SpringBoot整合Quartz框架,我们首先去创建一个项目,接下来我们需要在pom文件里添加坐标,我们在使用SpringBoot整合Quartz的时候,需要添加哪些坐标呢,我们来看一下, ...
springBoot项目集成quartz开发定时任务案例及注意事项
文章目录 quartz下载.安装实战案例常见问题及解决方案 quartz下载.安装 Quartz是完全由java开发的一个开源的任务日程管理系统,任务进度管理器就是一个在预先确定的时间到达时,负责 ...
SpringBoot项目整合Retrofit最佳实践，这才是最优雅的HTTP客户端工具！
作者:六点半起床 juejin.im/post/6854573211426750472 大家都知道okhttp是一款由square公司开源的java版本http客户端工具.实际上,square公司还开 ...
SpringBoot 2 整合 Spring Session 最简操作
SpringBoot 2 整合 SpringSession 前言 Spring Session 介绍 SpringBoot 快速整合 Spring Session Spring Session 测试 ...
springboot 自动生成quartz表
spring-boot 中自动生成 quartz 所需的表_冬无雪的博客-CSDN博客_quartz自动建表数据库使用spring-boot快速生成quartz所需的表_wltian的博客-CSDN ...

SpringBoot 快速整合 QuartZ

前言