Quartz与Spring整合练习源代码

package com.earl.quartz.test; import java.text.SimpleDateFormat; import java.util.Date; import org.junit.Test; import org.quartz.CronScheduleBuilder; import org.quartz.CronTrigger; import org.quartz.DateBuilder; import org.quartz.JobBuilder; import org.quartz.JobDetail; import org.quartz.ScheduleBuilder; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.SchedulerFactory; import org.quartz.SimpleScheduleBuilder; import org.quartz.SimpleTrigger; import org.quartz.Trigger; import org.quartz.TriggerBuilder; import org.quartz.impl.StdSchedulerFactory; import org.slf4j.Logger; import org.slf4j.LoggerFactory; import com.earl.quartz.test.job.CronJob; import com.earl.quartz.test.job.HelloJob; import com.earl.quartz.test.job.SimpleJob; public class MyTest { Logger logger=LoggerFactory.getLogger(MyTest.class); /** * DateBuilder方法测试 */ @Test public void test01(){ Date nowDate=new Date(); SimpleDateFormat sdf=new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); /* * evenXxxDate：返回给定日期的下一个整点，整分，整秒 * evenXxxDateAfterNow：返回当前日期的下一个整点，整分，整秒 * evenXxxDateBefore：返回给定日期的上一个整点，整分，整秒 */ logger.info(sdf.format(nowDate)+"--evenHourDate--"+sdf.format(DateBuilder.evenHourDate(nowDate))); logger.info(sdf.format(nowDate)+"--evenHourDateAfterNow--"+sdf.format(DateBuilder.evenHourDateAfterNow())); logger.info(sdf.format(nowDate)+"--evenHourDateBefore--"+sdf.format(DateBuilder.evenHourDateBefore(nowDate))); logger.info(sdf.format(nowDate)+"--evenMinuteDate--"+sdf.format(DateBuilder.evenMinuteDate(nowDate))); logger.info(sdf.format(nowDate)+"--evenMinuteDateAfterNow--"+sdf.format(DateBuilder.evenMinuteDateAfterNow())); logger.info(sdf.format(nowDate)+"--evenMinuteDateBefore--"+sdf.format(DateBuilder.evenMinuteDateBefore(nowDate))); logger.info(sdf.format(nowDate)+"--evenSecondDate--"+sdf.format(DateBuilder.evenSecondDate(nowDate))); logger.info(sdf.format(nowDate)+"--evenSecondDateAfterNow--"+sdf.format(DateBuilder.evenSecondDateAfterNow())); logger.info(sdf.format(nowDate)+"--evenSecondDateBefore--"+sdf.format(DateBuilder.evenSecondDateBefore(nowDate))); /* * nextGivenMinuteDate：将给定分钟数加于给定日期，如果给定日期为空，那么当前日期将会被设置，返回得到的日期。如果有进位，则只返回下一个整点日期 * nextGivenSecondDate：将给定秒数加于给定日期，如果给定日期为空，那么当前日期将会被设置，返回得到的日期。给定秒数区间为0~59。如果有进位，则只返回当前分钟的最大秒数。 */ logger.info(sdf.format(nowDate)+"--nextGivenMinuteDate--"+sdf.format(DateBuilder.nextGivenMinuteDate(nowDate, 10))); logger.info(sdf.format(nowDate)+"--nextGivenSecondDate--"+sdf.format(DateBuilder.nextGivenSecondDate(nowDate, 59))); } @Test public void test02(){ try { logger.info("------- 初始化 ----------------------"); //通过工厂方法创建Schedule Scheduler scheduler=getScheduler(); logger.info("------- 初始化完成 ----------------------"); Date triggerStartTime=DateBuilder.evenSecondDate(new Date()); logger.info("------- 作业调度开始 -------------------"); //获取jobs，triggers JobDetail job=JobBuilder.newJob(HelloJob.class).withIdentity("job", "group").build(); Trigger trigger=TriggerBuilder.newTrigger().withIdentity("trigger", "group").startAt(triggerStartTime).build(); scheduler.scheduleJob(job, trigger); logger.info(job.getKey() + " will run at: " + triggerStartTime); scheduler.start(); logger.info("------- 等待5秒 -------------------"); try { Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); } logger.info("------- 准备结束 -------------------"); scheduler.shutdown(true); logger.info("------- 结束完成 -------------------"); } catch (SchedulerException e) { e.printStackTrace(); } } @Test public void test03(){ logger.info("-----初始化调度程序-----"); Scheduler scheduler = getScheduler(); logger.info("-----初始化完成-----"); Date startDate=DateBuilder.nextGivenSecondDate(null, 3); JobDetail job1=JobBuilder.newJob(SimpleJob.class).withIdentity("job1", "group1").build(); SimpleTrigger trigger1=(SimpleTrigger) TriggerBuilder.newTrigger().withIdentity("trigger1", "group1").startAt(startDate).build(); logger.info(job1.getKey()+"------"+trigger1.getStartTime()); try { Date schedulerDate=scheduler.scheduleJob(job1, trigger1); logger.info("------调度程序在"+schedulerDate+"时执行------"); logger.info("-------开始执行调度程序--------"); scheduler.start(); try { logger.info("------- 等待5秒 -------------------"); Thread.sleep(5000); } catch (InterruptedException e) { e.printStackTrace(); } logger.info("------- 准备结束 -------------------"); scheduler.shutdown(true); logger.info("------- 结束完成 -------------------"); } catch (SchedulerException e) { e.printStackTrace(); } } @Test public void test04(){ logger.info("--------初始化调度程序-----"); Scheduler scheduler=getScheduler(); logger.info("--------初始化调度程序完成-----"); //返回当前时间加10秒 Date triggerStartTime=DateBuilder.nextGivenSecondDate(null, 10); JobDetail job=JobBuilder.newJob(SimpleJob.class).withIdentity("job", "group").build(); //设定5秒重复触发一次，直到永远 SimpleTrigger simpleTrigger=(SimpleTrigger) TriggerBuilder.newTrigger(). withIdentity("trigger", "group").startAt(triggerStartTime). withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(5)). build(); logger.info(job+"--------"+simpleTrigger.getRepeatCount()); try { scheduler.scheduleJob(job, simpleTrigger); logger.info("--------作业调度开始---------"); scheduler.start(); try { Thread.sleep(100000); } catch (InterruptedException e) { e.printStackTrace(); } logger.info("------- 准备结束 -------------------"); scheduler.shutdown(true); logger.info("------- 结束完成 -------------------"); } catch (SchedulerException e) { e.printStackTrace(); } } @Test public void test05(){ logger.info("-----初始化调度程序-----"); Scheduler scheduler = getScheduler(); logger.info("-----初始化完成-----"); /* * cron表达式有两种格式： * 1.秒 分 时 月中天 月 周中天 年 * 2.秒 分 时 月中天 月 周中天 * * 每个周周一及月末最后一天 * * * * L * MON * */ JobDetail cronJob=JobBuilder.newJob(CronJob.class).withIdentity("cronJob", "group").build(); CronTrigger cronTrigger=(CronTrigger) TriggerBuilder.newTrigger().withIdentity("cronTrigger", "group"). withSchedule(CronScheduleBuilder.cronSchedule("50 51 15 * * ?")).build(); try { scheduler.scheduleJob(cronJob, cronTrigger); scheduler.start(); try { Thread.sleep(100000); } catch (InterruptedException e) { e.printStackTrace(); } logger.info("------- 准备结束 -------------------"); scheduler.shutdown(true); logger.info("------- 结束完成 -------------------"); } catch (SchedulerException e) { e.printStackTrace(); } } private Scheduler getScheduler() { SchedulerFactory factory=new StdSchedulerFactory(); Scheduler scheduler=null; try { scheduler=factory.getScheduler(); } catch (SchedulerException e) { e.printStackTrace(); } return scheduler; } }