create table t_schedule_trigger
(
id bigint primary key auto_increment comment '触发器编号',
cron varchar(200) not null comment '触发器表达式',
status char(1) not null comment '触发器状态: 禁用 启用',
job_name varchar(200) not null comment '任务名称: 存放的任务类的全路径',
job_group varchar(200) not null comment '任务所处分组',
job_description varchar(200) not null comment '任务描述',
trigger_description varchar(200) not null comment '触发器描述',
unique index (job_name, job_group) comment '通过jobName和jobGroup来确定trigger的唯一性，所以这两列为联合唯一索引'
);
create table t_schedule_trigger_data
(
id bigint primary key auto_increment comment '数据编号',
name varchar(200) not null comment '对应的数据名称',
value varchar(512) comment '对应的数据值',
trigger_id bigint not null comment '外键: 引用t_schedule_trigger(id)',
foreign key (trigger_id) references t_schedule_trigger (id)
);
5.在运出来的两张表中插入模拟数据
（二）工具类解析 1.导入pox.xml配置文件
2.导入配置文件（使用数据库存储）quartz.properties4.0.0 com.lsy quartz_020.0.1-SNAPSHOT quartz_02 Demo project for Spring Boot 1.8 UTF-8 UTF-8 2.4.1 org.springframework.boot spring-boot-starter-quartzorg.springframework.boot spring-boot-starter-freemarkerorg.springframework.boot spring-boot-starter-testtest org.projectlombok lombokcom.alibaba druid-spring-boot-starter1.2.8 org.springframework.boot spring-boot-starter-webtk.mybatis mapper-spring-boot-starter2.0.2 javax.persistence persistence-api1.0 compile mysql mysql-connector-javaorg.springframework.boot spring-boot-dependencies${spring-boot.version} pom import org.apache.maven.plugins maven-compiler-plugin3.8.1 1.8 1.8 UTF-8 org.springframework.boot spring-boot-maven-plugin2.4.1 com.lsy.code.Quartz02Application repackage repackage
# #============================================================================ # Configure Main Scheduler Properties u8C03u5EA6u5668u5C5Eu6027 #============================================================================ org.quartz.scheduler.instanceName:DefaultQuartzScheduler 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 #============================================================================ #u5B58u50A8u65B9u5F0Fu4F7Fu7528JobStoreTX,u4E5Fu5C31u662Fu6570u636Eu5E93 org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate #u4F7Fu7528u81EAu5DF1,u7684u914Du7F6Eu6587u4EF6 org.quartz.jobStore.useProperties:true #u6570u636Eu5E93u4E2Dquartzu8868u7684u8868u540Du524Du7F00 org.quartz.jobStore.tablePrefix:qrtz_ org.quartz.jobStore.dataSource:qzDS #u662Fu5426u4F7Fu7528u96C6u7FA4(u5982u679Cu9879u76EEu53EAu90E8u7F72u5230 u4E00u53F0u670Du52A1u5668,u5C31u4E0Du7528u4E86) org.quartz.jobStore.isClustered=true #============================================================================ # Configure Datasources #============================================================================ #u914Du7F6Eu6570u636Eu5E93u6E90uFF08org.quartz.dataSource.qzDS.maxConnections: c3p0u914Du7F6Eu7684u662Fu6709su7684,druidu6570u636Eu6E90u6CA1u6709suFF09 org.quartz.dataSource.qzDS.connectionProvider.class:com.lsy.code.util.DruidConnectionProvider org.quartz.dataSource.qzDS.driver:com.mysql.cj.jdbc.Driver org.quartz.dataSource.qzDS.URL:jdbc:mysql://127.0.0.1:3306/sys?useUnicode=true&serverTimezone=Asia/Shanghai&useSSL=false&characterEncoding=utf-8 org.quartz.dataSource.qzDS.user:root org.quartz.dataSource.qzDS.password:123456 org.quartz.dataSource.qzDS.maxConnection:103.导入拓展类DruidConnectionProvider 作用：帮助quartz创建Druid连接池
package com.lsy.code.util;
import com.alibaba.druid.pool.DruidDataSource;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.SneakyThrows;
import org.quartz.utils.ConnectionProvider;
import java.sql.Connection;
//帮助quartz连接数据库
@Data
@NoArgsConstructor
@AllArgsConstructor
public class DruidConnectionProvider implements ConnectionProvider {
public String driver;
public String URL;
public String user;
public String password;
public int maxConnection;
public String validationQuery;
private boolean validateOnCheckout;
private int idleConnectionValidationSeconds;
public String maxCachedStatementsPerConnection;
private String discardIdleConnectionsSeconds;
public static final int DEFAULT_DB_MAX_ConNECTIONS = 10;
public static final int DEFAULT_DB_MAX_CACHED_STATEMENTS_PER_ConNECTION = 120;
private DruidDataSource datasource;
@Override
@SneakyThrows
public Connection getConnection() {
return datasource.getConnection();
}
@Override
public void shutdown() {
datasource.close();
}
@Override
@SneakyThrows
public void initialize() {
assert this.URL != null : "DB URL cannot be null";
assert this.driver != null : "DB driver class name cannot be null!";
assert this.maxConnection > 0 : "Max connections must be greater than zero!";
datasource = new DruidDataSource();
datasource.setDriverClassName(this.driver);
datasource.setUrl(this.URL);
datasource.setUsername(this.user);
datasource.setPassword(this.password);
datasource.setMaxActive(this.maxConnection);
datasource.setMinIdle(1);
datasource.setMaxWait(0);
datasource.setMaxPoolPreparedStatementPerConnectionSize(DruidConnectionProvider.DEFAULT_DB_MAX_CACHED_STATEMENTS_PER_CONNECTION);
if (this.validationQuery != null) {
datasource.setValidationQuery(this.validationQuery);
if (!this.validateOnCheckout) {
datasource.setTestonReturn(true);
} else {
datasource.setTestonBorrow(true);
}
datasource.setValidationQueryTimeout(this.idleConnectionValidationSeconds);
}
}
}
4.导入MyJobFactory类
作用：让quartz具备与spring交互的功能
package com.lsy.code.util;
import lombok.SneakyThrows;
import lombok.extern.slf4j.Slf4j;
import org.quartz.spi.TriggerFiredBundle;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
import org.springframework.scheduling.quartz.AdaptableJobFactory;
import org.springframework.stereotype.Component;
@Component
@Slf4j
public class MyJobFactory extends AdaptableJobFactory {
private final AutowireCapableBeanFactory autowireCapableBeanFactory;
@Autowired
public MyJobFactory(AutowireCapableBeanFactory autowireCapableBeanFactory) {
this.autowireCapableBeanFactory = autowireCapableBeanFactory;
}
@Override
@SneakyThrows
protected Object createJobInstance(TriggerFiredBundle bundle) {
Object jobInstance = super.createJobInstance(bundle);
//给予这个对象操作springBean的能力
autowireCapableBeanFactory.autowireBean(jobInstance);
return super.createJobInstance(bundle);
}
}
5.导入QuartzConfiguration配置类
作用：将调度器交给spring管理，以后在别的那种需要调度器，直接注入即可
package com.lsy.code.conf;
import com.lsy.code.util.MyJobFactory;
import com.lsy.code.util.MyJobFactory;
import lombok.SneakyThrows;
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.util.Properties;
//配置类 这个类的作用是为了quartz与数据库与spring互通
@Configuration
public class QuartzConfiguration {
private final MyJobFactory myJobFactory;
@Autowired
public QuartzConfiguration(MyJobFactory myJobFactory) {
this.myJobFactory = myJobFactory;
}
@Bean
public SchedulerFactoryBean schedulerFactoryBean() {
//1.创建SchedulerFactoryBean
SchedulerFactoryBean factoryBean = new SchedulerFactoryBean();
//2.加载自定义的quartz.properties配置文件
factoryBean.setQuartzProperties(quartzProperties());
//3.设置MyJobFactory
factoryBean.setJobFactory(myJobFactory);
return factoryBean;
}
@Bean
@SneakyThrows
public Properties quartzProperties() {
PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
propertiesFactoryBean.afterPropertiesSet();
return propertiesFactoryBean.getObject();
}
@Bean
public Scheduler scheduler() {
return schedulerFactoryBean().getScheduler();
}
}
6.编写application.yml文件
注：记得更改数据库连接名
spring:
datasource:
url: jdbc:mysql://127.0.0.1:3306/sys?useUnicode=true&serverTimezone=Asia/Shanghai&useSSL=false&characterEncoding=utf-8
username: root
password: 123456
driver-class-name: com.mysql.cj.jdbc.Driver
type: com.alibaba.druid.pool.DruidDataSource
druid:
initial-size: 5 # 初始化大小
min-idle: 10 # 最小连接数
max-active: 20 # 最大连接数
max-wait: 60000 # 获取连接时的最大等待时间
min-evictable-idle-time-millis: 300000 # 一个连接在池中最小生存的时间，单位是毫秒
time-between-eviction-runs-millis: 60000 # 多久才进行一次检测需要关闭的空闲连接，单位是毫秒
filters: stat # 配置扩展插件：stat-监控统计，log4j-日志，wall-防火墙（防止SQL注入），去掉后，监控界面的sql无法统计 ,wall
validation-query: SELECT 1 # 检测连接是否有效的 SQL语句，为空时以下三个配置均无效
test-on-borrow: true # 申请连接时执行validationQuery检测连接是否有效，默认true，开启后会降低性能
test-on-return: true # 归还连接时执行validationQuery检测连接是否有效，默认false，开启后会降低性能
test-while-idle: true # 申请连接时如果空闲时间大于timeBetweenEvictionRunsMillis，执行validationQuery检测连接是否有效，默认false，建议开启，不影响性能
stat-view-servlet:
enabled: true # 是否开启 StatViewServlet
allow: 127.0.0.1 # 访问监控页面 白名单，默认127.0.0.1
deny: 192.168.56.1 # 访问监控页面 黑名单
login-username: admin # 访问监控页面 登陆账号
login-password: 123 # 访问监控页面 登陆密码
filter:
stat:
enabled: true # 是否开启 FilterStat，默认true
log-slow-sql: true # 是否开启 慢SQL 记录，默认false
slow-sql-millis: 5000 # 慢 SQL 的标准，默认 3000,单位：毫秒
merge-sql: false # 合并多个连接池的监控数据，默认false
application:
name: quartz_02
freemarker:
#指定HttpServletRequest的属性是否可以覆盖controller的model的同名项
allow-request-override: false
#req访问request
request-context-attribute: req
#后缀名freemarker默认后缀为.ftl，当然你也可以改成自己习惯的.html
suffix: .ftl
#设置响应的内容类型
content-type: text/html;charset=utf-8
#是否允许mvc使用freemarker
enabled: true
#是否开启template caching
cache: false
#设定模板的加载路径，多个以逗号分隔，默认: [“classpath:/templates/”]
template-loader-path: classpath:/templates/
#设定Template的编码
charset: UTF-8
logging:
level:
com.yk.code.mapper: debug
（三）数据库存储代码开发
1.实体类
package com.lsy.code.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;
import tk.mybatis.mapper.annotation.KeySql;
import javax.persistence.Column;
import javax.persistence.Id;
import javax.persistence.Table;
@AllArgsConstructor
@NoArgsConstructor
@Data
@Accessors(chain = true)
@Table(name = "t_schedule_trigger")
public class ScheduleTrigger {
@Id
@KeySql(useGeneratedKeys = true)
@Column(name = "id")
private Long id;
@Column(name = "cron")
private String cron;
@Column(name = "status")
private String status;
@Column(name = "job_name")
private String jobName;
@Column(name = "job_group")
private String jobGroup;
@Column(name = "job_description")
private String JobDescription;
@Column(name = "trigger_description")
private String TriggerDescription;
}
package com.lsy.code.pojo;
import lombok.AllArgsConstructor;
import lombok.Data;
import lombok.NoArgsConstructor;
import lombok.experimental.Accessors;
import tk.mybatis.mapper.annotation.KeySql;
import javax.persistence.Column;
import javax.persistence.Id;
import javax.persistence.Table;
@AllArgsConstructor
@NoArgsConstructor
@Data
@Accessors(chain = true)
@Table(name = "t_schedule_trigger_data")
public class ScheduleTriggerData {
@Id
@KeySql(useGeneratedKeys = true)
@Column(name = "id", nullable = false)
private Long id;
@Column(name = "name")
private String name;
@Column(name = "value")
private String value;
@Column(name = "trigger_id")
private Long triggerId;
}
2.mapper类
继承通用mapper
package com.lsy.code.mapper; import com.lsy.code.pojo.ScheduleTrigger; import com.lsy.code.pojo.ScheduleTriggerData; import org.springframework.stereotype.Repository; import tk.mybatis.mapper.common.Mapper; @Repository public interface ScheduleTriggerDataMapper extends Mapper{ }
package com.lsy.code.mapper; import com.lsy.code.pojo.ScheduleTrigger; import org.springframework.stereotype.Repository; import tk.mybatis.mapper.common.Mapper; @Repository public interface ScheduleTriggerMapper extends Mapper3.service接口类{ }
package com.lsy.code.service;
import com.lsy.code.pojo.ScheduleTriggerData;
import java.util.List;
public interface ScheduleTriggerDataService {
List find(Long triggerId);
}
package com.lsy.code.service;
import com.lsy.code.pojo.ScheduleTrigger;
import java.util.List;
public interface ScheduleTriggerService {
List find();
}
4.service实现类
注：记得注入service注解
package com.lsy.code.service;
import com.lsy.code.mapper.ScheduleTriggerDataMapper;
import com.lsy.code.mapper.ScheduleTriggerMapper;
import com.lsy.code.pojo.ScheduleTriggerData;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.stereotype.Service;
import tk.mybatis.mapper.entity.Example;
import java.util.List;
@Service
public class ScheduleTriggerDataServiceImpl implements ScheduleTriggerDataService {
@Autowired
private ScheduleTriggerDataMapper mapper;
@Override
public List find(Long triggerId) {
Example example=new Example(ScheduleTriggerData.class);
example.createCriteria().andEqualTo("triggerId",triggerId);
return mapper.selectByExample(example);
}
}
查询所有的方法由于没有根据外键查询的方法，所以要用到example
package com.lsy.code.service;
import com.lsy.code.mapper.ScheduleTriggerMapper;
import com.lsy.code.pojo.ScheduleTrigger;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import java.util.List;
@Service
public class ScheduleTriggerServiceImpl implements ScheduleTriggerService {
@Autowired
private ScheduleTriggerMapper mapper;
@Override
public List find() {
return mapper.selectAll();
}
}
5.job类
package com.lsy.code.job;
import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
public class MyJob implements Job {
@Override
public void execute(JobExecutionContext context) throws JobExecutionException {
JobDataMap data = context.getJobDetail().getJobDataMap();
System.out.println(data.get("name")+"在搞"+data.get("loc")+"的卫生");
}
}
6.QuartzTask类
package com.lsy.code.util;
import com.lsy.code.job.MyJob;
import com.lsy.code.pojo.ScheduleTrigger;
import com.lsy.code.pojo.ScheduleTriggerData;
import com.lsy.code.service.ScheduleTriggerDataService;
import com.lsy.code.service.ScheduleTriggerService;
import lombok.SneakyThrows;
import org.quartz.*;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Component;
import static org.quartz.JobBuilder.newJob;
@Component
public class QuartzTask {
private ScheduleTriggerDataService dataService;
private ScheduleTriggerService triggerService;
private Scheduler scheduler;
@Autowired
public QuartzTask(ScheduleTriggerDataService dataService, ScheduleTriggerService triggerService,Scheduler scheduler) {
this.dataService = dataService;
this.triggerService = triggerService;
this.scheduler=scheduler;
}
@Scheduled(cron = "0/10 * * * * ?")
@SneakyThrows
public void register() {
//去数据库看看我的那两张表有没有变化
//查询数据库中的所有的任务
for (ScheduleTrigger t : triggerService.find()) {
//判读这个任务是否已经被quartz管理了
//拿到这个任务的名字和分组
String jobName = t.getJobName();
String jobGroup = t.getJobGroup();
String jobDescription = t.getJobDescription();
String triggerDescription = t.getTriggerDescription();
String cron = t.getCron();
//生成一个key 去调度器中那对应的元素
CronTrigger trigger = (CronTrigger)scheduler.getTrigger(TriggerKey.triggerKey(jobName, jobGroup));
if(trigger==null){//在我的表里面有 但是quartz没有管理他
//禁用
if("0".equals(t.getStatus())){
continue;
}
//新建 将任务放到quartz里面
//任务 job
JobDetail jobDetail = newJob((Class) Class.forName(jobName))
.withIdentity(jobName, jobGroup)
.withDescription(jobDescription)
.build();
//读取任务所需要的数据
for (ScheduleTriggerData data: dataService.find(t.getId())) {
//将所需要的任务数据放到任务中
jobDetail.getJobDataMap().put(data.getName(),data.getValue());
}
//触发器 Trigger
trigger = TriggerBuilder.newTrigger()
.withIdentity(jobName,jobGroup)
.withDescription(triggerDescription)
.withSchedule(CronScheduleBuilder.cronSchedule(cron))
.build();
//分配给调度器
scheduler.scheduleJob(jobDetail,trigger);
continue;
}
//任务已经在quartz中有了
if("0".equals(t.getStatus())){
//在quartz中删除那个任务
scheduler.deleteJob(JobKey.jobKey(jobName,jobGroup));
continue;
}
//任务存在而且不是禁用状态
//判断表达式是否被修改了
if (!trigger.getCronexpression().equals(cron)) {
//触发器 Trigger
trigger = TriggerBuilder.newTrigger()
.withIdentity(jobName,jobGroup)
.withDescription(triggerDescription)
.withSchedule(CronScheduleBuilder.cronSchedule(cron))
.build();
//让调度器更换触发器
//rescheduleJob()重新调度工作
scheduler.rescheduleJob(TriggerKey.triggerKey(jobName, jobGroup),trigger);
}
}
}
}
7.运行结果如下
