学步园

     在做web开发的时候，经常需要在一定的时间去跟新某些东西，或是加载某些东西，这就用到了定时器。

当Web工程启动时，定时器能自动开始计时，在整个Web工程的生命期里，定时器每过一段时间就执行一次，所以考虑定时器存放的位置。

定时器肯定不能不能简单的存在于单个Servlet或JavaBean中，必须能让定时器宿主的存活期为整个Web工程生命期，在工程启动时能自动加载运行。结合这两点，跟 Servlet上下文有关的侦听器就最合适不过了，通过在工程的配置文件中加以合理配置，会在工程启动时自动运行，并在整个工程生命期中处于监听状态。

下面就Servlet侦听器结合Java定时器来讲述整个实现过程：

import java.util.Timer;

import javax.servlet.ServletContextEvent;
import javax.servlet.ServletContextListener;
import javax.servlet.http.HttpServlet;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;

/**
 * @date 2010-1-14
 * @author wangpeng
 * 功能：监听器，用来实现计时器
 */
public class ContextListener extends HttpServlet implements
  ServletContextListener {
 /**
  *
  */
 private static final long serialVersionUID = 1L;

 private static final Log log = LogFactory.getLog(NewsTimerTask.class);
 
 public ContextListener() {
 }

 private Timer timer = null;

 public void contextInitialized(ServletContextEvent event) {
  timer = new Timer(true);
  log.info("定时器已启动");
  timer.schedule(new NewsTimerTask(event.getServletContext()),
    TIME_NEWS_DELAY, TIME_NEWS_PERIOD);
  log.info("已经添加任务调度表");
 }

 public void contextDestroyed(ServletContextEvent event) {
  timer.cancel(); //定时器的销毁
  log.info("定时器销毁");
 }

}

NewsTimerTask继承TimerTask
TimerTask是 由 Timer 安排为一次执行或重复执行的任务。

在这里我们把ServletContext传进来，就是为了方面一些存储的操作。我这里举的是调用spring，获取bean

import java.util.List;
import java.util.TimerTask;

import javax.servlet.ServletContext;

import org.apache.commons.logging.Log;
import org.apache.commons.logging.LogFactory;
import org.springframework.web.context.WebApplicationContext;
import org.springframework.web.context.support.WebApplicationContextUtils;

/**
 * @date 2010-1-14
 * @author wangpeng
 * 功能：计时器
 */
public class NewsTimerTask extends TimerTask {
 
 private static final Log log = LogFactory.getLog(NewsTimerTask.class);
 
 private ServletContext context = null;
 private NewsinfoDaoImpl newsinfoDao = null;
 private static boolean isRunning = false;
 public NewsTimerTask(){}
 
 public NewsTimerTask(ServletContext context) {
  this.context = context;
  WebApplicationContext wac = WebApplicationContextUtils.getRequiredWebApplicationContext(context);
  newsinfoDao = (NewsinfoDaoImpl) wac.getBean("newsinfoDao");
  System.out.println("-------------" + newsinfoDao.getById(1).get(0).getContent());
 }
 
 @Override
 public void run() {
  log.info("----------------定时器开始执行-----------------------");
  if(!isRunning) {
   isRunning = true;
   List<Newsinfo> listTopNews = newsinfoDao.queryByBake1(ConstantsConsumer.NEW_TOP_YES);
   List<Newsinfo> listTopSystem = newsinfoDao.queryByType(0, ConstantsConsumer.NEWS_SYSTEM);
   context.setAttribute("listTopNews", listTopNews);
   if(listTopSystem.size() > 0) {
    context.setAttribute("newsinfoSystem", listTopSystem.get(0));
   }
   isRunning = false;
  } else {
   log.info("上次还在执行中……");
  }
  log.info("----------------定时器执行结束-----------------------");
 }

}

最后在把监听器部署到web中就可以了

<listener>
  <listener-class>ContextListener</listener-class>
 </listener>