用java.util.Timer在Web工程中实现类似触发器的机制
现在正在做的项目要实现一个定时出帐的触发器, 开始打算用Spring整合的Quartz工具来实现(同时Spring也提供了对java.util.Timer的支持),
Spring对Quartz整合的方式,是在配置文件中通过bean的property项设置一个cronTrigger表达式来实现精确的时点触发,但是由于Spring只有在启动的时候对注入值进行读取,这样的话就很难实现通过运行时读取配置参数,达到不用重启服务即可改变出帐时间的目的,所以只好自己寻找好一点的解决方案.
在网上找到了一篇文章,看了很受启发,我略做了一些修改,实现了在每个月的某一天的某一个时间进行任务操作的功能.
代码及注释如下:
先要实现一个系统的监听器:
/** * <p>Title: </p> * <p>Description: </p> * <p>Copyright: Copyright (C)Chen Meng 2005</p> * <p>Company: 陈盟 </p> * * @author <a href="mailto:[email protected]">陈盟</a> * @version 1.0 * @since 2005-1-13 / 17:26:41 */ package com.wellsoon.cttbj.vab.background;
import java.util.Date;
import javax.servlet.ServletContextEvent; import javax.servlet.ServletContextListener;
public class SettleAccountListener implements ServletContextListener { private java.util.Timer timer = null;
/* * @see javax.servlet.ServletContextListener#contextInitialized(javax.servlet.ServletContextEvent) */ public void contextInitialized(ServletContextEvent event) { Date taskRun = null; // TODO Auto-generated method stub taskRun = new Date(); timer = new java.util.Timer(true); event.getServletContext().log("定时器已启动"); /在这里每隔一分钟轮询一次出帐任务,如果任务间隔比较大的话建议把这个值设的大一点,但此设置值将间接影响可设定的触发精度. timer.schedule(new SettleAccountTask(), 0, 60*1000); / event.getServletContext().log("已经添加任务调度表");
}
/* * @see javax.servlet.ServletContextListener#contextDestroyed(javax.servlet.ServletContextEvent) */ public void contextDestroyed(ServletContextEvent event) { // TODO Auto-generated method stub timer.cancel(); event.getServletContext().log("定时器销毁");
}
}
接着来看SettleAccountTask的实现:
/** * <p>Title: </p> * <p>Description: </p> * <p>Copyright: Copyright (C)Chen Meng 2005</p> * <p>Company: 陈盟 </p> * * @author <a href="mailto:[email protected]">陈盟</a> * @version 1.0 * @since 2005-1-13 / 17:35:55 */
package com.wellsoon.cttbj.vab.background;
import java.util.Calendar; import java.util.Date; import java.util.TimerTask;
public class SettleAccountTask extends TimerTask {
private static boolean isRunning = false; private static long doTaskMillis = 0l;
public void run() { System.out.println(doTaskMillis); //下面两个值代表每月的哪一天几点进行实际任务操作.可以通过数据库查询获得 int C_SCHEDULE_DATE = 10; int C_SCHEDULE_HOUR = 4; Calendar cal = Calendar.getInstance(); //如果任务量很大,在下次轮询时仍在执行上次轮询的任务,则跳过本次执行,直接错过. if (!isRunning) { //如果当前系统时间的DAY_OF_MONTH和HOUR_OF_DAY不满足以下条件,则跳过实际操作. if (C_SCHEDULE_DATE == cal.get(Calendar.DAY_OF_MONTH) && C_SCHEDULE_HOUR == cal.get(Calendar.HOUR_OF_DAY)) { //如果上次执行任务的时间距此次轮询时间间隔太短,则跳过实际操作. if((doTaskMillis + 2*60*60*1000) < cal.getTimeInMillis()) { // 详细任务 isRunning = true; System.out.println("执行出帐操作"); doTaskMillis = cal.getTimeInMillis(); System.out.println(doTaskMillis); isRunning = false; } } } else { System.out.println("错过"); } } }
最后,在web.xml中加上 <listener> <listener-class>com.xxx.background.SettleAccountListener</listener-class> </listener>
就可以了.
如果有更好的解决方式, 希望您回复. 
|