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

任务调度开源框架石英动态添加，修改和删除定时任务

2018-02-03 2119
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： Quartz是个开源的作业调度框架，为在Java应用程序中进行作业调度提供了简单却强大的机制.Quartz框架包含了调度器监听，作业和触发器监听。你可以配置作业和触发器监听为全局监听或者是特定于作业和触发器的监听.Quartz允许开发人员根据时间间隔（或天）来调度作业。

     Quartz是个开源的作业调度框架，为在Java应用程序中进行作业调度提供了简单却强大的机制.Quartz框架包含了调度器监听，作业和触发器监听。你可以配置作业和触发器监听为全局监听或者是特定于作业和触发器的监听.Quartz允许开发人员根据时间间隔（或天）来调度作业。

它实现了作业和触发器的多对多关系，还能把多个作业与不同的触发器关联。整合了Quartz的应用程序可以重用来自不同事件的作业，还可以作为一个事件组合多个作业。并且还能和Spring配置整合使用.Quartz在功能上远远超越了JDK自带的Timer，很好很强大好啦，直接上代码！

[java]  查看纯文本

 
  1. / **
  2.  * @说明： 
  3.  *
  4.  * @Title：QuartzManager.java
  5.  * @包com.joyce.quartz
  6.  * @版权：Copyright（c）2014
  7.  *
  8.  * @作者Comsys-LZP
  9.  * @date 2014-6-26下午03:15:52
  10.  * @version V2.0
  11.  * /
  12. 包 com.joyce.quartz;
  14. import  org.quartz.CronTrigger;
  15. import  org.quartz.JobDetail;
  16. 进口 org.quartz.Scheduler;
  17. import  org.quartz.SchedulerFactory;
  18. import  org.quartz.impl.StdSchedulerFactory;
  20. / **
  21.  * @Description：定时任务管理类
  22.  * 
  23.  * @ClassName：QuartzManager
  24.  * @版权：Copyright（c）2014
  25.  * 
  26.  * @作者Comsys-LZP
  27.  * @date 2014-6-26下午03:15:52
  28.  * @version V2.0
  29.  * /
  30. 公共类 QuartzManager {
  31.     private static  SchedulerFactory gSchedulerFactory =  new  StdSchedulerFactory（）;
  32.     私人静态 字符串JOB_GROUP_NAME =  “EXTJWEB_JOBGROUP_NAME” ;
  33.     私人静态 字符串TRIGGER_GROUP_NAME =  “EXTJWEB_TRIGGERGROUP_NAME” ;
  35.     / **
  36.      * @Description：添加一个定时任务，使用默认的任务组名，触发器名，触发器组名
  37.      * 
  38.      * @参数jobName
  39.      *任务名
  40.      * @参数cls
  41.      *任务
  42.      * @参数时间
  43.      *时间设置，参考石英说明文档
  44.      * 
  45.      * @Title：QuartzManager.java
  46.      * @版权：Copyright（c）2014
  47.      * 
  48.      * @作者Comsys-LZP
  49.      * @date 2014-6-26下午03:47:44
  50.      * @version V2.0
  51.      * /
  52.     @SuppressWarnings （“unchecked” ）
  53.     public static void  addJob（String jobName，Class cls，String time）{
  54.         尝试 {
  55.             调度程序sched = gSchedulerFactory.getScheduler（）;
  56.             JobDetail jobDetail =  新的 JobDetail（jobName，JOB_GROUP_NAME，cls）; //任务名，任务组，任务执行类
  57.             //触发器
  58.             CronTrigger触发器=  新的 CronTrigger（jobName，TRIGGER_GROUP_NAME）; //触发器名，触发器组
  59.             trigger.setCronExpression（时间）; //触发器时间设定
  60.             sched.scheduleJob（jobDetail，触发器）;
  61.             //启动
  62.             如果 （！sched.isShutdown（））{
  63.                 sched.start（）;
  64.             }
  65.         }  捕获 （例外五）{
  66.             抛出新的 RuntimeException（e）;
  67.         }
  68.     }
  70.     / **
  71.      * @Description：添加一个定时任务
  72.      * 
  73.      * @参数jobName
  74.      *任务名
  75.      * @参数jobGroupName
  76.      *任务组名
  77.      * @参数triggerName
  78.      *触发器名
  79.      * @参数triggerGroupName
  80.      *触发器组名
  81.      * @param jobClass
  82.      *任务
  83.      * @参数时间
  84.      *时间设置，参考石英说明文档
  85.      * 
  86.      * @Title：QuartzManager.java
  87.      * @版权：Copyright（c）2014
  88.      * 
  89.      * @作者Comsys-LZP
  90.      * @date 2014-6-26下午03:48:15
  91.      * @version V2.0
  92.      * /
  93.     @SuppressWarnings （“unchecked” ）
  94.     public static void  addJob（String jobName，String jobGroupName，
  95.             字符串triggerName，字符串triggerGroupName，类jobClass，
  96.             字符串时间）{
  97.         尝试 {
  98.             调度程序sched = gSchedulerFactory.getScheduler（）;
  99.             JobDetail jobDetail =  新的 JobDetail（jobName，jobGroupName，jobClass）; //任务名，任务组，任务执行类
  100.             //触发器
  101.             CronTrigger trigger =  new  CronTrigger（triggerName，triggerGroupName）; //触发器名，触发器组
  102.             trigger.setCronExpression（时间）; //触发器时间设定
  103.             sched.scheduleJob（jobDetail，触发器）;
  104.         }  捕获 （例外五）{
  105.             抛出新的 RuntimeException（e）;
  106.         }
  107.     }
  109.     / **
  110.      * @Description：修改一个任务的触发时间（使用默认的任务组名，触发器名，触发器组名）
  111.      * 
  112.      * @参数jobName
  113.      * @参数时间
  114.      * 
  115.      * @Title：QuartzManager.java
  116.      * @版权：Copyright（c）2014
  117.      * 
  118.      * @作者Comsys-LZP
  119.      * @date 2014-6-26下午03:49:21
  120.      * @version V2.0
  121.      * /
  122.     @SuppressWarnings （“unchecked” ）
  123.     public static void  modifyJobTime（String jobName，String time）{
  124.         尝试 {
  125.             调度程序sched = gSchedulerFactory.getScheduler（）;
  126.             CronTrigger触发器=（CronTrigger）sched.getTrigger（jobName，TRIGGER_GROUP_NAME）;
  127.             if  （trigger ==  null ）{
  128.                 返回;
  129.             }
  130.             String oldTime = trigger.getCronExpression（）;
  131.             if  （！oldTime.equalsIgnoreCase（time））{
  132.                 JobDetail jobDetail = sched.getJobDetail（jobName，JOB_GROUP_NAME）;
  133.                 Class objJobClass = jobDetail.getJobClass（）;
  134.                 removeJob（JOBNAME）;
  135.                 addJob（jobName，objJobClass，time）;
  136.             }
  137.         }  捕获 （例外五）{
  138.             抛出新的 RuntimeException（e）;
  139.         }
  140.     }
  142.     / **
  143.      * @Description：修改一个任务的触发时间
  144.      * 
  145.      * @参数triggerName
  146.      * @参数triggerGroupName
  147.      * @参数时间
  148.      * 
  149.      * @Title：QuartzManager.java
  150.      * @版权：Copyright（c）2014
  151.      * 
  152.      * @作者Comsys-LZP
  153.      * @date 2014-6-26下午03:49:37
  154.      * @version V2.0
  155.      * /
  156.     public static void  modifyJobTime（String triggerName，
  157.             字符串triggerGroupName，字符串时间）{
  158.         尝试 {
  159.             调度程序sched = gSchedulerFactory.getScheduler（）;
  160.             CronTrigger触发=（CronTrigger）sched.getTrigger（triggerName，triggerGroupName）;
  161.             if  （trigger ==  null ）{
  162.                 返回;
  163.             }
  164.             String oldTime = trigger.getCronExpression（）;
  165.             if  （！oldTime.equalsIgnoreCase（time））{
  166.                 CronTrigger ct =（CronTrigger）触发器;
  167.                 //修改时间
  168.                 ct.setCronExpression（时间）;
  169.                 //重启触发器
  170.                 sched.resumeTrigger（triggerName，triggerGroupName）;
  171.             }
  172.         }  捕获 （例外五）{
  173.             抛出新的 RuntimeException（e）;
  174.         }
  175.     }
  177.     / **
  178.      * @Description：移除一个任务（使用默认的任务组名，触发器名，触发器组名）
  179.      * 
  180.      * @参数jobName
  181.      * 
  182.      * @Title：QuartzManager.java
  183.      * @版权：Copyright（c）2014
  184.      * 
  185.      * @作者Comsys-LZP
  186.      * @date 2014-6-26下午03:49:51
  187.      * @version V2.0
  188.      * /
  189.     public static void  removeJob（String jobName）{
  190.         尝试 {
  191.             调度程序sched = gSchedulerFactory.getScheduler（）;
  192.             sched.pauseTrigger（jobName，TRIGGER_GROUP_NAME）; //停止触发器
  193.             sched.unscheduleJob（jobName，TRIGGER_GROUP_NAME）; //移除触发器
  194.             sched.deleteJob（jobName，JOB_GROUP_NAME）; //删除任务
  195.         }  捕获 （例外五）{
  196.             抛出新的 RuntimeException（e）;
  197.         }
  198.     }
  200.     / **
  201.      * @Description：移除一个任务
  202.      * 
  203.      * @参数jobName
  204.      * @参数jobGroupName
  205.      * @参数triggerName
  206.      * @参数triggerGroupName
  207.      * 
  208.      * @Title：QuartzManager.java
  209.      * @版权：Copyright（c）2014
  210.      * 
  211.      * @作者Comsys-LZP
  212.      * @date 2014-6-26下午03:50:01
  213.      * @version V2.0
  214.      * /
  215.     public static void  removeJob（String jobName，String jobGroupName，
  216.             字符串triggerName，字符串triggerGroupName）{
  217.         尝试 {
  218.             调度程序sched = gSchedulerFactory.getScheduler（）;
  219.             sched.pauseTrigger（triggerName，triggerGroupName）; //停止触发器
  220.             sched.unscheduleJob（triggerName，triggerGroupName）; //移除触发器
  221.             sched.deleteJob（jobName，jobGroupName）; //删除任务
  222.         }  捕获 （例外五）{
  223.             抛出新的 RuntimeException（e）;
  224.         }
  225.     }
  227.     / **
  228.      * @Description：启动所有定时任务
  229.      * 
  230.      * 
  231.      * @Title：QuartzManager.java
  232.      * @版权：Copyright（c）2014
  233.      * 
  234.      * @作者Comsys-LZP
  235.      * @date 2014-6-26下午03:50:18
  236.      * @version V2.0
  237.      * /
  238.     公共静态无效的 startJobs（）{
  239.         尝试 {
  240.             调度程序sched = gSchedulerFactory.getScheduler（）;
  241.             sched.start（）;
  242.         }  捕获 （例外五）{
  243.             抛出新的 RuntimeException（e）;
  244.         }
  245.     }
  247.     / **
  248.      * @Description：关闭所有定时任务
  249.      * 
  250.      * 
  251.      * @Title：QuartzManager.java
  252.      * @版权：Copyright（c）2014
  253.      * 
  254.      * @作者Comsys-LZP
  255.      * @date 2014-6-26下午03:50:26
  256.      * @version V2.0
  257.      * /
  258.     public static void  shutdownJobs（）{
  259.         尝试 {
  260.             调度程序sched = gSchedulerFactory.getScheduler（）;
  261.             如果 （！sched.isShutdown（））{
  262.                 sched.shutdown（）;
  263.             }
  264.         }  捕获 （例外五）{
  265.             抛出新的 RuntimeException（e）;
  266.         }
  267.     }
  268. }

以上就是石英任务调度对于任务的常用操作，封装起来以便在外部调用这样我们就需要任务的执行了！

[java]  查看纯文本

 
  1. / **
  2.  * @说明： 
  3.  *
  4.  * @Title：QuartzJob.java
  5.  * @包com.joyce.quartz
  6.  * @版权：Copyright（c）2014
  7.  *
  8.  * @作者Comsys-LZP
  9.  * @date 2014-6-26下午03:37:11
  10.  * @version V2.0
  11.  * /
  12. 包 com.joyce.quartz;
  14. import  java.text.SimpleDateFormat;
  15. import  java.util.Date;
  17. 进口 org.quartz.Job;
  18. import  org.quartz.JobExecutionContext;
  19. import  org.quartz.JobExecutionException;
  21. / **
  22.  * @Description：任务执行类
  23.  *
  24.  * @ClassName：QuartzJob
  25.  * @版权：Copyright（c）2014
  26.  *
  27.  * @作者Comsys-LZP
  28.  * @date 2014-6-26下午03:37:11
  29.  * @version V2.0
  30.  * /
  31. 公共类 QuartzJob  实现 作业{
  33.     @覆盖
  34.     public void  execute（JobExecutionContext arg0）  throws  JobExecutionException {
  35.         System.out.println（new  SimpleDateFormat（“yyyy-MM-dd HH：mm：ss” ）.format（new Date（））+  “” ）;
  36.     }
  37. }

好吧，我们来测试一下：

[java]  查看纯文本

 
  1. / **
  2.  * @说明： 
  3.  *
  4.  * @Title：QuartzTest.java
  5.  * @包com.joyce.quartz.main
  6.  * @版权：Copyright（c）2014
  7.  *
  8.  * @作者Comsys-LZP
  9.  * @date 2014-6-26下午03:35:05
  10.  * @version V2.0
  11.  * /
  12. 包 com.joyce.quartz.main;
  14. import  com.joyce.quartz.QuartzJob;
  15. import  com.joyce.quartz.QuartzManager;
  17. / **
  18.  * @Description：测试类
  19.  *
  20.  * @ClassName：QuartzTest
  21.  * @版权：Copyright（c）2014
  22.  *
  23.  * @作者Comsys-LZP
  24.  * @date 2014-6-26下午03:35:05
  25.  * @version V2.0
  26.  * /
  27. 公共类 QuartzTest {
  28.     public static void  main（String [] args）{
  29.         尝试 {
  30.             String job_name =  “动态任务调度” ;
  31.             System.out.println（“【系统启动】开始（每1秒输出一次）...” ）;
  32.             QuartzManager.addJob（JOB_NAME，QuartzJob 类，  “0/1 * * * *？” ）;
  34.             Thread.sleep（5000 ）;
  35.             System.out.println（“【修改时间】开始（每2秒输出一次）...” ）;
  36.             QuartzManager.modifyJobTime（job_name，  “10/2 * * * *？” ）;
  37.             Thread.sleep（6000 ）;
  38.             System.out.println（“【移除定时】开始...” ）;
  39.             QuartzManager.removeJob（JOB_NAME）;
  40.             System.out.println（“【移除定时】成功” ）;
  42.             System.out.println（“【再次添加定时任务】开始（每10秒输出一次）...” ）;
  43.             QuartzManager.addJob（JOB_NAME，QuartzJob 类，  “* / 10 * * * *？” ）;
  44.             Thread.sleep（60000 ）;
  45.             System.out.println（“【移除定时】开始...” ）;
  46.             QuartzManager.removeJob（JOB_NAME）;
  47.             System.out.println（“【移除定时】成功” ）;
  48.         }  捕获 （例外五）{
  49.             e.printStackTrace（）;
  50.         }
  51.     }
  52. }

 原文地址http://www.bieryun.com/850.html

文章标签：
Java
调度
Spring
优惠码发放
目录
相关文章
olnn3xpuk4r5u
|
11月前
|
人工智能 机器人 API
🤖 AstrBot 安卓 App：让每一个普通人都能拥有自己的 AI 聊天机器人
🤖 AstrBot 安卓 App：让每一个普通人都能拥有自己的 AI 聊天机器人
olnn3xpuk4r5u
3820 6
🤖 AstrBot 安卓 App：让每一个普通人都能拥有自己的 AI 聊天机器人
游客v2e3xldpuc7re
|
7月前
|
SQL 关系型数据库 MySQL
MySQL 慢 SQL 排查这件事，NineData 社区VS DBeaver/ Navicat 技术分析
DBeaver Community 和 Navicat Premium Lite 都是实用的客户端工具，在单条 SQL 的查询和验证上，依然是 DBA 常用的入口。NineData 社区版的定位不同，它是免费、本地化部署的数据管理平台，将数据库DevOps、数据复制、数据库对比三大能力整合于一体。
游客v2e3xldpuc7re
470 1
云计算小作者一枚
|
8月前
|
存储 弹性计算 Linux
2026年阿里云服务器购买攻略：三种核心购买方式对比与实操指南
阿里云服务器提供快速购买、自定义购买和活动购买三种方式，适合不同场景需求。选购前需综合考量业务场景、成本策略、地域选择及安全合规。快速购买适用于基础配置速购，提供基础、标准、专业、增强四类套餐，匹配个人开发、企业官网、电商平台等场景，并需注意镜像选择（如Alibaba Cloud Linux性能优化）、带宽计费模式（固定带宽、按量计费、共享带宽包）及完整购买流程。
云计算小作者一枚
1176 15
弹性计算小冉
|
机器学习/深度学习 弹性计算 缓存
简单聊聊，阿里云2核2G3M带宽云服务器与轻量应用服务器区别及选择参考
2核2G3M带宽云服务器与轻量应用服务器是目前阿里云的活动中，入门级走量型云服务器，轻量云服务器2核2G3M带宽68元一年，经济型e实例云服务器2核2G3M带宽99元1年。同样的配置，对于有的新手用户来说，有必要了解一下他们之间的区别，以及各自的购买和续费相关政策，从而选择更适合自己需求的云服务器。本文为大家简单分析一下我们应该选择哪一款。
弹性计算小冉
908 8
兵临天下19970108016
|
API 数据安全/隐私保护 网络架构
API接口
API（应用程序编程接口）是软件间通信的标准方式，通过定义规则和协议，便于开发者构建和集成服务。它通常基于RESTful架构或GraphQL实现，使用HTTP方法进行数据交互。以RESTful API为例，它通过GET、POST、PUT、DELETE等方法执行数据操作。示例中使用Python的requests库调用OpenWeatherMap API获取天气信息，展示了GET请求的实现。实际应用中，API还需结合OAuth 2.0等认证机制保障安全性。
兵临天下19970108016
1161 0
弹性计算小冉
|
存储 固态存储 异构计算
阿里云服务器租用一个月教程、收费标准与活动价格参考
阿里云服务器可以月租也可以年租，阿里云的活动中云服务器时长大多都是1年或3年，比较符合大多数用户的需求，但是也有少部分用户只想购买1个月或者3个月、6个月阿里云服务器来体验，但是又不知道选择月付的具体租用流程及月付的收费标准情况，本文为大家介绍一下租用时选择月付的具体流程以及月付的收费标准情况，以供参考。
弹性计算小冉
3016 6
阿里云服务器租用一个月教程、收费标准与活动价格参考
南瓜的奶酪-31235
|
人工智能 前端开发 API
手动开发？给我一条提示词，CodeBuddy能做的你都做不到！
本文介绍了使用CodeBuddy完成的一个五一期间的小项目，主要展示其编码能力。项目采用基础的HTML+CSS+JS实现界面，也提到可用React或Next.js复刻。文章重点讲解了通过提示词生成代码的方法，包括局部和整体两种方式，并展示了AI旅行规划功能的实现过程。通过与模型对话调整细节，最终生成满意的界面。CodeBuddy在前后端开发中表现出强大能力，未来可结合绘画作品生成惊艳网站。
南瓜的奶酪-31235
669 1
栈江湖
|
自然语言处理 前端开发 Java
API管理平台：你用的到底是哪个？
本文介绍了多个API管理和文档工具，包括Apifox、Swagger及其增强版Knife4j和RapiDoc、阿里RAP、去哪儿YApi以及Redoc。这些工具各有特色，适用于不同的开发场景。Apifox提供一体化协作平台，支持API文档、调试、Mock和测试；Swagger结合Knife4j适合Java与前端团队，界面美观且功能丰富；YApi则适用于跨语言开发，支持多种API形式的管理；阿里RAP专注于接口文档管理和Mock服务；Redoc则是开源的现代化API文档浏览器。总结而言，选择工具应根据团队需求和技术栈来决定。
栈江湖
5748 16
蓝易云
|
Ubuntu 开发工具 C++
Ubuntu 22.04上编译安装c++ libconfig library
通过本文的介绍，我们详细讲解了如何在Ubuntu 22.04上编译和安装libconfig库，并通过编写和运行一个简单的测试程序来验证安装是否成功。libconfig库的安装过程相对简单，主要包括环境准备、下载源码、编译和安装几个步骤。希望本文对您在项目中使用libconfig库有所帮助。
蓝易云
1034 13
wljslmz
|
数据采集 人工智能 物联网
智能与简易的交汇点：AI网关如何简化人工智能应用
【8月更文挑战第20天】
wljslmz
813 2

热门文章

最新文章

  • 1
    《ANSYS Workbench 16.0超级学习手册》——1.2　ANSYS Workbench 16.0平台及模块
  • 2
    解决前端H5调用后端接口出现302问题总结
  • 3
    2019阿里云峰会·北京 | 十年再出发
  • 4
    威胁快报|首爆，新披露Jenkins RCE漏洞成ImposterMiner挖矿木马新“跳板”
  • 5
    深圳云栖|阿里云总裁胡晓明深度解读：IoT为什么成为阿里巴巴新的主赛道
  • 6
    跨地域的VPC私网互通【高速通道案例】
  • 7
    postgresql中连接两张表更新第三张表（updata）
  • 8
    2022年在甘肃省全省三化推进工作汇报 进行《兰石集团推进兰石云平台建设、助力企业数字化转型》分享
  • 9
    Oracle笔记 十、PL/SQL存储过程
  • 10
    JNI之路径初探---5
  • 1
    KKCE主机测评：云服务器不该“手动初始化”用一套模板把 ECS 做成开机即就绪
    32
  • 2
    KKCE 在线ping：独立开发者的第一台香港服务器需要做什么？
    33
  • 3
    KKCE 网站测速：用香港VPS 搭一套“跨境边缘节点”API 中转、CDN 回源与抗攻击实践
    37
  • 4
    KKCE 主机测评：香港VPS 选型与初始化部署实战从网络测速到安全基线
    40
  • 5
    别再手写假数据了！MockForge — 可视化锻造百万级真实测试样本
    31
  • 6
    同等预算，向量检索吞吐最高约52倍！阿里云 Milvus EAGLE 内存索引性价比实测
    36
  • 7
    2026年阿里云双十一大促活动 EGS GPU 云服务器配置价格表，AI推理训练选型教程
    35
  • 8
    2026年阿里云双十一大促活动 ECS 云服务器配置价格表，选型与运维实操教程
    32
  • 9
    2026年阿里云双十一大促活动轻量应用服务器配置价格表，选购与部署教程
    34
  • 10
    集万家所长，一键复制的Agent.md！
    35

    • 相关电子书

    更多
  • 低代码开发师（初级）实战教程
  • 冬季实战营第三期：MySQL数据库进阶实战
  • 阿里巴巴DevOps 最佳实践手册
    • 下一篇
    一条命令迁移，帮你实现 OpenClaw 与 Hermes Agent 记忆互通！