AI 助理
文档备案控制台
开发者社区 开发与运维 文章 正文

spring中使用quartz框架（持久化到数据库+springboot）

2018-02-20 6949
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： spring中使用quartz框架（持久化到数据库+springboot）http://www.bieryun.com/1513.html 本例是在springboot中通过读取数据库的定时任务信息，动态生成quartz定时任务 1、导入依赖： [html] view plai...

spring中使用quartz框架（持久化到数据库+springboot）

本例是在springboot中通过读取数据库的定时任务信息，动态生成quartz定时任务

1、导入依赖：

[html] view plain copy

  1. <dependency>
  2.             <groupId>org.quartz-scheduler</groupId>
  3.             <artifactId>quartz</artifactId>
  4.             <version>2.2.1</version>
  5.         </dependency>
  6.         <dependency>
  7.              <groupId>org.springframework</groupId>
  8.              <artifactId>spring-context-support</artifactId>
  9.              <version>${spring.version}</version>
  10.         </dependency>

2、在项目中添加quartz.properties文件（这样就不会走它自带的properties文件）

[html] view plain copy

  1. # Default Properties file for use by StdSchedulerFactory
  2. # to create a Quartz Scheduler Instance, if a different
  3. # properties file is not explicitly specified.
  4. #
  6. #默认或是自己改名字都行
  7. org.quartz.scheduler.instanceName: DefaultQuartzScheduler
  9. #如果使用集群，instanceId必须唯一，设置成AUTO
  10. org.quartz.scheduler.instanceId = AUTO
  12. org.quartz.scheduler.rmi.export: false
  13. org.quartz.scheduler.rmi.proxy: false
  14. org.quartz.scheduler.wrapJobExecutionInUserTransaction: false
  16. org.quartz.threadPool.class: org.quartz.simpl.SimpleThreadPool
  17. org.quartz.threadPool.threadCount: 10
  18. org.quartz.threadPool.threadPriority: 5
  19. org.quartz.threadPool.threadsInheritContextClassLoaderOfInitializingThread: true
  21. org.quartz.jobStore.misfireThreshold: 60000
  22. #============================================================================
  23. # Configure JobStore
  24. #============================================================================
  26. #
  27. #org.quartz.jobStore.class: org.quartz.simpl.RAMJobStore
  29. #存储方式使用JobStoreTX，也就是数据库
  30. org.quartz.jobStore.class:org.quartz.impl.jdbcjobstore.JobStoreTX
  31. org.quartz.jobStore.driverDelegateClass:org.quartz.impl.jdbcjobstore.StdJDBCDelegate
  32. #使用自己的配置文件
  33. org.quartz.jobStore.useProperties:true
  34. #数据库中quartz表的表名前缀
  35. org.quartz.jobStore.tablePrefix:qrtz_
  36. org.quartz.jobStore.dataSource:qzDS
  37. #是否使用集群（如果项目只部署到 一台服务器，就不用了）
  38. org.quartz.jobStore.isClustered = true
  40. #============================================================================
  41. # Configure Datasources
  42. #============================================================================
  43. #配置数据源
  44. org.quartz.dataSource.qzDS.driver:com.mysql.jdbc.Driver
  45. org.quartz.dataSource.qzDS.URL:jdbc:mysql://10.4.33.251:3306/ecif_orgin
  46. org.quartz.dataSource.qzDS.user:reader1
  47. org.quartz.dataSource.qzDS.password:Reader12341
  48. org.quartz.dataSource.qzDS.maxConnection:10

 

3、在数据库中创建quartz相关的表

1）进入quartz的官网http://www.quartz-scheduler.org/，点击Downloads，下载后在目录\docs\dbTables下有常用数据库创建quartz表的脚本。

2）百度去搜创建quartz表

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

[java] view plain copy

  1. package com.nnfe.ecif.domain.bean;
  3. import org.quartz.spi.TriggerFiredBundle;
  4. import org.springframework.beans.factory.annotation.Autowired;
  5. import org.springframework.beans.factory.config.AutowireCapableBeanFactory;
  6. import org.springframework.scheduling.quartz.AdaptableJobFactory;
  7. import org.springframework.stereotype.Component;
  9. @Component
  10. public class MyJobFactory extends AdaptableJobFactory {
  12.       @Autowired
  13.       private AutowireCapableBeanFactory capableBeanFactory;
  15.       @Override
  16.       protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
  17.         Object jobInstance = super.createJobInstance(bundle);
  18.         capableBeanFactory.autowireBean(jobInstance); //这一步解决不能spring注入bean的问题
  19.         return jobInstance;
  20.       }
  22. }

5、创建调度器schedule

[java] view plain copy

  1. package com.nnfe.ecif.config;
  3. import java.io.IOException;
  4. import java.util.Properties;
  6. import org.quartz.Scheduler;
  7. import org.quartz.SchedulerException;
  8. import org.quartz.SchedulerFactory;
  9. import org.quartz.impl.StdSchedulerFactory;
  10. import org.springframework.beans.factory.annotation.Autowired;
  11. import org.springframework.beans.factory.config.PropertiesFactoryBean;
  12. import org.springframework.context.annotation.Bean;
  13. import org.springframework.context.annotation.Configuration;
  14. import org.springframework.core.io.ClassPathResource;
  15. import org.springframework.scheduling.quartz.SchedulerFactoryBean;
  17. import com.nnfe.ecif.domain.bean.MyJobFactory;
  19. @Configuration
  20. public class QuartzConfigration {
  22.      @Autowired
  23.      private MyJobFactory myJobFactory;  //自定义的factory

[java] view plain copy

  1. //获取工厂bean 
  2.     @Bean
  3.     public SchedulerFactoryBean schedulerFactoryBean() {
  4.       SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
  5.       try {
  6.         schedulerFactoryBean.setQuartzProperties(quartzProperties());
  7.         schedulerFactoryBean.setJobFactory(myJobFactory);
  8.     } catch (IOException e) {
  9.         // TODO Auto-generated catch block
  10.         e.printStackTrace();
  11.     }
  12.       return schedulerFactoryBean;
  13.     }

[java] view plain copy

  1. //指定quartz.properties
  2.     @Bean
  3.     public Properties quartzProperties() throws IOException {
  4.         PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
  5.         propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
  6.         propertiesFactoryBean.afterPropertiesSet();
  7.         return propertiesFactoryBean.getObject();
  8.     }
  10. //创建schedule  
  11.     @Bean(name = "scheduler")
  12.     public Scheduler scheduler() {
  13.       return schedulerFactoryBean().getScheduler();
  14.     }
  15. }

 

6、更新quartz中的任务

首先我们需要自己创建一张表，用来存放trigger的信息，然后从数据库读取这些信息来随时更新定时任务

现在我的数据库中有两个定时任务，注意：job_name存放的任务类的全路径，在quartz中通过jobName和jobGroup来确定trigger的唯一性，所以这两列为联合唯一索引。

接着创建实体类：

[java] view plain copy

  1. import javax.persistence.Column;
  2. import javax.persistence.Entity;
  3. import javax.persistence.GeneratedValue;
  4. import javax.persistence.GenerationType;
  5. import javax.persistence.Id;
  6. import javax.persistence.Table;
  8. import org.hibernate.annotations.GenericGenerator;
  10. @Entity
  11. @Table(name = "c_schedule_triggers")
  12. public class CScheduleTrigger {
  13.     @Id
  14.     @GenericGenerator(name = "mysqlNative", strategy = "native")
  15.     @GeneratedValue(generator = "mysqlNative")
  16.       private Integer id;
  18.       @Column
  19.       private String cron;  //时间表达式
  21.       private String status; //使用状态 0：禁用   1：启用
  23.       private String jobName; //任务名称
  25.       private String jobGroup; //任务分组

 

更新quartz中的任务

[html] view plain copy

  1. package com.nnfe.ecif.domain.service.impl;
  3. import java.util.List;
  5. import org.quartz.CronScheduleBuilder;
  6. import org.quartz.CronTrigger;
  7. import org.quartz.Job;
  8. import org.quartz.JobBuilder;
  9. import org.quartz.JobDetail;
  10. import org.quartz.JobKey;
  11. import org.quartz.Scheduler;
  13. import org.quartz.TriggerBuilder;
  14. import org.quartz.TriggerKey;
  15. import org.slf4j.Logger;
  16. import org.slf4j.LoggerFactory;
  17. import org.springframework.beans.factory.annotation.Autowired;
  18. import org.springframework.context.annotation.Configuration;
  19. import org.springframework.scheduling.annotation.EnableScheduling;
  20. import org.springframework.scheduling.annotation.Scheduled;
  21. import org.springframework.stereotype.Component;
  22. import org.springframework.stereotype.Service;
  24. import com.nnfe.ecif.domain.orm.w.CScheduleTriggerRepository;
  25. import com.nnfe.ecif.domain.orm.w.CScheduleTrigger;
  26. import com.nnfe.ecif.domain.service.ScheduleTriggerService;
  28. @Service
  29. public class ScheduleTriggerServiceImpl implements ScheduleTriggerService{
  30.     private static final Logger logger =  LoggerFactory.getLogger(ScheduleTriggerServiceImpl.class);
  31.     @Autowired
  32.     private Scheduler scheduler;
  34.     @Autowired
  35.     private CScheduleTriggerRepository triggerRepository;
  37.     @Override
  38.     @Scheduled(cron="0 0 23:00 * * ?")  //每天晚上11点调用这个方法来更新quartz中的任务
  39.     public void refreshTrigger() {
  40.         try {
  41.             //查询出数据库中所有的定时任务
  42.             List<CScheduleTrigger> jobList = triggerRepository.queryAll();
  43.             if(jobList!=null){
  44.                 for(CScheduleTrigger scheduleJob : jobList){
  45.                     String status = scheduleJob.getStatus(); //该任务触发器目前的状态
  46.                     TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
  47.                     CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
  48.                      //说明本条任务还没有添加到quartz中
  49.                     if (null == trigger) {
  50.                         if(status.equals("0")){ //如果是禁用，则不用创建触发器
  51.                             continue;
  52.                         }
  54.                         JobDetail jobDetail=null;
  55.                         try {
  56.                             //创建JobDetail（数据库中job_name存的任务全路径，这里就可以动态的把任务注入到JobDetail中）
  57.                             jobDetail = JobBuilder.newJob((Class<? extends Job>) Class.forName(scheduleJob.getJobName()))
  58.                                 .withIdentity(scheduleJob.getJobName(), scheduleJob.getJobGroup()).build();
  60.                             //表达式调度构建器
  61.                             CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob
  62.                                 .getCron());
  64.                             //按新的cronExpression表达式构建一个新的trigger
  65.                             trigger = TriggerBuilder.newTrigger().withIdentity(scheduleJob.getJobName(), scheduleJob.getJobGroup()).withSchedule(scheduleBuilder).build();
  67.                             //把trigger和jobDetail注入到调度器
  68.                             scheduler.scheduleJob(jobDetail, trigger);
  69.                         } catch (ClassNotFoundException e) {
  70.                             // TODO Auto-generated catch block
  71.                             e.printStackTrace();
  72.                         }
  74.                     } else {  //说明查出来的这条任务，已经设置到quartz中了
  75.                         // Trigger已存在，先判断是否需要删除，如果不需要，再判定是否时间有变化
  76.                         if(status.equals("0")){ //如果是禁用，从quartz中删除这条任务
  77.                             JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());
  78.                             scheduler.deleteJob(jobKey);
  79.                             continue;
  80.                         }
  81.                         String searchCron = scheduleJob.getCron(); //获取数据库的
  82.                         String currentCron = trigger.getCronExpression();
  83.                         if(!searchCron.equals(currentCron)){  //说明该任务有变化，需要更新quartz中的对应的记录
  84.                             //表达式调度构建器
  85.                             CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(searchCron);
  87.                             //按新的cronExpression表达式重新构建trigger
  88.                             trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)
  89.                                 .withSchedule(scheduleBuilder).build();
  91.                             //按新的trigger重新设置job执行
  92.                             scheduler.rescheduleJob(triggerKey, trigger);
  93.                         }
  94.                     }
  95.                 }
  96.             }
  97.         } catch (Exception e) {
  98.            logger.error("定时任务每日刷新触发器任务异常，在ScheduleTriggerServiceImpl的方法refreshTrigger中，异常信息：",e);
  99.         }
  100.     }

 

7、自定义任务

[html] view plain copy

  1. @Component
  2. public class MyTask1 implements Job{
  3.     //这里就可以通过spring注入bean了
  4.     @Autowired
  5.     private CScheduleTriggerRepository jobRepository;
  7.     @Autowired
  8.     private CScheduleRecordsRepository recordsRepository;
  10.     @Override
  11.     public void execute(JobExecutionContext context)
  12.             throws JobExecutionException {
  13.         boolean isExecute = false;  //是否已执行业务逻辑
  14.         boolean flag = false;  //业务逻辑执行后返回结果
  15.         try{
  16.             //可以通过context拿到执行当前任务的quartz中的很多信息，如当前是哪个trigger在执行该任务
  17.             CronTrigger trigger = (CronTrigger) context.getTrigger();
  18.             String corn = trigger.getCronExpression();
  19.             String jobName = trigger.getKey().getName();
  20.             String jobGroup = trigger.getKey().getGroup();

 

要搞清楚一个问题：从数据库读取任务信息动态生成定时任务，和把quartz持久化到数据库是没有关系的。

前者是我们自己定义的业务表，而后者是quartz使用自己的表来存储信息。持久化到数据库后，就算服务器重启或是多个quartz节点也没关系，因为他们共享数据库中的任务信息。

文章标签：
云数据库 RDS MySQL 版
Java
数据库
Spring
调度
相关实践学习
每个IT人都想学的“Web应用上云经典架构”实战
本实验从Web应用上云这个最基本的、最普遍的需求出发，帮助IT从业者们通过“阿里云Web应用上云解决方案”，了解一个企业级Web应用上云的常见架构，了解如何构建一个高可用、可扩展的企业级应用架构。
MySQL数据库入门学习
本课程通过最流行的开源数据库MySQL带你了解数据库的世界。 &nbsp; 相关的阿里云产品：云数据库RDS MySQL 版 阿里云关系型数据库RDS（Relational Database Service）是一种稳定可靠、可弹性伸缩的在线数据库服务，提供容灾、备份、恢复、迁移等方面的全套解决方案，彻底解决数据库运维的烦恼。 了解产品详情:&nbsp;https://www.aliyun.com/product/rds/mysql&nbsp;
优惠码发放
目录
相关文章
一枚后端工程狮
|
前端开发 Java 应用服务中间件
《深入理解Spring》 Spring Boot——约定优于配置的革命者
Spring Boot基于“约定优于配置”理念，通过自动配置、起步依赖、嵌入式容器和Actuator四大特性，简化Spring应用的开发与部署，提升效率，降低门槛，成为现代Java开发的事实标准。
一枚后端工程狮
1381 6
一枚后端工程狮
|
前端开发 Java 微服务
《深入理解Spring》：Spring、Spring MVC与Spring Boot的深度解析
Spring Framework是Java生态的基石，提供IoC、AOP等核心功能；Spring MVC基于其构建，实现Web层MVC架构；Spring Boot则通过自动配置和内嵌服务器，极大简化了开发与部署。三者层层演进，Spring Boot并非替代，而是对前者的高效封装与增强，适用于微服务与快速开发，而深入理解Spring Framework有助于更好驾驭整体技术栈。
一枚后端工程狮
2587 5
凉凉心.
|
XML Java 应用服务中间件
【SpringBoot（一）】Spring的认知、容器功能讲解与自动装配原理的入门，带你熟悉Springboot中基本的注解使用
SpringBoot专栏开篇第一章，讲述认识SpringBoot、Bean容器功能的讲解、自动装配原理的入门，还有其他常用的Springboot注解！如果想要了解SpringBoot，那么就进来看看吧！
凉凉心.
978 2
varin
|
人工智能 Java 机器人
基于Spring AI Alibaba + Spring Boot + Ollama搭建本地AI对话机器人API
Spring AI Alibaba集成Ollama，基于Java构建本地大模型应用，支持流式对话、knife4j接口可视化，实现高隐私、免API密钥的离线AI服务。
varin
7881 2
基于Spring AI Alibaba + Spring Boot + Ollama搭建本地AI对话机器人API
云流雨洄
|
缓存 Java 应用服务中间件
Spring Boot配置优化：Tomcat+数据库+缓存+日志，全场景教程
本文详解Spring Boot十大核心配置优化技巧，涵盖Tomcat连接池、数据库连接池、Jackson时区、日志管理、缓存策略、异步线程池等关键配置，结合代码示例与通俗解释，助你轻松掌握高并发场景下的性能调优方法，适用于实际项目落地。
云流雨洄
2081 5
存储 JSON Java
1133 0
aliyun4145988376
|
人工智能 Java 开发者
【Spring】原理解析：Spring Boot 自动配置
Spring Boot通过“约定优于配置”的设计理念，自动检测项目依赖并根据这些依赖自动装配相应的Bean，从而解放开发者从繁琐的配置工作中解脱出来，专注于业务逻辑实现。
aliyun4145988376
3160 0
微服务和网关
|
安全 Java Nacos
0代码改动实现Spring应用数据库帐密自动轮转
Nacos作为国内被广泛使用的配置中心，已经成为应用侧的基础设施产品，近年来安全问题被更多关注，这是中国国内软件行业逐渐迈向成熟的标志，也是必经之路，Nacos提供配置加密存储-运行时轮转的核心安全能力，将在应用安全领域承担更多职责。
微服务和网关
554 1
蓝易云
|
SQL XML Java
配置Spring框架以连接SQL Server数据库
最后，需要集成Spring配置到应用中，这通常在 `main`方法或者Spring Boot的应用配置类中通过加载XML配置或使用注解来实现。
蓝易云
892 0

热门文章

最新文章

  • 1
    Spring3 升级Spring 4
  • 2
    如何基于Nacos实现分布式配置中心？ | 带你读《Spring Cloud Alibaba（2019）》之七
  • 3
    阿里云工程师跟通义灵码结伴编程， 用Spring AI Alibaba来开发 AI 答疑助手
  • 4
    Spring Cloud Alibaba 2022.0.0.0 版本发布啦！
  • 5
    浅述 Spring / SpringMVC 框架中用到的哪些设计模式（下）
  • 6
    Spring Boot Servlet
  • 7
    Spring AOP配置文件引入
  • 8
    如何快速搭建一个 Spring Boot 项目？
  • 9
    springboot自定义拦截器的简单使用和一个小例子
  • 10
    Ehcache整合spring配置
  • 1
    SpringBoot启动时连接Redis报错：ERR This instance has cluster support disabled - 如何解决？
    873
  • 2
    基于springboot的大学生兼职系统
    792
  • 3
    基于springboot的宠物领养系统
    938
  • 4
    2025基于springboot的校车预定全流程管理系统
    976
  • 5
    基于springboot的美食城服务管理系统
    708
  • 6
    基于springboot的高校运动会系统
    654
  • 7
    【Spring Boot实战】EasyPoi神技：一篇搞定“一对多+图片”导入！
    2620
  • 8
    《深入理解Spring》 Spring Boot——约定优于配置的革命者
    1381
  • 9
    《深入理解Spring》：Spring、Spring MVC与Spring Boot的深度解析
    2587
  • 10
    基于springboot的网咖网吧管理系统
    838

    • 相关课程

    更多
  • 瑶池数据库 Data Agent 入门实战课
  • 开源PolarDB分布式版部署实操
  • 阿里云DAS-您的专属AI专家，引领数据库自治驾驶
  • 数据库仓库升级交付实践指引
  • 数据库开源校企合作“数据库内核从入门到精通 ”系列课

    • 相关电子书

    更多
  • 国产数据库研制人才培养实践
  • 阿里云&信通院《Serverless数据库技术研究报告》
  • DTCC 2022大会集锦《云原生一站式数据库技术与实践》

    • 相关实验场景

    更多
  • 自建数据库迁移到云数据库
  • 使用DAS实现数据库SQL优化
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！