文档章节

JAVA定时任务之-Quartz使用篇 | quartz 时间配置规则

袁梓皓
 袁梓皓
发布于 2016/03/01 15:17
字数 1958
阅读 548
收藏 1

 定时任务之-Quartz使用篇

 

        Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个Jobs这样复杂的日程序表。Jobs可以做成标准的Java组件或 EJBs。官方网站:http://www.opensymphony.com/quartz

相关Jar:
   quartz-all-1.6.0.jar
   jta.jar
   commons-logging-1.1.jar
   commons-collections3.2.jar

经过封装的管理类:

  1. /** 
     * 版权所有:华信软件 
     * 项目名称:公用模块 
     * 创建者: Wangdf 
     * 创建日期: 2011-1-22 
     * 文件说明: 定时任务管理类 
     * 最近修改者:Wangdf 
     * 最近修改日期:2011-1-22 
     */  
    package com.extjweb.quartz;  
      
    import java.text.ParseException;  
      
    import org.quartz.CronTrigger;  
    import org.quartz.JobDetail;  
    import org.quartz.Scheduler;  
    import org.quartz.SchedulerException;  
    import org.quartz.SchedulerFactory;  
    import org.quartz.impl.StdSchedulerFactory;  
      
    /** 
     * 定时任务管理类 
     * 
     * @author 王德封 
     */  
    public class QuartzManager {  
        private static SchedulerFactory gSchedulerFactory = new StdSchedulerFactory();  
        private static String JOB_GROUP_NAME = "EXTJWEB_JOBGROUP_NAME";  
        private static String TRIGGER_GROUP_NAME = "EXTJWEB_TRIGGERGROUP_NAME";  
      
        /** 
         * 添加一个定时任务,使用默认的任务组名,触发器名,触发器组名 
         * 
         * @param jobName 
         *            任务名 
         * @param jobClass 
         *            任务 
         * @param time 
         *            时间设置,参考quartz说明文档 
         * @throws SchedulerException 
         * @throws ParseException 
         */  
        public static void addJob(String jobName, String jobClass, String time) {  
            try {  
                Scheduler sched = gSchedulerFactory.getScheduler();  
                JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, Class.forName(jobClass));// 任务名,任务组,任务执行类  
                // 触发器  
                CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);// 触发器名,触发器组  
                trigger.setCronExpression(time);// 触发器时间设定  
                sched.scheduleJob(jobDetail, trigger);  
                // 启动  
                if (!sched.isShutdown()){  
                    sched.start();  
                }  
            } catch (Exception e) {  
                e.printStackTrace();  
                throw new RuntimeException(e);  
            }  
        }  
      
        /** 
         * 添加一个定时任务 
         * 
         * @param jobName 
         *            任务名 
         * @param jobGroupName 
         *            任务组名 
         * @param triggerName 
         *            触发器名 
         * @param triggerGroupName 
         *            触发器组名 
         * @param jobClass 
         *            任务 
         * @param time 
         *            时间设置,参考quartz说明文档 
         * @throws SchedulerException 
         * @throws ParseException 
         */  
        public static void addJob(String jobName, String jobGroupName,  
                String triggerName, String triggerGroupName, String jobClass, String time){  
            try {  
                Scheduler sched = gSchedulerFactory.getScheduler();  
                JobDetail jobDetail = new JobDetail(jobName, jobGroupName, Class.forName(jobClass));// 任务名,任务组,任务执行类  
                // 触发器  
                CronTrigger trigger = new CronTrigger(triggerName, triggerGroupName);// 触发器名,触发器组  
                trigger.setCronExpression(time);// 触发器时间设定  
                sched.scheduleJob(jobDetail, trigger);  
            } catch (Exception e) {  
                e.printStackTrace();  
                throw new RuntimeException(e);  
            }  
        }  
      
        /** 
         * 修改一个任务的触发时间(使用默认的任务组名,触发器名,触发器组名) 
         * 
         * @param jobName 
         * @param time 
         */  
        public static void modifyJobTime(String jobName, String time) {  
            try {  
                Scheduler sched = gSchedulerFactory.getScheduler();  
                CronTrigger trigger = (CronTrigger) sched.getTrigger(jobName, TRIGGER_GROUP_NAME);  
                if(trigger == null) {  
                    return;  
                }  
                String oldTime = trigger.getCronExpression();  
                if (!oldTime.equalsIgnoreCase(time)) {  
                    JobDetail jobDetail = sched.getJobDetail(jobName, JOB_GROUP_NAME);  
                    Class objJobClass = jobDetail.getJobClass();  
                    String jobClass = objJobClass.getName();  
                    removeJob(jobName);  
      
                    addJob(jobName, jobClass, time);  
                }  
            } catch (Exception e) {  
                e.printStackTrace();  
                throw new RuntimeException(e);  
            }  
        }  
      
        /** 
         * 修改一个任务的触发时间 
         * 
         * @param triggerName 
         * @param triggerGroupName 
         * @param time 
         */  
        public static void modifyJobTime(String triggerName,  
                String triggerGroupName, String time) {  
            try {  
                Scheduler sched = gSchedulerFactory.getScheduler();  
                CronTrigger trigger = (CronTrigger) sched.getTrigger(triggerName, triggerGroupName);  
                if(trigger == null) {  
                    return;  
                }  
                String oldTime = trigger.getCronExpression();  
                if (!oldTime.equalsIgnoreCase(time)) {  
                    CronTrigger ct = (CronTrigger) trigger;  
                    // 修改时间  
                    ct.setCronExpression(time);  
                    // 重启触发器  
                    sched.resumeTrigger(triggerName, triggerGroupName);  
                }  
            } catch (Exception e) {  
                e.printStackTrace();  
                throw new RuntimeException(e);  
            }  
        }  
      
        /** 
         * 移除一个任务(使用默认的任务组名,触发器名,触发器组名) 
         * 
         * @param jobName 
         */  
        public static void removeJob(String jobName) {  
            try {  
                Scheduler sched = gSchedulerFactory.getScheduler();  
                sched.pauseTrigger(jobName, TRIGGER_GROUP_NAME);// 停止触发器  
                sched.unscheduleJob(jobName, TRIGGER_GROUP_NAME);// 移除触发器  
                sched.deleteJob(jobName, JOB_GROUP_NAME);// 删除任务  
            } catch (Exception e) {  
                e.printStackTrace();  
                throw new RuntimeException(e);  
            }  
        }  
      
        /** 
         * 移除一个任务 
         * 
         * @param jobName 
         * @param jobGroupName 
         * @param triggerName 
         * @param triggerGroupName 
         */  
        public static void removeJob(String jobName, String jobGroupName,  
                String triggerName, String triggerGroupName) {  
            try {  
                Scheduler sched = gSchedulerFactory.getScheduler();  
                sched.pauseTrigger(triggerName, triggerGroupName);// 停止触发器  
                sched.unscheduleJob(triggerName, triggerGroupName);// 移除触发器  
                sched.deleteJob(jobName, jobGroupName);// 删除任务  
            } catch (Exception e) {  
                e.printStackTrace();  
                throw new RuntimeException(e);  
            }  
        }  
      
        /** 
         * 启动所有定时任务 
         */  
        public static void startJobs() {  
            try {  
                Scheduler sched = gSchedulerFactory.getScheduler();  
                sched.start();  
            } catch (Exception e) {  
                e.printStackTrace();  
                throw new RuntimeException(e);  
            }  
        }  
      
        /** 
         * 关闭所有定时任务 
         */  
        public static void shutdownJobs() {  
            try {  
                Scheduler sched = gSchedulerFactory.getScheduler();  
                if(!sched.isShutdown()) {  
                    sched.shutdown();  
                }  
            } catch (Exception e) {  
                e.printStackTrace();  
                throw new RuntimeException(e);  
            }  
        }  
    }
  2. package com.extjweb.quartz;  
    import java.util.Calendar;  
    import org.quartz.Job;  
    import org.quartz.JobExecutionContext;  
    import org.quartz.JobExecutionException;  
    public class TestJob implements Job {  
        @SuppressWarnings("deprecation")  
        public void execute(JobExecutionContext arg0) throws JobExecutionException {  
            System.out.println(Calendar.getInstance().getTime().toLocaleString()+ "★★★★★★★★★★★");  
        }  
      
    }

quartz 时间配置规则

格式: [秒] [分] [小时] [日] [月] [周] [年]

 序号 说明

 是否必填 允许填写的值 允许的通配符

 1 秒 是 0-59   , - * /
 2 分 是 0-59
  , - * /
 3小时 是 0-23  , - * /
 4 日 是 1-31  , - * ? / L W
 5 月 是 1-12 or JAN-DEC  , - * /
 6 周 是 1-7 or SUN-SAT  , - * ? / L #
 7 年 否 empty 或 1970-2099 , - * /

通配符说明:

* 表示所有值. 例如:在分的字段上设置 "*",表示每一分钟都会触发。

? 表示不指定值。使用的场景为不需要关心当前设置这个字段的值。例如:要在每月的10号触发一个操作,但不   关心    是周几,所以需要周位置的那个字段设置为"?" 具体设置为 0 0 0 10 * ?

- 表示区间。例如 在小时上设置 "10-12",表示 10,11,12点都会触发。

, 表示指定多个值,例如在周字段上设置 "MON,WED,FRI" 表示周一,周三和周五触发

/ 用于递增触发。如在秒上面设置"5/15" 表示从5秒开始,每增15秒触发(5,20,35,50)。在月字段上设置'1   /3'所示每月1号开始,每隔三天触发一次。

L 表示最后的意思。在日字段设置上,表示当月的最后一天(依据当前月份,如果是二月还会依据是否是润年[l   eap]), 在周字段上表示星期六,相当于"7"或"SAT"。如果在"L"前加上数字,则表示该数据的最后一个。   例如在周字段上设置"6L"这样的格式,则表示“本月最后一个星期五"

W 表示离指定日期的最近那个工作日(周一至周五). 例如在日字段上设置"15W",表示离每月15号最近的那个   工作日触发。如果15号正好是周六,则找最近的周五(14号)触发, 如果15号是周未,则找最近的下周一(16   号)触发.如果15号正好在工作日(周一至周五),则就在该天触发。如果指定格式为 "1W",它则表示每月1    号往后最近的工作日触发。如果1号正是周六,则将在3号下周一触发。(注,"W"前只能设置具体的数字,不   允许区间"-").

小提示:'L'和 'W'可以一组合使用。如果在日字段上设置"LW",则表示在本月的最后一个工作日触发(一般指         发工资 ) 

# 序号(表示每月的第几个周几),例如在周字段上设置"6#3"表示在每月的第三个周六.注意如果指定"#5",正     好第五周没有周六,则不会触发该配置(用在母亲节和父亲节再合适不过了)
小提示:周字段的设置,若使用英文字母是不区分大小写的 MON 与mon相同.


常用示例:

0 0 12 * * ?每天12点触发
0 15 10 ? * *每天10点15分触发
0 15 10 * * ?每天10点15分触发
0 15 10 * * ? *每天10点15分触发
0 15 10 * * ? 20052005年每天10点15分触发
0 * 14 * * ?每天下午的 2点到2点59分每分触发
0 0/5 14 * * ?每天下午的 2点到2点59分(整点开始,每隔5分触发)
0 0/5 14,18 * * ?
每天下午的 2点到2点59分(整点开始,每隔5分触发)
每天下午的 18点到18点59分(整点开始,每隔5分触发)
0 0-5 14 * * ?每天下午的 2点到2点05分每分触发
0 10,44 14 ? 3 WED3月分每周三下午的 2点10分和2点44分触发
0 15 10 ? * MON-FRI从周一到周五每天上午的10点15分触发
0 15 10 15 * ?每月15号上午10点15分触发
0 15 10 L * ?每月最后一天的10点15分触发
0 15 10 ? * 6L每月最后一周的星期五的10点15分触发
0 15 10 ? * 6L 2002-2005从2002年到2005年每月最后一周的星期五的10点15分触发
0 15 10 ? * 6#3每月的第三周的星期五开始触发
0 0 12 1/5 * ?每月的第一个中午开始每隔5天触发一次
0 11 11 11 11 ?每年的11月11号 11点11分触发(光棍节)


© 著作权归作者所有

袁梓皓
粉丝 10
博文 280
码字总数 139038
作品 0
嘉定
技术主管
私信 提问
Spring Cloud 2.x系列之springboot集成quartz

java设计模式之观察者模式 一大波视频分享 Mysql代理中间件Atlas安装和配置 在做项目时有时候会有定时器任务的功能,比如某某时间应该做什么,多少秒应该怎么样之类的。定时任务常用的业务场...

技术小能手
2018/10/15
0
0
SpringBoot整合Quartz定时任务

(1)什么是Quartz? (2)Quartz的特点; (3)Quartz专用词汇说明; (4)Quartz任务调度基本实现原理; 接下来看下具体的内容: (1)什么是Quartz? Quartz是一个完全由Java编写的开源作业...

weixin_38655836
2018/04/11
0
0
定时器 Quartz Java

1、几种任务调度的 Java 实现方法与比较 http://www.oschina.net/question/129540_28053 //特此感谢这篇文章的作者,我很喜欢这篇文章,里边介绍了好多关于目前定时器在工程中的使用,我总结...

soul_mate
2014/06/13
695
2
使用Spring3+Quartz实现定时任务

在本文中,我们使用Spring3+Quartz实现定时任务。spring中定义了一些接口来支持Quartz,可以使你的业务逻辑类和Quartz解耦。 这个例子中使用了如下maven的依赖项: <dependencies> <!-- Spri...

巴顿
2014/01/10
178
0
SpringBoot | 第二十二章:定时任务的使用

前言 上两章节,我们简单的讲解了关于异步调用和异步请求相关知识点。这一章节,我们来讲讲开发过程也是经常会碰见的定时任务。比如每天定时清理无效数据、定时发送短信、定时发送邮件、支付...

oKong
2018/08/19
1K
3

没有更多内容

加载失败,请刷新页面

加载更多

分布式协调服务zookeeper

ps.本文为《从Paxos到Zookeeper 分布式一致性原理与实践》笔记之一 ZooKeeper ZooKeeper曾是Apache Hadoop的一个子项目,是一个典型的分布式数据一致性的解决方案,分布式应用程序可以基于它...

ls_cherish
今天
4
0
redis 学习2

网站 启动 服务端 启动redis 服务端 在redis 安装目录下 src 里面 ./redis-server & 可以指定 配置文件或者端口 客户端 在 redis 的安装目录里面的 src 里面 ./redis-cli 可以指定 指定 连接...

之渊
昨天
2
0
Spring boot 静态资源访问

0. 两个配置 spring.mvc.static-path-patternspring.resources.static-locations 1. application中需要先行的两个配置项 1.1 spring.mvc.static-path-pattern 这个配置项是告诉springboo......

moon888
昨天
4
0
hash slot(虚拟桶)

在分布式集群中,如何保证相同请求落到相同的机器上,并且后面的集群机器可以尽可能的均分请求,并且当扩容或down机的情况下能对原有集群影响最小。 round robin算法:是把数据mod后直接映射...

李朝强
昨天
4
0
Kafka 原理和实战

本文首发于 vivo互联网技术 微信公众号 https://mp.weixin.qq.com/s/bV8AhqAjQp4a_iXRfobkCQ 作者简介:郑志彬,毕业于华南理工大学计算机科学与技术(双语班)。先后从事过电子商务、开放平...

vivo互联网技术
昨天
24
0

没有更多内容

加载失败,请刷新页面

加载更多

返回顶部
顶部