关键词：
1.创建quartz数据库并导入quartz的SQL脚本文件
quartz源码下载地址：http://www.quartz-scheduler.org/downloads/
下载完成后解压，在/src/org/quartz/impl/jdbcjobstore可以找到对应数据库的SQL脚本
我这里使用的是MySQL数据库，SQL脚本如下：
CREATE DATABASE `quartz` /*!40100 DEFAULT CHARACTER SET utf8 */;
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)
);
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)
);
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)
);
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(200) 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)
);
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)
);
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),
FOREIGN KEY (SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
REFERENCES QRTZ_TRIGGERS(SCHED_NAME,TRIGGER_NAME,TRIGGER_GROUP)
);
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)
);
CREATE TABLE QRTZ_PAUSED_TRIGGER_GRPS
(
SCHED_NAME VARCHAR(120) NOT NULL,
TRIGGER_GROUP VARCHAR(200) NOT NULL,
PRIMARY KEY (SCHED_NAME,TRIGGER_GROUP)
);
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)
);
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)
);
CREATE TABLE QRTZ_LOCKS
(
SCHED_NAME VARCHAR(120) NOT NULL,
LOCK_NAME VARCHAR(40) NOT NULL,
PRIMARY KEY (SCHED_NAME,LOCK_NAME)
);
commit;
2.构建SpringBoot工程整合Quartz
1.引入Quartz的POM依赖
<dependency>
<groupId>org.springframework.boot</groupId>
<artifactId>spring-boot-starter-quartz</artifactId>
</dependency>
2.YML配置
配置参考：https://github.com/wangmaoxiong/quartzjdbc/blob/master/src/main/resources/application-cluster.yml
spring:
# Mysql数据库
datasource:
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://127.0.0.1:3306/quartz?autoReconnect=true&useUnicode=true&characterEncoding=utf8&zeroDateTimeBehavior=CONVERT_TO_NULL&useSSL=false&serverTimezone=CTT
username: root
password: root
# 连接池大小
max-active: 20
max-pool-prepared-statement-per-connection-size: 20
# quartz相关配置
quartz:
# 将任务等保存化到数据库
job-store-type: jdbc
# 程序结束时会等待quartz相关的内容结束
wait-for-jobs-to-complete-on-shutdown: true
# QuartzScheduler启动时更新己存在的Job,这样就不用每次修改targetObject后删除qrtz_job_details表对应记录
overwrite-existing-jobs: true
properties:
org:
quartz:
# scheduler相关
scheduler:
# scheduler的实例名
instanceName: scheduler
instanceId: AUTO
# 持久化相关
jobStore:
class: org.quartz.impl.jdbcjobstore.JobStoreTX
driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
# 表示数据库中相关表是QRTZ_开头的
tablePrefix: QRTZ_
useProperties: false
# 配置集群
# 是否加入集群
isClustered: true
# 容许的最大作业延长时间
clusterCheckinInterval: 20000
# 线程池相关
threadPool:
class: org.quartz.simpl.SimpleThreadPool
# 线程数
threadCount: 10
# 线程优先级
threadPriority: 5
threadsInheritContextClassLoaderOfInitializingThread: true
3.编写Job类
/**
* @Author ScholarTang
* @Date 2021/7/14 下午4:09
* @Desc 定时任务处理（允许并发执行）
*/
@Slf4j
@Component
public class QuartzJobExecution implements Job
@Autowired
private SendNoticeUtils sendNoticeUtils;
@SneakyThrows
@Override
public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException
//执行逻辑体，发送消息
sendNoticeUtils.sendNotice(jobExecutionContext);
4.编写一个工具类，用来创建、删除定时调度任务的工具类
/**
* @Author ScholarTang
* @Date 2021/7/15 下午3:50
* @Desc 定时任务工具类
*/
@Component
public class ScheduleUtils
@Autowired
private Scheduler scheduler;
/**
* 构建任务触发对象
* @param jobName
* @param jobGroup
* @return
*/
public TriggerKey getTriggerKey(String jobName, String jobGroup)
return TriggerKey.triggerKey(jobName, jobGroup);
/**
* 构建任务键对象
* @param jobName
* @param jobGroup
* @return
*/
public JobKey getJobKey(String jobName, String jobGroup)
return JobKey.jobKey(jobName, jobGroup);
/**
* 创建日定时调度任务
* @param schedulingTaskVo
* @throws SchedulerException
* @throws TaskException
*/
public void createScheduleJob(SchedulingTaskVo schedulingTaskVo) throws SchedulerException, TaskException
// 构建job信息
String jobName = schedulingTaskVo.getJobId() + "_" + schedulingTaskVo.getJobName();
String jobGroupName = schedulingTaskVo.getJobGroupName();
//构建job实例
JobDetail jobDetail = JobBuilder.newJob(QuartzJobExecution.class).withIdentity(getJobKey(jobName, jobGroupName)).build();
// 表达式调度构建器
CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(schedulingTaskVo.getCronExpression());
cronScheduleBuilder = handleCronScheduleMisfirePolicy(schedulingTaskVo, cronScheduleBuilder);
// 按新的cronExpression表达式构建一个新的trigger
CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(getTriggerKey(jobName, jobGroupName))
.withSchedule(cronScheduleBuilder).build();
// 放入参数，运行时的方法可以获取
jobDetail.getJobDataMap().put("TASK_PROPERTIES", schedulingTaskVo);
// 判断是否存在
if (scheduler.checkExists(getJobKey(jobName, jobGroupName)))
// 防止创建时存在数据问题 先移除，然后在执行创建操作
scheduler.deleteJob(getJobKey(jobName, jobGroupName));
//创建定时任务调度
scheduler.scheduleJob(jobDetail, trigger);
// 暂停任务
if (schedulingTaskVo.getStatus().equals(ScheduleConstants.Status.PAUSE.getValue()))
scheduler.pauseJob(getJobKey(jobName, jobGroupName));
/**
* 删除定时调度任务
* @param schedulingTaskVo
* @throws SchedulerException
*/
public void deleteScheduleJob(SchedulingTaskVo schedulingTaskVo) throws SchedulerException
scheduler.deleteJob(getJobKey(schedulingTaskVo.getJobId() + "_" + schedulingTaskVo.getJobName(), schedulingTaskVo.getJobGroupName()));
/**
* 设置定时任务策略
* @param SchedulingTaskVo
* @param cb
* @return
*/
public CronScheduleBuilder handleCronScheduleMisfirePolicy(SchedulingTaskVo SchedulingTaskVo, CronScheduleBuilder cb) throws TaskException
switch (SchedulingTaskVo.getMisfirePolicy())
case "0":
return cb;
case "1":
return cb.withMisfireHandlingInstructionIgnoreMisfires();
case "2":
return cb.withMisfireHandlingInstructionFireAndProceed();
case "3":
return cb.withMisfireHandlingInstructionDoNothing();
default:
throw new TaskException("任务失败策略 '" + SchedulingTaskVo.getMisfirePolicy()
+ "' 不能在cron计划任务中使用", TaskException.Code.CONFIG_ERROR);
5.异常类
/**
* @Author ScholarTang
* @Date 2021/7/15 上午11:40
* @Desc 计划策略异常类
*/
public class TaskException extends Exception
private static final long serialVersionUID = 1L;
private Code code;
public TaskException(String msg, Code code)
this(msg, code, null);
public TaskException(String msg, Code code, Exception nestedEx)
super(msg, nestedEx);
this.code = code;
public Code getCode()
return code;
public enum Code
TASK_EXISTS, NO_TASK_EXISTS, TASK_ALREADY_STARTED, UNKNOWN, CONFIG_ERROR, TASK_NODE_NOT_AVAILABLE, SEND_NOTICE_ERROR
6.最后
到这里定时调度服务的代码就写完了，如果是想动态的去创建/删除定时调度任务的话只需要将这个utils工具类注入到需要使用它的类中，去调用工具类中的方法创建或删除定时任务即可。
在创建任务时会将任务持久化到数据库，删除则是将数据库中存储的定时任务进行删除。
springboot整合quartz实现动态的创建或删除定时任务并将定时调度任务持久化到mysql以及quartz集群配置(代码片段)
1.创建quartz数据库并导入quartz的SQL脚本文件quartz源码下载地址：http://www.quartz-scheduler.org/downloads/下载完成后解压，在/src/org/quartz/impl/jdbcjobstore可以找到对应数据库的SQL脚本我这里使用的是MySQL数据库，SQL脚本如下：... 查看详情
springboot整合quartz实现动态的创建或删除定时任务并将定时调度任务持久化到mysql以及quartz集群配置(代码片段)
1.创建quartz数据库并导入quartz的SQL脚本文件quartz源码下载地址：http://www.quartz-scheduler.org/downloads/下载完成后解压，在/src/org/quartz/impl/jdbcjobstore可以找到对应数据库的SQL脚本我这里使用的是MySQL数据库，SQL脚本如下：... 查看详情
spring与quartz整合实现分布式动态创建，删除，改变执行时间定时任务(mysql数据库)
...，当时想到了spring的quartz，写完发现费了很大功夫，光是整合就花了一上午，其中最大的问题就是版本问题，项目中用的是spring3.2.8的版本，查阅发现，3.0以上的版本需要使用quartz2.X以上版本，我就去官网下载了2.1.7的quartz，结... 查看详情
springboot整合quartz
1、创建 一、SpringBoot整合Quartz引入SpringBoot的基础依赖 1、引入依赖 2、编写简单任务类 3、创建任务调度类 4、创建任务调度方法 5、编写触发方式 fixedDe... 查看详情
springboot应用系列6--springboot2整合quartz
...bsp;Scheduler(调度器)：负责Job的执行。有两种方式可以实现SpringBoot与Quartz的整合：一、使用Spring 查看详情
spring整合quartz实现动态定时器
一、版本说明 spring3.1以下的版本必须使用quartz1.x系列，3.1以上的版本才支持quartz2.x，不然会出错。 原因：spring对于quartz的支持实现，org.springframework.scheduling.quartz.CronTriggerBean继承了org.quartz.CronTrigger，在quartz1.x系列中org.qu... 查看详情
springboot整合quartz定时器
概述 项目需要定时器的调度管理，原来使用SpringBoot自带的定时器，但是不能后台动态的操作暂停、启动以及新增任务等操作，维护起来相对麻烦；最近研究了Quartz的框架，觉得还算不错，整理了一下代码，整合到现有系统... 查看详情
springboot整合quartz实现定时任务
依赖包1<dependency>2<groupId>org.quartz-scheduler</groupId>3<artifactId>quartz</artifactId>4</dependency>5<dependency>6<groupId>org.springframework</gro 查看详情
springboot整合quartz
参考技术A写在前面：本项目环境springboot+springdatajpaQuartz核心概念：Job表示一个工作，要执行的具体内容。此接口中只有一个方法，如下：voidexecute(JobExecutionContextcontext)JobDetail表示一个具体的可执行的调度程序，Job是这个可执行... 查看详情
spring整合quartz实现动态定时器
一:首先了解spring定时器所使用到的场景比如:定时统计报表,或者登录账户密码验证失败冻结账户后,每晚12点将账户解锁等等... 使用jar包:2.0使用方法不同<!--定时器--> <dependency><groupId>org.quartz-scheduler</groupId><... 查看详情
springboot集成quartz动态定时任务
SpringBoot集成Quartz动态定时任务项目中需要用到定时任务，考虑了下java方面定时任务无非就三种：用Java自带的timer类。稍微看了一下，可以实现大部分的指定频率的任务的调度（timer.schedule（）），也可以实现关闭和开启（timer.ca... 查看详情
在springboot与quartz整合中@transaction失效
问题1：:springBoot在与quartz整合时，使用@Transaction注解时事务失效解决方案：创建一个类使用@Compent被spring管理，使用@Transaction标识主要方法，然后使用quartz的方法中调用这个类中的方法问题2：同一个类中，不加@Transaction... 查看详情
springboot开发案例之整合quartz任务管理系统
...统，适用于中小项目。开发环境JDK1.7、Maven、Eclipse技术栈SpringBoot1.5.2、thymeleaf、quartz2.3.0、iview、vue、layer、AdminLTE、bootstrap启动说明项目使用的数据库为MySql，选择resources/sql中的tables_mysql_innodb.sql 查看详情
springboot动态管理quartz
1.pom.xml文件引入Quartz协议<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId></dependency> 2.创建定时任务类实现Schedul 查看详情
springboot定时任务quartz整合（多数据源+quartz持久化到数据库）(代码片段)
...数据源参数，调用相应的service或mapper方法。(1条消息)Springboot整合多数据源（自定义注解+aop切面实现）_明湖起风了的博客-CSDN博客quartz：通过serviceImpl实现类实现核心业务逻辑（添加、暂停、修改任务等ÿ... 查看详情
quartz+springboot实现动态管理定时任务
项目实践过程中碰到一个动态管理定时任务的需求：针对每个人员进行信息的定时更新，具体更新时间可随时调整、启动、暂定等。思路将每个人员信息的定时配置保存到数据库中，这样实现了任务的动态展示和管理。任务的每... 查看详情
springboot整合quartz遇到的错误
1、springboot整合quartz执行多个定时任务时报：org.quartz.ObjectAlreadyExistsException:UnabletostoreJob:‘group1.job1‘,becauseonealreadyexistswiththisidentification.定时任务虽然执行，但报了错误。第一次执行时没有报错误，第二次及之后执行前会报这个... 查看详情
springboot技术专题「开发实战系列」动态化quartz任务调度机制+实时推送任务数据到前端(代码片段)
前提介绍SpringBoot2.0整合quartz实现多定时任务动态配置，实现任务增删改，生成Cron表达式动态化任务调度添加依赖包<!--quartz--><dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boo 查看详情