SpringBoot整合Quartz定时任务 的简单实例 2

(1)什么是Quartz? (2)Quartz的特点; (3)Quartz专用词汇说明; (4)Quartz任务调度基本实现原理;

       接下来看下具体的内容:

(1)什么是Quartz?

Quartz是一个完全由Java编写的开源作业调度框架,为在Java应用程序中进行作业调度提供了简单却强大的机制。Quartz允许开发人员根据时间间隔来调度作业。它实现了作业和触发器的多对多的关系,还能把多个作业与不同的触发器关联。简单地创建一个org.quarz.Job接口的Java类。

(2)Quartz的特点;

作为一个优秀的开源调度框架,Quartz 具有以下特点:

① 强大的调度功能,例如支持丰富多样的调度方法,可以满足各种常规及特殊需求;

②   灵活的应用方式,例如支持任务和调度的多种组合方式,支持调度数据的多种存储方式;

③ 分布式和集群能力,Terracotta 收购后在原来功能基础上作了进一步提升。

④ Quartz 很容易与 Spring 集成实现灵活可配置的调度功能。

(3)Quartz专用词汇说明;

下面是本文中用到的一些专用词汇,在此声明:

scheduler:

任务调度器

trigger:

触发器,用于定义任务调度时间规则

job:

任务,即被调度的任务

misfire:

错过的,指本来应该被执行但实际没有被执行的任务调度

(4)Quartz任务调度基本实现原理;

Quartz 任务调度的核心元素是 scheduler, trigger 和 job,其中 trigger 和 job 是任务调度的元数据,scheduler 是实际执行调度的控制器。

在 Quartz 中,trigger 是用于定义调度时间的元素,即按照什么时间规则去执行任务。Quartz 中主要提供了四种类型的 trigger:SimpleTrigger,CronTirgger,DateIntervalTrigger,和 NthIncludedDayTrigger。这四种 trigger 可以满足企业应用中的绝大部分需求。

在 Quartz 中,job 用于表示被调度的任务。主要有两种类型的 job:无状态的(stateless)和有状态的(stateful)。对于同一个 trigger 来说,有状态的 job 不能被并行执行,只有上一次触发的任务被执行完之后,才能触发下一次执行。Job 主要有两种属性:volatility 和 durability,其中 volatility 表示任务是否被持久化到数据库存储,而 durability 表示在没有 trigger 关联的时候任务是否被保留。两者都是在值为 true 的时候任务被持久化或保留。一个 job 可以被多个 trigger 关联,但是一个 trigger 只能关联一个 job。

       在 Quartz 中, scheduler 由 scheduler 工厂创建:DirectSchedulerFactory 或者 StdSchedulerFactory。 第二种工厂 StdSchedulerFactory 使用较多,因为 DirectSchedulerFactory 使用起来不够方便,需要作许多详细的手工编码设置。 Scheduler 主要有三种:RemoteMBeanScheduler, RemoteScheduler 和 StdScheduler。本文以最常用的 StdScheduler 为例讲解。这也是笔者在项目中所使用的 scheduler 类。

这一篇文章,我们紧接着上一篇的文章,讲讲在Quartz在java project的项目中如何进行使用,在这里我们使用maven进行构建项目。先看下本章的大纲:

(1)新建工程quartz-java; (2)配置pom.xml文件; (3)编码说明; (4)编写Job类; (5)编写启动类进行代码测试; (6)quartz.properties配置文件说明;

       接下里一起看下具体的内容:

(1)新建工程quartz-java;

       新建一个java project取名为quartz-java。

(2)配置pom.xml文件;

       在pom.xml文件中添加quartz的依赖:

<dependency>
            <groupId>org.quartz-scheduler</groupId>
            <artifactId>quartz</artifactId>
            <version>2.2.3</version>
</dependency>

(3)编码说明;

(一)首先我们需要定义一个任务类,比如为HelloJob ,该类需要继承Job类,然后添加execute(JobExecutionContext context)方法,在这个方法中就是我们具体的任务执行的地方。

(二)在哪里定义“在什么时候执行什么任务呢?”:那么我们需要Scheduler,此类的创建方式使用Quartz提供的工厂类StdSchedulerFactory.getDefaultScheduler()进行创建。

(三)如何触发呢:scheduler.scheduleJob(jobDetail,trigger);进行触发定时任务,在这里需要两个参数。jobDetail可以通过JobBuilder.newJob进行创建,在这里就需要制定一个Job类了,也就是我们第一步创建的HelloJob;trigger类的话,可以通过TriggerBuilder.newTrigger进行创建。

(4)编写Job类;

编写HelloJob任务类:

package com.kfit.job;
import java.util.Date;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
/**
 * 任务类.
 * @author Angel --守护天使
 * @version v.0.1
 * @date 2017年4月21日
 */
public class HelloJob implements Job{
 public void execute(JobExecutionContext context) throws JobExecutionException {
        // 执行响应的任务.
       System.out.println("HelloJob.execute,"+new Date());
    }
}

(5)编写启动类进行代码测试;

在Main方法中进行编码测试:

package com.kfit;
import java.util.concurrent.TimeUnit;
import org.quartz.JobBuilder;
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.kfit.job.HelloJob;
/**
 * 直接在Main方法中进行启动测试.
 * @author Angel --守护天使
 * @version v.0.1
 * @date 2017年4月21日
 */
public class App {
 public static void main(String[] args) throws SchedulerException, InterruptedException {
       /*
        *在 Quartz 中, scheduler 由 scheduler 工厂创建:DirectSchedulerFactory 或者StdSchedulerFactory。第二种工厂 StdSchedulerFactory 使用较多,
        *因为 DirectSchedulerFactory 使用起来不够方便,需要作许多详细的手工编码设置。
        */
       // 获取Scheduler实例
       Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
       scheduler.start();
       System.out.println("scheduler.start");
       //具体任务.
       JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("job1","group1").build();
       //触发时间点. (每5秒执行1次.)
       SimpleScheduleBuilder simpleScheduleBuilder = SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever();
       Trigger trigger = TriggerBuilder.newTrigger().withIdentity("trigger1","group1").startNow().withSchedule(simpleScheduleBuilder).build();
       // 交由Scheduler安排触发
       scheduler.scheduleJob(jobDetail,trigger);
       //睡眠20秒.
       TimeUnit.SECONDS.sleep(20);
       scheduler.shutdown();//关闭定时任务调度器.
       System.out.println("scheduler.shutdown");
    }
}

执行代码查看控制台的打印信息:

-----------------------------------------------------------

scheduler.start

HelloJob.execute,Fri Apr 21 19:50:01 CST 2017

HelloJob.execute,Fri Apr 21 19:50:06 CST 2017

HelloJob.execute,Fri Apr 21 19:50:11 CST 2017

HelloJob.execute,Fri Apr 21 19:50:16 CST 2017

HelloJob.execute,Fri Apr 21 19:50:21 CST 2017

scheduler.shutdown

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏祝威廉

Spark Streaming Dynamic Resource Allocation 文档(非官方特性)

减少资源时,采用启发式算法。根据之前周期的处理时间,计算需要保留的资源量(A),然后尝试分多轮试探性的减少(B),每个计算周期都会重复A,B动作,最后会收敛到一...

773
来自专栏Golang语言社区

社区leaf学习笔记|04. MongoDB测试

大家好,本篇文章给大家带来的是leaf原作者仅支持的mongoDB的相关测试;测试之前我们简单了解下MongoDB

963
来自专栏Linyb极客之路

杂谈Java高并发

对于我们开发的网站,如果网站的访问量非常大的话,那么我们就需要考虑相关的并发访问问题了。而并发问题是绝大部分的程序员头疼的问题,但话又说回来了,既然逃避不掉,那...

815
来自专栏Java帮帮-微信公众号-技术文章全总结

quartz使用入门篇【面试+工作】

你曾经需要应用执行一个任务吗?这个任务每天或每周星期二晚上11:30,或许仅仅每个月的最后一天执行。一个自动执行而无须干预的任务在执行过程中如果发生一个严重错误...

1144
来自专栏码神联盟

Java常见缓存机制cache(集成spring使用)

今天我们首先来总结下cache,一步步消化,消化完了cache,然后在总结redis,冰冻三尺非一日之寒,技术亦如此。 1理解cache 在Ja...

3106
来自专栏决胜机器学习

设计模式专题(十)——观察者模式

设计模式专题(十)——观察者模式 (原创内容,转载请注明来源,谢谢) 一、概述 观察者模式(Observer),又称做发布-订阅模式(Publish/Subs...

3339
来自专栏向治洪

Spring Boot微服务架构入门

概述 还记得在10年毕业实习的时候,当时后台三大框架为主流的后台开发框架成软件行业的标杆,当时对于软件的认识也就是照猫画虎,对于为什么会有这么样的写法,以及这种...

18510
来自专栏Golang语言社区

Golang负载均衡

请求者向均衡服务发送请求 type Request struct { fn func() int // The operation to perform....

35410
来自专栏Kirito的技术分享

浅析分布式下的事件驱动机制(PubSub模式)

上一篇文章《浅析Spring中的事件驱动机制》简单介绍了Spring对事件的支持。Event的整个生命周期,从publisher发出,经过application...

32410
来自专栏Java 源码分析

SpringBoot 笔记 ( 六):消息

1426

扫描关注云+社区