700字范文 > Quartz-2.2.1 任务调度框架在Java项目中的使用实例

Quartz-2.2.1 任务调度框架在Java项目中的使用实例

时间：2020-06-27 21:45:08

《 Quartz-2.2.1 任务调度框架在Java项目中的使用实例》

本实例是基于Quartz 2.2.1 版本为中心，也是目前最新的Quartz任务调度框架。

目前在 J2EE 项目开发的过程中用的最多的任务调度框架为 Quartz，项目完成后，总结一下，主要为一些核心 API 和接口的概念比较重要。

一、Quartz-2.2.1使用实例

下面是一个通用的项目实例，高度抽象的实例，创建一个任务调度，三个任务。

Common

package com.etc.mon;import com.etc.clear.img.job.ClearImgJob;import com.etc.clear.img.job.SendImgJob;import com.etc.clear.img.job.UnzipImgJob;import com.etc.clear.img.utils.ImgQuartzUtils;/*** 初始化图片清理任务* * * @ClassName : ClsImgUtils* * * @Description : TODO* * * @Author : HuaZai* * * @ContactInformation : 1461522031@/huazai6789@* * * @Date : 12月20日下午4:38:52* * * * @Version : V1.0.0***/public class InitImgQuartzCommon {/*** 初始化图片清除任务* * * @Title : initClearImg* * * @Description : TODO* * * @Author : HuaZai* * * @Date : 1月2日下午2:28:08* */public void startClearImg() {try {// 使用 SimpleTrigger 进行图片处理// QuartzUtils.addJobBySimple("job01", "trigger01",// UnzipImgJob.class, 3);// QuartzUtils.addJobBySimple("job02", "trigger02",// SendImgJob.class, 4);// QuartzUtils.addJobBySimple("job03", "trigger03",// ClearImgJob.class, 5);// 使用 CronTrigger 进行图片处理// 压缩文件ImgQuartzUtils.addJobByCron("job01", "trigger01", UnzipImgJob.class, "*/5 * * * * ?");// 发送文件ImgQuartzUtils.addJobByCron("job02", "trigger02", SendImgJob.class, "*/5 * * * * ?");// 删除文件ImgQuartzUtils.addJobByCron("job03", "trigger03", ClearImgJob.class, "*/5 * * * * ?");} catch (Exception e) {e.printStackTrace();System.out.println(e.toString());}}}

Job

package com.etc.clear.img.job;import org.quartz.Job;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;/*** 定义清除服务器图片的任务* * * @ClassName : ClearImgJob* * * @Description : TODO* * * @Author : HuaZai* * * @ContactInformation : 1461522031@/huazai6789@* * * @Date : 1月3日下午1:19:11* * @Version : V1.0.0**/public class ClearImgJob implements Job {/*** 清除图片任务*/@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {System.out.println("================ 进入图片《删除》阶段 ....");}}

package com.etc.clear.img.job;import org.quartz.Job;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;/*** 发送服务器图片任务* * * @ClassName : SendImgJob* * * @Description : TODO* * * @Author : HuaZai* * * @ContactInformation : 1461522031@/huazai6789@* * * @Date : 1月3日下午1:19:39* * @Version : V1.0.0**/public class SendImgJob implements Job {/*** 发送压缩包任务*/@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {System.out.println("================ 进入图片《发送》阶段 ....");}}

package com.etc.clear.img.job;import org.quartz.Job;import org.quartz.JobExecutionContext;import org.quartz.JobExecutionException;/*** 压缩服务器图片任务* * * @ClassName : UnzipImgJob* * * @Description : TODO* * * @Author : HuaZai* * * @ContactInformation : 1461522031@/huazai6789@* * * @Date : 1月3日下午1:16:30* * @Version : V1.0.0**/public class UnzipImgJob implements Job {/*** 压缩图片任务*/@Overridepublic void execute(JobExecutionContext context) throws JobExecutionException {System.out.println("================ 进入图片《压缩》阶段 ....");}}

Utils

package com.etc.clear.img.utils;import org.quartz.CronScheduleBuilder;import org.quartz.Job;import org.quartz.JobBuilder;import org.quartz.JobDetail;import org.quartz.Scheduler;import org.quartz.SchedulerFactory;import org.quartz.SimpleScheduleBuilder;import org.quartz.Trigger;import org.quartz.TriggerBuilder;import org.quartz.impl.StdSchedulerFactory;import org.slf4j.Logger;import org.slf4j.LoggerFactory;/*** 任务调度工具类* * * @ClassName : QuartzUtils* * * @Description : TODO* * * @Author : HuaZai* * * @ContactInformation : 1461522031@/huazai6789@* * * @Date : 1月3日下午1:21:13* * @Version : V1.0.0**/public class ImgQuartzUtils {private final static String JOB_GROUP_NAME = "QUARTZ_JOBGROUP_NAME"; // 任务组private final static String TRIGGER_GROUP_NAME = "QUARTZ_TRIGGERGROUP_NAME"; // 触发器组private static Logger log = LoggerFactory.getLogger(ImgQuartzUtils.class);// 日志打印/*** 创建 SimpleTrigger* * * @Title : addJob* * * @Description : TODO* * * @Author : HuaZai* * * @Date : 12月29日下午4:49:52* * * @throws Exception*/public static void addJobBySimple(String jobName, String triggerName, Class<? extends Job> jobClass, int seconds)throws Exception {log.info("================== 初始化 =================");// 创建一个SchedulerFactory工厂实例SchedulerFactory factory = new StdSchedulerFactory();// 通过SchedulerFactory工厂构建Scheduler容器对象Scheduler scheduler = factory.getScheduler();log.info("=================== 初始化完成 ===================");log.info("============== 将作业添加到任务作业调度中 ==================");// 构建一个jobDetail 作业实例JobDetail detail = JobBuilder.newJob(jobClass) // 构建一个新任务.withIdentity(jobName, JOB_GROUP_NAME) // 给新任务起名和分组.build(); // 绑定作业// 构建一个SimpleTrigger的触发器Trigger trigger = TriggerBuilder.newTrigger()// 创建一个新的TriggerBuilder.withIdentity(triggerName, TRIGGER_GROUP_NAME)// 给触发器起名和分组.startNow()// 立即执行.withSchedule(// 定义触发规则SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(seconds) // 时间间隔.repeatForever() // 一直执行).build();// 绑定出发规则// 将job任务和trigger触发器添加到Scheduler容器中scheduler.scheduleJob(detail, trigger);// 启动Quartz任务调度scheduler.start();}/*** 创建 CronTrigger* * * @Title : addJob* * * @Description : TODO* * * @Author : HuaZai* * * @Date : 12月29日下午4:49:52* * * @throws Exception*/public static void addJobByCron(String jobName, String triggerName, Class<? extends Job> jobClass, String cron)throws Exception {log.info("================== 初始化 =================");// 创建一个SchedulerFactory工厂实例SchedulerFactory factory = new StdSchedulerFactory();// 通过SchedulerFactory工厂构建Scheduler容器对象Scheduler scheduler = factory.getScheduler();log.info("=================== 初始化完成 ===================");log.info("============== 将作业添加到任务作业调度中 ==================");// 构建一个jobDetail 作业实例JobDetail detail = JobBuilder.newJob(jobClass) // 构建一个新任务.withIdentity(jobName, JOB_GROUP_NAME) // 给新任务起名和分组.build(); // 绑定作业// 构建一个 CronSchedule 的触发器Trigger trigger = TriggerBuilder.newTrigger()// 创建一个新的TriggerBuilder.withIdentity(triggerName, TRIGGER_GROUP_NAME)// 给触发器起名和分组.startNow()// 立即执行.withSchedule(// 定义触发规则CronScheduleBuilder.cronSchedule(cron)).build();// 绑定出发规则// 将job任务和trigger触发器添加到Scheduler容器中scheduler.scheduleJob(detail, trigger);// 启动Quartz任务调度scheduler.start();}}

Main

package com.etc.clear;import com.etc.mon.InitImgQuartzCommon;/*** 程序启动入口/调用任务的类* * * @ClassName : ClsMain* * * @Description : TODO* * * @Author : HuaZai* * * @ContactInformation : 1461522031@/huazai6789@* * * @Date : 1月3日下午1:21:56* * @Version : V1.0.0**/public class ApplicationMain {public static void main(String[] args) {// 初始化清理图片任务InitImgQuartzCommon imgQuartzCommon = new InitImgQuartzCommon();// 启动图片清理任务imgQuartzCommon.startClearImg();}}

关于这个实例使用到的Jar包：/download/hello_world_qwp/10178554

Quartz-2.2.1 任务调度框架在Java项目中的使用实例 Demo下载地址：/download/hello_world_qwp/10198020

二、相关简介

1、Quartz是什么？

Quartz是一个完全由java编写的开源作业调度框架。

Quartz框架的核心是调度器。调度器负责管理Quartz应用运行时环境。调度器不是靠自己做所有的工作，而是依赖框架内一些非常重要的部件。Quartz不仅仅是线程和线程管理。为确保可伸缩性，Quartz采用了基于多线程的架构。启动时，框架初始化一套worker线程，这套线程被调度器用来执行预定的作业。这就是Quartz怎样能并发运行多个作业的原理。Quartz依赖一套松耦合的线程池管理部件来管理线程环境。

2、Quartz的应用场景？

场景一：更新静态数据

场景二：提醒和报警

场景三：监听事务

场景四：定时作业

3、关于Quartz框架的部分核心 API

Scheduler：

作用：Scheduler接口是Quartz最核心的接口。Scheduler维护着JobDetail和Trigger的注册信息。一旦注册成功，Scheduler负责执行和Job关联的触发器。

一个Scheduler实例可以视为一个调度作业容器。可以通过start和shutdown方法来控制它的生命周期。

Job：

作用：开发者实现该接口定义需要执行的作业。JobExecutionContext类提供调度上下文的各种信息。

JobDetail：