Springboot 开发之任务调度框架（一）Quartz 简介

一、引言

常见的定时任务框架有 Quartz、elastic-job、xxl-job等等，本文主要介绍 Spirng Boot 集成 Quartz 定时任务框架。

在这里插入图片描述

二、Quartz 简介

Quartz 是一个功能强大且灵活的开源作业调度库，广泛用于 Java 应用中。它允许开发者创建复杂的调度任务，包括简单的周期性任务和复杂的日程安排。Quartz 支持多种类型的任务调度，包括按时间间隔、特定时间点、日历时间和其他复杂的时间表达式。

主要特性:

  • 丰富的调度表达式：支持 Cron 表达式，可以非常灵活地定义任务的调度时间。
  • 持久化支持：Quartz 支持将调度任务存储到数据库中，以保证任务在应用重启后能够继续执行。
  • 集群支持：Quartz 可以在集群环境中运行，提供高可用性和负载均衡功能。
  • 多种触发器：支持多种触发器，包括简单触发器、Cron触发器等。
  • 任务监听器：支持任务的监听器，能够在任务执行前后执行一些额外操作。

二、在 Spring Boot 中集成 Quartz

在 Spring Boot 中集成 Quartz 非常简单，Spring 提供了对 Quartz 的良好支持。以下是一个简单的例子，展示如何在 Spring Boot 项目中使用 Quartz。

步骤 1: 添加依赖

pom.xml 文件中添加以下依赖：

<dependency><groupId>org.springframework.boot</groupId><artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

步骤 2: 创建一个任务

定义一个简单的 Quartz 任务类：

package com.example.demo;import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.springframework.stereotype.Component;@Component
public class SampleJob implements Job {@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {System.out.println("Executing Sample Job at " + System.currentTimeMillis());}
}

步骤 3: 配置 Quartz

在 Spring Boot 中配置 Quartz 调度器。可以在 application.properties 或 application.yml 文件中进行配置，也可以通过代码配置。

# 指定Quartz使用的作业存储类型为内存（RAMJobStore），这意味着所有的作业和触发器信息都将存储在内存中。
# 这种方式的存取速度较快，但在系统重启后，所有数据将会丢失，因此它不适合需要持久化作业信息的集群环境。
spring.quartz.job-store-type=memory# 设置Quartz Scheduler的名称，用于区分不同的Scheduler实例。
spring.quartz.scheduler-name=SampleScheduler# 配置当应用启动时，如果检测到已存在的作业（job）与配置的作业相同，则允许覆盖它们。
# 这可以避免在修改作业后需要手动删除数据库中的相关记录。
spring.quartz.overwrite-existing-jobs=true# 配置Quartz线程池的线程数量，这里设置为5
spring.quartz.properties.org.quartz.threadPool.threadCount=5

步骤 4: 创建作业详情和触发器

通过 Java 配置类创建调度任务：

package com.example.demo;  import org.quartz.JobBuilder;  
import org.quartz.JobDetail;  
import org.quartz.SimpleScheduleBuilder;  
import org.quartz.Trigger;  
import org.quartz.TriggerBuilder;  
import org.springframework.context.annotation.Bean;  
import org.springframework.context.annotation.Configuration;  // 这是一个Spring配置类，用于定义Quartz的JobDetail和Trigger  
@Configuration  
public class QuartzConfig {  // 定义一个Bean，用于创建JobDetail实例  // JobDetail描述了Quartz要执行的具体任务  @Bean  public JobDetail sampleJobDetail() {  // 使用JobBuilder来构建一个JobDetail实例  // newJob(SampleJob.class)指定了实际要执行的Job类为SampleJob  // withIdentity("sampleJob")为这个JobDetail设置了一个唯一标识符  // storeDurably()使得JobDetail即使在没有Trigger关联的情况下也能被存储  return JobBuilder.newJob(SampleJob.class)  .withIdentity("sampleJob")  .storeDurably()  .build(); // 构建并返回JobDetail实例  }  // 定义一个Bean，用于创建Trigger实例（触发器）  // Trigger描述了JobDetail的执行计划，即何时开始执行、执行的频率等  @Bean  public Trigger sampleJobTrigger() {  // 使用SimpleScheduleBuilder来构建一个简单的调度计划  // withIntervalInSeconds(10)设置了任务执行的间隔为10秒  // repeatForever()表示任务将无限次重复执行  SimpleScheduleBuilder scheduleBuilder = SimpleScheduleBuilder.simpleSchedule()  .withIntervalInSeconds(10)  .repeatForever();  // 使用TriggerBuilder来构建Trigger实例  // forJob(sampleJobDetail())指定了Trigger关联的JobDetail为之前定义的sampleJobDetail  // withIdentity("sampleTrigger")为这个Trigger设置了一个唯一标识符  // withSchedule(scheduleBuilder)设置了之前定义的调度计划  return TriggerBuilder.newTrigger()  .forJob(sampleJobDetail()) // 注意这里通常使用JobDetail的引用而不是方法调用，但在这个例子里也可以  .withIdentity("sampleTrigger")  .withSchedule(scheduleBuilder)  .build(); // 构建并返回Trigger实例  }  
}

步骤 5: 启动应用

启动 Spring Boot 应用程序，Quartz 调度器会自动启动，并按照配置的调度策略执行任务。

三、持久化配置

  1. 在 application.properties 文件中加入 Quartz 相关配置。
# 将 Quartz 持久化方式修改为 jdbc
spring.quartz.job-store-type=jdbc
# 实例名称（默认为quartzScheduler）
spring.quartz.properties.org.quartz.scheduler.instanceName=SC_Scheduler
# 实例节点 ID 自动生成
spring.quartz.properties.org.quartz.scheduler.instanceId=AUTO
# 修改存储内容使用的类
spring.quartz.properties.org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
# 数据源信息
spring.quartz.properties.org.quartz.jobStore.dataSource=quartz_jobs
spring.quartz.properties.org.quartz.dataSource.quartz_jobs.driver=com.mysql.cj.jdbc.Driver
spring.quartz.properties.org.quartz.dataSource.quartz_jobs.URL=jdbc:mysql://127.0.0.1:3306/quartz_jobs?serverTimezone=UTC&useUnicode=true&characterEncoding=UTF-8
spring.quartz.properties.org.quartz.dataSource.quartz_jobs.user=root
spring.quartz.properties.org.quartz.dataSource.quartz_jobs.password=123456
  1. 初始化 Quartz 数据表信息

下载 Quartz 发布包，下载完成后，解压缩进入 quartz-2.2.3/docs/dbTables 目录，找到匹配数据库的 SQL 文件

下载地址：
https://www.quartz-scheduler.org/downloads/files/quartz-2.2.3-distribution.tar.gz

然后在数据库中执行 tables-mysql.sql 初始化脚本。

四、总结

通过以上步骤，可以在 Spring Boot 应用中成功集成并使用 Quartz 来进行任务调度。Quartz 的强大之处在于其灵活性和可扩展性，能够满足各种复杂的任务调度需求。在实际应用中，可以根据具体需求配置更多的 Quartz 特性，如持久化、集群等。

  • 在生产环境中，需要配置 Quartz 的持久化选项，以便在应用程序重启后仍然可以恢复调度任务的状态。
  • 可以使用 @Autowired 将 Scheduler 注入到你的服务或组件中，以动态地添加、删除或更新作业和触发器。
  • Quartz 还提供了很多其他的功能和选项，如监听器、插件、作业恢复等

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：http://www.mzph.cn/pingmian/26087.shtml

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

【Jenkins+K8s】持续集成与交付 （二十）：K8s集群通过Deployment方式部署安装Jenkins

【Jenkins+K8s】持续集成与交付 （二十）：K8s集群通过Deployment方式部署安装Jenkins

🟣【Jenkins+K8s】持续集成与交付 （二十）：K8s集群通过Deployment方式部署安装Jenkins 一、 准备工作二、安装 Jenkins2.1 设置NFS共享目录2.2 创建名称空间2.3 创建持久化卷和声明2.4 创建sa账号2.5 对sa账号授权2.6 通过Deployment方式部署Jenkins2.7 查看Jenkins是否创建…
阅读更多...
AdroitFisherman模块测试日志(2024/6/10)

AdroitFisherman模块测试日志(2024/6/10)

测试内容 测试AdroitFisherman分发包中SHAUtil模块。 测试用具 Django5.0.3框架&#xff0c;AdroitFisherman0.0.31 项目结构 路由设置 总路由 from django.contrib import admin from django.urls import path,include from Base64Util import urls urlpatterns [path(ad…
阅读更多...
SCRM的全面了解

SCRM的全面了解

一、什么是SCRM SCRM&#xff08;Social CRM&#xff0c;社会化客户关系管理&#xff09;&#xff0c;是以用户为中心&#xff0c;通过社交平台与用户建立联系&#xff0c;以内容、活动、客服、商城等服务吸引用户注意力&#xff0c;并不断与用户产生互动&#xff0c;实现用户…
阅读更多...
【Oracle篇】rman时间点异机恢复：从RAC环境到单机测试环境的转移（第六篇，总共八篇）

【Oracle篇】rman时间点异机恢复：从RAC环境到单机测试环境的转移（第六篇，总共八篇）

&#x1f4ab;《博主介绍》&#xff1a;✨又是一天没白过&#xff0c;我是奈斯&#xff0c;DBA一名✨ &#x1f4ab;《擅长领域》&#xff1a;✌️擅长Oracle、MySQL、SQLserver、阿里云AnalyticDB for MySQL(分布式数据仓库)、Linux&#xff0c;也在扩展大数据方向的知识面✌️…
阅读更多...
谷歌AI助力软件工程的进展及未来展望

谷歌AI助力软件工程的进展及未来展望

每周跟踪AI热点新闻动向和震撼发展 想要探索生成式人工智能的前沿进展吗&#xff1f;订阅我们的简报&#xff0c;深入解析最新的技术突破、实际应用案例和未来的趋势。与全球数同行一同&#xff0c;从行业内部的深度分析和实用指南中受益。不要错过这个机会&#xff0c;成为AI领…
阅读更多...
OpenAI 宕机事件：GPT 停摆的影响与应对

OpenAI 宕机事件：GPT 停摆的影响与应对

引言 2024年6月4日&#xff0c;OpenAI 的 GPT 模型发生了一次全球性的宕机&#xff0c;持续时间长达8小时。此次宕机不仅影响了OpenAI自家的服务&#xff0c;还导致大量用户涌向竞争对手平台&#xff0c;如Claude和Gemini&#xff0c;结果也导致这些平台出现故障。这次事件的广…
阅读更多...
lua网站开发中如何制作自定义模块

lua网站开发中如何制作自定义模块

自定义模块是FastWeb框架的重要拓展功能&#xff0c;用来扩展和增强服务的能力。通过自定义模块&#xff0c;开发者可以轻松添加特定的功能和特性&#xff0c;使得网站开发更加灵活和高效。本文将演示如何添加自己的模块作为FastWeb的拓展&#xff0c;为框架的壮大与支持提供重…
阅读更多...
在 Word 中，如何有效调整文字与下划线之间的距离

在 Word 中，如何有效调整文字与下划线之间的距离

&#x1f349; CSDN 叶庭云&#xff1a;https://yetingyun.blog.csdn.net/ 如果你在使用 Word 时&#xff0c;希望调整文字和下划线之间的距离&#xff0c;让它们看起来更加美观&#xff0c;可以按照以下步骤操作&#xff1a; 1. 在你想要加下划线的文字前后各加一个空格&…
阅读更多...
c++【入门】米老鼠偷糖果

c++【入门】米老鼠偷糖果

限制 时间限制 : 1 秒 内存限制 : 128 MB 题目 米老鼠发现了厨房放了n颗糖果&#xff0c;它一次可以背走a颗&#xff0c;请问米老鼠背了x次之后还剩多少颗&#xff1f;&#xff08;假设x次之后一定有糖果剩下&#xff09; 输入 三个整数n、a、x分别代表总共有n颗糖果&…
阅读更多...
在windows10 安装子系统linux（WSL安装方式）

在windows10 安装子系统linux（WSL安装方式）

在 windows 10 平台采用了WSL安装方式安装linux子系统 1 查找自己想要安装的linux子系统 wsl --list --online 2 在线安装 个人用Debian比较多&#xff0c;这里选择Debian&#xff0c;如下图&#xff1a; wsl --install -d Debian 安装过程中有一步要求输入用户名与密码&…
阅读更多...
使用Vue CLI在其他磁盘创建项目出现错误及解决

使用Vue CLI在其他磁盘创建项目出现错误及解决

Vue CLI是Vue.js官方推出的脚手架工具&#xff0c;可以帮我们快速的创建Vue项目框架。 我们创建Vue项目时一般默认都是在C盘&#xff0c;但由于某些因素我们需要在其他磁盘上创建Vue项目。 通过“winr”打开终端时默认位置都是C盘&#xff0c;但是Vue CLI不接受绝对路径作为参…
阅读更多...
802.11漫游流程简单解析与笔记_Part3

802.11漫游流程简单解析与笔记_Part3

原定计划在Part3分析ns3的Roaming流程抓包&#xff0c;但ns3并不支持漫游&#xff1a; 看过Part1的应该都知道&#xff0c;标准关联流程是auth*2 associate*2 key*4&#xff0c;但ns3里面没有与auth有关的部分&#xff0c;third脚本里面有cap字段&#xff0c;但无auth也无key&a…
阅读更多...
LabVIEW图像采集处理项目中相机选择与应用

LabVIEW图像采集处理项目中相机选择与应用

在LabVIEW图像采集处理项目中&#xff0c;选择合适的相机是确保项目成功的关键。本文将详细探讨相机选择时需要关注的参数、黑白相机与彩色相机的区别及其适用场合&#xff0c;帮助工程师和开发者做出明智的选择。 相机选择时需要关注的参数 1. 分辨率 定义&#xff1a;分辨率…
阅读更多...
HDFS 读写数据流程

HDFS 读写数据流程

优质博文&#xff1a;IT-BLOG-CN 一、HDFS 写数据流程 HDFS 文件写入流程图如下&#xff1a;三个模块&#xff08;客户端、NameNode、DataNode&#xff09; 【1】校验&#xff1a; 客户端通过 DistributedFileSystem 模块向 NameNode 请求上传文件&#xff0c;NameNode 会检…
阅读更多...
视频点播系统的设计

视频点播系统的设计

管理员账户功能包括&#xff1a;系统首页&#xff0c;个人中心&#xff0c;管理员管理&#xff0c;客服聊天管理&#xff0c;基础数据管理&#xff0c;论坛管理&#xff0c;公告管理 前台账户功能包括&#xff1a;系统首页&#xff0c;个人中心&#xff0c;论坛&#xff0c;视…
阅读更多...
6.8 c语言

6.8 c语言

6.2 格式输出函数 格式控制符&#xff0c;输出表(输出对象) %e:指数形式浮点小数 m :输出数据域宽&#xff0c;数据长度<m,左补空格&#xff1b;否则按实际输出 .n:对字符串&#xff0c;指定实际输出位数 #include <stdio.h> int main() {char a[] "hello,wor…
阅读更多...
【代码随想录训练营】【Day 45】【动态规划-5】| Leetcode 1049, 494, 474

【代码随想录训练营】【Day 45】【动态规划-5】| Leetcode 1049, 494, 474

【代码随想录训练营】【Day 45】【动态规划-5】| Leetcode 1049, 494, 474 需强化知识点 题目 1049. 最后一块石头的重量 II 代码随想录思路&#xff1a;尽量让石头分成重量相同的两堆&#xff0c;相撞之后剩下的石头最小&#xff0c;这样就化解成01背包问题了为什么两两单…
阅读更多...
pdf压缩到指定大小的简单方法

pdf压缩到指定大小的简单方法

压缩PDF文件是许多人在日常工作和学习中经常需要面对的问题。PDF文件因其跨平台、易阅读的特性而广受欢迎&#xff0c;但有时候文件体积过大&#xff0c;会给传输和存储带来不便。因此&#xff0c;学会如何有效地压缩PDF文件&#xff0c;就显得尤为重要。本文将详细介绍几种常见…
阅读更多...
课时151：项目发布_基础知识_技术要点

课时151：项目发布_基础知识_技术要点

1.1.3 技术要点 学习目标 这一节&#xff0c;我们从 解压缩、传输、备份、小结 三个方面来学习 解压缩 简介 文件的压缩压缩格式&#xff1a;tar zcvf 压缩后的文件名 将要压缩的文件 文件的解压解压格式&#xff1a;tar xf 压缩后的文件名 查看压缩文件内容查看格式&…
阅读更多...
Linux跨发行版软件包管理工具：AppImage、Snap和Flatpak

Linux跨发行版软件包管理工具：AppImage、Snap和Flatpak

Linux跨发行版软件包管理工具&#xff1a;AppImage、Snap和Flatpak Linux操作系统以其灵活性和强大的社区支持而闻名。随着Linux在各个领域的应用日益广泛&#xff0c;跨发行版的软件包管理工具应运而生&#xff0c;它们提供了一种简便的方法来安装、运行和管理应用程序&#…
阅读更多...
最新文章

Copyright @ 2022~2023