quartz动态添加和删除定时任务
2014-07-01 11:07
323 查看
动态添加和删除定时任务
package com.leweike.zz.timer;
import java.util.Iterator;
import java.util.Set;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.matchers.GroupMatcher;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;
public class TimerUtil {
public static void rollBackCredit(int cid,String time){
try {
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
GroupMatcher<JobKey> groupMatcher = GroupMatcher.groupEquals("rollbackCredit"+cid);
Set<JobKey> set = scheduler.getJobKeys(groupMatcher);
if (!CollectionUtils.isEmpty(set)) {
JobKey jobKey = null;
for (Iterator<JobKey> iterator = set.iterator(); iterator.hasNext();) {
jobKey = iterator.next();
scheduler.deleteJob(jobKey);
}
}
if (StringUtils.hasText(time)) {
String[] times = time.split(",");
JobDetail jobDetail = null;
CronScheduleBuilder scheduleBuilder =null;
CronTrigger trigger = null;
String[] strings = null;
for (String string : times) {
jobDetail = JobBuilder.newJob(RollBackJob.class).withIdentity(string, "rollbackCredit"+cid).build();
jobDetail.getJobDataMap().put("cId", cid);
if (StringUtils.hasText(string)) {
strings = string.split("-");
scheduleBuilder = CronScheduleBuilder.cronSchedule("59 59 23 "+Integer.valueOf(strings[1])+" "+Integer.valueOf(strings[0])+" ?");
trigger = TriggerBuilder.newTrigger().withIdentity(string, "rollbackCredit"+cid).withSchedule(scheduleBuilder).build();
scheduler.scheduleJob(jobDetail,trigger);
}
}
scheduler.start();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
package com.leweike.zz.timer;
import java.util.Iterator;
import java.util.Set;
import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.JobKey;
import org.quartz.Scheduler;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;
import org.quartz.impl.matchers.GroupMatcher;
import org.springframework.util.CollectionUtils;
import org.springframework.util.StringUtils;
public class TimerUtil {
public static void rollBackCredit(int cid,String time){
try {
Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
GroupMatcher<JobKey> groupMatcher = GroupMatcher.groupEquals("rollbackCredit"+cid);
Set<JobKey> set = scheduler.getJobKeys(groupMatcher);
if (!CollectionUtils.isEmpty(set)) {
JobKey jobKey = null;
for (Iterator<JobKey> iterator = set.iterator(); iterator.hasNext();) {
jobKey = iterator.next();
scheduler.deleteJob(jobKey);
}
}
if (StringUtils.hasText(time)) {
String[] times = time.split(",");
JobDetail jobDetail = null;
CronScheduleBuilder scheduleBuilder =null;
CronTrigger trigger = null;
String[] strings = null;
for (String string : times) {
jobDetail = JobBuilder.newJob(RollBackJob.class).withIdentity(string, "rollbackCredit"+cid).build();
jobDetail.getJobDataMap().put("cId", cid);
if (StringUtils.hasText(string)) {
strings = string.split("-");
scheduleBuilder = CronScheduleBuilder.cronSchedule("59 59 23 "+Integer.valueOf(strings[1])+" "+Integer.valueOf(strings[0])+" ?");
trigger = TriggerBuilder.newTrigger().withIdentity(string, "rollbackCredit"+cid).withSchedule(scheduleBuilder).build();
scheduler.scheduleJob(jobDetail,trigger);
}
}
scheduler.start();
}
} catch (Exception e) {
e.printStackTrace();
}
}
}
相关文章推荐
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务
- 任务调度开源框架Quartz动态添加、修改和删除定时任务