第三十七天 用Timer在Web工程中实现类似触发器的机制

类别:Java 点击:0 评论:0 推荐:

用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>

就可以了.

如果有更好的解决方式, 希望您回复.

本文地址:http://com.8s8s.com/it/it11909.htm