浅谈JobExecutionContext JobDataMap

JobExecutionContext是什么？

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

JobDataMap是什么？

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

JobDataMap的获取方式

方式一：从Map里面直接获取

import java.text.NumberFormat;
import java.text.SimpleDateFormat;
import java.util.Date;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 {//打印当前的执行时间Date date = new Date();SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String currentTime = sdf.format(date);System.out.println("Current Exec Time : "+currentTime);//编写具体的业务逻辑
        JobKey key = context.getJobDetail().getKey();System.out.println("my name is :"+key.getName()+" and group is:" +key.getGroup());TriggerKey trkey = context.getTrigger().getKey();System.out.println("my name is: "+trkey.getName()+" and group is:"+trkey.getGroup());JobDataMap dataMap = context.getJobDetail().getJobDataMap();JobDataMap tdataMap = context.getTrigger().getJobDataMap();String jobMessage = dataMap.getString("message");Float FloatJobValue = dataMap.getFloat("FloatJobValue");String triggerMessage = tdataMap.getString("message");Double DoubleTriggerValue = tdataMap.getDouble("DoubleTriggerValue");System.out.println(jobMessage);System.out.println(FloatJobValue);System.out.println(triggerMessage);System.out.println(DoubleTriggerValue);}}

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立即执行，并且每隔2秒钟重复执行一次，直到永远Trigger trigger = 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();scheduler.scheduleJob(jobDetail, trigger);}}

import java.text.NumberFormat;
import java.text.SimpleDateFormat;
import java.util.Date;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 {//打印当前的执行时间Date date = new Date();SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String currentTime = sdf.format(date);System.out.println("Current Exec Time : "+currentTime);//编写具体的业务逻辑
        JobKey key = context.getJobDetail().getKey();System.out.println("my name is :"+key.getName()+" and group is:" +key.getGroup());TriggerKey trkey = context.getTrigger().getKey();System.out.println("my name is: "+trkey.getName()+" and group is:"+trkey.getGroup());JobDataMap dataMap = context.getMergedJobDataMap();        String jobMessage = dataMap.getString("message");Float FloatJobValue = dataMap.getFloat("FloatJobValue");String triggerMessage = dataMap.getString("message");Double DoubleTriggerValue = dataMap.getDouble("DoubleTriggerValue");System.out.println(jobMessage);System.out.println(FloatJobValue);System.out.println(triggerMessage);System.out.println(DoubleTriggerValue);}}

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

package com.test.quartz.myquartz;import java.text.SimpleDateFormat;
import java.util.Date;
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;public void setMessage(String message) {this.message = message;}public void setFloatJobValue(Float floatJobValue) {FloatJobValue = floatJobValue;}
public void setDoubleTriggerValue(Double doubleTriggerValue) {DoubleTriggerValue = doubleTriggerValue;}public void execute(JobExecutionContext context) throws JobExecutionException {//打印当前的执行时间Date date = new Date();SimpleDateFormat sdf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");String currentTime = sdf.format(date);System.out.println("Current Exec Time : "+currentTime);//编写具体的业务逻辑
        JobKey key = context.getJobDetail().getKey();System.out.println("my name is :"+key.getName()+" and group is:" +key.getGroup());TriggerKey trkey = context.getTrigger().getKey();System.out.println("my name is: "+trkey.getName()+" and group is:"+trkey.getGroup());System.out.println("message is :" +message);System.out.println("FloatJobValue is :" +FloatJobValue);System.out.println("DoubleTriggerValue is :" +DoubleTriggerValue);}}

转载于:https://www.cnblogs.com/zhou-test/p/9720186.html

浅谈JobExecutionContext JobDataMap相关推荐

浅谈MySQL存储引擎-InnoDBMyISAM
浅谈MySQL存储引擎-InnoDB&MyISAM 存储引擎在MySQL的逻辑架构中位于第三层,负责MySQL中的数据的存储和提取.MySQL存储引擎有很多,不同的存储引擎保存数据和索引的方式 ...
【大话设计模式】——浅谈设计模式基础
初学设计模式给我最大的感受是:人类真是伟大啊!单单是设计模式的基础课程就让我感受到了强烈的生活气息. 个人感觉<大话设计模式>这本书写的真好.让貌似非常晦涩难懂的设计模式变的生活化.趣味化 ...
学校计算机机房好处,浅谈学校计算机机房维护
浅谈学校计算机机房维护现在的学校机房都配置了数量较多的计算机,而且机房的使用非常频繁.对于怎样维护好计算机,特别是计算机软件系统,对广大计算机教师来说是一个很重要且非常现实的问题.下面就本人在 ...
java 中的单元测试_浅谈Java 中的单元测试
单元测试编写 Junit 单元测试框架对于Java语言而言,其单元测试框架,有Junit和TestNG这两种, 下面是一个典型的JUnit测试类的结构 package com.example.dem ...
mybatis与php,浅谈mybatis中的#和$的区别
浅谈mybatis中的#和$的区别发布于 2016-07-30 11:14:47 | 236 次阅读 | 评论: 0 | 来源: 网友投递 MyBatis 基于Java的持久层框架MyBatis 本 ...
浅谈GCC预编译头技术
浅谈GCC预编译头技术文/jorge --谨以此文,悼念我等待MinGW编译时逝去的那些时间. 其实刚开始编程的时候,我是丝毫不重视编译速度之类的问题的,原因很简单,因为那时我用BASICA.后来 ...
【笔记】震惊！世上最接地气的字符串浅谈(HASH+KMP)
震惊!世上最接地气的字符串浅谈(HASH+KMP) 笔者过于垃圾,肯定会有些错的地方,欢迎各位巨佬指正,感激不尽! 引用:LYD的蓝书,一本通,DFC的讲稿,网上各路巨佬 Luguo id: 章鱼那个 ...
浅谈几种区块链网络攻击以及防御方案之其它网络攻击
旧博文,搬到 csdn 原文:http://rebootcat.com/2020/04/16/network_attack_of_blockchain_other_attack/ 写在前面的话自比特 ...
浅谈几种区块链网络攻击以及防御方案之拒绝服务攻击
旧博文,搬到 csdn 原文:http://rebootcat.com/2020/04/14/network_attack_of_blockchain_ddos_attack/ 写在前面的话自比特币 ...

浅谈JobExecutionContext JobDataMap

浅谈JobExecutionContext JobDataMap相关推荐

最新文章

热门文章