Quartz使用示例总结

Posted 汤高

tags:

篇首语：本文由小常识网(cha138.com)小编为大家整理，主要介绍了Quartz使用示例总结相关的知识，希望对你有一定的参考价值。

概述

了解Quartz体系结构

Quartz对任务调度的领域问题进行了高度的抽象，提出了调度器、任务和触发器这3个核心的概念，并在org.quartz通过接口和类对重要的这些核心概念进行描述：

●Job：是一个接口，只有一个方法void execute(JobExecutionContext context)，开发者实现该接口定义运行任务，JobExecutionContext类提供了调度上下文的各种信息。Job运行时的信息保存在JobDataMap实例中；

●JobDetail：Quartz在每次执行Job时，都重新创建一个Job实例，所以它不直接接受一个Job的实例，相反它接收一个Job实现类，以便运行时通过newInstance()的反射机制实例化Job。因此需要通过一个类来描述Job的实现类及其它相关的静态信息，如Job名字、描述、关联监听器等信息，JobDetail承担了这一角色。

通过该类的构造函数可以更具体地了解它的功用：JobDetail(java.lang.String name, java.lang.String group, java.lang.Class jobClass)，该构造函数要求指定Job的实现类，以及任务在Scheduler中的组名和Job名称；

●Trigger：是一个类，描述触发Job执行的时间触发规则。主要有SimpleTrigger和CronTrigger这两个子类。当仅需触发一次或者以固定时间间隔周期执行，SimpleTrigger是最适合的选择；而CronTrigger则可以通过Cron表达式定义出各种复杂时间规则的调度方案：如每早晨9:00执行，周一、周三、周五下午5:00执行等；

●Calendar：org.quartz.Calendar和java.util.Calendar不同，它是一些日历特定时间点的集合（可以简单地将org.quartz.Calendar看作java.util.Calendar的集合——java.util.Calendar代表一个日历时间点，无特殊说明后面的Calendar即指org.quartz.Calendar）。一个Trigger可以和多个Calendar关联，以便排除或包含某些时间点。

假设，我们安排每周星期一早上10:00执行任务，但是如果碰到法定的节日，任务则不执行，这时就需要在Trigger触发机制的基础上使用Calendar进行定点排除。针对不同时间段类型，Quartz在org.quartz.impl.calendar包下提供了若干个Calendar的实现类，如AnnualCalendar、MonthlyCalendar、WeeklyCalendar分别针对每年、每月和每周进行定义；

●Scheduler：代表一个Quartz的独立运行容器，Trigger和JobDetail可以注册到Scheduler中，两者在Scheduler中拥有各自的组及名称，组及名称是Scheduler查找定位容器中某一对象的依据，Trigger的组及名称必须唯一，JobDetail的组和名称也必须唯一（但可以和Trigger的组和名称相同，因为它们是不同类型的）。Scheduler定义了多个接口方法，允许外部通过组及名称访问和控制容器中Trigger和JobDetail。

Scheduler可以将Trigger绑定到某一JobDetail中，这样当Trigger触发时，对应的Job就被执行。一个Job可以对应多个Trigger，但一个Trigger只能对应一个Job。可以通过SchedulerFactory创建一个Scheduler实例。Scheduler拥有一个SchedulerContext，它类似于ServletContext，保存着Scheduler上下文信息，Job和Trigger都可以访问SchedulerContext内的信息。SchedulerContext内部通过一个Map，以键值对的方式维护这些上下文数据，SchedulerContext为保存和获取数据提供了多个put()和getXxx()的方法。可以通过Scheduler# getContext()获取对应的SchedulerContext实例；

●ThreadPool：Scheduler使用一个线程池作为任务运行的基础设施，任务通过共享线程池中的线程提高运行效率。

Job有一个StatefulJob子接口，代表有状态的任务，该接口是一个没有方法的标签接口，其目的是让Quartz知道任务的类型，以便采用不同的执行方案。无状态任务在执行时拥有自己的JobDataMap拷贝，对JobDataMap的更改不会影响下次的执行。而有状态任务共享共享同一个JobDataMap实例，每次任务执行对JobDataMap所做的更改会保存下来，后面的执行可以看到这个更改，也即每次执行任务后都会对后面的执行发生影响。

正因为这个原因，无状态的Job可以并发执行，而有状态的StatefulJob不能并发执行，这意味着如果前次的StatefulJob还没有执行完毕，下一次的任务将阻塞等待，直到前次任务执行完毕。有状态任务比无状态任务需要考虑更多的因素，程序往往拥有更高的复杂度，因此除非必要，应该尽量使用无状态的Job。

如果Quartz使用了数据库持久化任务调度信息，无状态的JobDataMap仅会在Scheduler注册任务时保持一次，而有状态任务对应的JobDataMap在每次执行任务后都会进行保存。

Trigger自身也可以拥有一个JobDataMap，其关联的Job可以通过JobExecutionContext#getTrigger().getJobDataMap()获取Trigger中的JobDataMap。不管是有状态还是无状态的任务，在任务执行期间对Trigger的JobDataMap所做的更改都不会进行持久，也即不会对下次的执行产生影响。

Quartz拥有完善的事件和监听体系，大部分组件都拥有事件，如任务执行前事件、任务执行后事件、触发器触发前事件、触发后事件、调度器开始事件、关闭事件等等，可以注册相应的监听器处理感兴趣的事件。




任务调度在目前的JAVA应用程序中运用的十分普遍，故掌握QUARTZ是必备的技能

闲话少说，上官网：http://www.quartz-scheduler.org/ 下载最新1.80资源包

commons-logging log4j sff4j 等jar包要添加进去,quartz的jar包则肯定必须

 首先写一个类实现Job接口

[html]  view plain  copy  
  1. public class QuartzDemo implements Job  
  2.   
  3.     @Override  
  4.     public void execute(JobExecutionContext arg0) throws JobExecutionException   
  5.         System.out.println("执行我.......");  
  6.           
  7.       
  8.   
  9.   

[html]  view plain  copy  
  1. public class Test   
  2.     private static final SimpleTrigger CronTrigger = null;  
  3.   
  4.     public static void main(String[] args)  
  5.       
  6.       
  7.     public void test1()  
  8.           //通过SchedulerFactory来获取一个调度器  
  9.         SchedulerFactory schedulerFactory = new StdSchedulerFactory();  
  10.         Scheduler scheduler;  
  11.         try   
  12.             scheduler = schedulerFactory.getScheduler();  
  13.           
  14.           
  15.           
  16.           
  17.         //引进作业程序  
  18.         JobDetail jobDetail =   
  19.         new JobDetail("jobDetail-s1", "jobDetailGroup-s1", QuartzDemo.class);  
  20.   
  21.          //new一个触发器  
  22.         SimpleTrigger simpleTrigger =   
  23.         new SimpleTrigger("simpleTrigger", "triggerGroup-s1");  
  24.   
  25.   
  26.         //设置作业启动时间  
  27.   
  28.         long ctime = System.currentTimeMillis();   
  29.         simpleTrigger.setStartTime(new Date(ctime));  
  30.   
  31.   
  32.         //设置作业执行间隔   
  33.         simpleTrigger.setRepeatInterval(1000);  
  34.   
  35.         //设置作业执行次数  
  36.         simpleTrigger.setRepeatCount(10);  
  37.   
  38.         //设置作业执行优先级默认为5  
  39.         //simpleTrigger.setPriority(10);  
  40.   
  41.   
  42.         //作业和触发器设置到调度器中  
  43.         scheduler.scheduleJob(jobDetail, simpleTrigger);  
  44.           
  45.         //启动调度器  
  46.         scheduler.start();  
  47.          catch (SchedulerException e)   
  48.             // TODO Auto-generated catch block  
  49.             e.printStackTrace();  
  50.           
  51.       
  52.       
  53.     public void test2()  
  54.   
  55.         try      
  56.             SchedulerFactory schedFact  =   new  org.quartz.impl.StdSchedulerFactory();  
  57.             Scheduler sched  =  schedFact.getScheduler();  
  58.             sched.start();  
  59.             JobDetail jobDetail  =   new  JobDetail( " Income Report " ,  
  60.                      " Report Generation " , QuartzDemo.class );  
  61.             jobDetail.getJobDataMap().put( " type " ,  " FULL " );  
  62.             CronTrigger trigger  =   new  CronTrigger( " Income Report " ,  
  63.                      " Report Generation " );  
  64.              /**/ /*  每1分钟执行一次  */   
  65.             trigger.setCronExpression( "0 33 16 * * ?" );  
  66.             sched.scheduleJob(jobDetail, trigger);  
  67.            catch  (Exception e)     
  68.             e.printStackTrace();  
  69.            
  70.       
  71.       
  72.     public void test3()  
  73.          //通过SchedulerFactory来获取一个调度器  
  74.       SchedulerFactory schedulerFactory = new StdSchedulerFactory();  
  75.       Scheduler scheduler;  
  76.         try   
  77.             scheduler = schedulerFactory.getScheduler();    
  78.       //引进作业程序  
  79.       JobDetail jobDetail =   
  80.       new JobDetail("jobDetail-s1", "jobDetailGroup-s1", QuartzDemo.class);  
  81.        //new一个触发器  
  82.       CronTrigger simpleTrigger =   
  83.         new CronTrigger("trigger", "group", "job", "group", "16 26/1 8-17 * * ?");  
  84.      // new SimpleTrigger("simpleTrigger", "triggerGroup-s1");  
  85.   
  86.   
  87.       //设置作业启动时间  
  88.     //Calendar excelCal = Calendar.getInstance();  
  89.         //excelCal.add(Calendar.DAY_OF_MONTH, 1);  
  90.         ///excelCal.set(Calendar.HOUR_OF_DAY, 16);  
  91.         //excelCal.set(Calendar.SECOND, 0);  
  92.         //excelCal.add(Calendar.MINUTE, 9);  
  93.      // long ctime = System.currentTimeMillis();   
  94.      // simpleTrigger.setStartTime(excelCal.getTime());  
  95.       //设置作业执行间隔   
  96.      // simpleTrigger.setRepeatInterval(1000);  
  97.       //设置作业执行次数  
  98.      // simpleTrigger.setRepeatCount(10);  
  99.       //设置作业执行优先级默认为5  
  100.       //simpleTrigger.setPriority(10);  
  101.           
  102.       //作业和触发器设置到调度器中  
  103.       scheduler.scheduleJob(jobDetail, simpleTrigger);  
  104.         
  105.       //启动调度器  
  106.       scheduler.start();  
  107. quartz开源作业调度框架的使用

    Quartz总结

    Quartz.net 3.x使用总结——简单使用

    Quartz总结：Quartz集成Spring的2个方法

    Quartz.NET总结Quartz 远程调度

    quartz.net 3.x 使用总结