quartz入门（二）SimpleTrigger简单实例

绝地灬酷狼 2022-05-29 01:07 239阅读 0赞

[http://blog.csdn.net/wo541075754/article/details/46502819][http_blog.csdn.net_wo541075754_article_details_46502819]

此篇博客为quartz2.2.1第二个例子的解析，此例子主要对SimpleTrigger的使用进行详细说明，详细使用说明均在代码中以注释的形式体现。

*  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());
    
        }
    }

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20
 *  21
 *  22
 *  23
 *  24

# 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();
        }
    }

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20
 *  21
 *  22
 *  23
 *  24
 *  25
 *  26
 *  27
 *  28
 *  29
 *  30
 *  31
 *  32
 *  33
 *  34
 *  35
 *  36
 *  37
 *  38
 *  39
 *  40
 *  41
 *  42
 *  43
 *  44
 *  45
 *  46
 *  47
 *  48
 *  49
 *  50
 *  51
 *  52
 *  53
 *  54
 *  55
 *  56
 *  57
 *  58
 *  59
 *  60
 *  61
 *  62
 *  63
 *  64
 *  65
 *  66
 *  67
 *  68
 *  69
 *  70
 *  71
 *  72
 *  73
 *  74
 *  75
 *  76
 *  77
 *  78
 *  79
 *  80
 *  81
 *  82
 *  83
 *  84
 *  85
 *  86
 *  87
 *  88
 *  89
 *  90
 *  91
 *  92
 *  93
 *  94
 *  95
 *  96
 *  97
 *  98
 *  99
 *  100
 *  101
 *  102
 *  103
 *  104
 *  105
 *  106
 *  107
 *  108
 *  109
 *  110
 *  111
 *  112
 *  113
 *  114
 *  115
 *  116
 *  117
 *  118
 *  119
 *  120
 *  121
 *  122
 *  123
 *  124
 *  125
 *  126
 *  127
 *  128
 *  129
 *  130
 *  131
 *  132
 *  133
 *  134
 *  135
 *  136
 *  137
 *  138

# 日志信息 #

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.

*  1
 *  2
 *  3
 *  4
 *  5
 *  6
 *  7
 *  8
 *  9
 *  10
 *  11
 *  12
 *  13
 *  14
 *  15
 *  16
 *  17
 *  18
 *  19
 *  20
 *  21
 *  22
 *  23
 *  24
 *  25
 *  26
 *  27
 *  28
 *  29
 *  30
 *  31
 *  32
 *  33
 *  34
 *  35
 *  36
 *  37
 *  38
 *  39
 *  40
 *  41
 *  42
 *

[http_blog.csdn.net_wo541075754_article_details_46502819]: http://blog.csdn.net/wo541075754/article/details/46502819