AI 助理
备案控制台
开发者社区 云计算 文章 正文

quartz入门（二）SimpleTrigger简单实例

2021-12-24 223
版权
版权声明：
本文内容由阿里云实名注册用户自发贡献，版权归原作者所有，阿里云开发者社区不拥有其著作权，亦不承担相应法律责任。具体规则请查看《 阿里云开发者社区用户服务协议》和 《阿里云开发者社区知识产权保护指引》。如果您发现本社区中有涉嫌抄袭的内容，填写 侵权投诉表单进行举报，一经查实，本社区将立刻删除涉嫌侵权内容。
简介： quartz入门（二）SimpleTrigger简单实例

此篇博客为quartz2.2.1第二个例子的解析，此例子主要对SimpleTrigger的使用进行详细说明，详细使用说明均在代码中以注释的形式体现。


SimpleTrigger:在某个时刻开始，然后按照某个时间间隔重复执行。

SimpleTrigger包括属性：开始时间，结束时间，重复次数，重复间隔。

SimpleJob


package com.secbro.job;
import org.quartz.Job;
import org.quartz.JobExecutionContext;
import org.quartz.JobExecutionException;
import org.quartz.JobKey;
import java.util.Date;
/**
 */
public class SimpleJob implements Job {
    @Override
    public void execute(JobExecutionContext context) throws JobExecutionException {
        // JobExecutionContext类提供了调度上线问的各种信息,为JobDetail和Trigger提供必要的信息
        // JobKey是由name和group组成，并且name必须在group内是唯一的。如果只指定一组则将使用默认的组名。
        JobKey jobKey = context.getJobDetail().getKey();
        System.out.println("SimpleJob says: " + jobKey + " executing at " + new Date());
    }
}

SimpleTriggerExample

package com.secbro.test;
import com.secbro.job.SimpleJob;
import org.quartz.*;
import org.quartz.impl.StdSchedulerFactory;
import java.util.Date;
/**
 * SimpleTrigger:在某个时刻开始，然后按照某个时间间隔重复执行;<br>
 * SimpleTrigger包括属性：开始时间，结束时间，重复次数，重复间隔。
 */
public class SimpleTriggerExample {
    public void run() throws SchedulerException {
        // 通过SchedulerFactory获取一个调度器实例
        StdSchedulerFactory sf = new StdSchedulerFactory();
        // 代表一个Quartz的独立运行容器
        Scheduler scheduler = sf.getScheduler();
        // 获取当前时间15秒之后的时间
        Date startDate = DateBuilder.nextGivenSecondDate(null,15);
        // ------------------------------------------Job1 start-------------------------------------------------
        // 创建一个JobDetail实例,此版本JobDetail已经作为接口（interface）存在，通过JobBuilder创建
        // 并指定Job在Scheduler中所属组及名称
        JobDetail jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job1","group1").build();
        // SimpleTrigger实现Trigger接口的子接口。此处只指定了开始执行定时任务的时间，使用默认的重复次数（0次）和重复间隔（0秒）
        SimpleTrigger simpleTrigger = (SimpleTrigger) TriggerBuilder.newTrigger().withIdentity("trigger1","group1").
                startAt(startDate).build();
        // 添加JobDetail到Scheduler容器中，并且和Trigger进行关联，返回执行时间
        Date date = scheduler.scheduleJob(jobDetail,simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job1 end-------------------------------------------------
        // ------------------------------------------Job2 start-------------------------------------------------
        // 与job1相同处理方式的job2，几乎同时执行两个job1和job2任务
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job2","group1").build();
        simpleTrigger = (SimpleTrigger) TriggerBuilder.newTrigger().withIdentity("trigger2","group1").startAt(startDate).build();
        date = scheduler.scheduleJob(jobDetail,simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job2 end-------------------------------------------------
        // ------------------------------------------Job3 start-------------------------------------------------
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job3","group1").build();
        // 设置定时任务执行规则为在指定的开始时间进行执行，每个十秒执行一次，重复执行十次。
        // 当指定为SimpleScheduleBuilder时，会发现不用对结果进行强制转换为SimpleTrigger了。
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger3", "group1").startAt(startDate)
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(10).withRepeatCount(10)).build();
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        scheduler.scheduleJob(jobDetail,simpleTrigger);
        // forJob 指定trigger对应的定时任务，另外一种实现形式。此Trigger和上面的Trigger共同出发一个任务，执行各自均执行
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger3","group2").startAt(startDate)
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(10).withRepeatCount(2)).forJob(jobDetail).build();
        scheduler.scheduleJob(simpleTrigger);
        System.out.println(jobDetail.getKey() + " will [also] run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job3 end-------------------------------------------------
        // ------------------------------------------Job4 start-----------------------------------------------
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job4","group1").build();
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger4", "group1").startAt(startDate).
                withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(10).withRepeatCount(5)).build();
        date = scheduler.scheduleJob(jobDetail, simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job4 end-------------------------------------------------
        // ------------------------------------------Job5 start-------------------------------------------------
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job5", "group1").build();
        simpleTrigger = (SimpleTrigger)TriggerBuilder.newTrigger().withIdentity("trigger5", "group1")
                .startAt(DateBuilder.futureDate(5, DateBuilder.IntervalUnit.MINUTE)).build();
        date = scheduler.scheduleJob(jobDetail, simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job5 end-------------------------------------------------
        // ------------------------------------------Job6 start-----------------------------------------------
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job6", "group1").build();
        // 此定时任务的规则为每隔40秒执行一次，永远执行下去
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger6", "group1").startAt(startDate)
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(40).repeatForever()).build();
        date = scheduler.scheduleJob(jobDetail, simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount() + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job6 end-------------------------------------------------
        System.out.println("------- Starting Scheduler ----------------");
        // 在scheduler.start之后调用，可以重新定义trigger，重新注册
        scheduler.start();
        System.out.println("------- Started Scheduler -----------------");
        // ------------------------------------------Job7 start-----------------------------------------------
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job7", "group1").build();
        // 每隔五分钟执行一次，执行20次
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger7", "group1").startAt(startDate)
                .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInMinutes(5).withRepeatCount(20)).build();
        date = scheduler.scheduleJob(jobDetail, simpleTrigger);
        System.out.println(jobDetail.getKey() + " will run at: " + date + " and repeat: " + simpleTrigger.getRepeatCount()
                + " times, every " + simpleTrigger.getRepeatInterval() / 1000L + " seconds");
        // ------------------------------------------Job7 end-------------------------------------------------
        // ------------------------------------------Job8 start-----------------------------------------------
        // storeDurably(),没有触发器指向任务的时候，将任务保存在队列中，然后可以通过手动进行出发
        jobDetail = JobBuilder.newJob(SimpleJob.class).withIdentity("job8", "group1").storeDurably().build();
        // 任务立即执行
        scheduler.addJob(jobDetail, true);
        System.out.println("手动触发   triggering job8...");
        scheduler.triggerJob(JobKey.jobKey("job8", "group1"));
        // ------------------------------------------Job8 end-------------------------------------------------
        scheduler.start();
        try {
            Thread.sleep(60000L);
        } catch (InterruptedException e) {
        }
        // 对Job7进行重新安排
        System.out.println("------- Rescheduling... --------------------");
        simpleTrigger = TriggerBuilder.newTrigger().withIdentity("trigger7", "group1").startAt(startDate).
                withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInMinutes(5).withRepeatCount(20)).build();
        date = scheduler.rescheduleJob(simpleTrigger.getKey(), simpleTrigger);
        System.out.println("job7 rescheduled to run at: " + date);
        System.out.println("------- Waiting five minutes... ------------");
        try {
            Thread.sleep(60000L);
        } catch (Exception ex) {
        }
        scheduler.shutdown(true);
        SchedulerMetaData metaData = scheduler.getMetaData();
        System.out.println("Executed " + metaData.getNumberOfJobsExecuted() + " jobs.");
    }
    public static void main(String[] args) throws SchedulerException {
        SimpleTriggerExample simpleTriggerExample = new SimpleTriggerExample();
        simpleTriggerExample.run();
    }
}

日志信息

group1.job1 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 0 times, every 0 seconds
group1.job2 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 0 times, every 0 seconds
group1.job3 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 10 times, every 10 seconds
group1.job3 will [also] run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 2 times, every 10 seconds
group1.job4 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 5 times, every 10 seconds
group1.job5 will run at: Mon Jun 15 13:30:12 CST 2015 and repeat: 0 times, every 0 seconds
group1.job6 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: -1 times, every 40 seconds
------- Starting Scheduler ----------------
------- Started Scheduler -----------------
group1.job7 will run at: Mon Jun 15 13:25:15 CST 2015 and repeat: 20 times, every 300 seconds
手动触发   triggering job8...
SimpleJob says: group1.job8 executing at Mon Jun 15 13:25:12 CST 2015
SimpleJob says: group1.job1 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job2 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job6 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job7 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:15 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:25 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:25:25 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:25 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:35 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:25:35 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:35 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:45 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:25:45 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:25:55 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:25:55 CST 2015
SimpleJob says: group1.job6 executing at Mon Jun 15 13:25:55 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:05 CST 2015
SimpleJob says: group1.job4 executing at Mon Jun 15 13:26:05 CST 2015
------- Rescheduling... --------------------
job7 rescheduled to run at: Mon Jun 15 13:25:15 CST 2015
------- Waiting five minutes... ------------
SimpleJob says: group1.job7 executing at Mon Jun 15 13:26:12 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:15 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:25 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:35 CST 2015
SimpleJob says: group1.job6 executing at Mon Jun 15 13:26:35 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:45 CST 2015
SimpleJob says: group1.job3 executing at Mon Jun 15 13:26:55 CST 2015
Executed 28 jobs.


longfor5
目录
相关文章
游客zn7mvnkypuy76
|
6月前
|
存储 Java 调度
技术笔记：quartz（从原理到应用）详解篇(转)
技术笔记：quartz（从原理到应用）详解篇(转)
游客zn7mvnkypuy76
162 0
VipSoft
|
4月前
|
容器
Quartz 简单使用
Quartz 简单使用
VipSoft
50 0
蜗牛ICU
|
4月前
|
Java 数据库连接 数据库
【Java 第十一篇章】Spring 框架介绍
Spring 是广泛用于企业级 Java 开发的开源框架，提供轻量级解决方案，助力构建灵活、可维护的应用。核心组件包括 IOC 容器、AOP、MVC、JDBC/ORM、事务处理及远程调用。依赖注入（DI）是其核心特性之一，允许容器自动管理对象间的依赖关系，提升代码的可测试性和解耦。面向切面编程（AOP）则支持将横切关注点（如日志、事务）与业务逻辑分离，促进代码复用和关注点分离。Spring 的 IoC 容器负责对象的创建和管理，简化对象的生命周期管理。Spring 框架具备低侵入性设计，易于整合主流技术栈。
蜗牛ICU
32 0
yuanzhengme
|
5月前
|
监控 安全 调度
JFinal如何实现定时任务
JFinal如何实现定时任务
yuanzhengme
152 0
收破烂的小熊猫
|
调度
Quartz的简单入门
Quartz的简单入门
收破烂的小熊猫
170 0
Quartz的简单入门
go-Jack
|
开发框架 Java API
【Quartz学习总结】——入门程序
【Quartz学习总结】——入门程序
go-Jack
86 0
【Quartz学习总结】——入门程序
1042238208560389
|
运维 NoSQL 数据库连接
Quartz实战与源码解析
Quartz实战与源码解析
1042238208560389
268 0
longfor5
quartz入门（一）下载及简单实例
quartz入门（一）下载及简单实例
longfor5
156 0
quartz入门（一）下载及简单实例
两个蝴蝶飞
|
Java 调度 开发者
JavaSE实现任务调度的三种方式(十六)
JavaSE实现任务调度的三种方式(十六)
两个蝴蝶飞
161 0
JavaSE实现任务调度的三种方式(十六)
Lux_Sun
Quartz - 入门案例
Quartz - 入门案例
Lux_Sun
95 0

热门文章

最新文章

  • 1
    基于区块链的机器学习模型创建方案
  • 2
    阿里云服务器ECS搭建个人网站新手教程（超详细）
  • 3
    上云，你需要了解的账号管理模型
  • 4
    RDS入门——Excel文件转存到RDS数据库实践
  • 5
    优秀的代码都是如何分层的？
  • 6
    3、Python与设计模式--建造者模式
  • 7
    跟阿里云技术专家阙寒一起深度了解视频直播CDN技术
  • 8
    当人工智能遇上区块链，会发生什么？
  • 9
    力挑VMWare 红帽推新虚拟化技术
  • 10
    Ext 4 概述（七）之面板Panel &amp; 杂项
  • 1
    【算法】——快排，分治算法合集
    33
  • 2
    【Spring】方法注解@Bean，配置类扫描路径
    104
  • 3
    【算法】栈
    30
  • 4
    【Spring】获取Bean对象需要哪些注解
    32
  • 5
    【Spring】IoC和DI，控制反转，Bean对象的获取方式
    28
  • 6
    【SpringBug】lombok插件失效，但是没有报错信息，@Data不能生成get和set方法
    31
  • 7
    【SpringMVC】应用分层
    25
  • 8
    【Spring项目】图书管理系统
    18
  • 9
    【Spring配置】idea编码格式导致注解汉字无法保存
    22
  • 10
    【算法】模拟
    19

    • 相关课程

    更多
  • Java Web开发系列课程 - Spring框架入门
  • SpringBoot快速掌握 - 高级应用
  • SpringBoot实战教程
  • SpringMVC框架入门

    • 相关电子书

    更多
  • Spring框架入门
  • Java Spring Boot开发实战系列课程【第6讲】：Spring Boot 2.0实战MyBatis与优化(Java面试题)
  • 杜万-Java reactive programming - Reactor 3 and Spring WebFlux
    • 下一篇
    手把手教你白嫖阿里云服务器(免费领服务器)