第三十七天 用Timer在Web工程中实现类似触发器的机制
用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:chen_meng@hotmail.com">陈盟</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:chen_meng@hotmail.com">陈盟</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>
就可以了.
如果有更好的解决方式, 希望您回复.
