Trigger介绍

Quartz有一些不同的触发器类型,不过,用得最多的是SimpleTrigger和CronTrigger

jobKey

表示job实例的标识,触发器被触发时,该指定的job实例会被执行

statrTime

表示触发器的时间表,第一次开始被触发的时间,它的数据类型是java.util.Date

endTime

指定触发器终止被触发时间,它的数据类型是java.uti.Date

环境准备工作实现任务调度需要导入两个quartz的maven依赖

 <!--quzrtz任务调度 核心包-->
<dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz</artifactId><version>2.3.2</version>
</dependency>
<!--工具包 可有可无-->
<dependency><groupId>org.quartz-scheduler</groupId><artifactId>quartz-jobs</artifactId><version>2.3.2</version>
</dependency>

使用的日志框架

<dependency><groupId>org.slf4j</groupId><artifactId>slf4j-log4j12</artifactId><version>1.7.2</version>
</dependency>
<dependency><groupId>log4j</groupId><artifactId>log4j</artifactId><version>1.2.17</version>
</dependency>

先创建一个类实现Job接口这个是完成的任务

package com.quartz;import org.quartz.*;import java.text.SimpleDateFormat;
import java.util.Date;/*** package_name:com.quartz* Author:徐亚远* Date:2020/1/16 19:59* 项目名:quartz-one* Desription:**/
public class HelloJobTrigger implements Job {@Overridepublic void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {Date date = new Date();SimpleDateFormat simpleDateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String dateString = simpleDateFormat.format(date);System.out.println("正在进行数据库的备份工作:数据库备份时间:"+dateString);Trigger trigger = jobExecutionContext.getTrigger();System.out.println("jobKey的名称:"+trigger.getKey().getName()+";  jobKey组的名称: "+trigger.getKey().getGroup());//startTime 开始任务时间System.out.println("任务开始执行的时间:"+simpleDateFormat.format(trigger.getStartTime()));//endTime  任务结束时间System.out.println("任务结束时间:"+simpleDateFormat.format(trigger.getEndTime()));}
}

在实现一个main方法 里面包括调度器Scheduler，任务实例JobDetail,触发器Trigger

package com.scheduler;import com.quartz.HelloJob;
import com.quartz.HelloJobTrigger;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;import java.util.Date;/*** package_name:com.scheduler* Author:徐亚远* Date:2020/1/16 20:03* 项目名:quartz-one* Desription:**/
public class HelloSchedulerTrigger {public static void main(String args[]) throws Exception {//调度器(Scheduler),从工厂中获取调度实例,Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();//开始时间 startTimeDate startDate = new Date();//任务的开始时间推迟五秒startDate.setTime(startDate.getTime() + 5000);//结束时间 endTimeDate endDate = new Date();//任务的结束时间推迟十秒(10秒后停止)endDate.setTime(endDate.getTime() + 10000);//任务实例(JobDetail)JobDetail jobDetail = JobBuilder.newJob(HelloJobTrigger.class) //加载任务类 完成与HelloJob的绑定 要求 HelloJob必须实现Job接口.withIdentity("job", "group1") //参数1 任务的名称 参数二 任务组的名称.usingJobData("message", "打印日志jobDetail") //传递参数.build();//触发器(Triger)Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1", "group1") //参数1触发器的名称 参数2 触发器组的名称//.startNow()  //马上启动触发器.withSchedule(SimpleScheduleBuilder.simpleSchedule().repeatSecondlyForever(5)).startAt(startDate) //设置任务的开始时间.endAt(endDate)  //设置任务的结束时间.build();//让调度器关联任务和触发器,保证按照触发器的条件执行任务scheduler.scheduleJob(jobDetail, trigger);//启动scheduler.start();}
}

输出结果