程序员经验分享-hwhale

Java定时任务调度工具详解之Quartz篇（中级）一：浅谈JobExecutionContext&JobDatai&浅谈Trigger

2023-11-01

概要：OpenSymphony提供的强大的开源任务调度框架
官网:http://www.quartz-scheduler.org/

纯java实现，精细控制排程

特点：强大的调度功能 ，灵活的应用方式，分布式和集群能力

主要用到的设计模式：Builder模式，Factory模式，组件模式，链式写法

三个核心概念：调度器，任务，触发器

这里写图片描述

重要组成：Job JobDetail JobBuilder JobStore
Trigger TriggerBuilder ThreadPool Scheduler

Calendar 一个Trigger可以和多个Calendar关联，以排除或包含某些时间点

监听器：JobListener TriggerListener SchedulerListener

一.第一个Quartz程序

Quartz使用：
准备工作—建立Maven项目工程
—引入Quartz jar包
任务：让任务每隔两秒钟打印一次helloworld

这里写图片描述

这里写图片描述

这里写图片描述

打开链接http://mavenrepository.com

搜索quartz

这里写图片描述

这里写图片描述

这里写图片描述

复制里面的内容，粘贴到项目中的pom.xml文件中dependencies下，保存

<!-- https://mvnrepository.com/artifact/org.quartz-scheduler/quartz -->
<dependency>
    <groupId>org.quartz-scheduler</groupId>
    <artifactId>quartz</artifactId>
    <version>2.2.3</version>
</dependency>

编辑器会自动下载Quartz相关架包

这里写图片描述

我们也可以Maven Install

这里写图片描述

代码示例：

HelloJob类：

package HelloQuartz.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;

public class HelloJob implements Job{

    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        //打印当前的执行时间，格式为2017-01-01 00：00:00
        Date date = new Date();
        SimpleDateFormat sf =new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Exec Time Is :" + sf.format(date));
        //编写具体的业务逻辑
        System.out.println("Hello World!");
    }

}

HelloScheduler类

package HelloQuartz.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {

    public static void main(String[] args) throws SchedulerException {
        // 创建一个JobDetail示例，将该示例与HelloJob Class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class)
                .withIdentity("myJob", "group1").build();
        // 创建一个Trigger实例，定义该job立即执行，并且每隔两秒钟重复执行一次，直到永远
        Trigger triger = TriggerBuilder.newTrigger()
                .withIdentity("myTrigger","group1")
                .startNow()
                .withSchedule(
                        SimpleScheduleBuilder.simpleSchedule()
                        .withIntervalInSeconds(2)
                        .repeatForever())
                .build();
        //创建Scheduler实例
        SchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        Date date = new Date();
        SimpleDateFormat sf =new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Exec Time Is :" + sf.format(date));
        scheduler.scheduleJob(jobDetail, triger);
    }
}

二.浅谈JobExecutionContext&JobDatai

JobExecutionContext是什么？
当Scheduler调用一个Job，就会将JobExecutionContext传递给Job的execute()方法；
Job能通过JobExecutionContext对象访问到Quartz运行时候的环境以及Job本身的明细数据

JobDataMap是什么？
在进行任务调度时，JobDataMap存储在JobExecutionContext中，非常方便获取
JobDataMap可以用来装载任何可序列化的数据对象，当job实例对象被执行时这些参数对象会传递给它。
JobDataMap实现了JDK的Map接口，并且添加了一些非常方便的方法用来存取基本数据类型。

获取JobDataMap的两种方式

第一种方式从Map中直接获取

代码示例：

HelloScheduler类

package HelloQuartz.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {

    public static void main(String[] args) throws SchedulerException {
        // 创建一个JobDetail示例，将该示例与HelloJob Class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1")
                .usingJobData("message", "hello MyJob1").usingJobData("FloatJobValue", 3.14F).build();
        // 创建一个Trigger实例，定义该job立即执行，并且每隔两秒钟重复执行一次，直到永远
        Trigger triger = TriggerBuilder.newTrigger()
                .withIdentity("myTrigger", "group1")
                .usingJobData("message","hello myTrigger1")
                .usingJobData("DoubleTriggerValue",2.0D)
                .startNow()
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
        // 创建Scheduler实例
        SchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Exec Time Is :" + sf.format(date));
        scheduler.scheduleJob(jobDetail, triger);
    }
}

HelloJob类

package HelloQuartz.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import javax.naming.Context;

import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.TriggerKey;

public class HelloJob implements Job {

    public void execute(JobExecutionContext context) throws JobExecutionException {
        // 打印当前的执行时间，格式为2017-01-01 00：00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Exec Time Is :" + sf.format(date));

        JobKey key = context.getJobDetail().getKey();
        System.out.println("My Job name and group are:" + key.getName() + ":" + key.getGroup());
        TriggerKey trkey = context.getTrigger().getKey();
        System.out.println("My Trigger name and group are:" + trkey.getName() + ":" + trkey.getGroup());
        JobDataMap dataMap = context.getJobDetail().getJobDataMap();
        JobDataMap tdataMap = context.getTrigger().getJobDataMap();
        String JobMsg = dataMap.getString("message");
        Float jobFloatValue = dataMap.getFloat("FloatJobValue");
        String triggerMsg = tdataMap.getString("message");
        Double triggerDoubleValue = tdataMap.getDouble("DoubleTriggerValue");
        System.out.println("JobMsg is :"+JobMsg);
        System.out.println("triggerMsg is :"+triggerMsg);
        System.out.println("jobFloatValue is :"+jobFloatValue);
        System.out.println("triggerDoubleValue is :"+triggerDoubleValue);
    }

}

第二种方式：Job实现类中添加setter方法对应JobDataMap的键值（Quartz框架默认的JobFactory实现类在初始化job示例对象时会自动地调用这些setter方法）

HelloJob类

package HelloQuartz.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import javax.naming.Context;

import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.TriggerKey;

public class HelloJob implements Job {

    private String message;
    private Float FloatJobValue;
    private Double DoubleTriggerValue;

    /**
     * @return the message
     */
    public String getMessage() {
        return message;
    }

    /**
     * @param message the message to set
     */
    public void setMessage(String message) {
        this.message = message;
    }

    /**
     * @return the floatJobValue
     */
    public Float getFloatJobValue() {
        return FloatJobValue;
    }

    /**
     * @param floatJobValue the floatJobValue to set
     */
    public void setFloatJobValue(Float floatJobValue) {
        FloatJobValue = floatJobValue;
    }

    /**
     * @return the doubleTriggerValue
     */
    public Double getDoubleTriggerValue() {
        return DoubleTriggerValue;
    }

    /**
     * @param doubleTriggerValue the doubleTriggerValue to set
     */
    public void setDoubleTriggerValue(Double doubleTriggerValue) {
        DoubleTriggerValue = doubleTriggerValue;
    }

    public void execute(JobExecutionContext context) throws JobExecutionException {
        // 打印当前的执行时间，格式为2017-01-01 00：00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Exec Time Is :" + sf.format(date));

        JobKey key = context.getJobDetail().getKey();
        System.out.println("My Job name and group are:" + key.getName() + ":" + key.getGroup());
        TriggerKey trkey = context.getTrigger().getKey();
        System.out.println("My Trigger name and group are:" + trkey.getName() + ":" + trkey.getGroup());
        JobDataMap dataMap = context.getMergedJobDataMap();//合并之后的dataMap

        System.out.println("msg is :"+message);
        System.out.println("jobFloatValue is :"+FloatJobValue);
        System.out.println("triggerDoubleValue is :"+DoubleTriggerValue);
    }

}

HelloScheduler类

package HelloQuartz.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {

    public static void main(String[] args) throws SchedulerException {
        // 创建一个JobDetail示例，将该示例与HelloJob Class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob", "group1")
                .usingJobData("message", "hello MyJob1").usingJobData("FloatJobValue", 3.14F).build();
        // 创建一个Trigger实例，定义该job立即执行，并且每隔两秒钟重复执行一次，直到永远
        Trigger triger = TriggerBuilder.newTrigger()
                .withIdentity("myTrigger", "group1")
                .usingJobData("message","hello myTrigger1")
                .usingJobData("DoubleTriggerValue",2.0D)
                .startNow()
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
        // 创建Scheduler实例
        SchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Exec Time Is :" + sf.format(date));
        scheduler.scheduleJob(jobDetail, triger);
    }
}

三.浅谈Trigger

Trigger是什么？
Quartz中的触发器用来告诉调度程序作业什么时候触发。即Trigger对象是用来触发执行Job的。

这里写图片描述

触发器通用属性：
JobKey：表示job实例的标识，触发器被触发时，该指定的job实例会执行。
StartTime：表示触发器的时间表首次被触发的时间。它的值的类型是Java.util.Date
EndTime:指定触发器的不再被触发的时间。它的值的类型是Java.util.Date。

HelloJob类

package HelloQuartz.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import javax.naming.Context;

import org.quartz.Job;
import org.quartz.JobDataMap;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import org.quartz.Trigger;
import org.quartz.TriggerKey;

public class HelloJob implements Job {

    private String message;
    private Float FloatJobValue;
    private Double DoubleTriggerValue;

    /**
     * @return the message
     */
    public String getMessage() {
        return message;
    }

    /**
     * @param message the message to set
     */
    public void setMessage(String message) {
        this.message = message;
    }

    /**
     * @return the floatJobValue
     */
    public Float getFloatJobValue() {
        return FloatJobValue;
    }

    /**
     * @param floatJobValue the floatJobValue to set
     */
    public void setFloatJobValue(Float floatJobValue) {
        FloatJobValue = floatJobValue;
    }

    /**
     * @return the doubleTriggerValue
     */
    public Double getDoubleTriggerValue() {
        return DoubleTriggerValue;
    }

    /**
     * @param doubleTriggerValue the doubleTriggerValue to set
     */
    public void setDoubleTriggerValue(Double doubleTriggerValue) {
        DoubleTriggerValue = doubleTriggerValue;
    }

    public void execute(JobExecutionContext context) throws JobExecutionException {
        // 打印当前的执行时间，格式为2017-01-01 00：00:00
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Exec Time Is :" + sf.format(date));
        Trigger currentTrigger = context.getTrigger();
        System.out.println("Start Time is :" +currentTrigger.getStartTime());
        System.out.println("End Time is :"+currentTrigger.getEndTime());
        JobKey jobKey = currentTrigger.getJobKey();
        System.out.println("JobKey info ---"+"JobName:"+jobKey.getName()+"jobGroup:"+jobKey.getGroup());
    }

}

HelloScheduler类

package HelloQuartz.helloQuartz;

import java.text.SimpleDateFormat;
import java.util.Date;

import org.quartz.JobBuilder;
import org.quartz.JobDetail;
import org.quartz.Scheduler;
import org.quartz.SchedulerException;
import org.quartz.SchedulerFactory;
import org.quartz.SimpleScheduleBuilder;
import org.quartz.Trigger;
import org.quartz.TriggerBuilder;
import org.quartz.impl.StdSchedulerFactory;

public class HelloScheduler {

    public static void main(String[] args) throws SchedulerException {
        Date date = new Date();
        SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
        System.out.println("Current Exec Time Is :" + sf.format(date));

        // 创建一个JobDetail示例，将该示例与HelloJob Class绑定
        JobDetail jobDetail = JobBuilder.newJob(HelloJob.class).withIdentity("myJob").build();
        //获取距离当前时间3秒后的时间
        date.setTime(date.getTime()+3000);
        //获取距离当前时间6秒后的时间
        Date endDate = new Date();
        endDate.setTime(endDate.getTime()+6000);
        // 创建一个Trigger实例，定义该job立即执行，并且每隔两秒钟重复执行一次，直到永远
        Trigger triger = TriggerBuilder
                .newTrigger()
                .withIdentity("myTrigger", "group1")
                .startAt(date)
                .endAt(endDate)
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(2).repeatForever()).build();
        // 创建Scheduler实例
        SchedulerFactory sfact = new StdSchedulerFactory();
        Scheduler scheduler = sfact.getScheduler();
        scheduler.start();

        scheduler.scheduleJob(jobDetail, triger);
    }
}
本文内容由网友自发贡献，版权归原作者所有，本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容，请联系:hwhale#tublm.com(使用前将#替换为@)

SSM到Spring Boot

Java

任务调度

Quartz

Java定时任务调度工具详解之Quartz篇（中级）一：浅谈JobExecutionContext&JobDatai&浅谈Trigger 的相关文章

随机推荐

  • 21.shell语言之if条件判断语句

    个人简介 作者简介 大家好 我是小鹏linux 运维领域新星创作者 个人主页 小鹏linux 支持我 点赞 收藏 留言 格言 你未必出类拔萃 但一定与众不同 系列专栏 阶段一 windows基础 原创16篇 阶段二 Linux基础知识 原创

  • Mac安装Redis后的配置

    Mac安装Redis后的配置 找到安装目录 配置文件修改 启动服务做测试连接 找到安装目录 1 双击 右键 访达 点击前往文件夹进行查找 如下图所示 2 然后再如下图所示中找到如下路径 usr local bin 3 找到redis con

  • hibernate mysql 超时_Hibernate连接数据库超时设置autoReconnect=true

    com mysql jdbc CommunicationsException The last packet successfully received from the server was58129 seconds ago The la

  • 小程序云开发——图片视频资源上传云端并返回云端路径

    在现在的应用中 包括小程序 图片视频等元素是产品必不可少的一部分 如果一个产品仅支持文字 将会很单调 有时候我们需要将图片视频上传到云端或者服务器 我这里将介绍在小程序中怎么上传图片和视频到云端 并返回云端路径 可以将这个云端路径存入数据库

  • 第三讲：IP地址和子网掩码

    一 标准分类的IP地址 每台计算机都要有IP地址 有了IP地址才能互相通信 计算机之间只能互相认识IP地址 IP地址可以理解为计算机的身份证号 一 二进制和十进制数转换 记住 10000000 2 128 10 1000000 2 64 1

  • PhpStorm+Xdebug+PHPStudy配置并调试

    首先 火狐浏览器搜索插件并安装 配置IDE key 打开phpinfo 将内容复制到Xdebug Support Tailored Installation Instructions 会推荐你适合版本的xdebug 当然你也可以选择phps

  • UE4 全局变量的应用(蓝图)

    4 20 1 创建全局变量 命名为MyGameInstance 2 创建一个变量 命名为MyB 3 在项目设置中 搜索GameInstence 并选中创建的全局变量 4 在蓝图里调用全局变量 5 成功打印

  • Tmux使用教程

    Tmux 是一款可以管理会话和分屏的终端复用器 在远程 SSH 断开后可以继续执行任务 重新连接后再继续会话 也能够将进程放到后台运行 需要时重新接管 为了防止 SSH 因网络断开造成的进程运行中断 推荐把所有需要长期运行的训练等任务都使用

  • 提升效率之如何打印出漂亮的带颜色的日志(输出高亮)

    花里胡哨的日志 1 花里胡哨的shell打印 2 c语言日志的彩色输出 日志系统对于一个软件的维护是很重要的 对于直接在本地打印的信息 可能包含非常多 如何才能快速发现自己想要打印的东西呢 带上颜色的输出 绝对是很好的选择 使用c c 的输

  • 二、网络编程之协议及协议格式详解

    引言 在网络编程中 我经常听人提起过协议 标准协议 协议族 TCP协议 传输层协议 诸如此类的协议概念 这些种类繁多的名词听着让人感觉头晕 所以今天继续学习和总结协议的相关知识 在前面一篇文章 网络编程之基础知识详解 中已经简单介绍过协议

  • vue3中使用echart多个图表，并且可以随着屏幕大小自适应布局

    一 在项目中安装echarts npm install echarts save 二 引入echarts 1 因为多个地方需要使用到这个echart图表 所以将这个echarts写在自定义组件中 子组件 chart vue div clas

  • Linux进程控制编程实验_02

    任务1 编写一个进程创建实验程序task51 c 创建如图所示的进程族亲结构 其中p1是程序启动时由加载程序创建第一个进程 各进程的输出信息分别如下 p1 I am father process p11 当前时间是 lt 年 月 日 时 分

  • Eclipse CDT c++支持C++11

    最近要在Linux 环境下面写一些代码 需要支持C 11 可是CDT 不认识C 11的特性 看了很多网上的配置资料 各种版本下面还是不一样 Eclipse 16 04 CDT 9 4 GCC 5 4 首先创建一个C project 写点C

  • mysql知识系列：用命令行远程登录Mysql

    参考 命令行登录Mysql 远程登录Mysql的方法 总结 mysql uxxx pxxx hxxx xxx xxx xxx P3306 xxx 为替换的内容

  • Python 基础合集8：类的继承和多态

    一 前言 本小节主要梳理类的继承和多态 继承包含三种形式 单继承 多层继承 多重继承 环境说明 Python 3 6 windows11 64位 二 继承 基础语法如下 class B A 表示的含义就是B 继承A A 是B 的父类 cla

  • 把数据插入到数据库的两种方法

    把表单中的数据插入到数据库中有两种方法 1 直接使用sql语句的 优点 速度快 不耗资源 缺点 不能传递太长的字段内容 字段比较多时不易排错 推荐有经验的编程者优先考虑 具体操作 假设表单中有以下字段 username password s

  • 阿里云免费试用服务器，怎么申请

    免费试用也要分个人用户和企业用户 个人用户选择比较少 目前只有下面这个配置 免费试用3个月 企业用户有4款机型 一 参与对象 满足以下全部条件的阿里云用户 1 阿里云注册会员用户 可以联系我注册账号 这样试用以后如果要新购也可以有优惠 2

  • 微信小程序调用天气信息

    在微信小程序中调用天气信息 下面是示例代码 wx request url example php 仅为示例 并非真实的接口地址 data x y header content type application json 默认值 succes

  • jdk和tomcat的关系

    1 什么是jvm 我们从操作系统的层面来理解 jvm其实就是操作系统中的一个进程 既然是一个进程 那么我们很容易的可以通过任务管理器来查看 假设此时我们启动myeclipse myeclipse其实就是用java语言编写的一个软件 他的运行

  • Java定时任务调度工具详解之Quartz篇（中级）一：浅谈JobExecutionContext&JobDatai&浅谈Trigger

    概要 OpenSymphony提供的强大的开源任务调度框架 官网 http www quartz scheduler org 纯java实现 精细控制排程 特点 强大的调度功能 灵活的应用方式 分布式和集群能力 主要用到的设计模式 Buil

热门标签