当前位置导航:炫浪网>>网络学院>>编程开发>>JAVA教程>>Java进阶

Web App用Quartz实现java schedule job


  关于Quartz
  
  1 下载Quartz java包copy到WEB-INF/lib下
  
  2 建立 scheduler初始化servlet
  
  在web.xml里加入
  <servlet>
  <servlet-name>Initializer</servlet-name>
  <servlet-class>
  com.nova.colimas.web.action.StartupServlet
  </servlet-class>
  <load-on-startup>1</load-on-startup>
  </servlet>
  
  初始化servlet代码如下:
  
  public class StartupServlet extends HttpServlet {
  public void init(ServletConfig cfg) throws
  javax.servlet.ServletException {
  initScheduler(cfg);
  return;
  }
  protected void initScheduler(ServletConfig cfg){
  logger.info("Quartz Init Servlet loaded, initializing Scheduler...");
  // Start now
  try{
  // Create an default instance of the Scheduler
  Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
  //将scheduler存入serlvet上下文。
  cfg.getServletContext().setAttribute(Constants.SCHEDULER_KEY,scheduler);
  }catch(Exception e){
  logger.error("Quartz Init Servlet failed");
  }
  }}
  
  3 程序配置一个schedule job
  
  /**
  * @author tyrone
  *
  * TODO To change the template for this generated type comment go to
  * Window - Preferences - Java - Code Style - Code Templates */public class BatchEditAction extends Action implements PrivilegedAction {
  private static Logger logger = null;
  private Scheduler scheduler=null;
  public ActionForward execute(ActionMapping mapping,
  ActionForm form,
  HttpServletRequest request,
  HttpServletResponse response)
  throws Exception{
  ActionMessages errors=new ActionMessages();
  logger = Logger.getLogger(this.getClass());
  //获得Servlet上下文
  ServletContext ctx =
  request.getSession().getServletContext();
  //获得scheduler对象
  scheduler=(Scheduler)ctx.getAttribute(Constants.SCHEDULER_KEY);
  //根据form属性建立job
  createJob(form);
  try{
  logger.info("Scheduler starting up...");
  //启动scheduler。
  scheduler.start();
  }catch(Exception e){
  logger.error("scheduler get error");
  }
  return mapping.findForward("success");
  }
  /**
  * create a job based on form info.
  * @param form
  * @return
  */  protected void createJob(ActionForm form) throws Exception{
  BatchInfoForm batchinfo=(BatchInfoForm)form;
  String classname=batchinfo.getFile();
  SimpleTrigger sTrigger=null;
  JobDetail jobDetail=null;
  Calendar cal=null;
  //如果是一天一次的job
  if (batchinfo.getFrequency().equalsIgnoreCase("onceDaily")){
  logger.info("Batch run OnceDaily");
  cal = new AnnualCalendar();
  //Add Calendar to the Scheduler
  /*
  * Setup a trigger to start firing now, with a null end date/time,
  * repeat forever and have (hour*60+ minute)*60000 ms between each firing.
  */
  //开始时间:11:45
  String[] time=batchinfo.getDailyStartTime().split(":");
  java.util.Calendar rightNow = java.util.Calendar.getInstance();
  rightNow.set(java.util.Calendar.HOUR_OF_DAY,new Integer(time[0]).intValue());
  rightNow.set(java.util.Calendar.MINUTE,new Integer(time[1]).intValue());
  //间隔24小时
  long repeatInterval=24*60*60000;
  sTrigger = new SimpleTrigger("Trigger",
  Scheduler.DEFAULT_GROUP, rightNow.getTime(), null,
  SimpleTrigger.REPEAT_INDEFINITELY, repeatInterval);
  }
  }
  // Trigger 关联一个Calendar, batchinfo.getName()唯一表示一个Calendar
  sTrigger.setCalendarName(batchinfo.getName());
  scheduler.addCalendar(batchinfo.getName(), cal, true, true);
  try{
  //job类名为com.nova.colimas.job.Test
  jobDetail = new JobDetail(classname,
  Scheduler.DEFAULT_GROUP, Class.forName(classname));
  //job关联一个Trigger,加入scheduler
  scheduler.scheduleJob(jobDetail, sTrigger);
  }catch(ClassNotFoundException ex){
  logger.error(ex);
  throw new Exception();
  }
  return ;
  }}
  
  4 Job代码,job必须继承org.quartz.Job
  
  package com.nova.colimas.job;import org.apache.log4j.Logger;
  import org.quartz.Job;
  import org.quartz.JobExecutionContext;
  import org.quartz.JobExecutionException;
  public class Test implements Job {
  private static Logger logger = null;
  public void execute(JobExecutionContext arg0) throws JobExecutionException {
  // 定时运行。
  logger = Logger.getLogger(this.getClass());
  logger.info("test job is running");
  }}
  
  5 运行结果
  
  [framework] 2005-08-23 11:45:29,440 - com.nova.colimas.job.Test -215700 [DefaultQuartzScheduler_Worker-0] INFO com.nova.colimas.job.Test - test job is running
相关内容
赞助商链接