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

 

时间: 2024-10-09 20:00:15

SpringBoot整合Quartz定时任务 的简单实例 2的相关文章

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

POM.XML文件 <!-- 定时器任务 quartz需要导入的坐标 --> <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>1.8.5</version> </dependency>     类似于控制器代码: package com.xiaowu.quart

khj-spring整合quartz定时任务报错,请大神们解救

问题描述 spring整合quartz定时任务报错,请大神们解救 web.xml中的配置 spring_mvcorg.springframework.web.servlet.DispatcherServlet contextConfigLocationclasspath:applicationContext spring_mvc/ applicationContext.xml的配置 <!-- 要调用的工作类 --> <!-- 定义调用对象和调用对象的方法 --> <!-- 调

Spring 3整合Quartz 2实现定时任务(转)

http://www.meiriyouke.net/?p=82 最近工作中需要用到定时任务的功能,虽然Spring3也自带了一个轻量级的定时任务实现,但感觉不够灵活,功能也不够强大.在考虑之后,决定整合更为专业的Quartz来实现定时任务功能. 首先,当然是添加依赖的jar文件,我的项目是maven管理的,以下的我项目的依赖: <dependencies> <dependency> <groupId>org.springframework</groupId>

Spring Boot整合Quartz实现定时任务表配置

最近有个小项目要做,spring mvc下的task设置一直不太灵活,因此在Spring Boot上想做到灵活的管理定时任务.需求就是,当项目启动的时候,如果有定时任务则加载进来,生成scheduler,通过后台表配置可以随时更新定时任务状态(启动.更改.删除). 添加依赖 <!-- spring's support for quartz --> <dependency> <groupId>org.springframework</groupId> <

Spring 3整合Quartz 2实现手动设置定时任务:新增,修改,删除,暂停和恢复----每一个你不满意的当下,都有一个你不曾努力的过去

  摘要:在项目的管理功能中,对定时任务的管理有时会很常见.但一般定时任务配置都在xml中完成,包括cronExpression表达式,十分的方便.但是如果我的任务信息是保存在数据库的,想要动态的初始化,还有就是任务较多的时候不是得有一大堆的xml配置?或者说我要修改一下trigger的表达式,使原来5秒运行一次的任务变成10秒运行一次,或者说我要控制定时任务的 " 暂停 " 呢?暂停之后又要在某个时间点 " 重启 " 该定时任务呢?或者说直接 " 删除 

Spring 3整合Quartz 2实现定时任务三:动态暂停 恢复 修改和删除任务

前面我们已经完成了spring 3和quartz 2的整合以及动态添加定时任务,我们接着来完善它,使之能支持更多的操作,例如暂停.恢复.修改等. 在动态添加定时任务中其实已经涉及到了其中的一些代码,这里我们再来细化的理一理.先来看一下我们初步要实现的目标效果图,这里我们只在内存中操作,并没有把quartz的任何信息保存到数据库,即使用的是RAMJobStore,当然如果你有需要,可以实现成JDBCJobStore,那样任务信息将会更全面,貌似还有专门的监控工具,不过本人没有用过: 如上图,我们要

Spring+Quartz定时任务

最近研究站内搜索,因为要定时的更新索引库,看了看Spring+Quartz定时任务,用它完成,定时创建索引的任务!! 给大家分享一下helloworld的简单例子,大家可以根据实际情况变化使用 业务方法类 Java代码 package com.task; /** * 业务方法 * */ public class TestJob { public void execute() { try { System.out.println("我的业务方法被调用了---------!"); } ca

项目ITP(六) spring4.0 整合 Quartz 实现动态任务调度

正文  spring4.0 整合 Quartz 实现任务调度.这真是期末项目的最后一篇,剩下到暑假吧.    Quartz 介绍   Quartz is a full-featured, open source job scheduling service that can be integrated with, or used along side virtually any Java application - from the smallest stand-alone applicatio

Spring整合Quartz实现定时任务调度的方法_java

最近项目中需要实现定时执行任务,比如定时计算会员的积分.调用第三方接口等,由于项目采用spring框架,所以这里结合spring框架来介绍. 编写作业类 即普通的pojo,如下: package com.pcmall.task; import org.slf4j.Logger; import org.slf4j.LoggerFactory; public class TaskA { private static Logger logger = LoggerFactory.getLogger(Ta