qidao123.com技术社区-IT企服评测·应用市场

标题: Quartz（1-Job任务界说与使用） [打印本页]
作者: 宝塔山    时间: 2025-4-22 12:31
标题: Quartz（1-Job任务界说与使用）
根本使用
  1. <dependency>
  2.     <groupId>org.quartz-scheduler</groupId>
  3.     <artifactId>quartz</artifactId>
  4.     <version>2.3.1</version>
  5. </dependency>
复制代码
  1. public class HelloJob implements Job {
  3.     @Override
  4.     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
  5.         //实际触发时间。例如，计划时间可能是 10:00:00，但如果调度程序太忙，实际触发时间可能是 10:00:03。
  6.         Date fireTime = jobExecutionContext.getFireTime();
  7.         System.out.println("fireTime:" + fireTime);
  8.         //上次触发时间
  9.         Date previousFireTime = jobExecutionContext.getPreviousFireTime();
  10.         System.out.println("previousFireTime:" + previousFireTime);
  11.         //下次触发时间
  12.         Date nextFireTime = jobExecutionContext.getNextFireTime();
  13.         System.out.println("nextFireTime:" + nextFireTime);
  14.         //触发器触发的预定时间。
  15.         Date scheduledFireTime = jobExecutionContext.getScheduledFireTime();
  16.         System.out.println("scheduledFireTime:" + scheduledFireTime);
  18.         JobDetail jobDetail = jobExecutionContext.getJobDetail();
  19.         System.out.println("jobDataMap:" + JSON.toJSONString(jobDetail.getJobDataMap()));
  20.         System.out.println("jobKey:" + JSON.toJSONString(jobDetail.getKey()));
  21.         System.out.println("jobDescription:" + jobDetail.getDescription());
  22.         System.out.println("==================================");
  23.     }
  25.     public static void main(String[] args) throws SchedulerException {
  26.         //1.创建一个jobDetail的实例，将该实例与HelloJob Class绑定
  27.         JobDetail jobDetail = JobBuilder
  28.                 .newJob(HelloJob.class) //定义Job类为HelloJob类，真正的执行逻辑所在
  29.                 .withIdentity("hello","group1")
  30.                 .withDescription("Quartz测试")
  31.                 .usingJobData("name", "小米")
  32.                 .usingJobData("age", 15)
  33.                 .build();
  35.         //2.创建一个Trigger触发器的实例，定义该job立即执行，并且每2秒执行一次，一直执行
  36.         SimpleTrigger trigger = TriggerBuilder.newTrigger()
  37.                 .withIdentity("myTrigger", "group1")
  38.                 .startNow() //立即生效
  39.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule()
  40.                         .withIntervalInSeconds(2) //每2秒执行一次
  41.                         .repeatForever()) //一直执行
  42.                 .build();
  43.         //3.创建schedule实例
  44.         StdSchedulerFactory factory = new StdSchedulerFactory();
  45.         Scheduler scheduler = factory.getScheduler();
  46.         scheduler.start(); //启动
  47.         scheduler.scheduleJob(jobDetail, trigger); // jobDetail和trigger加入调度
  48.     }
  49. }
复制代码
JobExecutionContext

当 Scheduler 调用一个 Job 就会将 JobExecutionContext 通报给 Job 的 execute()方法，Job 能通过 JobExecutionContext 对象访问到 Quartz 运行时候的环境和 Job 本身的明细数据
JobDetail、JobBuilder

方法

JobDetails 信息持久化到数据库的时候有一个属性 storeDurably，如果设置为 true 则无论与其关联的 Trigger 是否存在其都会一直存在，否则只要相关联的 trigger 删除掉了其会自动删除掉
请求规复，也就是说当应用发生故障的时候，是否重新实验默认是 false。如果一个 job 是可规复的，并且在其实验的时候，scheduler 发生硬关闭（hard shutdown)（好比运行的历程崩溃了，或者关机了），则当 scheduler 重新启动的时候，该 job 会被重新实验。此时，该 job 的 JobExecutionContext.isRecovering() 返回 true
添加 Job 数据，每个 JobDetail 内都有一个 JobDataMap，包含了关联到这个 Job 的数据，在 Job 类中，可以通过 context 取出该数据，进行业务流程处置惩罚。
给 JobDetail 起一个 Id，方便后面检索
用来对 job 进行描述，并没有什么实际作用
JobDataMap

JobDetail 是任务的界说，而 Job 是任务的实验逻辑，每一个 JobDetail 都会有一个 JobDataMap，JobDataMap 本质就是一个 Map 的扩展类，可以存储一些任务信息
JobDataMap 获取任务信息
  1. public class HelloJob implements Job {
  3.     @Override
  4.     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
  5.         JobDetail jobDetail = jobExecutionContext.getJobDetail();
  6.         JobDataMap jobDataMap = jobDetail.getJobDataMap();
  7.         System.out.println("name:" + jobDataMap.getString("name"));
  8.         System.out.println("age:" + jobDataMap.getInt("age"));
  9.         System.out.println("jobKey:" + JSON.toJSONString(jobDetail.getKey()));
  10.         System.out.println("jobDescription:" + jobDetail.getDescription());
  11.         System.out.println("==================================");
  12.     }
  14.     public static void main(String[] args) throws SchedulerException {
  15.         //1.创建一个jobDetail的实例，将该实例与HelloJob Class绑定
  16.         JobDetail jobDetail = JobBuilder
  17.                 .newJob(HelloJob.class) //定义Job类为HelloJob类，真正的执行逻辑所在
  18.                 .withIdentity("hello","group1")
  19.                 .withDescription("Quartz测试")
  20.                 .usingJobData("name", "小米")
  21.                 .usingJobData("age", 15)
  22.                 .build();
  24.         //2.创建一个Trigger触发器的实例，定义该job立即执行，并且每2秒执行一次，一直执行
  25.         SimpleTrigger trigger = TriggerBuilder.newTrigger()
  26.                 .withIdentity("myTrigger", "group1")
  27.                 .startNow() //立即生效
  28.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule()
  29.                         .withIntervalInSeconds(2) //每2秒执行一次
  30.                         .repeatForever()) //一直执行
  31.                 .build();
  32.         //3.创建schedule实例
  33.         StdSchedulerFactory factory = new StdSchedulerFactory();
  34.         Scheduler scheduler = factory.getScheduler();
  35.         scheduler.start(); //启动
  36.         scheduler.scheduleJob(jobDetail, trigger); // jobDetail和trigger加入调度
  37.     }
  38. }
复制代码
实体类获取任务信息
  1. public class HelloJob3 implements Job {
  3.     private String message;
  4.     private Float floatJobValue;
  5.     private Double doubleTriggerValue;
  7.     public String getMessage() {
  8.         return message;
  9.     }
  11.     public void setMessage(String message) {
  12.         this.message = message;
  13.     }
  15.     public Float getFloatJobValue() {
  16.         return floatJobValue;
  17.     }
  19.     public void setFloatJobValue(Float floatJobValue) {
  20.         this.floatJobValue = floatJobValue;
  21.     }
  23.     public Double getDoubleTriggerValue() {
  24.         return doubleTriggerValue;
  25.     }
  27.     public void setDoubleTriggerValue(Double doubleTriggerValue) {
  28.         this.doubleTriggerValue = doubleTriggerValue;
  29.     }
  31.     @Override
  32.     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
  33.         //打印当前的执行时间 例如 2017-11-22 00:00:00
  34.         Date date = new Date();
  35.         SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  36.         System.out.println("现在的时间是：" + sf.format(date));
  37.         //打印jobDataMap定义的message的值
  38.         System.out.println("jobDataMap定义的message的值 : " + message);
  39.         //jobDataMap定义的floatJobValue的值
  40.         System.out.println("jobDataMap定义的floatJobValue的值 : " + floatJobValue);   
  41.                 System.out.println("==================================");
  42.     }
  44.     public static void main(String[] args) throws SchedulerException {
  45.         //1.创建一个jobDetail的实例，将该实例与HelloJob Class绑定
  46.         JobDetail jobDetail = JobBuilder
  47.                 .newJob(HelloJob3.class) //定义Job类为HelloJob类，真正的执行逻辑所在
  48.                 .withIdentity("myJob", "group1") //定义name 和 group
  49.                 .usingJobData("message","hello myJob1") //加入属性到jobDataMap
  50.                 .usingJobData("FloatJobValue",8.88f) //加入属性到jobDataMap
  51.                 .build();
  53.         //2.创建一个Trigger触发器的实例，定义该job立即执行，并且每2秒执行一次，一直执行
  54.         SimpleTrigger trigger = TriggerBuilder.newTrigger()
  55.                 .withIdentity("myTrigger", "group1")
  56.                 .startNow() //立即生效
  57.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule()
  58.                         .withIntervalInSeconds(2) //每2秒执行一次
  59.                         .repeatForever()) //一直执行
  60.                 .build();
  61.         //3.创建schedule实例
  62.         StdSchedulerFactory factory = new StdSchedulerFactory();
  63.         Scheduler scheduler = factory.getScheduler();
  64.         scheduler.start(); //启动
  65.         scheduler.scheduleJob(jobDetail,trigger); // jobDetail和trigger加入调度
  66.     }
  67. }
复制代码
注解使用

@PersistJobDataAfterExecution

有状态的 Job 可以理解为多次 Job 调用期间可以持有一些状态信息，这些状态信息存储在 JobDataMap 中，而默认的无状态 Job 每次调用时都会创建一个新的 JobDataMap
留意：没有添加@PersistJobDataAfterExecution 注解，每次调用时都会创建一个新的 JobDataMap，不会累加；添加该注解后，多次调用期间可以持有一些状态信息
  1. @PersistJobDataAfterExecution
  2. public class HelloJob4 implements Job {
  4.     private Integer count;
  6.     public void setCount(Integer count) {
  7.         this.count = count;
  8.     }
  10.     @Override
  11.     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
  12.         System.out.println(++count);
  13.         jobExecutionContext.getJobDetail().getJobDataMap().put("count", count);
  14.     }
  16.     public static void main(String[] args) throws SchedulerException {
  17.         //1.创建一个jobDetail的实例，将该实例与HelloJob Class绑定
  18.         JobDetail jobDetail = JobBuilder
  19.                 .newJob(HelloJob4.class) //定义Job类为HelloJob类，真正的执行逻辑所在
  20.                 .withIdentity("myJob", "group1") //定义name 和 group
  21.                 .usingJobData("count",0) //加入属性到jobDataMap
  22.                 .build();
  24.         //2.创建一个Trigger触发器的实例，定义该job立即执行，并且每2秒执行一次，一直执行
  25.         SimpleTrigger trigger = TriggerBuilder.newTrigger()
  26.                 .withIdentity("myTrigger", "group1")
  27.                 .startNow() //立即生效
  28.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule()
  29.                         .withIntervalInSeconds(2) //每2秒执行一次
  30.                         .repeatForever()) //一直执行
  31.                 .build();
  32.         //3.创建schedule实例
  33.         StdSchedulerFactory factory = new StdSchedulerFactory();
  34.         Scheduler scheduler = factory.getScheduler();
  35.         scheduler.start(); //启动
  36.         scheduler.scheduleJob(jobDetail,trigger); // jobDetail和trigger加入调度
  37.     }
  38. }
复制代码
@DisallowConcurrentExecution

禁止并发实验多个雷同界说的 JobDetail，这个注解是加在 Job 类上的，但意思并不是不能同时实验多个 Job，而是不能并发实验同一个 Job
例如：同一个 Job 实现类 DemoJob 的两个 JobDetail 实例 A 和 B，设置 A 的定时实验频率为每 1 分钟实验一次，A 的实际运行耗时为 3 分钟，B 的定时实验频率也是每 1 分钟实验一次，B 的实际运行耗时为 30 秒。假如在 07:00 分 00 秒时 A 和 B 同时第一次运行，则到 07:00 分 30 秒时 B 运行结束，此时 A 还在运行中，到 07:01 分 00 秒时 A 和 B 又该实验了，但是由于注解@DisallowConcurrentExecution 的缘故，此时 A 不会再次运行，A 只能在其上一次运行结束后才气再次被调用实验。但是 B 会正常运行（B 不受 A 的影响，注解@DisallowConcurrentExecution 是作用于 JobDetail 实例而不是 Job 实现类）
留意：如果你使用了@PersistJobDataAfterExecution 注解，则猛烈建议你同时使用@DisallowConcurrentExecution 注解，由于当同一个 job（JobDetail）的两个实例被并发实验时，由于竞争，JobDataMap 中存储的数据很可能是不确定的。
使用同一个Job对象
  1. @DisallowConcurrentExecution
  2. public class HelloJob5 implements Job {
  4.     @Override
  5.     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
  6.         Date date = new Date();
  7.         SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  8.         System.out.println("现在的时间是：" + sf.format(date));
  9.         JobKey key = jobExecutionContext.getJobDetail().getKey();
  10.         //打印jobDetail 的name
  11.         System.out.println("jobDetail 的name ： " + key.getName());
  12.         //打印jobDetail 的group
  13.         System.out.println("jobDetail 的group ： " + key.getGroup());
  14.         System.out.println("==============================");
  15.         try {
  16.             Thread.sleep(3000);
  17.         } catch (InterruptedException e) {
  18.             throw new RuntimeException(e);
  19.         }
  20.     }
  22.     public static void main(String[] args) throws SchedulerException {
  23.         //1.创建一个jobDetail的实例，将该实例与HelloJob Class绑定
  24.         JobDetail jobDetail1 = JobBuilder
  25.                 .newJob(HelloJob5.class) //定义Job类为HelloJob类，真正的执行逻辑所在
  26.                 .withIdentity("group1", "group1") //定义name 和 group
  27.                 .build();
  29.         //2.创建一个Trigger触发器的实例，定义该job立即执行，并且每2秒执行一次，一直执行
  30.         SimpleTrigger trigger1 = TriggerBuilder.newTrigger()
  31.                 .withIdentity("myTrigger1", "group1")
  32.                 .startNow() //立即生效
  33.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule()
  34.                         .withIntervalInSeconds(2) //每2秒执行一次
  35.                         .repeatForever()) //一直执行
  36.                 .build();
  37.         //3.创建schedule实例
  38.         StdSchedulerFactory factory = new StdSchedulerFactory();
  39.         Scheduler scheduler = factory.getScheduler();
  40.         scheduler.start(); //启动
  41.         scheduler.scheduleJob(jobDetail1, trigger1); // jobDetail和trigger加入调度
  42.     }
  43. }
复制代码
  1. // 运行结果：
  2. 现在的时间是：2024-11-12 00:59:49
  3. jobDetail 的name ： group1
  4. jobDetail 的group ： group1
  5. ==============================
  6. 现在的时间是：2024-11-12 00:59:52
  7. jobDetail 的name ： group1
  8. jobDetail 的group ： group1
  9. ==============================
  10. 现在的时间是：2024-11-12 00:59:55
  11. jobDetail 的name ： group1
  12. jobDetail 的group ： group1
  13. ==============================
复制代码
  1. // 运行结果：
  2. 现在的时间是：2024-11-12 01:00:48
  3. jobDetail 的name ： group1
  4. jobDetail 的group ： group1
  5. ==============================
  6. 现在的时间是：2024-11-12 01:00:50
  7. jobDetail 的name ： group1
  8. jobDetail 的group ： group1
  9. ==============================
  10. 现在的时间是：2024-11-12 01:00:52
  11. jobDetail 的name ： group1
  12. jobDetail 的group ： group1
  13. ==============================
复制代码
创建两个 Job 对象
  1. @DisallowConcurrentExecution
  2. public class HelloJob5 implements Job {
  4.     @Override
  5.     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
  6.         Date date = new Date();
  7.         SimpleDateFormat sf = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");
  8.         System.out.println("现在的时间是：" + sf.format(date));
  9.         JobKey key = jobExecutionContext.getJobDetail().getKey();
  10.         //打印jobDetail 的name
  11.         System.out.println("jobDetail 的name ： " + key.getName());  
  12.         //打印jobDetail 的group
  13.         System.out.println("jobDetail 的group ： " + key.getGroup());   
  14.         System.out.println("==============================");
  15.         try {
  16.             Thread.sleep(3000);
  17.         } catch (InterruptedException e) {
  18.             throw new RuntimeException(e);
  19.         }
  20.     }
  22.     public static void main(String[] args) throws SchedulerException {
  23.         //1.创建一个jobDetail的实例，将该实例与HelloJob Class绑定
  24.         JobDetail jobDetail1 = JobBuilder
  25.                 .newJob(HelloJob5.class) //定义Job类为HelloJob类，真正的执行逻辑所在
  26.                 .withIdentity("group1", "group1") //定义name 和 group
  27.                 .build();
  29.         //2.创建一个Trigger触发器的实例，定义该job立即执行，并且每2秒执行一次，一直执行
  30.         SimpleTrigger trigger1 = TriggerBuilder.newTrigger()
  31.                 .withIdentity("myTrigger1", "group1")
  32.                 .startNow() //立即生效
  33.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule()
  34.                         .withIntervalInSeconds(2) //每2秒执行一次
  35.                         .repeatForever()) //一直执行
  36.                 .build();
  37.         //3.创建schedule实例
  38.         StdSchedulerFactory factory = new StdSchedulerFactory();
  39.         Scheduler scheduler = factory.getScheduler();
  40.         scheduler.start(); //启动
  41.         scheduler.scheduleJob(jobDetail1, trigger1); // jobDetail和trigger加入调度
  43.         JobDetail jobDetail2 = JobBuilder
  44.                 .newJob(HelloJob5.class) //定义Job类为HelloJob类，真正的执行逻辑所在
  45.                 .withIdentity("group2", "group2") //定义name 和 group
  46.                 .build();
  48.         //2.创建一个Trigger触发器的实例，定义该job立即执行，并且每2秒执行一次，一直执行
  49.         SimpleTrigger trigger2 = TriggerBuilder.newTrigger()
  50.                 .withIdentity("myTrigger2", "group2")
  51.                 .startNow() //立即生效
  52.                 .withSchedule(SimpleScheduleBuilder.simpleSchedule()
  53.                         .withIntervalInSeconds(3) //每3秒执行一次
  54.                         .repeatForever()) //一直执行
  55.                 .build();
  56.         //3.创建schedule实例
  57.         Scheduler scheduler2 = factory.getScheduler();
  58.         scheduler2.start(); //启动
  59.         scheduler2.scheduleJob(jobDetail2, trigger2); // jobDetail和trigger加入调度
  60.     }
  61. }
复制代码
  1. // 运行结果
  2. 现在的时间是：2024-11-12 01:08:37
  3. 现在的时间是：2024-11-12 01:08:37
  4. jobDetail 的name ： group2
  5. jobDetail 的name ： group1
  6. jobDetail 的group ： group1
  7. jobDetail 的group ： group2
  8. ==============================
  9. ==============================
  11. 现在的时间是：2024-11-12 01:08:40
  12. jobDetail 的name ： group2
  13. jobDetail 的group ： group2
  14. ==============================
  15. 现在的时间是：2024-11-12 01:08:40
  16. jobDetail 的name ： group1
  17. jobDetail 的group ： group1
  18. ==============================
复制代码


免责声明：如果侵犯了您的权益，请联系站长，我们会及时删除侵权内容，谢谢合作！更多信息从访问主页：qidao123.com:ToB企服之家，中国第一个企服评测及商务社交产业平台。



欢迎光临 qidao123.com技术社区-IT企服评测·应用市场 (https://dis.qidao123.com/) Powered by Discuz! X3.4