SpringBoot結(jié)合Quartz實(shí)現(xiàn)數(shù)據(jù)庫(kù)存儲(chǔ)
更新時(shí)間：2022年01月17日 15:43:04 作者：李白不白w
本文主要介紹了SpringBoot+Quartz+數(shù)據(jù)庫(kù)存儲(chǔ)，文中通過(guò)示例代碼介紹的非常詳細(xì)，具有一定的參考價(jià)值，感興趣的小伙伴們可以參考一下
一、先創(chuàng)建一個(gè)SpringBoot項(xiàng)目
還有一個(gè)截屏忘了截屏，就是選擇保存路徑選擇一下就點(diǎn)Finish就可以了。
更改application.properties為application.yml
application.yml文件如下
server:
port: 8080
#數(shù)據(jù)庫(kù)連接池druid配置
spring:
datasource:
#1.JDBC
type: com.alibaba.druid.pool.DruidDataSource
driver-class-name: com.mysql.cj.jdbc.Driver
url: jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
username: root
password: 123
druid:
#2.連接池配置
#初始化連接池的連接數(shù)量 大小，最小，最大
initial-size: 5
min-idle: 5
max-active: 20
#配置獲取連接等待超時(shí)的時(shí)間
max-wait: 60000
#配置間隔多久才進(jìn)行一次檢測(cè)，檢測(cè)需要關(guān)閉的空閑連接，單位是毫秒
time-between-eviction-runs-millis: 60000
# 配置一個(gè)連接在池中最小生存的時(shí)間，單位是毫秒
min-evictable-idle-time-millis: 30000
validation-query: SELECT 1 FROM DUAL
test-while-idle: true
test-on-borrow: true
test-on-return: false
# 是否緩存preparedStatement，也就是PSCache 官方建議MySQL下建議關(guān)閉 個(gè)人建議如果想用SQL防火墻 建議打開(kāi)
pool-prepared-statements: true
max-pool-prepared-statement-per-connection-size: 20
# 配置監(jiān)控統(tǒng)計(jì)攔截的filters，去掉后監(jiān)控界面sql無(wú)法統(tǒng)計(jì)，'wall'用于防火墻
filter:
stat:
merge-sql: true
slow-sql-millis: 5000
#3.基礎(chǔ)監(jiān)控配置
web-stat-filter:
enabled: true
url-pattern: /*
#設(shè)置不統(tǒng)計(jì)哪些URL
exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
session-stat-enable: true
session-stat-max-count: 100
stat-view-servlet:
enabled: true
url-pattern: /druid/*
reset-enable: true
#設(shè)置監(jiān)控頁(yè)面的登錄名和密碼
login-username: admin
login-password: admin
allow: 127.0.0.1
mybatis:
mapper-locations: classpath*:mapper/*.xml
type-aliases-package: com.zking.quartz02.model
二、導(dǎo)入依賴
1.導(dǎo)入Quartz依賴
<dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz-jobs</artifactId> <version>2.2.1</version> </dependency> <dependency> <groupId>org.springframework.boot</groupId> <artifactId>spring-boot-starter-quartz</artifactId> </dependency>
2.用于我用的是Druid數(shù)據(jù)庫(kù)連接池，所以我需要更換成Druid連接池，先引入Druid依賴。
<dependency> <groupId>com.alibaba</groupId> <artifactId>druid-spring-boot-starter</artifactId> <version>1.1.10</version> </dependency>
三、 導(dǎo)入DruidConnectionProvider.java(Druid連接池的Quartz擴(kuò)展類(lèi))
package com.zking.quartz02.utils;
import com.alibaba.druid.pool.DruidDataSource;
import org.quartz.SchedulerException;
import org.quartz.utils.ConnectionProvider;
import java.sql.Connection;
import java.sql.SQLException;
/*
#============================================================================
# JDBC
#============================================================================
org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties:false
org.quartz.jobStore.dataSource:qzDS
#org.quartz.dataSource.qzDS.connectionProvider.class:org.quartz.utils.PoolingConnectionProvider
org.quartz.dataSource.qzDS.connectionProvider.class:com.zking.q03.quartz.DruidConnectionProvider
org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver
org.quartz.dataSource.qzDS.URL:jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8
org.quartz.dataSource.qzDS.user:root
org.quartz.dataSource.qzDS.password:root
org.quartz.dataSource.qzDS.maxConnections:30
org.quartz.dataSource.qzDS.validationQuery: select 0
*/
/**
* [Druid連接池的Quartz擴(kuò)展類(lèi)]
*/
public class DruidConnectionProvider implements ConnectionProvider {
/*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*
* 常量配置，與quartz.properties文件的key保持一致(去掉前綴)，同時(shí)提供set方法，Quartz框架自動(dòng)注入值。
*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/
//JDBC驅(qū)動(dòng)
public String driver;
//JDBC連接串
public String URL;
//數(shù)據(jù)庫(kù)用戶名
public String user;
//數(shù)據(jù)庫(kù)用戶密碼
public String password;
//數(shù)據(jù)庫(kù)最大連接數(shù)
public int maxConnection;
//數(shù)據(jù)庫(kù)SQL查詢每次連接返回執(zhí)行到連接池，以確保它仍然是有效的。
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;
//Druid連接池
private DruidDataSource datasource;
/*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*
* 接口實(shí)現(xiàn)
*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/
public Connection getConnection() throws SQLException {
return datasource.getConnection();
}
public void shutdown() throws SQLException {
datasource.close();
}
public void initialize() throws SQLException{
if (this.URL == null) {
throw new SQLException("DBPool could not be created: DB URL cannot be null");
}
if (this.driver == null) {
throw new SQLException("DBPool driver could not be created: DB driver class name cannot be null!");
}
if (this.maxConnection < 0) {
throw new SQLException("DBPool maxConnectins could not be created: Max connections must be greater than zero!");
}
datasource = new DruidDataSource();
try{
datasource.setDriverClassName(this.driver);
} catch (Exception e) {
try {
throw new SchedulerException("Problem setting driver class name on datasource: " + e.getMessage(), e);
} catch (SchedulerException e1) {
}
}
datasource.setUrl(this.URL);
datasource.setUsername(this.user);
datasource.setPassword(this.password);
datasource.setMaxActive(this.maxConnection);
datasource.setMinIdle(1);
datasource.setMaxWait(0);
datasource.setMaxPoolPreparedStatementPerConnectionSize(this.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);
}
}
/*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*
* 提供get set方法
*
* ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
*/
public String getDriver() {
return driver;
}
public void setDriver(String driver) {
this.driver = driver;
}
public String getURL() {
return URL;
}
public void setURL(String URL) {
this.URL = URL;
}
public String getUser() {
return user;
}
public void setUser(String user) {
this.user = user;
}
public String getPassword() {
return password;
}
public void setPassword(String password) {
this.password = password;
}
public int getMaxConnection() {
return maxConnection;
}
public void setMaxConnection(int maxConnection) {
this.maxConnection = maxConnection;
}
public String getValidationQuery() {
return validationQuery;
}
public void setValidationQuery(String validationQuery) {
this.validationQuery = validationQuery;
}
public boolean isValidateOnCheckout() {
return validateOnCheckout;
}
public void setValidateOnCheckout(boolean validateOnCheckout) {
this.validateOnCheckout = validateOnCheckout;
}
public int getIdleConnectionValidationSeconds() {
return idleConnectionValidationSeconds;
}
public void setIdleConnectionValidationSeconds(int idleConnectionValidationSeconds) {
this.idleConnectionValidationSeconds = idleConnectionValidationSeconds;
}
public DruidDataSource getDatasource() {
return datasource;
}
public void setDatasource(DruidDataSource datasource) {
this.datasource = datasource;
}
}四、 修改自定義quartz.properties配置(在項(xiàng)目中添加quartz.properties文件(這樣就不會(huì)加載自帶的properties文件) )
# #============================================================================ # Configure Main Scheduler Properties \u8C03\u5EA6\u5668\u5C5E\u6027 #============================================================================ 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 #============================================================================ #\u5B58\u50A8\u65B9\u5F0F\u4F7F\u7528JobStoreTX\uFF0C\u4E5F\u5C31\u662F\u6570\u636E\u5E93 org.quartz.jobStore.class: org.quartz.impl.jdbcjobstore.JobStoreTX org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate #\u4F7F\u7528\u81EA\u5DF1\u7684\u914D\u7F6E\u6587\u4EF6 org.quartz.jobStore.useProperties:true #\u6570\u636E\u5E93\u4E2Dquartz\u8868\u7684\u8868\u540D\u524D\u7F00 org.quartz.jobStore.tablePrefix:qrtz_ org.quartz.jobStore.dataSource:qzDS #\u662F\u5426\u4F7F\u7528\u96C6\u7FA4\uFF08\u5982\u679C\u9879\u76EE\u53EA\u90E8\u7F72\u5230 \u4E00\u53F0\u670D\u52A1\u5668\uFF0C\u5C31\u4E0D\u7528\u4E86\uFF09 org.quartz.jobStore.isClustered = true #============================================================================ # Configure Datasources #============================================================================ #\u914D\u7F6E\u6570\u636E\u5E93\u6E90 org.quartz.dataSource.qzDS.connectionProvider.class: com.zking.quartz02.utils.DruidConnectionProvider org.quartz.dataSource.qzDS.driver: com.mysql.cj.jdbc.Driver #修改為自己的數(shù)據(jù)庫(kù)名稱、用戶名和密碼 org.quartz.dataSource.qzDS.URL: jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false org.quartz.dataSource.qzDS.user: root org.quartz.dataSource.qzDS.password: 123 org.quartz.dataSource.qzDS.maxConnection: 10
在數(shù)據(jù)庫(kù)中創(chuàng)建quartz相關(guān)的表
進(jìn)入quartz的官網(wǎng)http://www.quartz-scheduler.org/，點(diǎn)擊Downloads，
下載后在目錄\docs\dbTables下有常用數(shù)據(jù)庫(kù)創(chuàng)建quartz表的腳本，例如：“tables_mysql.sql”
五、自定義MyJobFactory，解決spring不能在quartz中注入bean的問(wèn)題
package com.zking.quartz02.quartz;
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;
//解決spring不能在quartz中注入bean的問(wèn)題
@Component
public class MyJobFactory extends AdaptableJobFactory {
@Autowired
private AutowireCapableBeanFactory autowireCapableBeanFactory;
@Override
protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
Object jobInstance = super.createJobInstance(bundle);
autowireCapableBeanFactory.autowireBean(jobInstance);
return jobInstance;
}
}六、創(chuàng)建調(diào)度器schedule
package com.zking.quartz02.quartz;
//quartz配置類(lèi)將調(diào)度器交給spring管理
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
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.annotation.Scheduled;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import java.io.IOException;
import java.util.Properties;
@Configuration
public class QuartzConfiguration {
@Autowired
private MyJobFactory myJobFactory;
@Bean
public Scheduler scheduler(){
return this.getSchedulerFactoryBean().getScheduler();
}
//讀取自定義配置文件，獲取調(diào)度器工廠
@Bean
public SchedulerFactoryBean getSchedulerFactoryBean(){
//1.創(chuàng)建SchedulerFactoryBean sc=new SchedulerFactoryBean
SchedulerFactoryBean sc=new SchedulerFactoryBean();
//2.加載自定義的quartz.properties
sc.setQuartzProperties(this.getProperties());
//3.設(shè)置自定義的MyJobFactory
sc.setJobFactory(myJobFactory);
return sc;
}
//讀取配置文件
@Bean
public Properties getProperties(){
try {
PropertiesFactoryBean propertiesFactoryBean =
new PropertiesFactoryBean();
//設(shè)置自定義配置文件位置
propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
//讀取配置文件
propertiesFactoryBean.afterPropertiesSet();
return propertiesFactoryBean.getObject();
} catch (IOException e) {
e.printStackTrace();
throw new RuntimeException(e);
}
}
}七、 創(chuàng)建自定義任務(wù)
首先我們需要自己創(chuàng)建一張表t_schedule_trigger，用來(lái)存放trigger的信息，然后從數(shù)據(jù)庫(kù)讀取這些信息來(lái)隨時(shí)更新定時(shí)任務(wù)
注意：job_name存放的任務(wù)類(lèi)的全路徑，在quartz中通過(guò)jobName和jobGroup來(lái)確定trigger的唯一性，所以這兩列為聯(lián)合唯一索引
t_schedule_trigger和t_schedule_trigger_param表生成的sql代碼如下(去執(zhí)行一下sql語(yǔ)句即可)
-- 注意：job_name存放的任務(wù)類(lèi)的全路徑，在quartz中通過(guò)jobName和jobGroup來(lái)確定trigger的唯一性，所以這兩列為聯(lián)合唯一索引 create table t_schedule_trigger ( id int primary key auto_increment, -- ID cron varchar(200) not null, -- 時(shí)間表達(dá)式 status char(1) not null, -- 使用狀態(tài) 0：禁用 1：?jiǎn)⒂? job_name varchar(200) not null, -- 任務(wù)名稱 job_group varchar(200) not null, -- 任務(wù)分組 unique index(job_name,job_group) ); -- 額外添加到任務(wù)中的參數(shù) create table t_schedule_trigger_param ( param_id int primary key auto_increment, -- ID name varchar(200) not null, -- 參數(shù)名 value varchar(512), -- 參數(shù)值 schedule_trigger_id int not null, -- 外鍵：引用t_schedule_trigger(id) foreign key(schedule_trigger_id) references t_schedule_trigger(id) );
注1：t_schedule_trigger的子表t_schedule_trigger_param還可以用來(lái)傳遞額外添加到任務(wù)中的參數(shù)
注2：實(shí)現(xiàn)org.quartz.Job或org.springframework.scheduling.quartz.QuartzJobBean創(chuàng)建任務(wù)，可通過(guò)JobExecutionContext傳參
八、 更新quartz中的任務(wù)
首先我們將t_schedule_trigger和t_schedule_trigger_param通過(guò)generatorConfig.xml自動(dòng)生成實(shí)體類(lèi)，XXmapper.java，XXmapper.xml.
<?xml version="1.0" encoding="UTF-8" ?>
<!DOCTYPE generatorConfiguration PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
"http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd" >
<generatorConfiguration>
<!-- 引入配置文件 -->
<!-- <properties resource="jdbc.properties"/>-->
<!--指定數(shù)據(jù)庫(kù)jdbc驅(qū)動(dòng)jar包的位置-->
<classPathEntry location="D:\\installpath\\apache-maven-3.5.4\\jar\\mysql\\mysql-connector-java\\5.1.44\\mysql-connector-java-5.1.44.jar"/>
<!-- 一個(gè)數(shù)據(jù)庫(kù)一個(gè)context -->
<context id="infoGuardian">
<!-- 注釋 -->
<commentGenerator>
<property name="suppressAllComments" value="true"/><!-- 是否取消注釋 -->
<property name="suppressDate" value="true"/> <!-- 是否生成注釋代時(shí)間戳 -->
</commentGenerator>
<!-- jdbc連接 -->
<jdbcConnection driverClass="com.mysql.jdbc.Driver"
connectionURL="jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=UTF-8" userId="root" password="123"/>
<!-- 類(lèi)型轉(zhuǎn)換 -->
<javaTypeResolver>
<!-- 是否使用bigDecimal， false可自動(dòng)轉(zhuǎn)化以下類(lèi)型（Long, Integer, Short, etc.） -->
<property name="forceBigDecimals" value="false"/>
</javaTypeResolver>
<!-- 01 指定javaBean生成的位置 -->
<!-- targetPackage：指定生成的model生成所在的包名 -->
<!-- targetProject：指定在該項(xiàng)目下所在的路徑 -->
<javaModelGenerator targetPackage="com.zking.quartz02.model"
targetProject="src/main/java">
<!-- 是否允許子包，即targetPackage.schemaName.tableName -->
<property name="enableSubPackages" value="false"/>
<!-- 是否對(duì)model添加構(gòu)造函數(shù) -->
<property name="constructorBased" value="true"/>
<!-- 是否針對(duì)string類(lèi)型的字段在set的時(shí)候進(jìn)行trim調(diào)用 -->
<property name="trimStrings" value="false"/>
<!-- 建立的Model對(duì)象是否 不可改變 即生成的Model對(duì)象不會(huì)有 setter方法，只有構(gòu)造方法 -->
<property name="immutable" value="false"/>
</javaModelGenerator>
<!-- 02 指定sql映射文件生成的位置 -->
<sqlMapGenerator targetPackage="mapper"
targetProject="src/main/resources">
<!-- 是否允許子包，即targetPackage.schemaName.tableName -->
<property name="enableSubPackages" value="false"/>
</sqlMapGenerator>
<!-- 03 生成XxxMapper接口 -->
<!-- type="ANNOTATEDMAPPER",生成Java Model 和基于注解的Mapper對(duì)象 -->
<!-- type="MIXEDMAPPER",生成基于注解的Java Model 和相應(yīng)的Mapper對(duì)象 -->
<!-- type="XMLMAPPER",生成SQLMap XML文件和獨(dú)立的Mapper接口 -->
<javaClientGenerator targetPackage="com.zking.quartz02.mapper"
targetProject="src/main/java" type="XMLMAPPER">
<!-- 是否在當(dāng)前路徑下新加一層schema,false路徑com.oop.eksp.user.model， true:com.oop.eksp.user.model.[schemaName] -->
<property name="enableSubPackages" value="false"/>
</javaClientGenerator>
<!-- 配置表信息 -->
<!-- schema即為數(shù)據(jù)庫(kù)名 -->
<!-- tableName為對(duì)應(yīng)的數(shù)據(jù)庫(kù)表 -->
<!-- domainObjectName是要生成的實(shí)體類(lèi) -->
<!-- enable*ByExample是否生成 example類(lèi) -->
<!--<table schema="" tableName="t_book" domainObjectName="Book"-->
<!--enableCountByExample="false" enableDeleteByExample="false"-->
<!--enableSelectByExample="false" enableUpdateByExample="false">-->
<!--<!– 忽略列，不生成bean 字段 –>-->
<!--<!– <ignoreColumn column="FRED" /> –>-->
<!--<!– 指定列的java數(shù)據(jù)類(lèi)型 –>-->
<!--<!– <columnOverride column="LONG_VARCHAR_FIELD" jdbcType="VARCHAR" /> –>-->
<!--</table>-->
<table schema="" tableName="t_schedule_trigger_param" domainObjectName="ScheduleTriggerParam"
enableCountByExample="false" enableDeleteByExample="false"
enableSelectByExample="false" enableUpdateByExample="false">
<!-- 忽略列，不生成bean 字段 -->
<!-- <ignoreColumn column="FRED" /> -->
<!-- 指定列的java數(shù)據(jù)類(lèi)型 -->
<!-- <columnOverride column="LONG_VARCHAR_FIELD" jdbcType="VARCHAR" /> -->
</table>
<table schema="" tableName="t_schedule_trigger" domainObjectName="ScheduleTrigger"
enableCountByExample="false" enableDeleteByExample="false"
enableSelectByExample="false" enableUpdateByExample="false">
<!-- 忽略列，不生成bean 字段 -->
<!-- <ignoreColumn column="FRED" /> -->
<!-- 指定列的java數(shù)據(jù)類(lèi)型 -->
<!-- <columnOverride column="LONG_VARCHAR_FIELD" jdbcType="VARCHAR" /> -->
</table>
</context>
</generatorConfiguration>記得修改數(shù)據(jù)庫(kù)jdbc驅(qū)動(dòng)jar包的位置為自己數(shù)據(jù)庫(kù)jdbc驅(qū)動(dòng)jar包的位置，jdbc連接數(shù)據(jù)庫(kù)名、用戶名和密碼改為自己的。
注意：targetPackage改成自己的包名。
自動(dòng)生成操作
命令：mybatis-generator:generate -e
注意：實(shí)體類(lèi)上加一個(gè)@Data,XXmapper.java上加一個(gè)@Repository自己需要寫(xiě)一個(gè)查詢?nèi)康姆椒ā?/p>
寫(xiě)一個(gè)IScheduleService接口，用來(lái)定時(shí)刷新任務(wù)，更新調(diào)度器中的任務(wù)
package com.zking.quartz02.service;
public interface IScheduleService {
//定時(shí)刷新任務(wù)，更新調(diào)度器中的任務(wù)
public void refresh();
}實(shí)現(xiàn)IScheduleService接口
package com.zking.quartz02.service.impl;
import com.zking.quartz02.mapper.ScheduleTriggerMapper;
import com.zking.quartz02.mapper.ScheduleTriggerParamMapper;
import com.zking.quartz02.model.ScheduleTrigger;
import com.zking.quartz02.model.ScheduleTriggerParam;
import com.zking.quartz02.service.IScheduleService;
import org.quartz.*;
import org.springframework.scheduling.annotation.Scheduled;
import org.springframework.stereotype.Service;
import javax.annotation.Resource;
import java.util.List;
@Service
public class ScheduleServiceImpl implements IScheduleService {
@Resource
private ScheduleTriggerMapper scheduleTriggerMapper;
@Resource
private ScheduleTriggerParamMapper scheduleTriggerParamMapper;
@Resource
private Scheduler scheduler;
@Scheduled(cron = "*/10 * * * * ?")
@Override
public void refresh() {
try {
//1.查詢數(shù)據(jù)庫(kù)中所有的任務(wù)
List<ScheduleTrigger> scheduleTriggers =
scheduleTriggerMapper.listScheduleTrigger();
//2.遍歷所有任務(wù)
for (ScheduleTrigger scheduleTrigger : scheduleTriggers) {
Integer id = scheduleTrigger.getId();
String cron = scheduleTrigger.getCron();
String status = scheduleTrigger.getStatus();
String jobName = scheduleTrigger.getJobName();
String jobGroup = scheduleTrigger.getJobGroup();
//設(shè)置triggerKey
TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);
//通過(guò)triggerKey獲取調(diào)度器中的觸發(fā)器
CronTrigger cronTrigger = (CronTrigger)scheduler.getTrigger(triggerKey);
if(null==cronTrigger){//如果為空,表示調(diào)度器中沒(méi)有該任務(wù)，不存在就添加任務(wù)
if("0".equals(status)){//如果該任務(wù)狀態(tài)為0,表示該任務(wù)不用添加，此次循環(huán)結(jié)束
continue;
}
//創(chuàng)建觸發(fā)器
CronTrigger cronTrigger1 = TriggerBuilder.newTrigger()
.withIdentity(jobName, jobGroup)
.withSchedule(CronScheduleBuilder.cronSchedule(cron))
.build();
//創(chuàng)建工作詳情實(shí)例
JobDetail jobDetail = JobBuilder.newJob((Class<? extends Job>) Class.forName(jobName))
.withIdentity(jobName, jobGroup)
.build();
JobDataMap jobDataMap = jobDetail.getJobDataMap();
//查詢?cè)撊蝿?wù)中所有的參數(shù)
List<ScheduleTriggerParam> scheduleTriggerParams = scheduleTriggerParamMapper.listScheduleTriggerParamById(id);
//遍歷所有參數(shù)，將參數(shù)設(shè)置到j(luò)obDataMap中
for (ScheduleTriggerParam scheduleTriggerParam : scheduleTriggerParams) {
jobDataMap.put(scheduleTriggerParam.getName(),scheduleTriggerParam.getValue());
}
//添加任務(wù)，將觸發(fā)器和工作詳情實(shí)例添加到調(diào)度器中
scheduler.scheduleJob(jobDetail,cronTrigger1);
}else{//如果不為空，表示調(diào)度器中存在該任務(wù)
if("0".equals(status)){//如果任務(wù)狀態(tài)改為禁用，移除該任務(wù)
JobKey jobKey = JobKey.jobKey(jobName, jobGroup);
scheduler.deleteJob(jobKey);//移除任務(wù)
}
//如果調(diào)度器中的觸發(fā)器的表達(dá)式和數(shù)據(jù)庫(kù)中的表達(dá)式不一致
//獲取調(diào)度器中觸發(fā)器的表達(dá)式
String cronExpression = cronTrigger.getCronExpression();
if(!cronExpression.equals(cron)){//不一致
//重新創(chuàng)建新的觸發(fā)器
CronTrigger cronTrigger2 = TriggerBuilder.newTrigger()
.withIdentity(jobName, jobGroup)
.withSchedule(CronScheduleBuilder.cronSchedule(cron))
.build();
//更新調(diào)度器中的觸發(fā)器
scheduler.rescheduleJob(triggerKey,cronTrigger2);
}
}
}
} catch (Exception e) {
e.printStackTrace();
throw new RuntimeException(e);
}
}
}1) service層實(shí)現(xiàn)類(lèi)使用@Scheduled注解聲明一個(gè)方法用于定時(shí)刷新數(shù)據(jù)庫(kù)中的調(diào)度任務(wù)；
2) 使用@Resource注解注入Scheduler，在第5點(diǎn)中已裝配到Spring上下文；
3) 在啟動(dòng)類(lèi)上加入@MapperScan(指定要變成實(shí)現(xiàn)類(lèi)的接口所在的包路徑，比如我的就是com.zking.quartz02.mapper)，然后包下面的所有接口在編譯之后都會(huì)生成相應(yīng)的實(shí)現(xiàn)類(lèi)；
4) 在啟動(dòng)類(lèi)上加入@EnableScheduling啟動(dòng)Spring自帶定時(shí)器任務(wù)；
小結(jié)：
要搞清楚一個(gè)問(wèn)題：從數(shù)據(jù)庫(kù)讀取任務(wù)信息動(dòng)態(tài)生成定時(shí)任務(wù)，和把quartz持久化到數(shù)據(jù)庫(kù)是沒(méi)有關(guān)系的。
前者是我們自己定義的業(yè)務(wù)表，而后者是quartz使用自己的表來(lái)存儲(chǔ)信息。持久化到數(shù)據(jù)庫(kù)后，
就算服務(wù)器重啟或是多個(gè)quartz節(jié)點(diǎn)也沒(méi)關(guān)系，因?yàn)樗麄児蚕頂?shù)據(jù)庫(kù)中的任務(wù)信息。
到此這篇關(guān)于SpringBoot結(jié)合Quartz實(shí)現(xiàn)數(shù)據(jù)庫(kù)存儲(chǔ)的文章就介紹到這了,更多相關(guān)SpringBoot Quartz數(shù)據(jù)庫(kù)存儲(chǔ)內(nèi)容請(qǐng)搜索腳本之家以前的文章或繼續(xù)瀏覽下面的相關(guān)文章希望大家以后多多支持腳本之家！
相關(guān)文章
Spring?Security?登錄時(shí)添加圖形驗(yàn)證碼實(shí)現(xiàn)實(shí)例
這篇文章主要為大家介紹了Spring?Security?登錄時(shí)添加圖形驗(yàn)證碼實(shí)現(xiàn)實(shí)例詳解，有需要的朋友可以借鑒參考下，希望能夠有所幫助，祝大家多多進(jìn)步，早日升職加薪2022-11-11
SPI的全稱是服務(wù)提供接口，可以用其來(lái)啟動(dòng)框架的擴(kuò)展和替換組件。本文將利用SPI實(shí)現(xiàn)解耦，文中的示例代碼講解詳細(xì)，具有一定的借鑒價(jià)值，需要的可以參考一下2023-04-04
Spring事件監(jiān)聽(tīng)機(jī)制使用和原理解析
Spring的監(jiān)聽(tīng)機(jī)制基于觀察者模式，就是就是我們所說(shuō)的發(fā)布訂閱模式，這種模式可以在一定程度上實(shí)現(xiàn)代碼的解耦，本文將從原理上解析Spring事件監(jiān)聽(tīng)機(jī)制,需要的朋友可以參考下2023-06-06
Spring Boot集成Mybatis的實(shí)例代碼(簡(jiǎn)潔版)
這篇文章主要介紹了Spring Boot集成Mybatis簡(jiǎn)潔版的教程,需要的朋友可以參考下2018-02-02
一分鐘掌握J(rèn)ava?ElasticJob分布式定時(shí)任務(wù)
ElasticJob?是面向互聯(lián)網(wǎng)生態(tài)和海量任務(wù)的分布式調(diào)度解決方案，本文主要通過(guò)簡(jiǎn)單的示例帶大家深入了解ElasticJob分布式定時(shí)任務(wù)的相關(guān)知識(shí)，需要的可以參考一下2023-05-05
SWT(JFace)體驗(yàn)之FillLayout布局
FillLayout是非常簡(jiǎn)單的一種布局方式，它會(huì)以同樣大小對(duì)父組件中的子組件進(jìn)行布局，這些子組件將以一行或一列的形式排列。2009-06-06
Spring-Web與Spring-WebFlux沖突問(wèn)題解決
Spring WebFlux是一套全新的Reactive Web技術(shù)棧,實(shí)現(xiàn)完全非阻塞,支持Reactive Streams背壓等特性,這篇文章主要給大家介紹了關(guān)于Spring-Web與Spring-WebFlux沖突問(wèn)題解決的相關(guān)資料,需要的朋友可以參考下2024-04-04
詳解Kotlin：forEach也能break和continue
這篇文章主要介紹了詳解Kotlin：forEach也能break和continue的相關(guān)資料,需要的朋友可以參考下2017-06-06
對(duì)比Java設(shè)計(jì)模式編程中的狀態(tài)模式和策略模式
這篇文章主要介紹了Java設(shè)計(jì)模式編程中的狀態(tài)模式和策略模式對(duì)比,文中列舉了兩種模式的相似點(diǎn)和不同點(diǎn),并都舉了代碼的實(shí)例作為參照,需要的朋友可以參考下2016-04-04
這篇文章主要介紹了Java線程池的拒絕策略實(shí)現(xiàn)詳解,文中通過(guò)示例代碼介紹的非常詳細(xì)，對(duì)大家的學(xué)習(xí)或者工作具有一定的參考學(xué)習(xí)價(jià)值,需要的朋友可以參考下2019-09-09