quartz入門（二）SimpleTrigger簡單實例

時間  2021-01-30
標籤 java web app ide svg spa .net 日誌 code 欄目 Quartz 简体版
原文   原文鏈接

此篇博客爲quartz2.2.1第二個例子的解析，此例子主要對SimpleTrigger的使用進行詳細說明，詳細使用說明均在代碼中以註釋的形式體現。java

  • SimpleTrigger:在某個時刻開始，而後按照某個時間間隔重複執行。
  • SimpleTrigger包括屬性：開始時間，結束時間，重複次數，重複間隔。

SimpleJob

package com.secbro.job;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;

import java.util.Date;

/** */
public class SimpleJob implements Job { 
 
   

    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // JobExecutionContext類提供了調度上線問的各類信息,爲JobDetail和Trigger提供必要的信息
        // JobKey是由name和group組成，而且name必須在group內是惟一的。若是隻指定一組則將使用默認的組名。
        JobKey jobKey = context.getJobDetail().getKey();

        System.out.println("SimpleJob says: " + jobKey + " executing at " + new Date());

    }
}

SimpleTriggerExample

package com.secbro.test;

import com.secbro.job.SimpleJob;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;

import java.util.Date;

/** * SimpleTrigger:在某個時刻開始，而後按照某個時間間隔重複執行;<br> * SimpleTrigger包括屬性：開始時間，結束時間，重複次數，重複間隔。 */
public class SimpleTriggerExample {

    public void run() throws SchedulerException {
        // 經過SchedulerFactory獲取一個調度器實例
        StdSchedulerFactory sf = new StdSchedulerFactory();
        // 表明一個Quartz的獨立運行容器
        Scheduler scheduler = sf.getScheduler();
        // 獲取當前時間15秒以後的時間
        Date startDate = DateBuilder.nextGivenSecondDate(null,15);

        // ------------------------------------------Job1 start-------------------------------------------------
        // 建立一個JobDetail實例,此版本JobDetail已經做爲接口（interface）存在，經過JobBuilder建立
        // 並指定Job在Scheduler中所屬組及名稱
        JobDetail jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job1","group1").build();

        // SimpleTrigger實現Trigger接口的子接口。此處只指定了開始執行定時任務的時間，使用默認的重複次數（0次）和重複間隔（0秒）
        SimpleTrigger simpleTrigger = (SimpleTrigger) TriggerBuilder.newTrigger().withIdentity("trigger1","group1").
                startAt(startDate).build();
        // 添加JobDetail到Scheduler容器中，而且和Trigger進行關聯，返回執行時間
        Date date = scheduler.scheduleJob(jobDetail,simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job1 end-------------------------------------------------
        // ------------------------------------------Job2 start-------------------------------------------------
        // 與job1相同處理方式的job2，幾乎同時執行兩個job1和job2任務
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job2","group1").build();
        simpleTrigger = (SimpleTrigger) TriggerBuilder.newTrigger().withIdentity("trigger2","group1").startAt(startDate).build();
        date = scheduler.scheduleJob(jobDetail,simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job2 end-------------------------------------------------
        // ------------------------------------------Job3 start-------------------------------------------------
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job3","group1").build();
        // 設置定時任務執行規則爲在指定的開始時間進行執行，每一個十秒執行一次，重複執行十次。
        // 當指定爲SimpleScheduleBuilder時，會發現不用對結果進行強制轉換爲SimpleTrigger了。
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger3", "group1").startAt(startDate)
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(10).withRepeatCount(10)).build();
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        scheduler.scheduleJob(jobDetail,simpleTrigger);
        // forJob 指定trigger對應的定時任務，另一種實現形式。此Trigger和上面的Trigger共同出發一個任務，執行各自均執行
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger3","group2").startAt(startDate)
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(10).withRepeatCount(2)).forJob(jobDetail).build();
        scheduler.scheduleJob(simpleTrigger);
        System.out.println(jobDetail.getKey() + " will [also] run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job3 end-------------------------------------------------
        // ------------------------------------------Job4 start-----------------------------------------------
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job4","group1").build();
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger4", "group1").startAt(startDate).
                withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(10).withRepeatCount(5)).build();
        date = scheduler.scheduleJob(jobDetail, simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");

        // ------------------------------------------Job4 end-------------------------------------------------
        // ------------------------------------------Job5 start-------------------------------------------------
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job5", "group1").build();
        simpleTrigger = (SimpleTrigger)TriggerBuilder.newTrigger().withIdentity("trigger5", "group1")
                .startAt(DateBuilder.futureDate(5, DateBuilder.IntervalUnit.MINUTE)).build();
        date = scheduler.scheduleJob(jobDetail, simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job5 end-------------------------------------------------
        // ------------------------------------------Job6 start-----------------------------------------------
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job6", "group1").build();
        // 此定時任務的規則爲每隔40秒執行一次，永遠執行下去
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger6", "group1").startAt(startDate)
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(40).repeatForever()).build();
        date = scheduler.scheduleJob(jobDetail, simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount() + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job6 end-------------------------------------------------
        System.out.println("------- Starting Scheduler ----------------");
        // 在scheduler.start以後調用，能夠從新定義trigger，從新註冊
        scheduler.start();
        System.out.println("------- Started Scheduler -----------------");
        // ------------------------------------------Job7 start-----------------------------------------------
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job7", "group1").build();
        // 每隔五分鐘執行一次，執行20次
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger7", "group1").startAt(startDate)
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInMinutes(5).withRepeatCount(20)).build();
        date = scheduler.scheduleJob(jobDetail, simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job7 end-------------------------------------------------
        // ------------------------------------------Job8 start-----------------------------------------------
        // storeDurably(),沒有觸發器指向任務的時候，將任務保存在隊列中，而後能夠經過手動進行出發
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job8", "group1").storeDurably().build();
        // 任務當即執行
        scheduler.addJob(jobDetail, true);
        System.out.println("手動觸發 triggering job8...");
        scheduler.triggerJob(JobKey.jobKey("job8", "group1"));
        // ------------------------------------------Job8 end-------------------------------------------------
        scheduler.start();
        try {
            Thread.sleep(60000L);
        } catch (InterruptedException e) {

        }

        // 對Job7進行從新安排
        System.out.println("------- Rescheduling... --------------------");
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger7", "group1").startAt(startDate).
                withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInMinutes(5).withRepeatCount(20)).build();
        date = scheduler.rescheduleJob(simpleTrigger.getKey(), simpleTrigger);
        System.out.println("job7 rescheduled to run at: " + date);
        System.out.println("------- Waiting five minutes... ------------");

        try {
            Thread.sleep(60000L);
        } catch (Exception ex) {
        }

        scheduler.shutdown(true);

        SchedulerMetaData metaData = scheduler.getMetaData();
        System.out.println("Executed " + metaData.getNumberOfJobsExecuted() + " jobs.");

    }

    public static void main(String[] args) throws SchedulerException {
        SimpleTriggerExample simpleTriggerExample = new SimpleTriggerExample();
        simpleTriggerExample.run();
    }
}

日誌信息

group1.job1 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 0 times, every 0 seconds
group1.job2 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 0 times, every 0 seconds
group1.job3 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 10 times, every 10 seconds
group1.job3 will [also] run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 2 times, every 10 seconds
group1.job4 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 5 times, every 10 seconds
group1.job5 will run at: Mon Jun 15 13:30:12 CST 2015 and repeat: 0 times, every 0 seconds
group1.job6 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: -1 times, every 40 seconds
------- Starting Scheduler ----------------
------- Started Scheduler -----------------
group1.job7 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 20 times, every 300 seconds
手動觸發   triggering job8...
SimpleJob says: group1.job8 executing at Mon Jun 15 13:25:12 CST 2015
SimpleJob says: group1.job1 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job2 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job6 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job7 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:25 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:25:25 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:25 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:35 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:25:35 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:35 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:45 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:25:45 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:55 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:25:55 CST 2015
SimpleJob says: group1.job6 executing at Mon Jun 15 13:25:55 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:05 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:26:05 CST 2015
------- Rescheduling... --------------------
job7 rescheduled to run at: Mon Jun 15 13:25:15 CST 2015
------- Waiting five minutes... ------------
SimpleJob says: group1.job7 executing at Mon Jun 15 13:26:12 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:15 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:25 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:35 CST 2015
SimpleJob says: group1.job6 executing at Mon Jun 15 13:26:35 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:45 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:55 CST 2015
Executed 28 jobs.

本文同步分享在 博客「程序新視界」（CSDN）。
若有侵權，請聯繫 support@oschina.cn 刪除。
本文參與「OSC源創計劃」，歡迎正在閱讀的你也加入，一塊兒分享。web

相關文章
相關標籤/搜索
每日一句
    每一个你不满意的现在，都有一个你没有努力的曾经。
本站公眾號
   歡迎關注本站公眾號,獲取更多信息
聯繫我們 最近搜索 最新文章 沪ICP备13005482号-10 MyBatis教程 SQL 教程 MySQL教程 Java 教程 Thymeleaf 教程 Hibernate教程 Spring教程 Redis教程