Quartz定時器實例

配置web

<!--啟動任務監聽器-->
<listener>
    <listener-class>com.suntek.web.pay.listener.ContextListener</listener-class>
</listener>

監聽類

public class ContextListener implements ServletContextListener {

    public void contextDestroyed(ServletContextEvent context) {
        // TODO Auto-generated method stub
        // 停止所有任務
        String[] jobNameSet = null;
        try {
            jobNameSet = JobScheduler.scheduler.getJobNames(Scheduler.DEFAULT_GROUP);
        } catch (SchedulerException e1) {
            // TODO Auto-generated catch block
            CommonLogger.logger.error(e1.getMessage(), e1);
        }

        for(String jobName : jobNameSet)
        {
            try {
                JobScheduler.scheduler.deleteJob(jobName, Scheduler.DEFAULT_GROUP);
            } catch (SchedulerException e) {
                // TODO Auto-generated catch block
                CommonLogger.logger.error(e.getMessage(), e);
            }
        }

        try {
            if( !JobScheduler.scheduler.isShutdown() )
                JobScheduler.scheduler.shutdown();
        } catch (SchedulerException e) {
            // TODO Auto-generated catch block
            CommonLogger.logger.error(e.getMessage(), e);
        }

    }

    public void contextInitialized(ServletContextEvent context) {
        // TODO Auto-generated method stub

        JobScheduler.addStockWarningJob(StockWarningJob.StockWarningJobName, StockWarningJob.StockWarningJobTrigger);
    }

}

JobScheduler

public class JobScheduler {

    public static Scheduler scheduler;

    static {
        try {
            scheduler = new StdSchedulerFactory().getScheduler();
        } catch (SchedulerException e) {
            // TODO Auto-generated catch block

        }
    }
    private static final String TRIGGER_GROUP_NAME = Constants.APP_NAME + "_trigger_group";
    /** 
     * @param jobName
     * @param triggerName
     * @author cwqi
     */
    public static void addStockWarningJob(String jobName, String triggerName) {
        try {
            // 判斷job是否存在
            if( isJobExist(jobName) ){
                scheduler.deleteJob(jobName, Scheduler.DEFAULT_GROUP);
            }
            CronTrigger trigger = new CronTrigger(triggerName, TRIGGER_GROUP_NAME);

            String cronExpression=Configure.getProperty("SEND_SMS_EXEC_INTERVAL");
            //每個月周一到周五的9點到17點，每隔30分鐘執行一次
            //cronExpression ="0 0/1 9-17 ? * 2-6";
            cronExpression=StringUtils.isBlank(cronExpression)?"0 0/30 9-17 ? * 2-6":cronExpression+" ? * 2-6";
            trigger.setCronExpression( cronExpression);

            //Date nextFireTime = trigger.getNextFireTime();
            Date nextFireTime = trigger.computeFirstFireTime(new BaseCalendar());
            SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
            String nextFireTimeStr = sdf.format(nextFireTime);

            CommonLogger.logger.debug("[JobScheduler.addStockWarningJob]JobName"+jobName+"next execute time:"+nextFireTimeStr);
            JobDetail jobDetail = new JobDetail(jobName, Scheduler.DEFAULT_GROUP, StockWarningJob.class);

            JobDataMap dataMap = jobDetail.getJobDataMap();
            dataMap.put("TASK_STOCKWARNINGJOB_NAME", jobName);

            scheduler.scheduleJob(jobDetail, trigger);
            if(scheduler.isShutdown()){
                scheduler.start();
            }


        } catch (Exception e) {
            // TODO Auto-generated catch block
            CommonLogger.logger.error("[JobScheduler.addStockWarningJob]fail:"+jobName);
            CommonLogger.logger.error("添加定時任務異常", e);
        }
    }


    private static boolean isJobExist(String jobName) {
        boolean isExist = false;
        try {
            String[] jobNames = scheduler.getJobNames(jobName);
            if( jobNames == null )
                return false;

            if( Arrays.asList(jobNames).contains(jobName) )
                return true;
        } catch (SchedulerException e) {
            // TODO Auto-generated catch block
            CommonLogger.logger.error(e.getMessage(), e);
        }
        return isExist;
    }

}

Job

public class StockWarningJob implements Job {

    // 備份任務觸發器名稱、任務名稱
    public static final String StockWarningJobTrigger = Constants.APP_NAME + "_StockWarningJobTrigger";
    public static final String StockWarningJobName = Constants.APP_NAME + "_StockWarningJobName";
    protected Logger logger = CommonLogger.logger;
    String stockValveString=Configure.getProperty("QBSTOCK_NOTENOUGH_WARNING");
    int stockValve=StringUtils.isBlank(stockValveString)?10:Integer.parseInt(stockValveString);

    public void execute(JobExecutionContext context) throws JobExecutionException {
        // TODO Auto-generated method stub
        JobDetail jobDetail = context.getJobDetail();
        JobDataMap dataMap = jobDetail.getJobDataMap();      
        String taskName = dataMap.getString("TASK_STOCKWARNINGJOB_NAME");    
        logger.debug("[StockWarningJob.execute]start:"+taskName);

    }
}

此外還有一種定時器是使用timerTask。