java spring boot 动态添加 cron(表达式)任务、动态添加停止单个cron任务
java spring boot 动态添加 cron(表达式)任务、动态添加停止单个cron任务
- 添加对应的maven
<dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz</artifactId><version>2.3.0</version></dependency> - 添加一个工具类 SchedulerManager
import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.SchedulerFactory; import org.quartz.impl.StdSchedulerFactory;public class SchedulerManager {private static Scheduler scheduler;// 初始化 Scheduler public static void initScheduler() throws SchedulerException {SchedulerFactory schedulerFactory = new StdSchedulerFactory();scheduler = schedulerFactory.getScheduler();// 为了方便直接创建后启用scheduler.start();}// 使用同步块确保线程安全public static Scheduler getScheduler() {if (scheduler == null) {synchronized (SchedulerManager.class) {if (scheduler == null) { // 双重检查try {initScheduler();} catch (SchedulerException e) {// 处理异常或抛出自定义异常e.printStackTrace();}}}}return scheduler;}// 启动 scheduler public static void start() {try {if (!scheduler.isStarted()) {scheduler.start();}} catch (SchedulerException e) {// 处理异常或抛出自定义异常e.printStackTrace();}}// 暂停任务/删除任务public static void stopTask(String jobKey) {try {Scheduler scheduler = SchedulerManager.getScheduler();JobKey key = new JobKey(jobKey, jobKey);JobDetail jobDetail = scheduler.getJobDetail(key);if (jobDetail != null) {// 获取JobDataMapJobDataMap dataMap = jobDetail.getJobDataMap();dataMap.put("ok", false);// 暂停任务scheduler.pauseJob(key);// 或者删除当前任务// scheduler.deleteJob(key);}} catch (SchedulerException e) {e.printStackTrace();}}// 恢复任务public static int startTask(String jobKey) {int o = 0;try {Scheduler scheduler = SchedulerManager.getScheduler();JobKey key = new JobKey(jobKey, jobKey);JobDetail jobDetail = scheduler.getJobDetail(key);if (jobDetail != null) {// 获取JobDataMapJobDataMap dataMap = jobDetail.getJobDataMap();dataMap.put("ok", true);// 恢复任务scheduler.resumeJob(key);o = 1;}} catch (SchedulerException e) {e.printStackTrace();}finally {return o;}}/*** 停止所有任务*/public static void stopAllTask() {try {Scheduler scheduler = context.getScheduler();try {// 停止调度器scheduler.shutdown();} catch (SchedulerException e) {logger.error("停止调度器时出错", e);throw new JobExecutionException("停止调度器时出错", e);}} catch (SchedulerException e) {e.printStackTrace();}}} - 添加cron执行任务类
import lombok.extern.slf4j.Slf4j; import org.quartz.*; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import org.springframework.stereotype.Component; import org.springframework.stereotype.Service;import java.text.SimpleDateFormat; import java.util.Date;@Component @Slf4j @Service public class CronThread implements Job {private final static Logger logger = LoggerFactory.getLogger(MediaServerServiceImpl.class);// 详情idString detailId = "";// 启用/停用(双重保险)boolean ok = true;// 设备idint facilityId = -1;public void setOK(boolean ok) {this.ok = ok;}@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {try {JobDataMap dataMap = context.getJobDetail().getJobDataMap();this.ok = dataMap.getBoolean("ok");if (ok){this.detailId = dataMap.getString("detailId");this.facilityId = dataMap.getInt("facilityId");logger.info("任务执行: " + new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date()) + "。key=" + context.getJobDetail().getKey());frameSave();}} catch (Exception e) {logger.error("执行任务异常,内容", e);logger.info("停止任务:{}",context.getJobDetail().getKey());Scheduler scheduler = context.getScheduler();try {// 暂停当前任务 // scheduler.pauseJob(context.getJobDetail().getKey());// 或者删除当前任务scheduler.deleteJob(context.getJobDetail().getKey());} catch (SchedulerException s) {logger.error("暂停或删除任务时出错", s);throw new JobExecutionException("暂停或删除任务时出错", s);}}}public void frameSave() {try {logger.info("执行任务");} catch (Exception e) {logger.error("执行异常,内容: ", e);}} } - 启动/使用 方式
// 启动全部public void startAllTasks(List<Map<String,Object>> mapList){// 获取schedulerScheduler scheduler = SchedulerManager.getScheduler();for (Map<String, Object> map : mapList) {try {// 像任务执行类传入参数JobDataMap jobDataMap = new JobDataMap();jobDataMap.put("detailId", map.get("detailId").toString());jobDataMap.put("facilityId", (int) map.get("detailId"));jobDataMap.put("ok", true);// 任务唯一标识 根据情况来定,后续停止或启用单个的时候需要用到该唯一值String key = map.get("detailId").toString() + "-" + map.get("facilityId").toString();// 上面创建的 cron 执行任务类JobDetail jobDetail = JobBuilder.newJob(CronThread.class).withIdentity(key, key).setJobData(jobDataMap).build();Trigger trigger = TriggerBuilder.newTrigger().withIdentity(key, key).withSchedule(CronScheduleBuilder.cronSchedule(map.get("cronStr").toString())) //cron表达式.build();// 添加任务 到时间后会自动调用(在上面获取scheduler时里面有启动的操作)scheduler.scheduleJob(jobDetail, trigger);} catch (Exception e){e.printStackTrace();logger.error("启动抽帧任务报错:: ", e);}}}// 停止单个任务public void stopOneTask(String detailId,int facilityId){// 任务唯一标识String key = detailId + "-" + facilityId;SchedulerManager.stopTask(key);}// 启动单个任务public int startOneTask(String detailId,int facilityId,String cronStr){// 任务唯一标识String key = detailId + "-" + facilityId;int i = PollingAlgorithmCron.startTask(detailId + "-" + facilityId);if (i == 0) {// 该任务已被删除 重新添加try {// 可以将下面代码封装成一个方法,否则会和上面启动全部任务的操作代码重复JobKey jobKey = new JobKey(key, key);Scheduler scheduler = SchedulerManager.getScheduler();if (scheduler.checkExists(jobKey)) {return 1;}JobDataMap jobDataMap = new JobDataMap();jobDataMap.put("detailId", detailId);jobDataMap.put("facilityId", facilityId);jobDataMap.put("ok", true);JobDetail jobDetail = JobBuilder.newJob(CronThread.class).withIdentity(key, key).setJobData(jobDataMap).build();Trigger trigger = TriggerBuilder.newTrigger().withIdentity(key, key).withSchedule(CronScheduleBuilder.cronSchedule(cronStr)).build();scheduler.scheduleJob(jobDetail, trigger);return 1;} catch (SchedulerException e) {// 处理调度器异常e.printStackTrace();logger.error("One Scheduler exception: ", e);return 0;}}return 0;}
相关文章:
java spring boot 动态添加 cron(表达式)任务、动态添加停止单个cron任务
java spring boot 动态添加 cron(表达式)任务、动态添加停止单个cron任务 添加对应的maven <dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz</artifactId><version>2.3.0</version…...
sqlgun靶场漏洞挖掘
1.xss漏洞 搜索框输入以下代码,验证是否存在xss漏洞 <script>alert(1)</script> OK了,存在xss漏洞 2.SQL注入 经过测试,输入框存在SQL注入漏洞 查询数据库名 查询管理员账号密码 此处密码为MD5加密,解码内容如下 找…...
好用的 Markdown 编辑器组件
ByteMD bytedance/bytemd: ByteMD v1 repository (github.com) 这里由于我的项目是 Next,所以安装 bytemd/react, 阅读官方文档,执行命令来安装编辑器主体、以及 gfm(表格支持)插件、highlight 代码高亮插件…...
uniapp vite3 require导入commonJS 的js文件方法
vite3 导入commonJS 方式导出 在Vite 3中,你可以通过配置vite.config.js来实现导入CommonJS(CJS)风格的模块。Vite 默认支持ES模块导入,但如果你需要导入CJS模块,可以使用特定的插件,比如originjs/vite-pl…...
通义灵码用户说:“人工编写测试用例需要数十分钟,通义灵码以毫秒级的速度生成测试代码,且准确率和覆盖率都令人满意”
通过一篇文章,详细跟大家分享一下我在使用通义灵码过程中的感受。 一、定义 通义灵码,是一个智能编码助手,它基于通义大模型,提供代码智能生成、研发智能问答能力。 在体验过程中有任何问题均可点击下面的连接前往了解和学习。 …...
MySQL中的约束
约束概述 1.1 为什么需要约束 数据完整性(Data Integrity)是指数据的精确性(Accuracy)和可靠性(Reliability)。它是防止数据库中存在不符合语义规定的数据和防止因错误信息的输入输出造成无效操作或错误信…...
Leetcode 寻找重复数
可以使用 位运算 来解决这道题目。使用位运算的一个核心思想是基于数字的二进制表示,统计每一位上 1 的出现次数,并与期望的出现次数做比较。通过这种方法,可以推断出哪个数字重复。 class Solution { public:int findDuplicate(vector<i…...
大一新生以此篇开启你的算法之路
各位大一计算机萌新们,你们好,本篇博客会带领大家进行算法入门,给各位大一萌新答疑解惑。博客文章略长,可根据自己的需要观看,在博客中会有给大一萌新问题的解答,请不要错过。 入门简介: 算法…...
【AI大模型】ChatGPT模型原理介绍(上)
目录 🍔 什么是ChatGPT? 🍔 GPT-1介绍 2.1 GPT-1模型架构 2.2 GPT-1训练过程 2.2.1 无监督的预训练语言模型 2.2.2 有监督的下游任务fine-tunning 2.2.3 整体训练过程架构图 2.3 GPT-1数据集 2.4 GPT-1模型的特点 2.5 GPT-1模型总结…...
基于UE5和ROS2的激光雷达+深度RGBD相机小车的仿真指南(五):Blender锥桶建模
前言 本系列教程旨在使用UE5配置一个具备激光雷达深度摄像机的仿真小车,并使用通过跨平台的方式进行ROS2和UE5仿真的通讯,达到小车自主导航的目的。本教程默认有ROS2导航及其gazebo仿真相关方面基础,Nav2相关的学习教程可以参考本人的其他博…...
C++竞赛初阶L1-15-第六单元-多维数组(34~35课)557: T456507 图像旋转
题目内容 输入一个 n 行 m 列的黑白图像,将它顺时针旋转 90 度后输出。 输入格式 第一行包含两个整数 n 和 m,表示图像包含像素点的行数和列数。1≤n≤100,1≤m≤100。 接下来 n 行,每行 m 个整数,表示图像的每个像…...
无线领夹麦克风哪个牌子好?西圣、罗德、猛犸领夹麦克风深度评测
如今短视频和直播行业蓬勃发展,无线领夹麦克风成为了许多创作者不可或缺的工具。然而,市场上的无线领夹麦克风品牌众多、质量参差不齐,为了帮助大家挑选到满意的产品,我作为数码测评博主,对无线领夹麦克风市场进行了…...
React Native 0.76,New Architecture 将成为默认模式,全新的 RN 来了
关于 React Native 的 New Architecture 概念,最早应该是从 2018 年 RN 团队决定重写大量底层实现开始,因为那时候 React Native 面临各种结构问题和性能瓶颈,最终迫使 RN 团队开始进行重构。 而从 React Native 0.68 开始,New A…...
Java并发:互斥锁,读写锁,Condition,StampedLock
3,Lock与Condition 3.1,互斥锁 3.1.1,可重入锁 锁的可重入性(Reentrant Locking)是指在同一个线程中,已经获取锁的线程可以再次获取该锁而不会导致死锁。这种特性允许线程在持有锁的情况下,可…...
客户端负载均衡Ribbon实例
文章目录 一,概述二,实现过程三,项目源码1. 源码放送:2. 部署方式 四,功能演示五,其他 一,概述 一般来说,提到负载均衡,大家一般很容易想到浏览器 -> NGINX -> 反…...
MySQL数据库负载均衡
数据库负载均衡是通过将数据库请求分散到多个数据库服务器上,以提高数据库的处理能力和可用性。在高并发的场景下,使用数据库负载均衡器可以有效避免单点故障,提高系统的整体性能和可靠性。 数据库负载均衡器 数据库负载均衡器可以是硬件设…...
达梦CASE_SENSITIVE参数解析
1. 参数含义 标识符大小写敏感,默认值为 Y。 当大小写敏感时,小写的标识符应用双引号括起,否则被转换为大写;当大小写不敏感时,系统不自动转换标识符的大小写,在标识符比较时也不区分大小写。 CASE_SENS…...
酒店智能轻触开关工作原理
在现代化酒店中,智能轻触开关已成为提升宾客居住体验的重要设备之一。这些开关不仅操作便捷,而且功能丰富,能够实现对灯光、窗帘、空调等设备的精准控制。本文将深入探讨酒店智能轻触开关的工作原理。 一、智能轻触开关的基本概念 智能轻触开…...
web基础之RCE
简介:RCE称为远程代码执行漏洞;是互联网的一种安全漏洞;攻击者可以直接向后台服务器远程注入操作系统命令;从而操控后台系统;也是CTF比较常考的一个方面 1、eval执行 (1)分析后端代码…...
c语言--水仙花数,求Sn的前五项和
用C语言实现输出水仙花数 什么是“水仙花数”? 所谓“水仙花数”是指一个n位数,其各位数字n次方之和等于该数本身。 例如:1531 ^3 5 ^3 3 ^3 如何求解水仙花数? 思路: 步骤1:先计算出数i的位数&#x…...
零门槛NAS搭建:WinNAS如何让普通电脑秒变私有云?
一、核心优势:专为Windows用户设计的极简NAS WinNAS由深圳耘想存储科技开发,是一款收费低廉但功能全面的Windows NAS工具,主打“无学习成本部署” 。与其他NAS软件相比,其优势在于: 无需硬件改造:将任意W…...
QT: `long long` 类型转换为 `QString` 2025.6.5
在 Qt 中,将 long long 类型转换为 QString 可以通过以下两种常用方法实现: 方法 1:使用 QString::number() 直接调用 QString 的静态方法 number(),将数值转换为字符串: long long value 1234567890123456789LL; …...
C++八股 —— 单例模式
文章目录 1. 基本概念2. 设计要点3. 实现方式4. 详解懒汉模式 1. 基本概念 线程安全(Thread Safety) 线程安全是指在多线程环境下,某个函数、类或代码片段能够被多个线程同时调用时,仍能保证数据的一致性和逻辑的正确性…...
基于Java+MySQL实现(GUI)客户管理系统
客户资料管理系统的设计与实现 第一章 需求分析 1.1 需求总体介绍 本项目为了方便维护客户信息为了方便维护客户信息,对客户进行统一管理,可以把所有客户信息录入系统,进行维护和统计功能。可通过文件的方式保存相关录入数据,对…...
【JVM面试篇】高频八股汇总——类加载和类加载器
目录 1. 讲一下类加载过程? 2. Java创建对象的过程? 3. 对象的生命周期? 4. 类加载器有哪些? 5. 双亲委派模型的作用(好处)? 6. 讲一下类的加载和双亲委派原则? 7. 双亲委派模…...
适应性Java用于现代 API:REST、GraphQL 和事件驱动
在快速发展的软件开发领域,REST、GraphQL 和事件驱动架构等新的 API 标准对于构建可扩展、高效的系统至关重要。Java 在现代 API 方面以其在企业应用中的稳定性而闻名,不断适应这些现代范式的需求。随着不断发展的生态系统,Java 在现代 API 方…...
Kubernetes 节点自动伸缩(Cluster Autoscaler)原理与实践
在 Kubernetes 集群中,如何在保障应用高可用的同时有效地管理资源,一直是运维人员和开发者关注的重点。随着微服务架构的普及,集群内各个服务的负载波动日趋明显,传统的手动扩缩容方式已无法满足实时性和弹性需求。 Cluster Auto…...
数据结构第5章:树和二叉树完全指南(自整理详细图文笔记)
名人说:莫道桑榆晚,为霞尚满天。——刘禹锡(刘梦得,诗豪) 原创笔记:Code_流苏(CSDN)(一个喜欢古诗词和编程的Coder😊) 上一篇:《数据结构第4章 数组和广义表》…...
Spring事务传播机制有哪些?
导语: Spring事务传播机制是后端面试中的必考知识点,特别容易出现在“项目细节挖掘”阶段。面试官通过它来判断你是否真正理解事务控制的本质与异常传播机制。本文将从实战与源码角度出发,全面剖析Spring事务传播机制,帮助你答得有…...
更新 Docker 容器中的某一个文件
🔄 如何更新 Docker 容器中的某一个文件 以下是几种在 Docker 中更新单个文件的常用方法,适用于不同场景。 ✅ 方法一:使用 docker cp 拷贝文件到容器中(最简单) 🧰 命令格式: docker cp <…...
