在项目中很多地方会用到定时器,列如:每天完善0点关闭服务或收集今天的运行数据进行统计。
Quartz定时器是一个简单、功能比较完善的定时器,它的强大之处它可以配置定时表达式,使定时时间点非常灵活,下面是我个人的使用案例:
package cn.test; import static org.quartz.CronScheduleBuilder.cronSchedule; import static org.quartz.JobBuilder.newJob; import static org.quartz.TriggerBuilder.newTrigger; import itour.cn.utils.ConfiUtil; import org.apache.commons.configuration.Configuration; import org.quartz.CronTrigger; import org.quartz.Job; import org.quartz.JobDetail; import org.quartz.JobExecutionContext; import org.quartz.JobExecutionException; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.SchedulerFactory; import org.quartz.impl.StdSchedulerFactory; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class QTaxQuartz implements Job { private static Logger log = LoggerFactory.getLogger(QTaxQuartz.class); private static SchedulerFactory sf = new StdSchedulerFactory(); private String qtaxTime = null; public QTaxQuartz() { //触发时间可配置,更多示例参考下表Cron表达式 Configuration config = ConfiUtil.getConfig(); if (config != null) { this.qtaxTime = "0 0 2 * * ?";//config.getString("QtaxTime"); } else { log.warn("QTaxQuartz 初始化失败,请检查配置文件!"); } } @Override public void execute(JobExecutionContext context) throws JobExecutionException { startQtax(); } //start Qtax public void startQtax() { try{ //写业务代码 }catch(Exception e){ log.error(e.getMessage(),e); } } //QtaxJob:任务名,QtaxGroup:任务组 //QtaxTrigger:触发器名 TQtaxGroup:触发器组名 public void initialQuartz() { try { Scheduler sched = sf.getScheduler(); JobDetail job = newJob(QTaxQuartz.class).withIdentity("QtaxJob", "QtaxGroup").build(); CronTrigger trigger = newTrigger().withIdentity("QtaxTrigger", "TQtaxGroup").withSchedule(cronSchedule(qtaxTime)).build(); sched.scheduleJob(job, trigger); if (!sched.isStarted()) { log.info("QTaxQuartz initialQuartz start"); sched.start(); } else log.info("QTaxQuartz initialQuartz started"); } catch (SchedulerException e) { log.error("QTaxQuartz initialQuartz start failed!!!"); } } public void destory() { try { Scheduler sched = sf.getScheduler(); if (!sched.isShutdown()) sched.shutdown(); log.info("Quartz destory!"); } catch (Exception e) { log.error("QTaxQuartz destory stop failed!!!"); } } }
Cron表示式示例
表示式 |
说明 |
"0 0 12 * * ? " |
每天12点运行 |
"0 15 10 ? * *" |
每天10:15运行 |
"0 15 10 * * ?" |
每天10:15运行 |
"0 15 10 * * ? *" |
每天10:15运行 |
"0 15 10 * * ? 2008" |
在2008年的每天10:15运行 |
"0 * 14 * * ?" |
每天14点到15点之间每分钟运行一次,开始于14:00,结束于14:59。 |
"0 0/5 14 * * ?" |
每天14点到15点每5分钟运行一次,开始于14:00,结束于14:55。 |
"0 0/5 14,18 * * ?" |
每天14点到15点每5分钟运行一次,此外每天18点到19点每5钟也运行一次。 |
"0 0-5 14 * * ?" |
每天14:00点到14:05,每分钟运行一次。 |
"0 10,44 14 ? 3 WED" |
3月每周三的14:10分到14:44,每分钟运行一次。 |
"0 15 10 ? * MON-FRI" |
每周一,二,三,四,五的10:15分运行。 |
"0 15 10 15 * ?" |
每月15日10:15分运行。 |
"0 15 10 L * ?" |
每月最后一天10:15分运行。 |
"0 15 10 ? * 6L" |
每月最后一个星期五10:15分运行。 |
"0 15 10 ? * 6L 2007-2009" |
在2007,2008,2009年每个月的最后一个星期五的10:15分运行。 |
"0 15 10 ? * 6#3" |
每月第三个星期五的10:15分运行。 |
定时器一般还与容器监听器配合使用,容器启动时开始定时器,关闭是停止定时器
package cn.test; import itour.cn.fare.gateway.QTaxQuartz; import javax.servlet.ServletContextEvent; import javax.servlet.ServletContextListener; public class CrashController implements ServletContextListener { QTaxQuartz qTax = new QTaxQuartz();//Q税定时器控制 public void contextInitialized(ServletContextEvent event) { //定时Q税开启 qTax.initialQuartz(); } public void contextDestroyed(ServletContextEvent event) { //宕机时,销毁Q税定时器 qTax.destory(); } }
注意在web.xml中加上配置:
<listener>
<listener-class>itour.cn.fare.gateway.service.CrashController</listener-class>
</listener>
有关quartz的使用,更多内容:http://wenku.baidu.com/view/2a0ae0c9f90f76c660371a1c.html