Quartz應用實踐入門案例二(基於java工程)

　　在web應用程序中添加定時任務，Quartz的簡單介紹可以參看博文《Quartz應用實踐入門案例一(基於Web應用)》 。其實一旦學會了如何應用開源框架就應該很容易將這中框架應用與自己的任何程序中。只要你的程序中需要這項功能！但是對於一些剛開始學習某種框架的菜鳥而言，這似乎就不是那么簡單了。如果在學習開源框架API的同時，能有一兩個案例小程序配着其API去看，那應該就是事半功倍了。

　　本文是在自己學習源碼和網上查找資料的基礎上完成的，將詳細敘述在java工程中如何巧妙的融入Quartz框架，小案例的運行你會發現在不用xml配置文件的時候，依然是如此的簡單。通過這兩篇博文的學習你會知道如何在不同的應用軟件中部署這種框架。這些個小程序僅供參考學習用，博文版權歸作者和博客園共有。

　　作者：itRed   郵箱：[e-mail]    博客：http://www.cnblogs.com/itred

　　如果你先看了《Quartz應用實踐入門案例一(基於Web應用)》這篇博文，那么看這篇時，你會覺得比較輕松。因為其配置的原理和大概的走向都是一樣的。最主要的不同就是將web應用程序中的xml配置寫入了java源碼中。直接運行(main方法測試通過)。如果你是大神級人物，歡迎拍磚，其他的。我們就共同學習，共同進步。

　　先說一下這個小程序demo的主要效果：每隔2s向控制台輸出當前時間，具體形式參見最后運行結果。

　　一．新建項目java項目：

　　　　　　注意：不是web工程；

　　二. 添加包名和jar包：

　　　　在src目下建立包 com.red.quartz；

　　　　在項目目錄下見文件夾，命名為lib，用於存放項目所需的jar包；

　　　　然后將所需的jar包拷貝到lib文件夾下，然后build path到自己的項目中。實現過程如圖示：

　　　　　　　　　　

　　　　項目結構圖：

　　　　　　　　　　

　　三. 在quartz包下見一個quartz管理的java類，即：quartz管理器（quartz控制器）,為  QuartzController.java：

    private static SchedulerFactory gSchedulerFactory = new StdSchedulerFactory();
    private static String JOB_GROUP_NAME = "EXTJWEB_JOBGROUP_NAME";
    private static String TRIGGER_GROUP_NAME = "EXTJWEB_TRIGGERGROUP_NAME";

    public static void addJob(String jobName, String jobClass, String time) {
       try {
           Scheduler sched = gSchedulerFactory.getScheduler();
           JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, Class.forName(jobClass));// 任務名，任務組，任務執行類
           // 觸發器
           CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);// 觸發器名,觸發器組
           trigger.setCronExpression(time);// 觸發器時間設定
           sched.scheduleJob(jobDetail, trigger);
            // 啟動
           if (!sched.isShutdown()){
                  sched.start();
                 }
          } catch (Exception e) {
                e.printStackTrace();
                throw new RuntimeException(e);
            }
        }

 

　　四．新建一個TestJob類，繼承job接口，並實現execute方法：　

 　　　　@SuppressWarnings("deprecation")
        public void execute(JobExecutionContext arg0) throws JobExecutionException {
            System.out.println(Calendar.getInstance().getTime().toLocaleString()+ "★★★★★★★★★★★");
        }

 

　　java代碼方面的quartz已經就做完了。只需要寫一個測試類main方法，就可以查看這個程序的運行效果。

　　測試main方法如下：

1　　　　 public static void main(String[] args) {
            QuartzController qm=new QuartzController();
            String ts="com.red.quartz.TestJob";
            qm.addJob("job", ts, "0/2 * * * * ?");
        }

 

　　五. 程序運行效果如下：

　　　　

　　六. 程序之外：

　　　　貼出認為比較好的關於quartz學習的文章：http://www.ibm.com/developerworks/cn/java/j-quartz/

　　　　在xml和java代碼中應用Quartz框架，總結一些基礎配置的使用：

　　　　時間配置，網上搜一下就是一大把這方面的配置信息，只總結一些重要的知識：

　　　　　　　　星號由左到右按順序代表 ：     *    *     *     *    *     *   *     
                          　　　　　　　　　  格式: [秒] [分] [小時] [日] [月] [周] [年] 

　　　　　　　　通配符說明: 
　　　　　　　　　　* 表示所有值. 例如:在分的字段上設置 "*",表示每一分鍾都會觸發。 
　　　　　　　　　　? 表示不指定值。使用的場景為不需要關心當前設置這個字段的值。例如:要在每月的10號觸發一個操作，但不關心是周幾，所以需要周位置的那個字段設置為"?" 具體設置為 0 0 0 10 * ? 
　　　　　　　　　　- 表示區間。例如 在小時上設置 "10-12",表示 10,11,12點都會觸發。 
　　　　　　　　　　, 表示指定多個值，例如在周字段上設置 "MON,WED,FRI" 表示周一，周三和周五觸發 
　　　　　　　　　　/ 用於遞增觸發。如在秒上面設置"5/15" 表示從5秒開始，每增15秒觸發(5,20,35,50)。在月字段上設置'1/3'所示每月1號開始，每隔三天觸發一次。 
　　　　　　　　　　L 表示最后的意思。在日字段設置上，表示當月的最后一天(依據當前月份，如果是二月還會依據是否是潤年[leap]), 在周字段上表示星期六，相當於"7"或"SAT"。如果在"L"前加上數字，則　                       表示該數據的最后一個。例如在周字段上設置"6L"這樣的格式,則表示“本月最后一個星期五" 
　　　　　　　　　　W 表示離指定日期的最近那個工作日(周一至周五). 例如在日字段上設置"15W"，表示離每月15號最近的那個工作日觸發。如果15號正好是周六，則找最近的周五(14號)觸發, 如果15號是周                         未，則找最近的下周一(16號)觸發.如果15號正好在工作日(周一至周五)，則就在該天觸發。如果指定格式為 "1W",它則表示每月1號往后最近的工作日觸發。如果1號正是周六，則將在3號下周一觸                       發。(注，"W"前只能設置具體的數字,不允許區間"-"). 
　　　　提示 
　　　　　　'L'和 'W'可以一組合使用。如果在日字段上設置"LW",則表示在本月的最后一個工作日觸發(一般指發工資 ) 
　　　　　　# 序號(表示每月的第幾個周幾)，例如在周字段上設置"6#3"表示在每月的第三個周六.注意如果指定"#5",正好第五周沒有周六，則不會觸發該配置(用在母親節和父親節再合適不過了) 
　　　　　　周字段的設置，若使用英文字母是不區分大小寫的 MON 與mon相同. 

　　　　關於常用時間配置實例，自己百度。

給一些希望深入學習Quartz的朋友：QuartzController.java中源碼可以有很好的控制job。盡管本案例只是實現了一個任務，但是自己親測，多個是沒有任何問題的。

package com.red.quartz;

import java.text.ParseException;

import org.quartz.CronTrigger;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.impl.StdSchedulerFactory;

/**
 * 定時任務管理類
 */
public class QuartzController {
    private static SchedulerFactory gSchedulerFactory = new StdSchedulerFactory();
    private static String JOB_GROUP_NAME = "EXTJWEB_JOBGROUP_NAME";
    private static String TRIGGER_GROUP_NAME = "EXTJWEB_TRIGGERGROUP_NAME";

    /**
     * 添加一個定時任務，使用默認的任務組名，觸發器名，觸發器組名
     * 
     * @param jobName
     *            任務名
     * @param jobClass
     *            任務
     * @param time
     *            時間設置，參考quartz說明文檔
     */
    public static void addJob(String jobName, String jobClass, String time) {
        try {
            Scheduler sched = gSchedulerFactory.getScheduler();
            JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME,
                    Class.forName(jobClass));// 任務名，任務組，任務執行類
            // 觸發器
            CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);// 觸發器名,觸發器組
            trigger.setCronExpression(time);// 觸發器時間設定
            sched.scheduleJob(jobDetail, trigger);
            // 啟動
            if (!sched.isShutdown()) {
                sched.start();
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }

    /**
     * 添加一個定時任務
     * 
     * @param jobName
     *            任務名
     * @param jobGroupName
     *            任務組名
     * @param triggerName
     *            觸發器名
     * @param triggerGroupName
     *            觸發器組名
     * @param jobClass
     *            任務
     * @param time
     *            時間設置，參考quartz說明文檔
     */
    public static void addJob(String jobName, String jobGroupName,
            String triggerName, String triggerGroupName, String jobClass,
            String time) {
        try {
            Scheduler sched = gSchedulerFactory.getScheduler();
            JobDetail jobDetail = new JobDetail(jobName, jobGroupName,
                    Class.forName(jobClass));// 任務名，任務組，任務執行類
            // 觸發器
            CronTrigger trigger = new CronTrigger(triggerName, triggerGroupName);// 觸發器名,觸發器組
            trigger.setCronExpression(time);// 觸發器時間設定
            sched.scheduleJob(jobDetail, trigger);
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }

    /**
     * 修改一個任務的觸發時間(使用默認的任務組名，觸發器名，觸發器組名)
     * 
     * @param jobName
     * @param time
     */
    public static void modifyJobTime(String jobName, String time) {
        try {
            Scheduler sched = gSchedulerFactory.getScheduler();
            CronTrigger trigger = (CronTrigger) sched.getTrigger(jobName,
                    TRIGGER_GROUP_NAME);
            if (trigger == null) {
                return;
            }
            String oldTime = trigger.getCronExpression();
            if (!oldTime.equalsIgnoreCase(time)) {
                JobDetail jobDetail = sched.getJobDetail(jobName,
                        JOB_GROUP_NAME);
                Class objJobClass = jobDetail.getJobClass();
                String jobClass = objJobClass.getName();
                removeJob(jobName);

                addJob(jobName, jobClass, time);
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }

    /**
     * 修改一個任務的觸發時間
     * 
     * @param triggerName
     * @param triggerGroupName
     * @param time
     */
    public static void modifyJobTime(String triggerName,
            String triggerGroupName, String time) {
        try {
            Scheduler sched = gSchedulerFactory.getScheduler();
            CronTrigger trigger = (CronTrigger) sched.getTrigger(triggerName,
                    triggerGroupName);
            if (trigger == null) {
                return;
            }
            String oldTime = trigger.getCronExpression();
            if (!oldTime.equalsIgnoreCase(time)) {
                CronTrigger ct = (CronTrigger) trigger;
                // 修改時間
                ct.setCronExpression(time);
                // 重啟觸發器
                sched.resumeTrigger(triggerName, triggerGroupName);
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }

    /**
     * 移除一個任務(使用默認的任務組名，觸發器名，觸發器組名)
     * 
     * @param jobName
     */
    public static void removeJob(String jobName) {
        try {
            Scheduler sched = gSchedulerFactory.getScheduler();
            sched.pauseTrigger(jobName, TRIGGER_GROUP_NAME);// 停止觸發器
            sched.unscheduleJob(jobName, TRIGGER_GROUP_NAME);// 移除觸發器
            sched.deleteJob(jobName, JOB_GROUP_NAME);// 刪除任務
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }

    /**
     * 移除一個任務
     * 
     * @param jobName
     * @param jobGroupName
     * @param triggerName
     * @param triggerGroupName
     */
    public static void removeJob(String jobName, String jobGroupName,
            String triggerName, String triggerGroupName) {
        try {
            Scheduler sched = gSchedulerFactory.getScheduler();
            sched.pauseTrigger(triggerName, triggerGroupName);// 停止觸發器
            sched.unscheduleJob(triggerName, triggerGroupName);// 移除觸發器
            sched.deleteJob(jobName, jobGroupName);// 刪除任務
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }

    /**
     * 啟動所有定時任務
     */
    public static void startJobs() {
        try {
            Scheduler sched = gSchedulerFactory.getScheduler();
            sched.start();
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }

    /**
     * 關閉所有定時任務
     */
    public static void shutdownJobs() {
        try {
            Scheduler sched = gSchedulerFactory.getScheduler();
            if (!sched.isShutdown()) {
                sched.shutdown();
            }
        } catch (Exception e) {
            e.printStackTrace();
            throw new RuntimeException(e);
        }
    }
}

　　　　本文源碼下載

作者：itRed     郵箱：[e-mail] 博客鏈接：http://www.cnblogs.com/itred    
版權聲明：本文版權歸作者和博客園共有，歡迎轉載，但請在文章顯眼位置標明文章出處。未經本人書面同意，將其作為他用，本人保留追究責任的所有權利。