Loading [MathJax]/jax/output/CommonHTML/config.js
首页
学习
活动
专区
圈层
工具
发布
首页
学习
活动
专区
圈层
工具
MCP广场
社区首页 >专栏 >SpringBoot Quartz实现动态定时任务

SpringBoot Quartz实现动态定时任务

作者头像
jwangkun
发布于 2021-12-23 09:27:37
发布于 2021-12-23 09:27:37
2.4K00
代码可运行
举报
文章被收录于专栏:John Wong's BlogJohn Wong's Blog
运行总次数:0
代码可运行

Quartz是一个定时任务的调度框架,涉及到的主要概念有以下几个:

Scheduler:调度器,所有的调度都由它控制,所有的任务都由它管理。

Job:任务,定义业务逻辑。

JobDetail:基于Job,进一步封装。其中关联一个Job,并为Job指定更详细的信息。

Trigger:触发器,可以指定给某个任务,指定任务的触发机制。

一 创建简单任务

1.1 Quartz依赖

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
<dependency>
    <groupId>org.springframework.boot</groupId>
    <artifactId>spring-boot-starter-quartz</artifactId>
</dependency>

1.2 创建任务

任务创建需要实现Job接口,重写execute(JobExecutionContext jobExecutionContext)方法,增加定时任务的业务逻辑,这里我只是简单的打印一下定时任务执行。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@Slf4j
public class SimpleJob implements Job {
    @Override
    public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
        log.info("job execute---"+new Date());
    }
}

1.3 JobDetail增加属性

这里增加的属性可以在Job实现类中获取,来处理业务。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
JobDetail jobDetail = JobBuilder.newJob(SimpleJob.class)
                                // 任务标识,及任务分组
                                .withIdentity("job1", "group1")
                                // 链接调用,增加需要的参数
                                .usingJobData("name","Java旅途")
                                .usingJobData("age",18)
                                .build();

1.4 Trigger实现

Trigger分为两种,SimpleTriggerCronTriggerSimpleTrigger是根据Quartz的一些api实现的简单触发行为。CronTrigger用的比较多,使用cron表达式进行触发。这里先用SimpleTrigger来实现。

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
SimpleTrigger simpleTrigger = TriggerBuilder.newTrigger()
                                            .withIdentity("trigger1", "group1")
                                            // 立即执行
                                            .startNow()
                                            // 10s后停止
                                            .endAt(new Date(System.currentTimeMillis()+10*1000))
                                            .withSchedule(
                                            SimpleScheduleBuilder.simpleSchedule()
                                            // 每秒执行一次
                                            .withIntervalInSeconds(1)
                                            // 一直执行
                                            .repeatForever()
                                            ).build();

1.5 启动任务

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@Autowired
private Scheduler scheduler;

scheduler.scheduleJob(jobDetail,simpleTrigger);

1.6 执行效果

启动项目后,任务立即执行,每秒执行一次,10s后停止,执行效果图如下:

二 动态操作定时任务

有时候除了已经开发好的定时任务外,还需要我们手动去创建任务并且控制任务的执行。

2.1 创建任务

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@GetMapping("create")
public void createJob(String jobName,String jobGroup,String cron,String triggerName,String triggerGroup) throws SchedulerException {

    JobKey jobKey = new JobKey(jobName,jobGroup);
    // 如果存在这个任务,则删除
    if(scheduler.checkExists(jobKey)) {
        scheduler.deleteJob(jobKey);
    }

    JobDetail jobDetail = JobBuilder.newJob(SimpleJob.class)
        .withIdentity(jobKey)
        .build();

    CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(cron);

    Trigger trigger = TriggerBuilder.newTrigger()
        .withIdentity(triggerName,triggerGroup)
        .withSchedule(cronScheduleBuilder).build();
    scheduler.scheduleJob(jobDetail,trigger);
}

2.2 暂停任务

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@GetMapping("pause")
public void pauseJob(String jobName,String jobGroup) throws SchedulerException {

    JobKey jobKey = JobKey.jobKey(jobName, jobGroup);
    JobDetail jobDetail = scheduler.getJobDetail(jobKey);
    if (jobDetail == null) {
        return;
    }
    scheduler.pauseJob(jobKey);
}

2.3 恢复暂停的任务

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@GetMapping("remuse")
public void remuseJob(String jobName, String jobGroup) throws SchedulerException {
    JobKey jobKey = JobKey.jobKey(jobName, jobGroup);
    JobDetail jobDetail = scheduler.getJobDetail(jobKey);
    if (jobDetail == null) {
        return;
    }
    scheduler.resumeJob(jobKey);
}

2.4 删除定时任务

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
@GetMapping("remove")
public void removeJob(String jobName, String jobGroup,String triggerName,String triggerGroup) throws SchedulerException {

    TriggerKey triggerKey = TriggerKey.triggerKey(triggerName, triggerGroup);
    JobKey jobKey = JobKey.jobKey(jobName, jobGroup);
    Trigger trigger =  scheduler.getTrigger(triggerKey);
    if (trigger == null) {
        return;
    }
    // 停止触发器
    scheduler.pauseTrigger(triggerKey);
    // 移除触发器
    scheduler.unscheduleJob(triggerKey);
    // 删除任务
    scheduler.deleteJob(jobKey);
}

三 任务持久化

Quartz默认使用RAMJobStore存储方式将任务存储在内存中,除了这种方式还支持使用JDBC将任务存储在数据库,为了防止任务丢失,我们一般会将任务存储在数据库中。

这里使用mysql进行存储,在quartz的源码包中找到文件tables_mysql_innodb.sql,然后在客户端进行运行sql文件。如果嫌源码包不好下载的话,我已经将sql文件上传至GitHub了,可以直接访问github拉去表结构,数据表如下:

3.1 增加mysql和jdbc依赖

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
<dependency>
    <groupId>mysql</groupId>
    <artifactId>mysql-connector-java</artifactId>
    <version>8.0.11</version>
</dependency>

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

3.2 指定使用jdbc存储

quartz默认使用memory存储,这里修改成jdbc进行存储,并配置jdbc的相关信息

代码语言:javascript
代码运行次数:0
运行
AI代码解释
复制
spring:
  quartz:
    job-store-type: jdbc
  datasource:
    driver-class-name: com.mysql.cj.jdbc.Driver
    url: jdbc:mysql://localhost:3306/simple_fast
    username: root
    password: root

3.3 创建任务

启动项目,调用create接口创建任务,然后数据表中就会新增任务相关的数据了。

下一篇: Spring Task实现简单定时任务→

本文参与 腾讯云自媒体同步曝光计划,分享自作者个人站点/博客。
原始发表:2020-11-10,如有侵权请联系 cloudcommunity@tencent.com 删除

本文分享自 作者个人站点/博客 前往查看

如有侵权,请联系 cloudcommunity@tencent.com 删除。

本文参与 腾讯云自媒体同步曝光计划  ,欢迎热爱写作的你一起参与!

评论
登录后参与评论
暂无评论
推荐阅读
编辑精选文章
换一批
​分布式定时任务框架Quartz
项目中总要写那么几个定时任务来处理一些事情。一些简单的定时任务使用Spring自带的定时任务就能完成。但是如果需要大量的定时任务的话要怎么才能统一管理呢?
乱敲代码
2020/05/21
4.9K0
spring-boot-route(二十一)Quartz实现动态定时任务
JobDetail:基于Job,进一步封装。其中关联一个Job,并为Job指定更详细的信息。
Java旅途
2020/10/21
6320
spring-boot-route(二十一)Quartz实现动态定时任务
重学SpringBoot3-整合Quartz定时任务
Quartz 是一个开源的任务调度框架,用于在应用程序中创建、管理和调度定时任务。将 Quartz 和 Spring Boot 3 结合,可以轻松实现定时任务的灵活管理。本文将详细介绍如何在 Spring Boot 3 项目中集成 Quartz Scheduler 并实现示例任务的调度。
CoderJia
2024/11/14
3390
重学SpringBoot3-整合Quartz定时任务
Quartz定时任务[通俗易懂]
job就是想要实现的任务类,每一个job必须实现job接口,且实现接口中的 excute()方法。
全栈程序员站长
2022/08/02
9320
Quartz定时任务[通俗易懂]
SpringBoot 整合 Quartz 实现 JAVA 定时任务的动态配置
首先说下这次主题,动态配置。没接触过定时任务的同学可以先看下此篇:JAVA定时任务实现的几种方式
业余草
2020/07/17
2.3K0
SpringBoot 整合 Quartz 实现 JAVA 定时任务的动态配置
Quartz定时任务框架使用教程详解
Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,完全由Java开发,可以用来执行定时任务,类似于java.util.Timer。但是相较于Timer, Quartz增加了很多功能:
大忽悠爱学习
2021/12/07
2.4K0
Quartz定时任务框架使用教程详解
SpringBoot 整合 Quartz 实现 JAVA 定时任务的动态配置
来源:https://www.cnblogs.com/laoyeye/p/9352002.html老爷爷的博客园
java进阶架构师
2020/10/23
8650
SpringBoot 整合 Quartz 实现 JAVA 定时任务的动态配置
springboot动态定时任务小案例
大家好,我是麦洛,大家想了解springboot动态定时任务的实现方法示例的相关内容吗?在本文为您仔细讲解springboot动态定时任务的相关知识和一些Code实例,欢迎阅读和指正,我们先划重点:
麦洛
2021/03/23
4560
springboot动态定时任务小案例
springboot使用quartz实现定时任务_quartz集群任务调度
springboot使用quartz实现定时任务_quartz集群任务调度前言本文是对之前的一篇文章Spring+SpringMVC+mybatis+Quartz整合代码部分做的一个修改和补充,其中最大的变化就是后台框架变成了SpringBoot。本工程所用到的技术或工具有:SpringBootMybatisQuartzPageHelperVueJSElementUIMySql数据库正文配置本例中仍然是使用mysql数据库作为Quartz任务持久化的
Java架构师必看
2022/05/10
3.2K2
springboot使用quartz实现定时任务_quartz集群任务调度
springboot整合quartz实现定时任务的动态修改,启动,暂停等操作
一个定时任务调度框架,简单易用,功能强大可以使实现定时任务的。 在项目开发过程当中,某些定时任务,可能在运行一段时间之后,就不需要了,或者需要修改下定时任务的执行时间等等。 需要在代码当中进行修改然后重新打包发布,很麻烦。使用Quartz来实现的话不需要重新修改代码而达到要求。
海加尔金鹰
2020/06/09
19.6K5
定时任务框架Quartz-(一)Quartz入门与Demo搭建
大部分公司都会用到定时任务这个功能。 拿火车票购票来说,当你下单后,后台就会插入一条待支付的task(job),一般是30分钟,超过30min后就会执行这个job,去判断你是否支付,未支付就会取消此次订单;当你支付完成之后,后台拿到支付回调后就会再插入一条待消费的task(job),Job触发日期为火车票上的出发日期,超过这个时间就会执行这个job,判断是否使用等。
全栈程序员站长
2022/07/22
9810
定时任务框架Quartz-(一)Quartz入门与Demo搭建
springboot 之集成quartz
一直没机会做spring生态圈的框架,公司选择的是一些小众的微服务,鉴于此考虑,丰富自己的技术栈,花了两天时间从网上各网站上学习了springboot一些基础知识。 本章只介绍springboot微服务集成quartz,用于项目中用到的一些定时任务,调度任务框架。
felixxue
2022/12/30
3540
springboot 之集成quartz
SpringBoot整合Quartz实现定时任务(单任务、多任务)
前言 Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个Jobs这样复杂的程序。Jobs可以做成标准的Java组件或 EJBs 一、添加依赖 Code <dependencies> <dependency> <groupId>org.springframework.boot</groupId>
MiChong
2020/09/24
2.7K0
spring-boot-2.0.3之quartz集成,不是你想的那样哦!
前言   开心一刻     晚上回家,爸妈正在吵架,见我回来就都不说话了,看见我妈坐在那里瞪着我爸,我就问老爸“你干什么了惹我妈生这么大气?”  我爸说“没有什么啊,倒是你,这么大了还没有媳妇,要是你
青石路
2018/12/19
1.2K0
quartz监控日志(四)自定义QuartzJobBean来实现监控
上面几章介绍了quartz监控的几种方式,下面再介绍一种监听方式:自定义QuartzJobBean
一笠风雨任生平
2020/03/19
2.2K1
springboot Quartz 定时任务工具类
package org.fh.util; import java.util.Map; import org.quartz.CronScheduleBuilder; import org.quartz.CronTrigger; import org.quartz.Job; import org.quartz.JobBuilder; import org.quartz.JobDetail; import org.quartz.JobKey; import org.quartz.Scheduler; im
FHAdmin
2021/06/28
6670
Spring Boot 配置 Quartz 定时任务
Job:是一个接口,只定义一个方法 execute(JobExecutionContext context),在实现接口的 execute 方法中编写所需要定时执行的 Job(任务)  Double slongitude = Double.valueOf(jobExecutionContext.getJobDetail().getJobDataMap().get("slongitude").toString()); JobDetail:Quartz 每次调度 Job 时,都重新创建一个 Job 实例,因此它不接受一个 Job 的实例,相反它接收一个 Job 实现类(JobDetail,描述 Job 的实现类及其他相关的静态信息,如 Job 名字、描述、关联监听器等信息),以便运行时通过 newInstance() 的反射机制实例化 Job。 rigger:是一个类,描述触发 Job 执行的时间触发规则,主要有 SimpleTrigger 和 CronTrigger 这两个子类。当且仅当需调度一次或者以固定时间间隔周期执行调度,SimpleTrigger 是最适合的选择;而 CronTrigger 则可以通过 Cron 表达式定义出各种复杂时间规则的调度方案:如工作日周一到周五的 15:00 ~ 16:00 执行调度等。 Scheduler:调度器就相当于一个容器,装载着任务和触发器,该类是一个接口,代表一个 Quartz 的独立运行容器,Trigger 和 JobDetail 可以注册到 Scheduler 中,两者在 Scheduler 中拥有各自的组及名称,组及名称是 Scheduler 查找定位容器中某一对象的依据,Trigger 的组及名称必须唯一,JobDetail 的组和名称也必须唯一(但可以和 Trigger 的组和名称相同,因为它们是不同类型的)。Scheduler 定义了多个接口方法,允许外部通过组及名称访问和控制容器中 Trigger 和 JobDetail。
FHAdmin
2021/09/07
1.9K0
它来了,任务调度框架 Quartz保姆级教程奉上
点击上方蓝色字体,选择“设为星标” 回复”学习资料“获取学习宝典 前言 项目中遇到一个,需要 客户自定任务启动时间 的需求。原来一直都是在项目里硬编码一些定时器,所以没有学习过。 很多开源的项目管理框架都已经做了 Quartz 的集成。我们居然连这么常用得东西居然没有做成模块化,实在是不应该。 Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,完全由Java开发,可以用来执行定时任务,类似于java.util.Timer。但是相较于Timer, Quart
猿天地
2022/05/25
1K0
它来了,任务调度框架 Quartz保姆级教程奉上
SpringBoot集成Quartz实现定时任务的动态创建、启动、暂停、恢复、删除。
链接:blog.csdn.net/qq_39648029/article/details/108993476
肉眼品世界
2020/11/11
3.2K0
SpringBoot集成Quartz实现定时任务的动态创建、启动、暂停、恢复、删除。
springboot quartz定时任务调度
在我们添加spring-boot-starter-quartz依赖后就不需要主动声明工厂类,因为spring-boot-starter-quartz已经为我们自动化配置好了。展开spring-boot-autoconfigure-2.0.0.RELEASE.jar,找到org.springframework.boot.autoconfigure.quartz,该目录就是SpringBoot为我们提供的Quartz自动化配置源码实现,在该目录下有如下所示几个类:
山行AI
2019/08/30
2.1K0
推荐阅读
相关推荐
​分布式定时任务框架Quartz
更多 >
交个朋友
加入腾讯云官网粉丝站
蹲全网底价单品 享第一手活动信息
领券
问题归档专栏文章快讯文章归档关键词归档开发者手册归档开发者手册 Section 归档
本文部分代码块支持一键运行,欢迎体验
本文部分代码块支持一键运行,欢迎体验