java 动态增加定时任务

直接上代码

import org.apache.tools.ant.util.DateUtils;
import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerFactory;
import org.quartz.impl.StdSchedulerFactory;import java.util.Calendar;
import java.util.Date;/*** @Description: 定时任务管理类* Created by zhangxb on 2017/2/10.*/
public class QuartzManager {private static SchedulerFactory gSchedulerFactory = new StdSchedulerFactory();private static String JOB_GROUP_NAME = "EXTJWEB_JOBGROUP_NAME";private static String TRIGGER_GROUP_NAME = "EXTJWEB_TRIGGERGROUP_NAME";/*** @Description: 添加一个定时任务，使用默认的任务组名，触发器名，触发器组名** @param jobName*            任务名* @param cls*            任务* @param time*            时间设置，参考quartz说明文档** @Title: QuartzManager.java*/@SuppressWarnings("unchecked")public static void addJob(String jobName, Class cls, String time,Object params) {try {Scheduler sched = gSchedulerFactory.getScheduler();JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, cls);// 任务名，任务组，任务执行类jobDetail.getJobDataMap().put("params", params);// 触发器CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);// 触发器名,触发器组trigger.setCronExpression(time);// 触发器时间设定
            sched.scheduleJob(jobDetail, trigger);// 启动if (!sched.isShutdown()) {sched.start();}} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description: 添加一个定时任务** @param jobName*            任务名* @param jobGroupName*            任务组名* @param triggerName*            触发器名* @param triggerGroupName*            触发器组名* @param jobClass*            任务* @param time*            时间设置，参考quartz说明文档**/@SuppressWarnings("unchecked")public static void addJob(String jobName, String jobGroupName,String triggerName, String triggerGroupName, Class jobClass,String time,Object params) {try {Scheduler sched = gSchedulerFactory.getScheduler();JobDetail jobDetail = new JobDetail(jobName, jobGroupName, jobClass);// 任务名，任务组，任务执行类jobDetail.getJobDataMap().put("params",params);// 触发器CronTrigger trigger = new CronTrigger(triggerName, triggerGroupName);// 触发器名,触发器组trigger.setCronExpression(time);// 触发器时间设定
            sched.scheduleJob(jobDetail, trigger);} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description: 修改一个任务的触发时间(使用默认的任务组名，触发器名，触发器组名)** @param jobName* @param time**/@SuppressWarnings("unchecked")public static void modifyJobTime(String jobName, String time) {try {Scheduler sched = gSchedulerFactory.getScheduler();CronTrigger trigger = (CronTrigger) sched.getTrigger(jobName,TRIGGER_GROUP_NAME);if (trigger == null) {return;}String oldTime = trigger.getCronExpression();if (!oldTime.equalsIgnoreCase(time)) {JobDetail jobDetail = sched.getJobDetail(jobName,JOB_GROUP_NAME);Class objJobClass = jobDetail.getJobClass();removeJob(jobName);addJob(jobName, objJobClass, time ,jobDetail.getJobDataMap());}} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description: 修改一个任务的触发时间**/public static void modifyJobTime(String triggerName,String triggerGroupName, String time) {try {Scheduler sched = gSchedulerFactory.getScheduler();CronTrigger trigger = (CronTrigger) sched.getTrigger(triggerName,triggerGroupName);if (trigger == null) {return;}String oldTime = trigger.getCronExpression();if (!oldTime.equalsIgnoreCase(time)) {CronTrigger ct = (CronTrigger) trigger;// 修改时间
                ct.setCronExpression(time);// 重启触发器
                sched.resumeTrigger(triggerName, triggerGroupName);}} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description: 移除一个任务(使用默认的任务组名，触发器名，触发器组名)** @param jobName**/public static void removeJob(String jobName) {try {Scheduler sched = gSchedulerFactory.getScheduler();sched.pauseTrigger(jobName, TRIGGER_GROUP_NAME);// 停止触发器sched.unscheduleJob(jobName, TRIGGER_GROUP_NAME);// 移除触发器sched.deleteJob(jobName, JOB_GROUP_NAME);// 删除任务} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description: 移除一个任务**/public static void removeJob(String jobName, String jobGroupName,String triggerName, String triggerGroupName) {try {Scheduler sched = gSchedulerFactory.getScheduler();sched.pauseTrigger(triggerName, triggerGroupName);// 停止触发器sched.unscheduleJob(triggerName, triggerGroupName);// 移除触发器sched.deleteJob(jobName, jobGroupName);// 删除任务} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description:启动所有定时任务*/public static void startJobs() {try {Scheduler sched = gSchedulerFactory.getScheduler();sched.start();} catch (Exception e) {throw new RuntimeException(e);}}/*** @Description:关闭所有定时任务**/public static void shutdownJobs() {try {Scheduler sched = gSchedulerFactory.getScheduler();if (!sched.isShutdown()) {sched.shutdown();}} catch (Exception e) {throw new RuntimeException(e);}}public static String formatTime(Date date){//0/1 * * * * ?String time = DateUtils.format( date, "s m h d * ?");System.out.println(time);return time;}
}

测试类

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;import java.text.SimpleDateFormat;
import java.util.Calendar;
import java.util.Date;/*** @Description: 任务执行类* Created by zhangxb on 2017/2/10.*/
public class QuartzJob implements Job {@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {Object params =   context.getJobDetail().getJobDataMap().get("params");System.out.println(params);System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+ "★★★★★★★★★★★");System.out.println("【移除定时】开始...");QuartzManager.removeJob((String)params);System.out.println("【移除定时】成功");}public static void main(String[] args) {try {String job_name = "动态任务调度";System.out.println("【系统启动】开始(每1秒输出一次)...");Calendar cal = Calendar.getInstance();cal.add( Calendar.SECOND,10);QuartzManager.addJob(job_name, QuartzJob.class, QuartzManager.formatTime(cal.getTime()),job_name);Thread.sleep(11);cal.setTime( new Date());cal.add( Calendar.SECOND,10);QuartzManager.addJob(job_name+1, QuartzJob.class, QuartzManager.formatTime(cal.getTime()),job_name+1);Thread.sleep(11);
//            System.out.println("【修改时间】开始(每2秒输出一次)...");
//            QuartzManager.modifyJobTime(job_name, "10/2 * * * * ?");
//            Thread.sleep(6000);
//            System.out.println("【移除定时】开始...");
//            QuartzManager.removeJob(job_name);
//            System.out.println("【移除定时】成功");
//
//            System.out.println("【再次添加定时任务】开始(每10秒输出一次)...");
//            QuartzManager.addJob(job_name, QuartzJob.class, "*/10 * * * * ?");
//            Thread.sleep(60000);
//            System.out.println("【移除定时】开始...");
//            QuartzManager.removeJob(job_name);
//            System.out.println("【移除定时】成功");} catch (Exception e) {e.printStackTrace();}}
}

不过最后发现，还是没法做动态延迟。后面用延时mq实现的。

转载于:https://www.cnblogs.com/foreverzxb/p/6491190.html

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

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

相关文章

基于JavaFX的SimpleDateFormat演示程序

基于JavaFX的SimpleDateFormat演示程序

对于使用Java Date进行格式化的新手甚至对于使用Java Date进行格式化的有经验的Java开发人员而言，可能有些棘手的事情是使用SimpleDateFormat规范日期/时间格式。 SimpleDateFormat的基于类级别的Javadoc的文档非常详尽，涵盖了表示日期/时间的各个组成部…
阅读更多...
mysql中预定义常量_PHP预定义常量

mysql中预定义常量_PHP预定义常量

这些常量在 PHP 的内核中定义。它包含 PHP、Zend 引擎和 SAPI 模块。PHP_VERSION (string)PHP_OS (string)PHP_EOL (string)自 PHP 4.3.10 和 PHP 5.0.2 起可用PHP_INT_MAX (integer)自 PHP 4.4.0 和 PHP 5.0.5 起可用PHP_INT_SIZE (integer)自 PHP 4.4.0 和 PHP 5.0.5 起可用D…
阅读更多...
iOS与H5交互

iOS与H5交互

前提：在iOS控制器中加载UIWebView，设置代理，遵守UIWebViewDelegate协议。 一、iOS调用JS方法 通过iOS调用JS代码实现起来比较方便直接调用UIWebView的方法- (nullable NSString *)stringByEvaluatingJavaScriptFromString:(NSString *)script…
阅读更多...
cocos2dx 3.x 蒙板 遮罩 点击圆功能

cocos2dx 3.x 蒙板 遮罩 点击圆功能

//注册触摸EventListenerTouchOneByOne *listener EventListenerTouchOneByOne::create();listener->onTouchBegan CC_CALLBACK_2(HelloWorld::onTouchBegan,this);listener->onTouchMoved CC_CALLBACK_2(HelloWorld::onTouchMoved,this);listener->onTouchEnded …
阅读更多...
markdownTest

markdownTest

MARKDOWNTEST 11111111111111有一种神奇的语言，它比html还简单，它巧妙地将内容与格式整合在一起——它就是Markdown有一种神奇的语言，它比html还简单，它巧妙地将内容与格式整合在一起——它就是Markdown 111111111111111222222222…
阅读更多...
python模拟密码有效性检测功能_检查密码有效性（Django/Python）

python模拟密码有效性检测功能_检查密码有效性（Django/Python）

我有一个非常小的Django应用程序，主要是为了学习。我使用的是Django提供的内置用户模型。为了学习这个功能，我创建了一些页面，这些页面允许我创建和编辑用户，而不必进入管理面板。在register页面允许我非常容易地检查密码和电子邮…
阅读更多...
教程：Hibernate，JPA –第1部分

教程：Hibernate，JPA –第1部分

这是关于使用Hibernate和JPA的教程的第一部分。 这部分是对JPA和Hibernate的介绍。 第二部分将研究使用Spring ORM组合Spring MVC应用程序以减少创建CRUD应用程序所需的代码量。 为此，您需要熟悉Maven，JUnit，SQL和关系数据库。 依存关系 首…
阅读更多...
TCP、UDP套接字的数据传输

TCP、UDP套接字的数据传输

tcp发送数据&#xff1a; 1 #include <sys/types.h> 2 #include <socket.h> 3 ssize_t send(int sockfd,const void *msg,size_t len,int flags); 函数send只能对面向连接的套接字使用。参数sockfd为已经建立好连接的套接字描述符。参数msg指向待发送数据的缓冲区&…
阅读更多...
Windows下用PIP安装scipy出现no lapack/blas resources found

Windows下用PIP安装scipy出现no lapack/blas resources found

Windows下升级了pandas&#xff0c;但是发现scipy包随后引用出错&#xff0c;后来确认需重新安装scipy&#xff0c; 在用PIP安装scipy出现no lapack/blas resources found的错误&#xff0c;具体原因可参考 这里。 后来找到一种简便的解决方案&#xff0c;只要在网站 Unofficia…
阅读更多...
Aleri –复杂事件处理

Aleri –复杂事件处理

Sybase的Aleri流媒体平台是CEP市场中最受欢迎的产品之一。 它在Sybase的交易平台RAP版本中使用&#xff0c;该版本在资本市场中广泛用于管理投资组合中的头寸。 今天&#xff0c;在这个由多个部分组成的系列文章的第一个部分中&#xff0c;我希望提供Aleri平台的概述&#xff0…
阅读更多...
python版本回退_Python爬虫之BeautifulSoup解析之路

python版本回退_Python爬虫之BeautifulSoup解析之路

上一篇分享了正则表达式的使用&#xff0c;相信大家对正则也已经有了一定的了解。它可以针对任意字符串做任何的匹配并提取所需信息。但是我们爬虫基本上解析的都是html或者xml结构的内容&#xff0c;而非任意字符串。正则表达式虽然很强大灵活&#xff0c;但是对于html这样结构…
阅读更多...
0615 团队第二阶段贡献

0615 团队第二阶段贡献

0615 团队第二阶段贡献 列志华http://www.cnblogs.com/liezhihua/ 26% 组长 黄柏堂 http://www.cnblogs.com/huang123/ 22% 团队 韩麒麟 http://www.cnblogs.com/hanqilin/ 26% 团队 王俊杰 http://www.cnblogs.com/wangjunjie123/ 28%团队posted on 2016…
阅读更多...
WebStorm 运行Rect Native 项目

WebStorm 运行Rect Native 项目

今天教大家如何直接使用WebStorm这个IDE直接完成编码运行项目工作.这样就可以不用打开Xcode了. 1.首先点击WebStorm右上方的下拉箭头弹出的Edit Configurations.... 2.然后会进入一个配置页面.点击左上方的.在弹出的列表中选中npm.如图. 3.在右边的配置框中,先选择Command为hel…
阅读更多...
python编程比赛_用Python编程分析4W场球赛后，2018世界杯冠军竟是…

python编程比赛_用Python编程分析4W场球赛后，2018世界杯冠军竟是…

比赛已经开始&#xff0c;我们不妨用 Python 来对参赛队伍的实力情况进行分析&#xff0c;并大胆的预测下本届世界杯的夺冠热门球队吧&#xff01;通过数据分析&#xff0c;可以发现很多有趣的结果&#xff0c;比如&#xff1a;找出哪些队伍是首次进入世界杯的黑马队伍找出2018…
阅读更多...
GlassFish 3.1.2充满了MOXy（EclipseLink JAXB）

GlassFish 3.1.2充满了MOXy（EclipseLink JAXB）

我非常高兴地宣布&#xff0c; EclipseLink JAXB&#xff08;MOXy&#xff09;现在是GlassFish 3.1.2中的JAXB&#xff08; JSR-222 &#xff09;提供程序。 我要感谢EclipseLink和GlassFish提交者为实现这一目标付出的​​辛勤工作。 在本文中&#xff0c;我将介绍如何利用MOX…
阅读更多...
梦断代码阅读笔记03

梦断代码阅读笔记03

读完《梦断代码(Dream In Code)》样书&#xff0c;我感觉心情有点沉重&#xff0c;Chandler项目的结局&#xff0c;它失败了&#xff0c;它成了众多失败软件项目中的一个。这个结局让那个我感受到软件实在是太难了&#xff0c;我觉得当初选这个专业可能到最后只是一个码农。但是…
阅读更多...
Java访问权限的范围

Java访问权限的范围

二、下面用表格来展示四种修饰符的访问权限范围&#xff1a; 同一个类 同一个包 不同包的子类 不同包的非子类 public √ √ √ √ protected √ √ √ 默认(default) √ √ private √ 转载于:https://www.cnblogs.com/jianxin-lilang/p/6…
阅读更多...
JavaFX 2 GameTutorial第2部分

JavaFX 2 GameTutorial第2部分

介绍 Ť他的是一系列与一个JavaFX 2游戏教程博客条目的第二批。 如果您尚未阅读第1部分&#xff0c;请参阅JavaFX 2游戏教程的简介部分。 在第1部分中&#xff0c;我提到了游戏的某些方面以及原型飞船的简单演示&#xff08;原型由简单的形状组成&#xff09;&#xff0c;该飞船…
阅读更多...
sqlyog连接mysql教程_如何用SQLyog实现远程连接MySQL

sqlyog连接mysql教程_如何用SQLyog实现远程连接MySQL

SQLyog客户端&#xff0c;用root用户远程链接MySQL时&#xff0c;提示ldquo;访问被拒绝rdquo;&#xff0c;在网上搜索了一下原因。原来是MySQL没有授权其远程链1&#xff0c;SQLyog客户端&#xff0c;&#xff0c;用root用户远程链接MySQL时&#xff0c;提示“访问被拒绝”&…
阅读更多...
动态SQL+变量绑定：解决ORA-01704: 字符串文字太长的问题

动态SQL+变量绑定：解决ORA-01704: 字符串文字太长的问题

最近在做一个ESB项目&#xff0c;有一个trigger里面执行动态SQL的时候报错&#xff1a; ORA-01704: 字符串文字太长 经检查发现SQL里面有个字段是clob类型&#xff0c;内容长度4009&#xff0c;在oracle里面&#xff0c; 一对引号内的字符长度如果超过4000&#xff0c;就会报OR…
阅读更多...
最新文章

Copyright @ 2022~2023