java-框架-Quartz

简介: Quartz是OpenSymphony开源组织在Job scheduling领域又一个开源项目,它可以与J2EE与J2SE应用程序相结合也可以单独使用。Quartz可以用来创建简单或为运行十个,百个,甚至是好几万个Jobs这样复杂的日程序表。

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

第三方包

通过测试。一个简单任务只需要以下几个包:commons-beanutils.jar、commons-collections.jar、commons-logging.jar、commons-digester.jar、quartz.jar即可

名称 必须/备注 网址
activation.jar 主要是 JavaMail 要用到 http://java.sun.com/products/javabeans/glasgow/jaf.html
commons-beanutils.jar 是 http://jakarta.apache.org/commons/beanutils
commons-collections.jar 是 http://jakarta.apache.org/commons/collections
commons-dbcp-1.1.jar 是,假如用到数据库作为作业存储 http://jakarta.apache.org/commons/dbcp
commons-digester.jar 是 假如你使用了某些插件,就需要它
commons-logging.jar 是 http://jakarta.apache.org/commons/logging/
commons-pool-1.1.jar http://jakarta.apache.org/commons/pool/
javamail.jar 发送 e-mail 用 http://java.sun.com/products/javamail/
jdbc2_0-stdext.jar 是,假如用到数据库作为作业存储 http://java.sun.com/products/jdbc/
jta.jar 是,假如用到数据库作为作业存储 http://java.sun.com/products/jta/database
quartz.jar 是 Quart 框架核心包
servlet.jar 假如使用了Servlet 容器,但容器中应该存在 http://java.sun.com/products/servlet/
log4j.jar 是,日志 http://logging.apache.org/

//测试main函数  
//QuartzTest.java  
package quartzPackage;  


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

public class QuartzTest {  

    /** *//** 
     * @param args 
     */  
    public static void main(String[] args) {  
        // TODO Auto-generated method stub  
        SimpleDateFormat DateFormat = new SimpleDateFormat("yyyyMMddHHmmss");  
        Date d = new Date();  
        String returnstr = DateFormat.format(d);          

        TestJob job = new TestJob();  
        String job_name ="11";  
        try {  
            System.out.println(returnstr+ "【系统启动】");  
            QuartzManager.addJob(job_name,job,"0/2 * * * * ?"); //每2秒钟执行一次  

//            Thread.sleep(10000);  
//            System.out.println("【修改时间】");  
//            QuartzManager.modifyJobTime(job_name,"0/10 * * * * ?");  
//            Thread.sleep(20000);  
//            System.out.println("【移除定时】");  
//            QuartzManager.removeJob(job_name);  
//            Thread.sleep(10000);  
//              
//            System.out.println("/n【添加定时任务】");  
//            QuartzManager.addJob(job_name,job,"0/5 * * * * ?");  

        }  catch (Exception e) {  
            e.printStackTrace();  
        }  
    }  
}  
//简单的任务管理类  
//QuartzManager.java  

package quartzPackage;  

import java.text.ParseException;  
import org.quartz.CronTrigger;  
import org.quartz.Job;  
import org.quartz.JobDetail;  
import org.quartz.Scheduler;  
import org.quartz.SchedulerException;  
import org.quartz.SchedulerFactory;  
import org.quartz.Trigger;  
import org.quartz.impl.StdSchedulerFactory;  

/** *//** 
 * @Title:Quartz管理类 
 *  
 * @Description: 
 *  
 * @Copyright:  
 * @author zz  2008-10-8 14:19:01 
 * @version 1.00.000 
 * 
 */  
public class QuartzManager {  
   private static SchedulerFactory sf = new StdSchedulerFactory();  
   private static String JOB_GROUP_NAME = "group1";  
   private static String TRIGGER_GROUP_NAME = "trigger1";  


   /** *//** 
    *  添加一个定时任务,使用默认的任务组名,触发器名,触发器组名 
    * @param jobName 任务名 
    * @param job     任务 
    * @param time    时间设置,参考quartz说明文档 
    * @throws SchedulerException 
    * @throws ParseException 
    */  
   public static void addJob(String jobName,Job job,String time)   
                               throws SchedulerException, ParseException{  
       Scheduler sched = sf.getScheduler();  
       JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, job.getClass());//任务名,任务组,任务执行类  
       //触发器  
       CronTrigger  trigger =   
            new CronTrigger(jobName, TRIGGER_GROUP_NAME);//触发器名,触发器组  
       trigger.setCronExpression(time);//触发器时间设定  
       sched.scheduleJob(jobDetail,trigger);  
       //启动  
       if(!sched.isShutdown())  
          sched.start();  
   }  

   /** *//** 
    * 添加一个定时任务 
    * @param jobName 任务名 
    * @param jobGroupName 任务组名 
    * @param triggerName  触发器名 
    * @param triggerGroupName 触发器组名 
    * @param job     任务 
    * @param time    时间设置,参考quartz说明文档 
    * @throws SchedulerException 
    * @throws ParseException 
    */  
   public static void addJob(String jobName,String jobGroupName,  
                             String triggerName,String triggerGroupName,  
                             Job job,String time)   
                               throws SchedulerException, ParseException{  
       Scheduler sched = sf.getScheduler();  
       JobDetail jobDetail = new JobDetail(jobName, jobGroupName, job.getClass());//任务名,任务组,任务执行类  
       //触发器  
       CronTrigger  trigger =   
            new CronTrigger(triggerName, triggerGroupName);//触发器名,触发器组  
       trigger.setCronExpression(time);//触发器时间设定  
       sched.scheduleJob(jobDetail,trigger);  
       if(!sched.isShutdown())  
          sched.start();  
   }  

   /** *//** 
    * 修改一个任务的触发时间(使用默认的任务组名,触发器名,触发器组名) 
    * @param jobName 
    * @param time 
    * @throws SchedulerException 
    * @throws ParseException 
    */  
   public static void modifyJobTime(String jobName,String time)   
                                  throws SchedulerException, ParseException{  
       Scheduler sched = sf.getScheduler();  
       Trigger trigger =  sched.getTrigger(jobName,TRIGGER_GROUP_NAME);  
       if(trigger != null){  
           CronTrigger  ct = (CronTrigger)trigger;  
           ct.setCronExpression(time);  
           sched.resumeTrigger(jobName,TRIGGER_GROUP_NAME);  
       }  
   }  

   /** *//** 
    * 修改一个任务的触发时间 
    * @param triggerName 
    * @param triggerGroupName 
    * @param time 
    * @throws SchedulerException 
    * @throws ParseException 
    */  
   public static void modifyJobTime(String triggerName,String triggerGroupName,  
                                    String time)   
                                  throws SchedulerException, ParseException{  
       Scheduler sched = sf.getScheduler();  
       Trigger trigger =  sched.getTrigger(triggerName,triggerGroupName);  
       if(trigger != null){  
           CronTrigger  ct = (CronTrigger)trigger;  
           //修改时间  
           ct.setCronExpression(time);  
           //重启触发器  
           sched.resumeTrigger(triggerName,triggerGroupName);  
       }  
   }  

   /** *//** 
    * 移除一个任务(使用默认的任务组名,触发器名,触发器组名) 
    * @param jobName 
    * @throws SchedulerException 
    */  
   public static void removeJob(String jobName)   
                               throws SchedulerException{  
       Scheduler sched = sf.getScheduler();  
       sched.pauseTrigger(jobName,TRIGGER_GROUP_NAME);//停止触发器  
       sched.unscheduleJob(jobName,TRIGGER_GROUP_NAME);//移除触发器  
       sched.deleteJob(jobName,JOB_GROUP_NAME);//删除任务  
   }  

   /** *//** 
    * 移除一个任务 
    * @param jobName 
    * @param jobGroupName 
    * @param triggerName 
    * @param triggerGroupName 
    * @throws SchedulerException 
    */  
   public static void removeJob(String jobName,String jobGroupName,  
                                String triggerName,String triggerGroupName)   
                               throws SchedulerException{  
       Scheduler sched = sf.getScheduler();  
       sched.pauseTrigger(triggerName,triggerGroupName);//停止触发器  
       sched.unscheduleJob(triggerName,triggerGroupName);//移除触发器  
       sched.deleteJob(jobName,jobGroupName);//删除任务  
   }  
}  
//测试工作类  
//TestJob.java  

package quartzPackage;  

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

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

public class TestJob implements Job {  
    SimpleDateFormat DateFormat = new SimpleDateFormat("yyyy-MM-dd HH:mm:ss");  
    Date d = new Date();  
    String returnstr = DateFormat.format(d);    

    public void execute(JobExecutionContext arg0) throws JobExecutionException {  
        // TODO Auto-generated method stub  
        System.out.println(returnstr+"");  
    }  

}  

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 表示最后的意思。在日字段设置上,表示当月的最后一天(依据当前月份,如果是二月还会依据是否是润年[leap]), 在周字段上表示星期六,相当于”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 * * ? 2005 2005年每天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 WED 3月分每周三下午的 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分触发(光棍节)

目录
相关文章
|
17天前
|
Java 数据库
在Java中使用Seata框架实现分布式事务的详细步骤
通过以上步骤,利用 Seata 框架可以实现较为简单的分布式事务处理。在实际应用中,还需要根据具体业务需求进行更详细的配置和处理。同时,要注意处理各种异常情况,以确保分布式事务的正确执行。
|
17天前
|
消息中间件 Java Kafka
在Java中实现分布式事务的常用框架和方法
总之,选择合适的分布式事务框架和方法需要综合考虑业务需求、性能、复杂度等因素。不同的框架和方法都有其特点和适用场景,需要根据具体情况进行评估和选择。同时,随着技术的不断发展,分布式事务的解决方案也在不断更新和完善,以更好地满足业务的需求。你还可以进一步深入研究和了解这些框架和方法,以便在实际应用中更好地实现分布式事务管理。
|
27天前
|
JSON Java Apache
非常实用的Http应用框架,杜绝Java Http 接口对接繁琐编程
UniHttp 是一个声明式的 HTTP 接口对接框架,帮助开发者快速对接第三方 HTTP 接口。通过 @HttpApi 注解定义接口,使用 @GetHttpInterface 和 @PostHttpInterface 等注解配置请求方法和参数。支持自定义代理逻辑、全局请求参数、错误处理和连接池配置,提高代码的内聚性和可读性。
104 3
|
2月前
|
算法 Java 数据处理
从HashSet到TreeSet,Java集合框架中的Set接口及其实现类以其“不重复性”要求,彻底改变了处理唯一性数据的方式。
从HashSet到TreeSet,Java集合框架中的Set接口及其实现类以其“不重复性”要求,彻底改变了处理唯一性数据的方式。HashSet基于哈希表实现,提供高效的元素操作;TreeSet则通过红黑树实现元素的自然排序,适合需要有序访问的场景。本文通过示例代码详细介绍了两者的特性和应用场景。
45 6
|
2月前
|
存储 Java
深入探讨了Java集合框架中的HashSet和TreeSet,解析了两者在元素存储上的无序与有序特性。
【10月更文挑战第16天】本文深入探讨了Java集合框架中的HashSet和TreeSet,解析了两者在元素存储上的无序与有序特性。HashSet基于哈希表实现,添加元素时根据哈希值分布,遍历时顺序不可预测;而TreeSet利用红黑树结构,按自然顺序或自定义顺序存储元素,确保遍历时有序输出。文章还提供了示例代码,帮助读者更好地理解这两种集合类型的使用场景和内部机制。
43 3
|
2月前
|
存储 Java 数据处理
Java Set接口凭借其独特的“不重复”特性,在集合框架中占据重要地位
【10月更文挑战第16天】Java Set接口凭借其独特的“不重复”特性,在集合框架中占据重要地位。本文通过快速去重和高效查找两个案例,展示了Set如何简化数据处理流程,提升代码效率。使用HashSet可轻松实现数据去重,而contains方法则提供了快速查找的功能,彰显了Set在处理大量数据时的优势。
34 2
|
12天前
|
存储 缓存 安全
Java 集合框架优化:从基础到高级应用
《Java集合框架优化:从基础到高级应用》深入解析Java集合框架的核心原理与优化技巧,涵盖列表、集合、映射等常用数据结构,结合实际案例,指导开发者高效使用和优化Java集合。
25 3
|
1月前
|
人工智能 前端开发 Java
基于开源框架Spring AI Alibaba快速构建Java应用
本文旨在帮助开发者快速掌握并应用 Spring AI Alibaba,提升基于 Java 的大模型应用开发效率和安全性。
基于开源框架Spring AI Alibaba快速构建Java应用
|
1月前
|
消息中间件 Java 数据库连接
Java 反射最全详解 ,框架设计必掌握!
本文详细解析Java反射机制,包括反射的概念、用途、实现原理及应用场景。关注【mikechen的互联网架构】,10年+BAT架构经验倾囊相授。
Java 反射最全详解 ,框架设计必掌握!
|
22天前
|
开发框架 Java 关系型数据库
Java哪个框架适合开发API接口?
在快速发展的软件开发领域,API接口连接了不同的系统和服务。Java作为成熟的编程语言,其生态系统中出现了许多API开发框架。Magic-API因其独特优势和强大功能,成为Java开发者优选的API开发框架。本文将从核心优势、实际应用价值及未来展望等方面,深入探讨Magic-API为何值得选择。
29 2