经验首页 前端设计 程序设计 Java相关 移动开发 数据库/运维 软件/图像 大数据/云计算 其他经验
当前位置:技术经验 » Java相关 » Spring » 查看文章
SpringBoot结合Quartz实现数据库存储
来源:jb51  时间:2022/1/17 16:40:56  对本文有异议

一、先创建一个SpringBoot项目

还有一个截屏忘了截屏,就是选择保存路径选择一下就点Finish就可以了。 

更改application.properties为application.yml

application.yml文件如下

  1. server:
  2. port: 8080
  3. #数据库连接池druid配置
  4. spring:
  5. datasource:
  6. #1.JDBC
  7. type: com.alibaba.druid.pool.DruidDataSource
  8. driver-class-name: com.mysql.cj.jdbc.Driver
  9. url: jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
  10. username: root
  11. password: 123
  12. druid:
  13. #2.连接池配置
  14. #初始化连接池的连接数量 大小,最小,最大
  15. initial-size: 5
  16. min-idle: 5
  17. max-active: 20
  18. #配置获取连接等待超时的时间
  19. max-wait: 60000
  20. #配置间隔多久才进行一次检测,检测需要关闭的空闲连接,单位是毫秒
  21. time-between-eviction-runs-millis: 60000
  22. # 配置一个连接在池中最小生存的时间,单位是毫秒
  23. min-evictable-idle-time-millis: 30000
  24. validation-query: SELECT 1 FROM DUAL
  25. test-while-idle: true
  26. test-on-borrow: true
  27. test-on-return: false
  28. # 是否缓存preparedStatement,也就是PSCache 官方建议MySQL下建议关闭 个人建议如果想用SQL防火墙 建议打开
  29. pool-prepared-statements: true
  30. max-pool-prepared-statement-per-connection-size: 20
  31. # 配置监控统计拦截的filters,去掉后监控界面sql无法统计,'wall'用于防火墙
  32. filter:
  33. stat:
  34. merge-sql: true
  35. slow-sql-millis: 5000
  36. #3.基础监控配置
  37. web-stat-filter:
  38. enabled: true
  39. url-pattern: /*
  40. #设置不统计哪些URL
  41. exclusions: "*.js,*.gif,*.jpg,*.png,*.css,*.ico,/druid/*"
  42. session-stat-enable: true
  43. session-stat-max-count: 100
  44. stat-view-servlet:
  45. enabled: true
  46. url-pattern: /druid/*
  47. reset-enable: true
  48. #设置监控页面的登录名和密码
  49. login-username: admin
  50. login-password: admin
  51. allow: 127.0.0.1
  52. mybatis:
  53. mapper-locations: classpath*:mapper/*.xml
  54. type-aliases-package: com.zking.quartz02.model

二、导入依赖 

1.导入Quartz依赖

  1. <dependency>
  2. <groupId>org.quartz-scheduler</groupId>
  3. <artifactId>quartz-jobs</artifactId>
  4. <version>2.2.1</version>
  5. </dependency>
  6. <dependency>
  7. <groupId>org.springframework.boot</groupId>
  8. <artifactId>spring-boot-starter-quartz</artifactId>
  9. </dependency>

2.用于我用的是Druid数据库连接池,所以我需要更换成Druid连接池,先引入Druid依赖。

  1. <dependency>
  2. <groupId>com.alibaba</groupId>
  3. <artifactId>druid-spring-boot-starter</artifactId>
  4. <version>1.1.10</version>
  5. </dependency>

三、 导入DruidConnectionProvider.java(Druid连接池的Quartz扩展类)

  1. package com.zking.quartz02.utils;
  2. import com.alibaba.druid.pool.DruidDataSource;
  3. import org.quartz.SchedulerException;
  4. import org.quartz.utils.ConnectionProvider;
  5. import java.sql.Connection;
  6. import java.sql.SQLException;
  7. /*
  8. #============================================================================
  9. # JDBC
  10. #============================================================================
  11. org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate
  12. org.quartz.jobStore.useProperties:false
  13. org.quartz.jobStore.dataSource:qzDS
  14. #org.quartz.dataSource.qzDS.connectionProvider.class:org.quartz.utils.PoolingConnectionProvider
  15. org.quartz.dataSource.qzDS.connectionProvider.class:com.zking.q03.quartz.DruidConnectionProvider
  16. org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver
  17. org.quartz.dataSource.qzDS.URL:jdbc:mysql://127.0.0.1:3306/test?useUnicode=true&characterEncoding=UTF-8
  18. org.quartz.dataSource.qzDS.user:root
  19. org.quartz.dataSource.qzDS.password:root
  20. org.quartz.dataSource.qzDS.maxConnections:30
  21. org.quartz.dataSource.qzDS.validationQuery: select 0
  22. */
  23. /**
  24. * [Druid连接池的Quartz扩展类]
  25. */
  26. public class DruidConnectionProvider implements ConnectionProvider {
  27. /*
  28. * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  29. *
  30. * 常量配置,与quartz.properties文件的key保持一致(去掉前缀),同时提供set方法,Quartz框架自动注入值。
  31. *
  32. * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  33. */
  34. //JDBC驱动
  35. public String driver;
  36. //JDBC连接串
  37. public String URL;
  38. //数据库用户名
  39. public String user;
  40. //数据库用户密码
  41. public String password;
  42. //数据库最大连接数
  43. public int maxConnection;
  44. //数据库SQL查询每次连接返回执行到连接池,以确保它仍然是有效的。
  45. public String validationQuery;
  46. private boolean validateOnCheckout;
  47. private int idleConnectionValidationSeconds;
  48. public String maxCachedStatementsPerConnection;
  49. private String discardIdleConnectionsSeconds;
  50. public static final int DEFAULT_DB_MAX_CONNECTIONS = 10;
  51. public static final int DEFAULT_DB_MAX_CACHED_STATEMENTS_PER_CONNECTION = 120;
  52. //Druid连接池
  53. private DruidDataSource datasource;
  54. /*
  55. * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  56. *
  57. * 接口实现
  58. *
  59. * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  60. */
  61. public Connection getConnection() throws SQLException {
  62. return datasource.getConnection();
  63. }
  64. public void shutdown() throws SQLException {
  65. datasource.close();
  66. }
  67. public void initialize() throws SQLException{
  68. if (this.URL == null) {
  69. throw new SQLException("DBPool could not be created: DB URL cannot be null");
  70. }
  71. if (this.driver == null) {
  72. throw new SQLException("DBPool driver could not be created: DB driver class name cannot be null!");
  73. }
  74. if (this.maxConnection < 0) {
  75. throw new SQLException("DBPool maxConnectins could not be created: Max connections must be greater than zero!");
  76. }
  77. datasource = new DruidDataSource();
  78. try{
  79. datasource.setDriverClassName(this.driver);
  80. } catch (Exception e) {
  81. try {
  82. throw new SchedulerException("Problem setting driver class name on datasource: " + e.getMessage(), e);
  83. } catch (SchedulerException e1) {
  84. }
  85. }
  86. datasource.setUrl(this.URL);
  87. datasource.setUsername(this.user);
  88. datasource.setPassword(this.password);
  89. datasource.setMaxActive(this.maxConnection);
  90. datasource.setMinIdle(1);
  91. datasource.setMaxWait(0);
  92. datasource.setMaxPoolPreparedStatementPerConnectionSize(this.DEFAULT_DB_MAX_CACHED_STATEMENTS_PER_CONNECTION);
  93. if (this.validationQuery != null) {
  94. datasource.setValidationQuery(this.validationQuery);
  95. if(!this.validateOnCheckout)
  96. datasource.setTestOnReturn(true);
  97. else
  98. datasource.setTestOnBorrow(true);
  99. datasource.setValidationQueryTimeout(this.idleConnectionValidationSeconds);
  100. }
  101. }
  102. /*
  103. * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  104. *
  105. * 提供get set方法
  106. *
  107. * ~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~~
  108. */
  109. public String getDriver() {
  110. return driver;
  111. }
  112. public void setDriver(String driver) {
  113. this.driver = driver;
  114. }
  115. public String getURL() {
  116. return URL;
  117. }
  118. public void setURL(String URL) {
  119. this.URL = URL;
  120. }
  121. public String getUser() {
  122. return user;
  123. }
  124. public void setUser(String user) {
  125. this.user = user;
  126. }
  127. public String getPassword() {
  128. return password;
  129. }
  130. public void setPassword(String password) {
  131. this.password = password;
  132. }
  133. public int getMaxConnection() {
  134. return maxConnection;
  135. }
  136. public void setMaxConnection(int maxConnection) {
  137. this.maxConnection = maxConnection;
  138. }
  139. public String getValidationQuery() {
  140. return validationQuery;
  141. }
  142. public void setValidationQuery(String validationQuery) {
  143. this.validationQuery = validationQuery;
  144. }
  145. public boolean isValidateOnCheckout() {
  146. return validateOnCheckout;
  147. }
  148. public void setValidateOnCheckout(boolean validateOnCheckout) {
  149. this.validateOnCheckout = validateOnCheckout;
  150. }
  151. public int getIdleConnectionValidationSeconds() {
  152. return idleConnectionValidationSeconds;
  153. }
  154. public void setIdleConnectionValidationSeconds(int idleConnectionValidationSeconds) {
  155. this.idleConnectionValidationSeconds = idleConnectionValidationSeconds;
  156. }
  157. public DruidDataSource getDatasource() {
  158. return datasource;
  159. }
  160. public void setDatasource(DruidDataSource datasource) {
  161. this.datasource = datasource;
  162. }
  163. }

四、 修改自定义quartz.properties配置(在项目中添加quartz.properties文件(这样就不会加载自带的properties文件) )

  1. #
  2. #============================================================================
  3. # Configure Main Scheduler Properties \u8C03\u5EA6\u5668\u5C5E\u6027
  4. #============================================================================
  5. org.quartz.scheduler.instanceName: DefaultQuartzScheduler
  6. org.quartz.scheduler.instanceId = AUTO
  7. org.quartz.scheduler.rmi.export: false
  8. org.quartz.scheduler.rmi.proxy: false
  9. org.quartz.scheduler.wrapJobExecutionInUserTransaction: false
  10. org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
  11. org.quartz.threadPool.threadCount= 10
  12. org.quartz.threadPool.threadPriority: 5
  13. org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true
  14. org.quartz.jobStore.misfireThreshold: 60000
  15. #============================================================================
  16. # Configure JobStore
  17. #============================================================================
  18. #\u5B58\u50A8\u65B9\u5F0F\u4F7F\u7528JobStoreTX\uFF0C\u4E5F\u5C31\u662F\u6570\u636E\u5E93
  19. org.quartz.jobStore.class: org.quartz.impl.jdbcjobstore.JobStoreTX
  20. org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate
  21. #\u4F7F\u7528\u81EA\u5DF1\u7684\u914D\u7F6E\u6587\u4EF6
  22. org.quartz.jobStore.useProperties:true
  23. #\u6570\u636E\u5E93\u4E2Dquartz\u8868\u7684\u8868\u540D\u524D\u7F00
  24. org.quartz.jobStore.tablePrefix:qrtz_
  25. org.quartz.jobStore.dataSource:qzDS
  26. #\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
  27. org.quartz.jobStore.isClustered = true
  28. #============================================================================
  29. # Configure Datasources
  30. #============================================================================
  31. #\u914D\u7F6E\u6570\u636E\u5E93\u6E90
  32. org.quartz.dataSource.qzDS.connectionProvider.class: com.zking.quartz02.utils.DruidConnectionProvider
  33. org.quartz.dataSource.qzDS.driver: com.mysql.cj.jdbc.Driver
  34. #修改为自己的数据库名称、用户名和密码
  35. org.quartz.dataSource.qzDS.URL: jdbc:mysql://localhost:3306/quartz?useUnicode=true&characterEncoding=utf8&serverTimezone=GMT%2B8&useSSL=false
  36. org.quartz.dataSource.qzDS.user: root
  37. org.quartz.dataSource.qzDS.password: 123
  38. org.quartz.dataSource.qzDS.maxConnection: 10

在数据库中创建quartz相关的表
   进入quartz的官网http://www.quartz-scheduler.org/,点击Downloads,
   下载后在目录\docs\dbTables下有常用数据库创建quartz表的脚本,例如:“tables_mysql.sql”

五、自定义MyJobFactory,解决spring不能在quartz中注入bean的问题

  1. package com.zking.quartz02.quartz;
  2. import org.quartz.spi.TriggerFiredBundle;
  3. import org.springframework.beans.factory.annotation.Autowired;
  4. import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
  5. import org.springframework.scheduling.quartz.AdaptableJobFactory;
  6. import org.springframework.stereotype.Component;
  7. //解决spring不能在quartz中注入bean的问题
  8. @Component
  9. public class MyJobFactory extends AdaptableJobFactory {
  10. @Autowired
  11. private AutowireCapableBeanFactory autowireCapableBeanFactory;
  12. @Override
  13. protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
  14. Object jobInstance = super.createJobInstance(bundle);
  15. autowireCapableBeanFactory.autowireBean(jobInstance);
  16. return jobInstance;
  17. }
  18. }

六、创建调度器schedule

  1. package com.zking.quartz02.quartz;
  2. //quartz配置类将调度器交给spring管理
  3. import org.quartz.Scheduler;
  4. import org.quartz.SchedulerFactory;
  5. import org.springframework.beans.factory.annotation.Autowired;
  6. import org.springframework.beans.factory.config.PropertiesFactoryBean;
  7. import org.springframework.context.annotation.Bean;
  8. import org.springframework.context.annotation.Configuration;
  9. import org.springframework.core.io.ClassPathResource;
  10. import org.springframework.scheduling.annotation.Scheduled;
  11. import org.springframework.scheduling.quartz.SchedulerFactoryBean;
  12. import java.io.IOException;
  13. import java.util.Properties;
  14. @Configuration
  15. public class QuartzConfiguration {
  16. @Autowired
  17. private MyJobFactory myJobFactory;
  18. @Bean
  19. public Scheduler scheduler(){
  20. return this.getSchedulerFactoryBean().getScheduler();
  21. }
  22. //读取自定义配置文件,获取调度器工厂
  23. @Bean
  24. public SchedulerFactoryBean getSchedulerFactoryBean(){
  25. //1.创建SchedulerFactoryBean sc=new SchedulerFactoryBean
  26. SchedulerFactoryBean sc=new SchedulerFactoryBean();
  27. //2.加载自定义的quartz.properties
  28. sc.setQuartzProperties(this.getProperties());
  29. //3.设置自定义的MyJobFactory
  30. sc.setJobFactory(myJobFactory);
  31. return sc;
  32. }
  33. //读取配置文件
  34. @Bean
  35. public Properties getProperties(){
  36. try {
  37. PropertiesFactoryBean propertiesFactoryBean =
  38. new PropertiesFactoryBean();
  39. //设置自定义配置文件位置
  40. propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
  41. //读取配置文件
  42. propertiesFactoryBean.afterPropertiesSet();
  43. return propertiesFactoryBean.getObject();
  44. } catch (IOException e) {
  45. e.printStackTrace();
  46. throw new RuntimeException(e);
  47. }
  48. }
  49. }

七、 创建自定义任务

 首先我们需要自己创建一张表t_schedule_trigger,用来存放trigger的信息,然后从数据库读取这些信息来随时更新定时任务
   注意:job_name存放的任务类的全路径,在quartz中通过jobName和jobGroup来确定trigger的唯一性,所以这两列为联合唯一索引 

t_schedule_trigger和t_schedule_trigger_param表生成的sql代码如下(去执行一下sql语句即可)

  1. -- 注意:job_name存放的任务类的全路径,在quartz中通过jobNamejobGroup来确定trigger的唯一性,所以这两列为联合唯一索引
  2. create table t_schedule_trigger
  3. (
  4. id int primary key auto_increment, -- ID
  5. cron varchar(200) not null, -- 时间表达式
  6. status char(1) not null, -- 使用状态 0:禁用 1:启用
  7. job_name varchar(200) not null, -- 任务名称
  8. job_group varchar(200) not null, -- 任务分组
  9. unique index(job_name,job_group)
  10. );
  11. -- 额外添加到任务中的参数
  12. create table t_schedule_trigger_param
  13. (
  14. param_id int primary key auto_increment, -- ID
  15. name varchar(200) not null, -- 参数名
  16. value varchar(512), -- 参数值
  17. schedule_trigger_id int not null, -- 外键:引用t_schedule_trigger(id)
  18. foreign key(schedule_trigger_id) references t_schedule_trigger(id)
  19. );

   注1:t_schedule_trigger的子表t_schedule_trigger_param还可以用来传递额外添加到任务中的参数

   注2:实现org.quartz.Job或org.springframework.scheduling.quartz.QuartzJobBean创建任务,可通过JobExecutionContext传参

八、 更新quartz中的任务

首先我们将t_schedule_trigger和t_schedule_trigger_param通过generatorConfig.xml自动生成实体类,XXmapper.java,XXmapper.xml.

  1. <?xml version="1.0" encoding="UTF-8" ?>
  2. <!DOCTYPE generatorConfiguration PUBLIC "-//mybatis.org//DTD MyBatis Generator Configuration 1.0//EN"
  3. "http://mybatis.org/dtd/mybatis-generator-config_1_0.dtd" >
  4. <generatorConfiguration>
  5. <!-- 引入配置文件 -->
  6. <!-- <properties resource="jdbc.properties"/>-->
  7. <!--指定数据库jdbc驱动jar包的位置-->
  8. <classPathEntry location="D:\\installpath\\apache-maven-3.5.4\\jar\\mysql\\mysql-connector-java\\5.1.44\\mysql-connector-java-5.1.44.jar"/>
  9. <!-- 一个数据库一个context -->
  10. <context id="infoGuardian">
  11. <!-- 注释 -->
  12. <commentGenerator>
  13. <property name="suppressAllComments" value="true"/><!-- 是否取消注释 -->
  14. <property name="suppressDate" value="true"/> <!-- 是否生成注释代时间戳 -->
  15. </commentGenerator>
  16. <!-- jdbc连接 -->
  17. <jdbcConnection driverClass="com.mysql.jdbc.Driver"
  18. connectionURL="jdbc:mysql://localhost:3306/quartz?useUnicode=true&amp;characterEncoding=UTF-8" userId="root" password="123"/>
  19. <!-- 类型转换 -->
  20. <javaTypeResolver>
  21. <!-- 是否使用bigDecimal, false可自动转化以下类型(Long, Integer, Short, etc.) -->
  22. <property name="forceBigDecimals" value="false"/>
  23. </javaTypeResolver>
  24. <!-- 01 指定javaBean生成的位置 -->
  25. <!-- targetPackage:指定生成的model生成所在的包名 -->
  26. <!-- targetProject:指定在该项目下所在的路径 -->
  27. <javaModelGenerator targetPackage="com.zking.quartz02.model"
  28. targetProject="src/main/java">
  29. <!-- 是否允许子包,即targetPackage.schemaName.tableName -->
  30. <property name="enableSubPackages" value="false"/>
  31. <!-- 是否对model添加构造函数 -->
  32. <property name="constructorBased" value="true"/>
  33. <!-- 是否针对string类型的字段在set的时候进行trim调用 -->
  34. <property name="trimStrings" value="false"/>
  35. <!-- 建立的Model对象是否 不可改变 即生成的Model对象不会有 setter方法,只有构造方法 -->
  36. <property name="immutable" value="false"/>
  37. </javaModelGenerator>
  38. <!-- 02 指定sql映射文件生成的位置 -->
  39. <sqlMapGenerator targetPackage="mapper"
  40. targetProject="src/main/resources">
  41. <!-- 是否允许子包,即targetPackage.schemaName.tableName -->
  42. <property name="enableSubPackages" value="false"/>
  43. </sqlMapGenerator>
  44. <!-- 03 生成XxxMapper接口 -->
  45. <!-- type="ANNOTATEDMAPPER",生成Java Model 和基于注解的Mapper对象 -->
  46. <!-- type="MIXEDMAPPER",生成基于注解的Java Model 和相应的Mapper对象 -->
  47. <!-- type="XMLMAPPER",生成SQLMap XML文件和独立的Mapper接口 -->
  48. <javaClientGenerator targetPackage="com.zking.quartz02.mapper"
  49. targetProject="src/main/java" type="XMLMAPPER">
  50. <!-- 是否在当前路径下新加一层schema,false路径com.oop.eksp.user.model, true:com.oop.eksp.user.model.[schemaName] -->
  51. <property name="enableSubPackages" value="false"/>
  52. </javaClientGenerator>
  53. <!-- 配置表信息 -->
  54. <!-- schema即为数据库名 -->
  55. <!-- tableName为对应的数据库表 -->
  56. <!-- domainObjectName是要生成的实体类 -->
  57. <!-- enable*ByExample是否生成 example类 -->
  58. <!--<table schema="" tableName="t_book" domainObjectName="Book"-->
  59. <!--enableCountByExample="false" enableDeleteByExample="false"-->
  60. <!--enableSelectByExample="false" enableUpdateByExample="false">-->
  61. <!--&lt;!&ndash; 忽略列,不生成bean 字段 &ndash;&gt;-->
  62. <!--&lt;!&ndash; <ignoreColumn column="FRED" /> &ndash;&gt;-->
  63. <!--&lt;!&ndash; 指定列的java数据类型 &ndash;&gt;-->
  64. <!--&lt;!&ndash; <columnOverride column="LONG_VARCHAR_FIELD" jdbcType="VARCHAR" /> &ndash;&gt;-->
  65. <!--</table>-->
  66. <table schema="" tableName="t_schedule_trigger_param" domainObjectName="ScheduleTriggerParam"
  67. enableCountByExample="false" enableDeleteByExample="false"
  68. enableSelectByExample="false" enableUpdateByExample="false">
  69. <!-- 忽略列,不生成bean 字段 -->
  70. <!-- <ignoreColumn column="FRED" /> -->
  71. <!-- 指定列的java数据类型 -->
  72. <!-- <columnOverride column="LONG_VARCHAR_FIELD" jdbcType="VARCHAR" /> -->
  73. </table>
  74. <table schema="" tableName="t_schedule_trigger" domainObjectName="ScheduleTrigger"
  75. enableCountByExample="false" enableDeleteByExample="false"
  76. enableSelectByExample="false" enableUpdateByExample="false">
  77. <!-- 忽略列,不生成bean 字段 -->
  78. <!-- <ignoreColumn column="FRED" /> -->
  79. <!-- 指定列的java数据类型 -->
  80. <!-- <columnOverride column="LONG_VARCHAR_FIELD" jdbcType="VARCHAR" /> -->
  81. </table>
  82. </context>
  83. </generatorConfiguration>

记得修改数据库jdbc驱动jar包的位置为自己数据库jdbc驱动jar包的位置,jdbc连接数据库名、用户名和密码改为自己的。

注意:targetPackage改成自己的包名。

自动生成操作

命令:mybatis-generator:generate -e

注意:实体类上加一个@Data,XXmapper.java上加一个@Repository自己需要写一个查询全部的方法。

写一个IScheduleService接口,用来定时刷新任务,更新调度器中的任务

  1. package com.zking.quartz02.service;
  2. public interface IScheduleService {
  3. //定时刷新任务,更新调度器中的任务
  4. public void refresh();
  5. }

实现IScheduleService接口

  1. package com.zking.quartz02.service.impl;
  2. import com.zking.quartz02.mapper.ScheduleTriggerMapper;
  3. import com.zking.quartz02.mapper.ScheduleTriggerParamMapper;
  4. import com.zking.quartz02.model.ScheduleTrigger;
  5. import com.zking.quartz02.model.ScheduleTriggerParam;
  6. import com.zking.quartz02.service.IScheduleService;
  7. import org.quartz.*;
  8. import org.springframework.scheduling.annotation.Scheduled;
  9. import org.springframework.stereotype.Service;
  10. import javax.annotation.Resource;
  11. import java.util.List;
  12. @Service
  13. public class ScheduleServiceImpl implements IScheduleService {
  14. @Resource
  15. private ScheduleTriggerMapper scheduleTriggerMapper;
  16. @Resource
  17. private ScheduleTriggerParamMapper scheduleTriggerParamMapper;
  18. @Resource
  19. private Scheduler scheduler;
  20. @Scheduled(cron = "*/10 * * * * ?")
  21. @Override
  22. public void refresh() {
  23. try {
  24. //1.查询数据库中所有的任务
  25. List<ScheduleTrigger> scheduleTriggers =
  26. scheduleTriggerMapper.listScheduleTrigger();
  27. //2.遍历所有任务
  28. for (ScheduleTrigger scheduleTrigger : scheduleTriggers) {
  29. Integer id = scheduleTrigger.getId();
  30. String cron = scheduleTrigger.getCron();
  31. String status = scheduleTrigger.getStatus();
  32. String jobName = scheduleTrigger.getJobName();
  33. String jobGroup = scheduleTrigger.getJobGroup();
  34. //设置triggerKey
  35. TriggerKey triggerKey = TriggerKey.triggerKey(jobName, jobGroup);
  36. //通过triggerKey获取调度器中的触发器
  37. CronTrigger cronTrigger = (CronTrigger)scheduler.getTrigger(triggerKey);
  38. if(null==cronTrigger){//如果为空,表示调度器中没有该任务,不存在就添加任务
  39. if("0".equals(status)){//如果该任务状态为0,表示该任务不用添加,此次循环结束
  40. continue;
  41. }
  42. //创建触发器
  43. CronTrigger cronTrigger1 = TriggerBuilder.newTrigger()
  44. .withIdentity(jobName, jobGroup)
  45. .withSchedule(CronScheduleBuilder.cronSchedule(cron))
  46. .build();
  47. //创建工作详情实例
  48. JobDetail jobDetail = JobBuilder.newJob((Class<? extends Job>) Class.forName(jobName))
  49. .withIdentity(jobName, jobGroup)
  50. .build();
  51. JobDataMap jobDataMap = jobDetail.getJobDataMap();
  52. //查询该任务中所有的参数
  53. List<ScheduleTriggerParam> scheduleTriggerParams = scheduleTriggerParamMapper.listScheduleTriggerParamById(id);
  54. //遍历所有参数,将参数设置到jobDataMap中
  55. for (ScheduleTriggerParam scheduleTriggerParam : scheduleTriggerParams) {
  56. jobDataMap.put(scheduleTriggerParam.getName(),scheduleTriggerParam.getValue());
  57. }
  58. //添加任务,将触发器和工作详情实例添加到调度器中
  59. scheduler.scheduleJob(jobDetail,cronTrigger1);
  60. }else{//如果不为空,表示调度器中存在该任务
  61. if("0".equals(status)){//如果任务状态改为禁用,移除该任务
  62. JobKey jobKey = JobKey.jobKey(jobName, jobGroup);
  63. scheduler.deleteJob(jobKey);//移除任务
  64. }
  65. //如果调度器中的触发器的表达式和数据库中的表达式不一致
  66. //获取调度器中触发器的表达式
  67. String cronExpression = cronTrigger.getCronExpression();
  68. if(!cronExpression.equals(cron)){//不一致
  69. //重新创建新的触发器
  70. CronTrigger cronTrigger2 = TriggerBuilder.newTrigger()
  71. .withIdentity(jobName, jobGroup)
  72. .withSchedule(CronScheduleBuilder.cronSchedule(cron))
  73. .build();
  74. //更新调度器中的触发器
  75. scheduler.rescheduleJob(triggerKey,cronTrigger2);
  76. }
  77. }
  78. }
  79. } catch (Exception e) {
  80. e.printStackTrace();
  81. throw new RuntimeException(e);
  82. }
  83. }
  84. }

1) service层实现类使用@Scheduled注解声明一个方法用于定时刷新数据库中的调度任务;
 2) 使用@Resource注解注入Scheduler,在第5点中已装配到Spring上下文;

 3) 在启动类上加入@MapperScan(指定要变成实现类的接口所在的包路径,比如我的就是com.zking.quartz02.mapper),然后包下面的所有接口在编译之后都会生成相应的实现类;
 4) 在启动类上加入@EnableScheduling启动Spring自带定时器任务;

小结:

   要搞清楚一个问题:从数据库读取任务信息动态生成定时任务,和把quartz持久化到数据库是没有关系的。
   前者是我们自己定义的业务表,而后者是quartz使用自己的表来存储信息。持久化到数据库后,
   就算服务器重启或是多个quartz节点也没关系,因为他们共享数据库中的任务信息。

到此这篇关于SpringBoot结合Quartz实现数据库存储的文章就介绍到这了,更多相关SpringBoot Quartz数据库存储内容请搜索w3xue以前的文章或继续浏览下面的相关文章希望大家以后多多支持w3xue!

 友情链接:直通硅谷  点职佳  北美留学生论坛

本站QQ群:前端 618073944 | Java 606181507 | Python 626812652 | C/C++ 612253063 | 微信 634508462 | 苹果 692586424 | C#/.net 182808419 | PHP 305140648 | 运维 608723728

W3xue 的所有内容仅供测试,对任何法律问题及风险不承担任何责任。通过使用本站内容随之而来的风险与本站无关。
关于我们  |  意见建议  |  捐助我们  |  报错有奖  |  广告合作、友情链接(目前9元/月)请联系QQ:27243702 沸活量
皖ICP备17017327号-2 皖公网安备34020702000426号