<rt id="bn8ez"></rt>
<label id="bn8ez"></label>

  • <span id="bn8ez"></span>

    <label id="bn8ez"><meter id="bn8ez"></meter></label>

    無線&移動互聯網技術研發

    換位思考·····
    posts - 19, comments - 53, trackbacks - 0, articles - 283
      BlogJava :: 首頁 :: 新隨筆 :: 聯系 :: 聚合  :: 管理

    Spring Quartz Trigger 和表達式(二)

    Posted on 2010-05-27 13:41 Gavin.lee 閱讀(4117) 評論(0)  編輯  收藏 所屬分類: SSH2 --Spring
     

    使用SimpleTrigger

    SimpleTrigger擁有多個重載的構造函數,用以在不同場合下構造出對應的實例:

    ●SimpleTrigger(String name, String group):通過該構造函數指定Trigger所屬組和名稱;

    ●SimpleTrigger(String name, String group, Date startTime):除指定Trigger所屬組和名稱外,還可以指定觸發的開發時間;

    ●SimpleTrigger(String name, String group, Date startTime, Date endTime, int repeatCount, long repeatInterval):除指定以上信息外,還可以指定結束時間、重復執行次數、時間間隔等參數;

    ●SimpleTrigger(String name, String group, String jobName, String jobGroup, Date startTime, Date endTime, int repeatCount, long repeatInterval):這是最復雜的一個構造函數,在指定觸發參數的同時,還通過jobGroupjobName,讓該TriggerScheduler中的某個任務關聯起來。

    通過實現 org.quartz..Job 接口,可以使 Java 類化身為可調度的任務。代碼清單1提供了 Quartz 任務的一個示例:

    代碼清單1 SimpleJob:簡單的Job實現類

    package com.baobaotao.basic.quartz;

    import java.util.Date;

    import org.quartz.Job;

    import org.quartz.JobExecutionContext;

    import org.quartz.JobExecutionException;

    publicclass SimpleJob 
    implements Job {

        
    // ①實例Job接口方法

        publicvoid execute(JobExecutionContext jobCtx) 
    throws JobExecutionException {

           System.out.println(jobCtx.getTrigger().getName() 
    + " triggered. time is:" + (new Date()));

        }


    }

     

    這個類用一條非常簡單的輸出語句實現了Job接口的execute(JobExecutionContext context) 方法,這個方法可以包含想要執行的任何代碼。下面,我們通過SimpleTriggerSimpleJob進行調度:

    代碼清單2 SimpleTriggerRunner:使用SimpleTrigger進行調度

    package com.baobaotao.basic.quartz;

    import java.util.Date;

    import org.quartz.JobDetail;

    import org.quartz.Scheduler;

    import org.quartz.SchedulerFactory;

    import org.quartz.SimpleTrigger;

    import org.quartz.impl.StdSchedulerFactory;

    publicclass SimpleTriggerRunner 
    {

        publicstaticvoid main(String args[]) 
    {

           
    try {

               
    // ①創建一個JobDetail實例,指定SimpleJob

               JobDetail jobDetail 
    = new JobDetail("job1_1""jGroup1", SimpleJob.class);

               
    // ②通過SimpleTrigger定義調度規則:馬上啟動,每2秒運行一次,共運行100次

               SimpleTrigger simpleTrigger 
    = new SimpleTrigger("trigger1_1""tgroup1");

               simpleTrigger.setStartTime(
    new Date());

               simpleTrigger.setRepeatInterval(
    2000);

               simpleTrigger.setRepeatCount(
    100);

               
    // ③通過SchedulerFactory獲取一個調度器實例

               SchedulerFactory schedulerFactory 
    = new StdSchedulerFactory();

               Scheduler scheduler 
    = schedulerFactory.getScheduler();

               
    // ④注冊并進行調度

               scheduler.scheduleJob(jobDetail, simpleTrigger);

               
    // ⑤調度啟動

               scheduler.start();

           }
     catch (Exception e) {

               e.printStackTrace();

           }


        }


    }

     

    首先在處通過JobDetail封裝SimpleJob,同時指定JobScheduler中所屬組及名稱,這里,組名為jGroup1,而名稱為job1_1。

    處創建一個SimpleTrigger實例,指定該TriggerScheduler中所屬組及名稱。接著設置調度的時間規則。

    最后,需要創建Scheduler實例,并將JobDetailTrigger實例注冊到Scheduler中。這里,我們通過StdSchedulerFactory獲取一個Scheduler實例,并通過scheduleJob(JobDetail jobDetail, Trigger trigger)完成兩件事:

    1)JobDetailTrigger注冊到Scheduler中;

    2)Trigger指派給JobDetail,將兩者關聯起來。

    Scheduler啟動后,Trigger將定期觸發并執行SimpleJobexecute(JobExecutionContext jobCtx)方法,然后每 10 秒重復一次,直到任務被執行 100 次后停止。

    還可以通過SimpleTriggersetStartTime(java.util.Date startTime)setEndTime(java.util.Date endTime)指定運行的時間范圍,當運行次數和時間范圍沖突時,超過時間范圍的任務運行不被執行。如可以通過simpleTrigger.setStartTime(new Date(System.currentTimeMillis() + 60000L))指定60秒鐘以后開始。

    除了通過scheduleJob(jobDetail, simpleTrigger)建立TriggerJobDetail的關聯,還有另外一種關聯TriggerJobDetail的方式:

    JobDetail jobDetail = new JobDetail("job1_1","jGroup1", SimpleJob.class);

    SimpleTrigger simpleTrigger = new SimpleTrigger("trigger1_1","tgroup1");

    simpleTrigger.setJobGroup("jGroup1");①-1:指定關聯的Job組名

    simpleTrigger.setJobName("job1_1");①-2:指定關聯的Job名稱

    scheduler.addJob(jobDetail, true);注冊JobDetail

    scheduler.scheduleJob(simpleTrigger);注冊指定了關聯JobDetailTrigger

    在這種方式中,Trigger通過指定Job所屬組及Job名稱,然后使用SchedulerscheduleJob(Trigger trigger)方法注冊Trigger。有兩個值得注意的地方:

    通過這種方式注冊的Trigger實例必須已經指定Job組和Job名稱,否則調用注冊Trigger的方法將拋出異常;

    引用的JobDetail對象必須已經存在于Scheduler中。也即,代碼中、的先后順序不能互換。

    在構造Trigger實例時,可以考慮使用org.quartz.TriggerUtils工具類,該工具類不但提供了眾多獲取特定時間的方法,還擁有眾多獲取常見Trigger的方法,如makeSecondlyTrigger(String trigName)方法將創建一個每秒執行一次的Trigger,而makeWeeklyTrigger(String trigName, int dayOfWeek, int hour, int minute)將創建一個每星期某一特定時間點執行一次的Trigger。而getEvenMinuteDate(Date date)方法將返回某一時間點一分鐘以后的時間。

    使用CronTrigger

    CronTrigger 能夠提供比 SimpleTrigger 更有具體實際意義的調度方案,調度規則基于 Cron 表達式,CronTrigger 支持日歷相關的重復時間間隔(比如每月第一個周一執行),而不是簡單的周期時間間隔。因此,相對于SimpleTrigger而言,CronTrigger在使用上也要復雜一些。

    Cron表達式

    Quartz使用類似于Linux下的Cron表達式定義時間規則,Cron表達式由67個由空格分隔的時間字段組成,如表1所示:

    1 Cron表達式時間字段

    位置

    時間域名

    允許值

    允許的特殊字符

    1

    0-59

    , - * /

    2

    分鐘

    0-59

    , - * /

    3

    小時

    0-23

    , - * /

    4

    日期

    1-31

    , - * ? / L W C

    5

    月份

    1-12

    , - * /

    6

    星期

    1-7

    , - * ? / L C #

    7

    (可選)

    空值1970-2099

    , - * /

    Cron表達式的時間字段除允許設置數值外,還可使用一些特殊的字符,提供列表、范圍、通配符等功能,細說如下:

    星號(*):可用在所有字段中,表示對應時間域的每一個時刻,例如,*在分鐘字段時,表示每分鐘;

    問號(?):該字符只在日期和星期字段中使用,它通常指定為無意義的值,相當于點位符;

    減號(-):表達一個范圍,如在小時字段中使用“10-12”,則表示從1012點,即10,11,12;

    逗號(,):表達一個列表值,如在星期字段中使用“MON,WED,FRI”,則表示星期一,星期三和星期五;

    斜杠(/)x/y表達一個等步長序列,x為起始值,y為增量步長值。如在分鐘字段中使用0/15,則表示為0,15,3045秒,而5/15在分鐘字段中表示5,20,35,50,你也可以使用*/y,它等同于0/y;

    ●L:該字符只在日期和星期字段中使用,代表“Last”的意思,但它在兩個字段中意思不同。L在日期字段中,表示這個月份的最后一天,如一月的31號,非閏年二月的28號;如果L用在星期中,則表示星期六,等同于7。但是,如果L出現在星期字段里,而且在前面有一個數值X,則表示這個月的最后X,例如,6L表示該月的最后星期五;

    ●W:該字符只能出現在日期字段里,是對前導日期的修飾,表示離該日期最近的工作日。例如15W表示離該月15號最近的工作日,如果該月15號是星期六,則匹配14號星期五;如果15日是星期日,則匹配16號星期一;如果15號是星期二,那結果就是15號星期二。但必須注意關聯的匹配日期不能夠跨月,如你指定1W,如果1號是星期六,結果匹配的是3號星期一,而非上個月最后的那天。W字符串只能指定單一日期,而不能指定日期范圍;

    ●LW組合:在日期字段可以組合使用LW,它的意思是當月的最后一個工作日;

    井號(#):該字符只能在星期字段中使用,表示當月某個工作日。如6#3表示當月的第三個星期五(6表示星期五,#3表示當前的第三個),而4#5表示當月的第五個星期三,假設當月沒有第五個星期三,忽略不觸發;

    ● C:該字符只在日期和星期字段中使用,代表“Calendar”的意思。它的意思是計劃所關聯的日期,如果日期沒有被關聯,則相當于日歷中所有日期。例如5C在日期字段中就相當于日歷5日以后的第一天。1C在星期字段中相當于星期日后的第一天。

    Cron表達式對特殊字符的大小寫不敏感,對代表星期的縮寫英文大小寫也不敏感。

    2下面給出一些完整的Cron表示式的實例:

    2 Cron表示式示例

    表示式

    說明

    "0 0 12 * * ? "

    每天12點運行

    "0 15 10 ? * *"

    每天10:15運行

    "0 15 10 * * ?"

    每天10:15運行

    "0 15 10 * * ? *"

    每天10:15運行

    "0 15 10 * * ? 2008"

    2008年的每天1015運行

    "0 * 14 * * ?"

    每天14點到15點之間每分鐘運行一次,開始于14:00,結束于14:59

    "0 0/5 14 * * ?"

    每天14點到15點每5分鐘運行一次,開始于14:00,結束于14:55

    "0 0/5 14,18 * * ?"

    每天14點到15點每5分鐘運行一次,此外每天18點到19點每5鐘也運行一次。

    "0 0-5 14 * * ?"

    每天14:00點到14:05,每分鐘運行一次。

    "0 10,44 14 ? 3 WED"

    3月每周三的14:10分到14:44,每分鐘運行一次。

    "0 15 10 ? * MON-FRI"

    每周一,二,三,四,五的10:15分運行。

    "0 15 10 15 * ?"

    每月1510:15分運行。

    "0 15 10 L * ?"

    每月最后一天10:15分運行。

    "0 15 10 ? * 6L"

    每月最后一個星期五10:15分運行。

    "0 15 10 ? * 6L 2007-2009"

    2007,2008,2009年每個月的最后一個星期五的10:15分運行。

    "0 15 10 ? * 6#3"

    每月第三個星期五的10:15分運行。

    CronTrigger實例

    下面,我們使用CronTriggerSimpleJob進行調度,通過Cron表達式制定調度規則,讓它每5秒鐘運行一次:

    代碼清單3 CronTriggerRunner:使用CronTrigger進行調度

    package com.baobaotao.basic.quartz;

    import org.quartz.CronExpression;

    import org.quartz.CronTrigger;

    import org.quartz.JobDetail;

    import org.quartz.Scheduler;

    import org.quartz.SchedulerFactory;

    import org.quartz.impl.StdSchedulerFactory;

    public class CronTriggerRunner {

        
    public static void main(String args[]) {

           
    try {

               JobDetail jobDetail 
    = new JobDetail("job1_2""jGroup1", SimpleJob.class);

               
    // ①-1:創建CronTrigger,指定組及名稱

               CronTrigger cronTrigger 
    = new CronTrigger("trigger1_2""tgroup1");

               
    // ①-2:定義Cron表達式

               CronExpression cexp 
    = new CronExpression("0/5 * * * * ?");

               
    // ①-3:設置Cron表達式

               cronTrigger.setCronExpression(cexp);

               SchedulerFactory schedulerFactory 
    = new StdSchedulerFactory();

               Scheduler scheduler 
    = schedulerFactory.getScheduler();

               scheduler.scheduleJob(jobDetail, cronTrigger);

               scheduler.start();

               
    // ②

           }
     catch (Exception e) {

               e.printStackTrace();

           }


        }


    }

     

    運行CronTriggerRunner,每5秒鐘將觸發運行SimpleJob一次。默認情況下Cron表達式對應當前的時區,可以通過CronTriggerRunnersetTimeZone(java.util.TimeZone timeZone)方法顯式指定時區。你還也可以通過setStartTime(java.util.Date startTime)setEndTime(java.util.Date endTime)指定開始和結束的時間。

    在代碼清單3處需要通過Thread.currentThread.sleep()的方式讓主線程睡眠,以便調度器可以繼續工作執行任務調度。否則在調度器啟動后,因為主線程馬上退出,也將同時引起調度器關閉,調度器中的任務都將相應銷毀,這將導致看不到實際的運行效果。在單元測試的時候,讓主線程睡眠經常使用的辦法。對于某些長周期任務調度的測試,你可以簡單地調整操作系統時間進行模擬。

    使用Calendar

    在實際任務調度中,我們不可能一成不變地按照某個周期性的調度規則運行任務,必須考慮到實現生活中日歷上特定日期,就象習慣了大男人作風的人在214號也會有不同表現一樣。

    下面,我們安排一個任務,每小時運行一次,并將五一節和國際節排除在外,其代碼如代碼清單4所示:

    代碼清單4 CalendarExample:使用Calendar

    package com.baobaotao.basic.quartz;

    import java.util.Calendar;

    import java.util.Date;

    import java.util.GregorianCalendar;

    import org.quartz.JobDetail;

    import org.quartz.Scheduler;

    import org.quartz.SchedulerFactory;

    import org.quartz.SimpleTrigger;

    import org.quartz.TriggerUtils;

    import org.quartz.impl.StdSchedulerFactory;

    import org.quartz.impl.calendar.AnnualCalendar;

    public class CalendarExample {

        
    public static void main(String[] args) throws Exception {

           SchedulerFactory sf 
    = new StdSchedulerFactory();

           Scheduler scheduler 
    = sf.getScheduler();

           
    // ①法定節日是以每年為周期的,所以使用AnnualCalendar

           AnnualCalendar holidays 
    = new AnnualCalendar();

           
    // ②五一勞動節

           Calendar laborDay 
    = new GregorianCalendar();

           laborDay.add(Calendar.MONTH, 
    5);

           laborDay.add(Calendar.DATE, 
    1);

           
    // ②-1:排除的日期,如果設置為false則為包含

           holidays.setDayExcluded(laborDay, 
    true);

           
    // ③國慶節

           Calendar nationalDay 
    = new GregorianCalendar();

           nationalDay.add(Calendar.MONTH, 
    10);

           nationalDay.add(Calendar.DATE, 
    1);

           
    // ③-1:排除該日期

           holidays.setDayExcluded(nationalDay, 
    true);

           
    // ④向Scheduler注冊日歷

           scheduler.addCalendar(
    "holidays", holidays, falsefalse);

           
    // ⑤4月1號上午10點

           Date runDate 
    = TriggerUtils.getDateOf(001014);

           JobDetail job 
    = new JobDetail("job1""group1", SimpleJob.class);

           SimpleTrigger trigger 
    = new SimpleTrigger("trigger1""group1",    runDate, null, SimpleTrigger.REPEAT_INDEFINITELY, 60L * 60L * 1000L);

           
    // ⑥讓Trigger應用指定的日歷規則

           trigger.setCalendarName(
    "holidays");

           scheduler.scheduleJob(job, trigger);

           scheduler.start();

           
    // 實際應用中主線程不能停止,否則Scheduler得不到執行,此處從略

        }


    }

     

    由于節日是每年重復的,所以使用org.quartz.CalendarAnnualCalendar實現類,通過、的代碼,指定五一和國慶兩個節日并通過AnnualCalendar#setDayExcluded(Calendar day, boolean exclude)方法添加這兩個日期。excludetrue時表示排除指定的日期,如果為false時表示包含指定的日期。

    在定制好org.quartz.Calendar后,還需要通過Scheduler#addCalendar(String calName, Calendar calendar, boolean replace, boolean updateTriggers)進行注冊,如果updateTriggerstrueScheduler中已引用CalendarTrigger將得到更新,如所示。

    處,我們讓一個Trigger指定使用Scheduler中代表節日的Calendar,這樣Trigger就會避開五一和國慶這兩個特殊日子了。

    主站蜘蛛池模板: 黄色免费网站网址| 爱情岛论坛免费视频| 久久青青草原亚洲av无码app| 久久久久无码专区亚洲av| 亚洲av成人一区二区三区在线观看| 免费黄色小视频网站| 免费爱爱的视频太爽了| 天天拍拍天天爽免费视频| 午夜一级毛片免费视频| 免费国产不卡午夜福在线 | 欧美亚洲国产SUV| 亚洲av无码专区在线观看下载| 亚洲av无一区二区三区| 男男gvh肉在线观看免费| 一级毛片大全免费播放| 精品乱子伦一区二区三区高清免费播放 | 一个人看www在线高清免费看| 久久久久国色AV免费看图片| 午夜小视频免费观看| 亚洲真人日本在线| 亚洲成AV人片在| 亚洲精品mv在线观看| 亚洲中文字幕乱码一区| 国产精品亚洲五月天高清| 黄色网页在线免费观看| 免费无码又爽又刺激高潮视频 | 18禁在线无遮挡免费观看网站| 久久成人免费大片| 91嫩草国产在线观看免费| 国产免费午夜a无码v视频| 亚洲中文字幕无码爆乳av中文| 亚洲日韩精品一区二区三区无码 | 亚洲精品中文字幕无乱码麻豆| 亚洲伊人久久大香线蕉AV| 免费一级毛suv好看的国产网站| 国产乱妇高清无乱码免费| 亚洲美女免费视频| 免费在线一级毛片| 亚洲日本va午夜中文字幕一区| 亚洲AV成人影视在线观看| 一级毛片一级毛片免费毛片 |