Java任务调度框架Quartz入门教程指南(二) 使用job、trigger、schedule调用定时任务

本文主要是介绍Java任务调度框架Quartz入门教程指南(二) 使用job、trigger、schedule调用定时任务,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

http://blog.csdn.net/zixiao217/article/details/53044890

读完第一节,我们已经对Quartz有了一个大体的认识,它可以定时帮我们执行一些处理程序,尽管可能你之前对Quartz不了解以至于第一节很多术语(job、trigger等)不理解,没关系,从现在开始,笔者和你一起在实例中深入理解它们。没有code,就没有话语权——程序界真理

(本文章分享在CSDN平台,更多精彩请阅读 东陆之滇的csdn博客:http://blog.csdn.net/zixiao217)

本系列教程主要使用Maven风格编写代码,对于怎样使用maven,大家可以读读许晓斌的《Maven实战》,相当不错,笔者入门也是得此书。认真耐心读完哦。

本节主要内容

  • 下载 Quartz
  • 安装 Quartz
  • 根据你自己的需要配置 Quartz
  • 编写第一个示例应用程序

下载和安装Quartz

首先,你需要下载最新(不一定)稳定版本的Quartz。本系列教程我们使用2.2.1。你可以在官网http://www.quartz-scheduler.org/downloads/下载需要的版本jar包,现在我们使用maven方式:

pom.xml引入quartz依赖:
<dependency><groupId>org.quartz-scheduler</groupId> <artifactId>quartz</artifactId> <version>2.2.1</version> </dependency> <dependency> <groupId>org.quartz-scheduler</groupId> <artifactId>quartz-jobs</artifactId> <version>2.2.1</version> </dependency>

 

quartz 属性配置文件

Quartz使用一个quartz.properties的属性配置文件。它不是必需的,但是使用它的话,你必须将它放置在你项目的classpath目录下,也就是最终打包后位于WEN-INF/classes目录下(web项目),使用Maven我们在src/main/resources目录放置该文件即可。 


Quartz是一个可配置化的应用程序。最好的配置Quartz的方式是使用quartz.properties配置文件。关于Quartz的配置属性文件的详细技巧,我们在本系列教程最后会单独讲到,务必精益求精。 
迅速开始一个配置文件的内容,可以参考如下示例编写:

 

quartz.properties
org.quartz.scheduler.instanceName = MyScheduler
org.quartz.threadPool.threadCount = 3 org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

使用上述配置文件创建的任务调度程序有以下特点:

  • org.quartz.scheduler.instanceName - 设置调度程序scheduler的名称为MyScheduler
  • org.quartz.threadPool.threadCount - 线程里设置了3个线程,意味着最多同时运行3个job
  • org.quartz.jobStore.class - 指定为RAMJobStore,表示所有Quartz的数据,包括jobDetail、trigger等均运行在内存中(而不是数据库中)。 如果你想Quartz使用你的数据库,还是建议你在使用数据库配置之前使用RAMJobStore进行工作。通过使用一个数据库,你可以打开一个全新的维度,但在这之前,建议你使用RAMJobStore。

编写第一个quartz示例程序

第一步:编写一个job类,需要实现org.quartz.Job接口

这里编写一个样例,该任务只做一件事,就是打印任务执行时间以及汇报任务已经执行。Hello.Java代码如下:

package org.byron4j.quartz;import org.byron4j.utils.DateUtil;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException; /** * 实现org.quartz.Job接口,声明该类是一个可执行任务类 * @author Administrator * */ public class HelloJob implements Job { @Override public void execute(JobExecutionContext context) throws JobExecutionException { System.out.println("现在是北京时间:" + DateUtil.getCurrDateTime() + " - helloJob任务执行"); } } 

 

第二步:编写日期时间工具类,提供获取不同格式时间的公共方法

DateUtil.java代码如下:

package org.byron4j.utils;import java.text.SimpleDateFormat;
import java.util.Date;public class DateUtil { private static SimpleDateFormat officerSdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss"); public static String getCurrDateTime(){ return officerSdf.format(new Date()); } } 

 

第三步:使用job、trigger、schedule调用定时任务

在该实例中我们使用了静态引入,引入了3个静态方法

import static org.quartz.JobBuilder.newJob;
import static org.quartz.SimpleScheduleBuilder.simpleSchedule; import static org.quartz.TriggerBuilder.newTrigger;

 

 

你也可以分别使用替代,视个人习惯选择:

JobBuilder.newJob(...)
SimpleScheduleBuilder.simpleSchedule(...)
TriggerBuilder.newTrigger(...)

 

QuartzTest.java代码如下:

package org.byron4j.quartz;import static org.quartz.JobBuilder.newJob; import static org.quartz.SimpleScheduleBuilder.simpleSchedule; import static org.quartz.TriggerBuilder.newTrigger; import org.quartz.JobDetail; import org.quartz.Scheduler; import org.quartz.SchedulerException; import org.quartz.Trigger; import org.quartz.impl.StdSchedulerFactory; public class QuartzTest { public static void main(String[] args) { try { //从调度程序工厂获取一个调度程序的实例 Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler(); //显示调度程序的名称(这里会展示我们在quartz.properties文件中的名称) System.out.println("scheduleName = " + scheduler.getSchedulerName()); /** 重要: * 定义一个job,并绑定到我们自定义的HelloJob的class对象 * 这里并不会马上创建一个HelloJob实例,实例创建是在scheduler安排任务触发执行时创建的 * 这种机制也为后面使用Spring集成提供了便利 */ JobDetail job = newJob(HelloJob.class) .withIdentity("job1", "group1") .build(); // 声明一个触发器,现在就执行(schedule.start()方法开始调用的时候执行);并且每间隔2秒就执行一次 Trigger trigger = newTrigger() .withIdentity("trigger1", "group1") .startNow() .withSchedule(simpleSchedule() .withIntervalInSeconds(2) .repeatForever()) .build(); // 告诉quartz使用定义的触发器trigger安排执行任务job scheduler.scheduleJob(job, trigger); //启动任务调度程序,内部机制是线程的启动 scheduler.start(); //关闭任务调度程序,如果不关闭,调度程序schedule会一直运行着 //scheduler.shutdown(); } catch (SchedulerException e) { e.printStackTrace(); } } } 

 

重点指明一下job实例创建的时机: 
/** 重要: 
* 定义一个job,并绑定到我们自定义的HelloJob的class对象 
* 这里并不会马上创建一个HelloJob实例,实例创建是在scheduler安排任务触发执行时创建的 
* 这种机制也为后面使用spring集成提供了便利 
*/ 
JobDetail job = newJob(HelloJob.class) 
.withIdentity(“job1”, “group1”) 
.build();

第四步:执行调用你的定时任务

运行QuartzTest.java的main方法,我们可以看到控制台输出,每隔2秒就执行了我们预先安排的打印时间和工作内容的任务:

scheduleName = MyScheduler
现在是北京时间:2016-11-05 13:08:30 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:32 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:34 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:36 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:38 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:40 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:42 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:44 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:46 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:48 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:50 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:52 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:54 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:56 - helloJob任务执行
现在是北京时间:2016-11-05 13:08:58 - helloJob任务执行
现在是北京时间:2016-11-05 13:09:00 - helloJob任务执行

这篇关于Java任务调度框架Quartz入门教程指南(二) 使用job、trigger、schedule调用定时任务的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!


原文地址:
本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.chinasem.cn/article/868575

相关文章

Java中JSON格式反序列化为Map且保证存取顺序一致的问题

《Java中JSON格式反序列化为Map且保证存取顺序一致的问题》:本文主要介绍Java中JSON格式反序列化为Map且保证存取顺序一致的问题,具有很好的参考价值,希望对大家有所帮助,如有错误或未... 目录背景问题解决方法总结背景做项目涉及两个微服务之间传数据时,需要提供方将Map类型的数据序列化为co

Java Lambda表达式的使用详解

《JavaLambda表达式的使用详解》:本文主要介绍JavaLambda表达式的使用方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录一、前言二、Lambda表达式概述1. 什么是Lambda表达式?三、Lambda表达式的语法规则1. 无参数的Lambda表

java中Optional的核心用法和最佳实践

《java中Optional的核心用法和最佳实践》Java8中Optional用于处理可能为null的值,减少空指针异常,:本文主要介绍java中Optional核心用法和最佳实践的相关资料,文中... 目录前言1. 创建 Optional 对象1.1 常规创建方式2. 访问 Optional 中的值2.1

Spring Boot 整合 Apache Flink 的详细过程

《SpringBoot整合ApacheFlink的详细过程》ApacheFlink是一个高性能的分布式流处理框架,而SpringBoot提供了快速构建企业级应用的能力,下面给大家介绍Spri... 目录Spring Boot 整合 Apache Flink 教程一、背景与目标二、环境准备三、创建项目 & 添

Spring组件实例化扩展点之InstantiationAwareBeanPostProcessor使用场景解析

《Spring组件实例化扩展点之InstantiationAwareBeanPostProcessor使用场景解析》InstantiationAwareBeanPostProcessor是Spring... 目录一、什么是InstantiationAwareBeanPostProcessor?二、核心方法解

详解如何使用Python构建从数据到文档的自动化工作流

《详解如何使用Python构建从数据到文档的自动化工作流》这篇文章将通过真实工作场景拆解,为大家展示如何用Python构建自动化工作流,让工具代替人力完成这些数字苦力活,感兴趣的小伙伴可以跟随小编一起... 目录一、Excel处理:从数据搬运工到智能分析师二、PDF处理:文档工厂的智能生产线三、邮件自动化:

深入解析 Java Future 类及代码示例

《深入解析JavaFuture类及代码示例》JavaFuture是java.util.concurrent包中用于表示异步计算结果的核心接口,下面给大家介绍JavaFuture类及实例代码,感兴... 目录一、Future 类概述二、核心工作机制代码示例执行流程2. 状态机模型3. 核心方法解析行为总结:三

Spring @RequestMapping 注解及使用技巧详解

《Spring@RequestMapping注解及使用技巧详解》@RequestMapping是SpringMVC中定义请求映射规则的核心注解,用于将HTTP请求映射到Controller处理方法... 目录一、核心作用二、关键参数说明三、快捷组合注解四、动态路径参数(@PathVariable)五、匹配请

Java -jar命令如何运行外部依赖JAR包

《Java-jar命令如何运行外部依赖JAR包》在Java应用部署中,java-jar命令是启动可执行JAR包的标准方式,但当应用需要依赖外部JAR文件时,直接使用java-jar会面临类加载困... 目录引言:外部依赖JAR的必要性一、问题本质:类加载机制的限制1. Java -jar的默认行为2. 类加

Java进程CPU使用率过高排查步骤详细讲解

《Java进程CPU使用率过高排查步骤详细讲解》:本文主要介绍Java进程CPU使用率过高排查的相关资料,针对Java进程CPU使用率高的问题,我们可以遵循以下步骤进行排查和优化,文中通过代码介绍... 目录前言一、初步定位问题1.1 确认进程状态1.2 确定Java进程ID1.3 快速生成线程堆栈二、分析