Quartz遇到的问题

本文首次发布于My Blog,作者@张琦(Ian),转载请保留原文链接。

有状态和无状态

　　使用有状态（StatefulJob）还是无状态的任务（Job）
在 Quartz 中，基本来说，任务分为有状态和无状态两种。实现 Job 接口的任务缺省为无状态的。Quartz 中还有另外一个接口 StatefulJob。实现 StatefulJob 接口的任务为有状态的。

无状态任务：一般指可以并发的任务，即任务之间是独立的，不会互相干扰。有状态反之。

通过Quartz获得状态为启动的所有job

 /*
Create a GroupMatcher that matches job groups starting with the given string.*/
GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup();/*
Get the keys of all the JobDetails in the matching groups.*/
Set<JobKey> jobKeys = sched.getJobKeys(matcher);

　　通过jobKeys可以获取job的名称，和一系列的东西。不知道怎么获得，可以看quartz定时任务了解下，再根据下面的api文档基本就没问题了。

这两个是放job类上的注解。
@DisallowConcurrentExecution //意思是：禁止并发执行多个相同定义的JobDetail，就是我们想要的。
@PersistJobDataAfterExecution //意思是：放在JobDetail 里的JobDataMap是共享的，也就是相同任务之间执行时可以传输信息

工具类：

import java.sql.Timestamp;
import java.util.ArrayList;
import java.util.List;
import java.util.Set;import javax.annotation.PostConstruct;import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobExecutionContext;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.TriggerKey;
import org.quartz.impl.matchers.GroupMatcher;
import org.slf4j.Logger;
import org.slf4j.LoggerFactory;
import org.springframework.beans.factory.annotation.Autowired;
import org.springframework.scheduling.quartz.SchedulerFactoryBean;
import org.springframework.stereotype.Service;import cn.net.yto.o2iMonitor.quartz.QuartzJobFactory;
import cn.net.yto.o2iMonitor.quartz.QuartzJobFactoryDisallowConcurrentExecution;
import cn.net.yto.o2iMonitor.quartz.ScheduleJob;
import cn.net.yto.o2iMonitor.quartz.mapper.JobConfigMapper;public class JobConfigService {private static final Logger LOGGER = LoggerFactory.getLogger(JobConfigService.class);@Autowiredprivate SchedulerFactoryBean schedulerFactoryBean;@Autowiredprivate JobConfigMapper scheduleJobMapper;/*** 从数据库中取 区别于getAllJob* * @return*/public List<ScheduleJob> getAllTask() {return scheduleJobMapper.getAll();}/*** 添加到数据库中 区别于addJob*/public void addTask(ScheduleJob job) {job.setCreateTime(new Timestamp(System.currentTimeMillis()));scheduleJobMapper.insertSelective(job);}/*** 从数据库中查询job*/public ScheduleJob getTaskById(Long jobId) {return scheduleJobMapper.selectByPrimaryKey(jobId);}/*** 更改任务状态* * @throws SchedulerException*/public void changeStatus(Long jobId, String cmd) throws SchedulerException {ScheduleJob job = getTaskById(jobId);if (job == null) {return;}if ("stop".equals(cmd)) {deleteJob(job);job.setStatus(ScheduleJob.STATUS_NOT_RUNNING);} else if ("start".equals(cmd)) {job.setStatus(ScheduleJob.STATUS_RUNNING);addJob(job);}scheduleJobMapper.updateByPrimaryKeySelective(job);}/*** 更改任务 cron表达式* * @throws SchedulerException*/public void updateCron(Long jobId, String cron) throws SchedulerException {ScheduleJob job = getTaskById(jobId);if (job == null) {return;}job.setCron(cron);if (ScheduleJob.STATUS_RUNNING.equals(job.getStatus())) {updateJobCron(job);}scheduleJobMapper.updateByPrimaryKeySelective(job);}/*** 添加任务* * @param scheduleJob* @throws SchedulerException*/public void addJob(ScheduleJob job) throws SchedulerException {if (job == null || !ScheduleJob.STATUS_RUNNING.equals(job.getStatus())) {return;}Scheduler scheduler = schedulerFactoryBean.getScheduler();LOGGER.debug(scheduler+ ".......................................................................................add");TriggerKey triggerKey = TriggerKey.triggerKey(job.getName(), job.getGroup());CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);// 不存在，创建一个if (null == trigger) {Class clazz = ScheduleJob.CONCURRENT_IS.equals(job.getIsConcurrent()) ? QuartzJobFactory.class: QuartzJobFactoryDisallowConcurrentExecution.class;JobDetail jobDetail = JobBuilder.newJob(clazz).withIdentity(job.getName(), job.getGroup()).build();jobDetail.getJobDataMap().put("scheduleJob", job);CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCron());trigger = TriggerBuilder.newTrigger().withIdentity(job.getName(), job.getGroup()).withSchedule(scheduleBuilder).build();scheduler.scheduleJob(jobDetail, trigger);} else {// Trigger已存在，那么更新相应的定时设置CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(job.getCron());// 按新的cronExpression表达式重新构建triggertrigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();// 按新的trigger重新设置job执行scheduler.rescheduleJob(triggerKey, trigger);}}@PostConstructpublic void init() throws Exception {Scheduler scheduler = schedulerFactoryBean.getScheduler();// 这里获取任务信息数据List<ScheduleJob> jobList = scheduleJobMapper.getAll();for (ScheduleJob job : jobList) {addJob(job);}}/*** 获取所有计划中的任务列表* * @return* @throws SchedulerException*/public List<ScheduleJob> getAllJob() throws SchedulerException {Scheduler scheduler = schedulerFactoryBean.getScheduler();GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup();Set<JobKey> jobKeys = scheduler.getJobKeys(matcher);List<ScheduleJob> jobList = new ArrayList<ScheduleJob>();for (JobKey jobKey : jobKeys) {List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);for (Trigger trigger : triggers) {ScheduleJob job = new ScheduleJob();job.setName(jobKey.getName());job.setGroup(jobKey.getGroup());job.setDescription("触发器:" + trigger.getKey());Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());job.setStatus(triggerState.name());if (trigger instanceof CronTrigger) {CronTrigger cronTrigger = (CronTrigger) trigger;String cronExpression = cronTrigger.getCronExpression();job.setCron(cronExpression);}jobList.add(job);}}return jobList;}/*** 所有正在运行的job* * @return* @throws SchedulerException*/public List<ScheduleJob> getRunningJob() throws SchedulerException {Scheduler scheduler = schedulerFactoryBean.getScheduler();List<JobExecutionContext> executingJobs = scheduler.getCurrentlyExecutingJobs();List<ScheduleJob> jobList = new ArrayList<ScheduleJob>(executingJobs.size());for (JobExecutionContext executingJob : executingJobs) {ScheduleJob job = new ScheduleJob();JobDetail jobDetail = executingJob.getJobDetail();JobKey jobKey = jobDetail.getKey();Trigger trigger = executingJob.getTrigger();job.setName(jobKey.getName());job.setGroup(jobKey.getGroup());job.setDescription("触发器:" + trigger.getKey());Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());job.setStatus(triggerState.name());if (trigger instanceof CronTrigger) {CronTrigger cronTrigger = (CronTrigger) trigger;String cronExpression = cronTrigger.getCronExpression();job.setCron(cronExpression);}jobList.add(job);}return jobList;}/*** 暂停一个job* * @param scheduleJob* @throws SchedulerException*/public void pauseJob(ScheduleJob scheduleJob) throws SchedulerException {Scheduler scheduler = schedulerFactoryBean.getScheduler();JobKey jobKey = JobKey.jobKey(scheduleJob.getName(), scheduleJob.getGroup());scheduler.pauseJob(jobKey);}/*** 恢复一个job* * @param scheduleJob* @throws SchedulerException*/public void resumeJob(ScheduleJob scheduleJob) throws SchedulerException {Scheduler scheduler = schedulerFactoryBean.getScheduler();JobKey jobKey = JobKey.jobKey(scheduleJob.getName(), scheduleJob.getGroup());scheduler.resumeJob(jobKey);}/*** 删除一个job* * @param scheduleJob* @throws SchedulerException*/public void deleteJob(ScheduleJob scheduleJob) throws SchedulerException {Scheduler scheduler = schedulerFactoryBean.getScheduler();JobKey jobKey = JobKey.jobKey(scheduleJob.getName(), scheduleJob.getGroup());scheduler.deleteJob(jobKey);}/*** 立即执行job* * @param scheduleJob* @throws SchedulerException*/public void runAJobNow(ScheduleJob scheduleJob) throws SchedulerException {Scheduler scheduler = schedulerFactoryBean.getScheduler();JobKey jobKey = JobKey.jobKey(scheduleJob.getName(), scheduleJob.getGroup());scheduler.triggerJob(jobKey);}/*** 更新job时间表达式* * @param scheduleJob* @throws SchedulerException*/public void updateJobCron(ScheduleJob scheduleJob) throws SchedulerException {Scheduler scheduler = schedulerFactoryBean.getScheduler();TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getName(), scheduleJob.getGroup());CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob.getCron());trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();scheduler.rescheduleJob(triggerKey, trigger);}public static void main(String[] args) {CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule("xxxxx");}}

Quartz 版本为 Quartz 2.2.3：http://d2zwv9pap9ylyd.cloudfront.net/quartz-2.2.3-distribution.tar.gz

006tKfTcgy1fqj5aochgoj309k09kmwz.jpg

扫描关注：热爱生活的大叔

（转载本站文章请注明作者和出处 热爱生活的大叔-uniquezhangqi）

转载于:https://www.cnblogs.com/uniquezhangqi/p/9199316.html

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

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

相关文章

android baseactivity,Android应用开发Android通过BaseActivity获取到当前启动的Activity名称...

android baseactivity,Android应用开发Android通过BaseActivity获取到当前启动的Activity名称...

本文将带你了解Android应用开发Android通过BaseActivity获取到当前启动的Activity名称&#xff0c;希望本文对大家学Android有所帮助。<在BaseActivity的onCreate方法中:public class BaseActivity extends AppCompatActivity { Override protected void onCreate(Nul…
阅读更多...
RIP RETE时间获得PHREAKY

RIP RETE时间获得PHREAKY

我刚刚完成了我称为PHREAK的新规则算法的一些高级文档&#xff0c;这是混合推理中的一个文字游戏。 它仍然有点粗糙和高水平&#xff0c;但希望仍然很有趣。 它建立在ReteOO之上&#xff0c;非常好阅读。 ReteOO算法 ReteOO是在3、4和5系列发行版中开发的。 它采用RETE算法并应…
阅读更多...
Hadoop自学笔记（三）MapReduce简单介绍

Hadoop自学笔记（三）MapReduce简单介绍

1. MapReduce Architecture MapReduce是一套可编程的框架&#xff0c;大部分MapReduce的工作都能够用Pig或者Hive完毕。可是还是要了解MapReduce本身是怎样工作的&#xff0c;由于这才是Hadoop的核心&#xff0c;而且能够为以后优化和自己写做准备。 Job Client, 就是用户 Job …
阅读更多...
洛谷 P2051 [AHOI2009]中国象棋 解题报告

洛谷 P2051 [AHOI2009]中国象棋 解题报告

P2051 [AHOI2009]中国象棋 题目描述 这次小可可想解决的难题和中国象棋有关&#xff0c;在一个N行M列的棋盘上&#xff0c;让你放若干个炮&#xff08;可以是0个&#xff09;&#xff0c;使得没有一个炮可以攻击到另一个炮&#xff0c;请问有多少种放置方法。大家肯定很清楚&am…
阅读更多...
VirtualDOM与diff(Vue实现)

VirtualDOM与diff(Vue实现)

写在前面 因为对Vue.js很感兴趣&#xff0c;而且平时工作的技术栈也是Vue.js&#xff0c;这几个月花了些时间研究学习了一下Vue.js源码&#xff0c;并做了总结与输出。文章的原地址&#xff1a;https://github.com/answershuto/learnVue。在学习过程中&#xff0c;为Vue加上了…
阅读更多...
使用Java的RESTful Web服务

使用Java的RESTful Web服务

REST代表“代表性状态转移”&#xff0c;由Roy Fielding于2000年在其论文“建筑风格和基于网络的软件体系结构设计”中首次提出。 REST是一种建筑风格。 HTTP是一种协议&#xff0c;其中包含一组REST体系结构约束。 REST基础 REST中的所有内容都被视为资源。 每个资源都由UR…
阅读更多...
android 基础应用程序,android应用程序基本实现(基础篇).ppt

android 基础应用程序,android应用程序基本实现(基础篇).ppt

《android应用程序基本实现(基础篇).ppt》由会员分享&#xff0c;可在线阅读&#xff0c;更多相关《android应用程序基本实现(基础篇).ppt(22页珍藏版)》请在人人文库网上搜索。1、Android应用程序基本实现,复杂的应用,上节课&#xff0c;我们实现了一个基本的android的应用程序…
阅读更多...
windows npm安装webpack

windows npm安装webpack

Webpack: Webpack 是一个前端资源加载/打包工具。 它将根据模块的依赖关系进行静态分析&#xff0c;然后将这些模块按照指定的规则生成对应的静态资源。 参考下图&#xff1a; 安装Webpack: 1.首先需要安装node.js&#xff08;npm&#xff09; 下载地址&#xff1a;node.js dow…
阅读更多...
ThreadLocal如何实现？

ThreadLocal如何实现？

这是我上周的帖子的后续文章&#xff0c;在那篇文章中我解释了ThreadLocal用法的动机 。 从帖子中我们可以回想起&#xff0c;如果您希望每个线程都有一个独立初始化的变量副本&#xff0c;则ThreadLocal确实是一个很酷的概念。 现在&#xff0c;好奇的人可能已经开始问“我如何…
阅读更多...
WPFの操作文件浏览框几种方式

WPFの操作文件浏览框几种方式

WPFの操作文件浏览框几种方式 原文:WPFの操作文件浏览框几种方式方式1&#xff1a; 使用win32控件OpenFileDialog Microsoft.Win32.OpenFileDialog ofd new Microsoft.Win32.OpenFileDialog(); ofd.DefaultExt ".xml"; ofd.Filter "xml file|*.xml"; if…
阅读更多...
为什么你应该尝试@reach/router

为什么你应该尝试@reach/router

最近react-router的一个作者另外写了一个类react-router的组件 reach/router&#xff0c;尝试后感觉太棒了。如果你的项目只是web端的话我认为可以把你的react-router换掉了。下面是我到目前看到的所有非常好的点。 小&#xff0c;就4kb,压缩后比react-router小40kb左右。 更少…
阅读更多...
android 浏览器 div穿透,解决IE 上重叠div 对 mouseover 事件的穿透方法之一

android 浏览器 div穿透,解决IE 上重叠div 对 mouseover 事件的穿透方法之一

解决IE 下重叠div 对 mouseover 事件的穿透方法之一? ? ? ? 历经一天半的时间&#xff0c;我这前端的白痴终于想到了一个解决IE 下重叠div ?对 mouseover 事件的穿透方法。??现象&#xff1a; 两个并列关系的Div(没有父子关系)&#xff0c;但是两个Div在位置上面有重叠&…
阅读更多...
类加载器工作机制

类加载器工作机制

类加载器工作机制&#xff1a;1.装载&#xff1a;将Java二进制代码导入jvm中&#xff0c;生成Class文件。2.连接&#xff1a;a&#xff09;校验&#xff1a;检查载入Class文件数据的正确性 b&#xff09;准备&#xff1a;给类的静态变量分配存储空间 c&#xff09;解析&#xf…
阅读更多...
webviewjavascriptbridge android ios,js与ios交互使用WebViewJavascriptBridge如何写多个函数

webviewjavascriptbridge android ios,js与ios交互使用WebViewJavascriptBridge如何写多个函数

//js与webview交互初始化function setupWebViewJavascriptBridge(callback) {if (window.WebViewJavascriptBridge) {return callback(WebViewJavascriptBridge);}if (window.WVJBCallbacks) {return window.WVJBCallbacks.push(callback);}window.WVJBCallbacks [callback];v…
阅读更多...
JavaFX中的塔防

JavaFX中的塔防

我想长时间使用我的游戏引擎来编写《塔防》游戏&#xff0c;但是由于另一个小组努力创建JavaFX《塔防》游戏&#xff0c;所以我认为我宁愿创建另一款游戏。 从邮件列表中&#xff0c;我了解到不再开发其他游戏。 因此&#xff0c;我决定尝试一下。 塔防是一款非常适合基于图块…
阅读更多...
CSS pointer-events属性的使用

CSS pointer-events属性的使用

楔子 在前端的开发中&#xff0c;我们都是直接与用户接触&#xff0c;应该尽量让用户感到操作畅快愉悦&#xff0c;获得类似native的感觉。其中动画是最常用的方法。 这里的需求是&#xff0c;弹层的设计&#xff0c;这个弹层希望可以像 native 上的弹层一样&#xff0c;点击…
阅读更多...
海思NB-IOT的SDK看门狗的使用

海思NB-IOT的SDK看门狗的使用

1. 看门狗需要喂狗&#xff0c;如果自己写的任务一直运行&#xff0c;那么空闲任务无法运行会导致看门狗复位&#xff0c;来看下看门狗的机制&#xff0c;首先系统启动的时候创建了空闲任务 在这个函数里面void vTaskStartScheduler( void )创建了下面的空闲任务 xReturn xTas…
阅读更多...
分布式Session框架

分布式Session框架

分布式Session框架 配置服务器&#xff0c;Zookeeper集群管理服务器可以统一管理所有服务器的配置文件共享这些Session存储在一个分布式缓存中&#xff0c;可以随时写入和读取&#xff0c;而且性能要很好&#xff0c;如Memcache&#xff0c;Tair。封装一个类继承自HttpSession&…
阅读更多...
向您的JVM添加一些熵

向您的JVM添加一些熵

能否生成真正的随机数取决于系统中的熵。 有人声称&#xff0c;这可以通过掷骰子来保证。 其他人认为&#xff0c;用此主体替换OpenJDK的java.math.Random.nextInt&#xff08;&#xff09;方法将有所帮助&#xff1a; public int nextInt() {return 14; }资料来源&#xff1a…
阅读更多...
android源码多少行,Android源码资料

android源码多少行,Android源码资料

缺点&#xff1a;有时会访问不了优点&#xff1a;搜索方便&#xff0c;支持跳转引用)一个操作的小技巧&#xff0c;不想跳转引用的类覆盖当前页面&#xff0c;可以按下ctrl键点击。https://www.cnblogs.com/CVstyle/p/6395662.htmlhttps://www.jianshu.com/p/25a908c7eefaAndro…
阅读更多...
最新文章

Copyright @ 2022~2023