永康网站开发公司,网站接入,wordpress分类模板制作,深圳宝安区律师事务所本文首次发布于My Blog,作者张琦(Ian),转载请保留原文链接。 有状态和无状态 使用有状态#xff08;StatefulJob#xff09;还是无状态的任务#xff08;Job#xff09; 在 Quartz 中#xff0c;基本来说#xff0c;任务分为有状态和无状态两种。实现 Job 接口的任务缺省… 本文首次发布于My Blog,作者张琦(Ian),转载请保留原文链接。 有状态和无状态 使用有状态StatefulJob还是无状态的任务Job 在 Quartz 中基本来说任务分为有状态和无状态两种。实现 Job 接口的任务缺省为无状态的。Quartz 中还有另外一个接口 StatefulJob。实现 StatefulJob 接口的任务为有状态的。 无状态任务一般指可以并发的任务即任务之间是独立的不会互相干扰。有状态反之。 通过Quartz获得状态为启动的所有job /*
Create a GroupMatcher that matches job groups starting with the given string.*/
GroupMatcherJobKey matcher GroupMatcher.anyJobGroup();/*
Get the keys of all the JobDetails in the matching groups.*/
SetJobKey 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 ListScheduleJob 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();// 这里获取任务信息数据ListScheduleJob jobList scheduleJobMapper.getAll();for (ScheduleJob job : jobList) {addJob(job);}}/*** 获取所有计划中的任务列表* * return* throws SchedulerException*/public ListScheduleJob getAllJob() throws SchedulerException {Scheduler scheduler schedulerFactoryBean.getScheduler();GroupMatcherJobKey matcher GroupMatcher.anyJobGroup();SetJobKey jobKeys scheduler.getJobKeys(matcher);ListScheduleJob jobList new ArrayListScheduleJob();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 ListScheduleJob getRunningJob() throws SchedulerException {Scheduler scheduler schedulerFactoryBean.getScheduler();ListJobExecutionContext executingJobs scheduler.getCurrentlyExecutingJobs();ListScheduleJob jobList new ArrayListScheduleJob(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.3http://d2zwv9pap9ylyd.cloudfront.net/quartz-2.2.3-distribution.tar.gz 扫描关注热爱生活的大叔转载本站文章请注明作者和出处 热爱生活的大叔-uniquezhangqi 转载于:https://www.cnblogs.com/uniquezhangqi/p/9199316.html
