Quartz(02) 两种Trigger(SimpleTrigger/CronTrigger)

article/2025/10/25 22:01:52

上一章讲了Quartz 的几个核心概念(上一章节地址Quartz快速入门).接下来看看Quartz的两种Trigger. SimpleTrigger/CronTrigger. 简单的定时任务,可以采用SimpleTrigger,复杂的任务一般采用CronTrigger.

源码下载地址

1.SimpleTrigger
SimpleTrigger是Quartz中最简单Trigger.它是为那种需要在特定的日期/时间启动，且以一个可能的间隔时间重复执行 n 次的 Job 所设计的。下面有一个例子,每5秒钟执行一次,一共执行4次的任务.

实现了com.quartz.job接口的类

package com.quartz.job;import java.text.SimpleDateFormat;
import java.util.Date;import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;//实现了job接口的Q1 job
public class Q1 implements Job {@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {System.out.println("------------------------");SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd hh:mm:ss");System.out.println(sdf.format(new Date()));// 获取jobDetail 中的参数JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();String para1 = jobDataMap.getString("para1");System.out.println("jobDataMap中的para1:" + para1);System.out.println("------------------------");}}

使用SimpleTrigger

package com.quartz.test;import org.quartz.JobBuilder;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;import com.quartz.job.Q1;/*** 1.一个Job可以对应 多个Trigger，但一个Trigger只能对应一个Job* * 2.一个新的scheduler 或是处于standby状态的scheduler可以调用start方法* * @author Administrator*/
public class Listing_3_5 {public Listing_3_5() {}public Scheduler createScheduler() throws SchedulerException {return StdSchedulerFactory.getDefaultScheduler();}@SuppressWarnings("static-access")public void scheduleJob(Scheduler scheduler) throws SchedulerException {JobDetail jobDetail = JobBuilder.newJob(Q1.class).withIdentity("job1_1", "jGroup1").build();JobDataMap jobDataMap = jobDetail.getJobDataMap();jobDataMap.put("para1", "hello");// 一个scheduler 可以绑定多个job// 一个 Job 在同一个 Scheduler 实例中通过名称和组名能唯一被标识// 每5秒执行一次,共执行四次(注意参数为3)SimpleScheduleBuilder builder = SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).withRepeatCount(3);Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger_1", "tGroup1").startNow().withSchedule(builder).build();scheduler.scheduleJob(jobDetail, trigger);}public static void main(String[] args) throws Exception {Listing_3_5 example = new Listing_3_5();Scheduler scheduler = example.createScheduler();example.scheduleJob(scheduler);scheduler.start();}
}

运行结果(只运行了4次)
这里写图片描述

2.CronTrigger 不仅可以设定简单的触发时间表,更可以设定非常复杂的触发时间表。 CronTrigger 是基于 Unix类似于 cron 表达式,如果对cron表达式比较熟悉,那么学习起来经非常简单. 即使对cron表达式不熟悉,花一会儿的功夫也可以学会. cron 表达式在下一章重点讲解,本章稍作了解.假定有一个任务需要在21:00-21:03每分钟运行一次,此时我们发现SimpleTrigger 已经不能满足这个需求了.这个就是CronTrigger 登场的时候了,满足这个需求的对应的cron表达式是 0 00-03 21 * * ? (读者暂时不必深究这个表达式).实现如下

实现了com.quartz.job接口的类,

package com.quartz.job;import java.text.SimpleDateFormat;
import java.util.Date;import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;//实现了job接口的Q1 job
public class Q1 implements Job {@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {System.out.println("------------------------");SimpleDateFormat sdf = new SimpleDateFormat("yyyyMMdd hh:mm:ss");System.out.println(sdf.format(new Date()));// 获取jobDetail 中的参数JobDataMap jobDataMap = context.getJobDetail().getJobDataMap();String para1 = jobDataMap.getString("para1");System.out.println("jobDataMap中的para1:" + para1);System.out.println("------------------------");}}

使用CronTrigger

package com.quartz.test;import org.quartz.CronScheduleBuilder;
import org.quartz.CronTrigger;
import org.quartz.JobBuilder;
import org.quartz.JobDataMap;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;import com.quartz.job.Q1;/*** 1.一个Job可以对应 多个Trigger，但一个Trigger只能对应一个Job* * 2.一个新的scheduler 或是处于standby状态的scheduler可以调用start方法* * @author Administrator*/
public class Listing_3_6 {public Listing_3_6() {}public Scheduler createScheduler() throws SchedulerException {return StdSchedulerFactory.getDefaultScheduler();}public void scheduleJob(Scheduler scheduler) throws SchedulerException {JobDetail jobDetail = JobBuilder.newJob(Q1.class).withIdentity("job1_1", "jGroup1").build();JobDataMap jobDataMap = jobDetail.getJobDataMap();jobDataMap.put("num", "123");// cronTrigger 创建// 21:00 - 21:03 每分钟执行一次CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule("0 00-03 21 * * ?");CronTrigger cronTrigger = TriggerBuilder.newTrigger().withIdentity("trigger_1", "tGroup1").withSchedule(cronScheduleBuilder).build();scheduler.scheduleJob(jobDetail, cronTrigger);}public static void main(String[] args) throws Exception {Listing_3_6 example = new Listing_3_6();Scheduler scheduler = example.createScheduler();example.scheduleJob(scheduler);scheduler.start();}
}