Quartz2 定時器 《三》（動態定時）
這裏先簡單列一下具體實現：spring
1、Spring的配置（只須要在配置中加入下面這一句就行）xcode
<bean id="schedulerFactoryBean" class="org.springframework.scheduling.quartz. SchedulerFactoryBean" />
2、首先我列一下具體實現的入口異步
@Autowired private Scheduler scheduler; //這個在jar包中，Scheduler是一個接口 @Autowired private ScheduleJobManager scheduleJobManager; ...... //建立advert開始任務 ScheduleJob jobStart = scheduleJobManager.creatScheduleAdStart(advert); //建立個做業 ScheduleUtils.createScheduleJobAd(scheduler, jobStart,"start"); //創建做業的定時器 //建立advert結束任務 ScheduleJob jobEnd = scheduleJobManager.creatScheduleAdEnd(advert); ScheduleUtils.createScheduleJobAd(scheduler, jobEnd,"end");
3、這裏看到須要建立ScheduleJob類（同時，這裏還有用到另外一個ide
public class ScheduleJob{
/** 任務id */
private Long scheduleJobId;
/** 任務名稱 */
private String jobName;
/** 任務別名 */
private String aliasName;
/** 任務分組 */
private String jobGroup;
/** 觸發器 */
private String jobTrigger;
/** 任務狀態 */
private String status;
/** 任務運行時間表達式 */
private String cronExpression;
/** 是否異步 */
private Boolean isSync;
/** 任務描述 */
private String description;
/** 建立時間 */
private Date gmtCreate;
/** 修改時間 */
private Date gmtModify;
....getter & setter.....
這裏後面還用到工具
public class ScheduleJobVo{
/** 任務調度的參數key */
public static final String JOB_PARAM_KEY = "jobParam";
public static final String JOB_FLAG_KEY = "jobFlag";
public static final String JOB_SCHEDULER_KEY = "jobScheduler";
/** 任務id */
private Long scheduleJobId;
/** 任務名稱 */
private String jobName;
/** 任務別名 */
private String aliasName;
/** 任務分組 */
private String jobGroup;
/** 觸發器 */
private String jobTrigger;
/** 任務狀態 */
private String status;
/** 任務運行時間表達式 */
private String cronExpression;
/** 是否異步 */
private Boolean isSync;
/** 任務描述 */
private String description;
/** 建立時間 */
private Date gmtCreate;
/** 修改時間 */
private Date gmtModify;
....getter & setter
}
4、首先先看下serviceimpl中寫的ScheduleJobManager，這裏能夠建立不少個做業。ui
@Service
public class ScheduleJobManager {
//廣告自動生效
public ScheduleJob creatScheduleAdStart(Advert advert) {
ScheduleJob job = new ScheduleJob();
job.setScheduleJobId(advert.getId()); //任務實體的id做爲做業id
String jobName = advert.getId()+"_advertStartGroup_"; //設置做業名稱
job.setJobName(jobName);
job.setJobGroup("advertStartGroup"); //設置分組
//下面是設置定時器的啓動時間
Date advertStartTime = advert.getAdStartTime();//從實體中獲取定時器啓動時間
Calendar cal=Calendar.getInstance();
cal.setTime(advertStartTime);
int year = cal.get(Calendar.YEAR);
int month = cal.get(Calendar.MONTH)+1;
int day = cal.get(Calendar.DAY_OF_MONTH);
int hour = cal.get(Calendar.HOUR_OF_DAY);
int minute = cal.get(Calendar.MINUTE);
int second = cal.get(Calendar.SECOND);
String cronExpression = second+" "+minute+" "+hour+" "+day+" "+month+" ? "+year;//模板
job.setCronExpression(cronExpression);//設置了啓動時間
job.setIsSync(true);
return job; //返回一個做業
}
}
5、而後咱們再來看一下建立定時器的具體實現，入口程序中寫了code
ScheduleUtils.createScheduleJobAd(scheduler, jobStart,"start"); //創建做業的定時器
在ScheduleUtils中，看一下createScheduleJobAd這個方法 （把建立定時器寫到了工具類）接口
public static void createScheduleJobAd(Scheduler scheduler, ScheduleJob scheduleJob,
Object jobFlag) {//只須要建立三個參數來便可，而後調用另外一個方法去執行
createScheduleJobAd(scheduler, scheduleJob.getJobName(), scheduleJob.getJobGroup(),
scheduleJob.getCronExpression(), scheduleJob.getIsSync(), scheduleJob, jobFlag);
}
如下是上面用到的方法（建立定時任務）：ip
public static void createScheduleJobAd(Scheduler scheduler, String jobName, String jobGroup,
String cronExpression, boolean isSync, Object param, Object jobFlag) {
//構建job信息
JobDetail jobDetail = JobBuilder.newJob(QuartzJobAdFactory.class) //這個是任務執行的類
.withIdentity(jobName, jobGroup).build();
//放入參數，定時器觸發後執行方法時能夠獲取
jobDetail.getJobDataMap().put(ScheduleJobVo.JOB_PARAM_KEY, param);
jobDetail.getJobDataMap().put(ScheduleJobVo.JOB_FLAG_KEY, jobFlag);
jobDetail.getJobDataMap().put(ScheduleJobVo.JOB_SCHEDULER_KEY, scheduler);
//表達式調度構建器
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
//按新的cronExpression表達式構建一個新的trigger
CronTrigger trigger = TriggerBuilder.newTrigger().withIdentity(jobName, jobGroup)
.withSchedule(scheduleBuilder).build();
try {
scheduler.scheduleJob(jobDetail, trigger); //建立定時器
System.out.println(jobName+"定時任務建立完成");
} catch (SchedulerException e) {
LOG.error("建立定時任務失敗", e);
//throw new ScheduleException("建立定時任務失敗");
}
}
6、QuartzJobAdFactory.class 這個定時器到時間後執行的任務get
public class QuartzJobAdFactory implements Job {
private static Logger logger = Logger.getLogger(QuartzJobAdFactory.class);
@Override
public void execute(JobExecutionContext context)throws JobExecutionException {
Map<String,Object> m = new HashMap<String,Object>();
WebApplicationContext wac = ContextLoader.getCurrentWebApplicationContext();
AdvertDAO advertDAO = (AdvertDAO) wac.getBean("advertDAO");
//以上是項目須要，根據我的須要修改
ScheduleJob scheduleJob = (ScheduleJob) context.getMergedJobDataMap().get(
ScheduleJobVo.JOB_PARAM_KEY);
String jobFlag = (String)context.getMergedJobDataMap().get(ScheduleJobVo.JOB_FLAG_KEY);
Scheduler scheduler = (Scheduler) context.getMergedJobDataMap().get(
ScheduleJobVo.JOB_SCHEDULER_KEY);
//上面其實就是獲取建立定時器時候，傳來的參數
String jobName= scheduleJob.getJobName();
String jobGroup = scheduleJob.getJobGroup();
System.out.print("QuartzJobAdFactory: 開始執行...「"+jobName+"」"+new Date()+"\r\n");
//自動發佈操做,更新活動狀態
Long id = scheduleJob.getScheduleJobId(); //這裏放的就是實體類advert的id，能夠直接用
try {
if(jobFlag.equals("start")){
//×××××××
寫入商城本身的邏輯
××××××××//
}else if(jobFlag.equals("end")){
//×××××寫入商城邏輯
××××××××××××//
}
System.out.print("QuartzJobAdFactory: 執行結束...「"+jobName+"」"+new Date()+"\r\n");
//執行完任務以後刪除任務
ScheduleUtils.deleteScheduleJob(scheduler, jobName, jobGroup);
//執行完任務，將其刪除
} catch (Exception e) {
logger.info(e.toString());
System.out.print("QuartzJobAdFactory: 執行更新狀態報錯...「"+jobName+"」"+new Date()+"\r\n");
}
}
}
7、刪除定時任務
public static void deleteScheduleJob(Scheduler scheduler, String jobName, String jobGroup) {
try {
scheduler.deleteJob(getJobKey(jobName, jobGroup));
System.out.println("刪除定時任務成功..."+jobName);
} catch (SchedulerException e) {
LOG.error("刪除定時任務失敗", e);
//throw new ScheduleException("刪除定時任務失敗");
}
}
8、更新定時任務
public static void updateScheduleJob(Scheduler scheduler, ScheduleJob scheduleJob) {
updateScheduleJob(scheduler, scheduleJob.getJobName(), scheduleJob.getJobGroup(),
scheduleJob.getCronExpression(), scheduleJob.getIsSync(), scheduleJob);
}
具體實現
public static void updateScheduleJob(Scheduler scheduler, String jobName, String jobGroup,
String cronExpression, boolean isSync, Object param) {
try {
TriggerKey triggerKey = ScheduleUtils.getTriggerKey(jobName, jobGroup);
//表達式調度構建器
CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(cronExpression);
CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);
//按新的cronExpression表達式從新構建trigger
trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();
//按新的trigger從新設置job執行
scheduler.rescheduleJob(triggerKey, trigger);
} catch (SchedulerException e) {
LOG.error("更新定時任務失敗", e);
//throw new ScheduleException("更新定時任務失敗");
}
}
9、其餘操做
暫停
Scheduler scheduler = schedulerFactoryBean.getScheduler(); JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup()); scheduler.pauseJob(jobKey);
恢復
Scheduler scheduler = schedulerFactoryBean.getScheduler(); JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup()); scheduler.resumeJob(jobKey);
當即執行
Scheduler scheduler = schedulerFactoryBean.getScheduler(); JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup()); scheduler.triggerJob(jobKey);
上面就是定時器，動態實現的代碼實現，只可做爲參考。
文章有參考：
http://www.dexcoder.com/selfly/article/311如下出處
相關文章
- 1. Quartz2 定時器 《一》（概述）
- 2. 動態添加定時任務-quartz定時器
- 3. Java 動態定時器
- 4. Spring動態定時器
- 5. 轉spring配置定時任務quartz2
- 6. springboot定時、動態定時任務
- 7. quartz 定時器的動態加載和取消定時任務
- 8. Java Timer定時器 使用
- 9. spring定時器運用
- 10. Quartz實現動態定時任務
- 更多相關文章...
- • PHP 5 時區 - PHP參考手冊
- • XSD 限定 / Facets - XML Schema 教程
- • RxJava操作符（十）自定義操作符
- • Docker容器實戰(七) - 容器眼光下的文件系統
相關標籤/搜索
每日一句
-
每一个你不满意的现在，都有一个你没有努力的曾经。
歡迎關注本站公眾號,獲取更多信息
相關文章
- 1. Quartz2 定時器 《一》（概述）
- 2. 動態添加定時任務-quartz定時器
- 3. Java 動態定時器
- 4. Spring動態定時器
- 5. 轉spring配置定時任務quartz2
- 6. springboot定時、動態定時任務
- 7. quartz 定時器的動態加載和取消定時任務
- 8. Java Timer定時器 使用
- 9. spring定時器運用
- 10. Quartz實現動態定時任務