Quartz深入浅出入门教程二



Quartz深入浅出(二)Hello Quartz / 本文通过一个简单的例子让大家快速了解Quartz,上手，并了解Ｑuartz内的一些关键对象 如 Scheduler、Job、Trigger、JobExecutionContext等对象

  1. 导入Quartz所需的两个jar包 <quartz-2.2.1.jarr、quartz-jobs-2.2.1.jar>
    1. 创建我们自己的Job类 HelloJob，进行简单的输出
      1. package org.quartz.examples.examples01;
      3. import java.util.Date;
      4. import org.slf4j.Logger;
      5. import org.slf4j.LoggerFactory;
      6. import org.quartz.Job;
      7. import org.quartz.JobExecutionContext;
      8. import org.quartz.JobExecutionException;
      10. /**
      11.  * hello world Quartz
      12.  * @author weeks
      13.  *
      14.  */
      15. public class HelloJob implements Job {
      17.     private static Logger _log = LoggerFactory.getLogger(HelloJob .class );
      19.     /**
      20.      * Job，Job需要一个公有的构造函数，否则Factory无法构建
      21.      */
      22.     public HelloJob() {
      23.     }
      25.     /**
      26.      * 实现execute方法
      27.      */
      28.     public void execute(JobExecutionContext context)
      29.         throws JobExecutionException {
      30.         _log.info( ”Hello World! - ” + new Date());
      31.     }
      33. }
    3. 创建我们的Job运行例子，在下一分钟执行我们自己Job
      1. package org.quartz.examples.examples01;
      3. import static org.quartz.DateBuilder.evenMinuteDate ;
      4. import static org.quartz.JobBuilder.newJob ;
      5. import static org.quartz.TriggerBuilder.newTrigger ;
      6. import org.quartz.JobDetail;
      7. import org.quartz.Scheduler;
      8. import org.quartz.SchedulerFactory;
      9. import org.quartz.Trigger;
      10. import org.quartz.impl.StdSchedulerFactory;
      11. import org.slf4j.Logger;
      12. import org.slf4j.LoggerFactory;
      13. import java.util.Date;
      15. /**
      16.  * 此Demo将演示如何启动和关闭Quartz调度器，以及如何运作
      17.  * @author weeks
      18.  *
      19.  */
      20. public class SimpleExample {
      22.   public void run() throws Exception {
      23.     Logger log = LoggerFactory.getLogger(SimpleExample.class);
      25.     log.info(“——- Initializing ———————-”);
      27.     // 1、工厂模式 构建Scheduler的Factory，其中STD为Quartz默认的Factory，开发者亦可自行实现自己的Factory;Job、Trigger等组件
      28.     SchedulerFactory sf = new StdSchedulerFactory();
      29.     // 2、通过SchedulerFactory获得Scheduler对象
      30.     Scheduler sched = sf.getScheduler();
      32.     log.info(“——- Initialization Complete ———–”);
      34.     // 3、org.quartz.DateBuilder.evenMinuteDate <下一分钟>  – 通过DateBuilder构建Date
      35.     Date runTime = evenMinuteDate(new Date());
      37.     log.info(“——- Scheduling Job  ——————-”);
      39.     // 4、org.quartz.JobBuilder.newJob –通过JobBuilder构建Job
      40.     JobDetail job = newJob(HelloJob.class).withIdentity(“job1″, ”group1″).build();
      42.     // 5、通过TriggerBuilder进行构建
      43.     Trigger trigger = newTrigger().withIdentity(“trigger1″ , ”group1″).startAt(runTime ).build();
      45.     // 6、工厂模式，组装各个组件<JOB，Trigger>
      46.     sched.scheduleJob(job, trigger);
      48.     // [group1.job1] will run at:
      49.     log.info(job.getKey() + ” will run at: ” + runTime);
      51.     // 7、start
      52.     sched.start();
      54.     log.info(“——- Started Scheduler —————–”);
      56.     log.info(“——- Waiting 65 seconds… ————-”);
      57.     try {
      58.       // wait 65 seconds to show job
      59.       Thread.sleep(65L * 1000L);
      60.       // executing…
      61.     } catch (Exception e) {
      62.       //
      63.     }
      65.     // shut down the scheduler
      66.     log.info(“——- Shutting Down ———————”);
      67.     // 8、通过Scheduler销毁内置的Trigger和Job
      68.     sched.shutdown(true);
      69.     log.info(“——- Shutdown Complete —————–”);
      70.   }
      72.   public static void main(String[] args) throws Exception {
      74.     SimpleExample example = new SimpleExample();
      75.     example.run();
      77.   }
      79. }
  2. 让我们来看看上面的代码究竟做了些什么：
    1. 创建一个Quartz Job类，必须实现 org.quartz.Job ，这个接口只有一个你要实现的方法,execute方法，其中execute的接口定义如下
      1.   void execute(JobExecutionContext  context)  throws JobExecutionException;
      2.   当Quartz调度器到约定的时间，它就会生成一个Job的实例，所以你实现Job接口　必须提供一个公有函数，否则会抛出异常，并调用execute方法．其中调度器只管执行，而不关心结果，除非抛出JobExecutionException异常．
      3. 　JobExecutionContext 中封装有Quartz运行所需要的所有信息，可以参见下面具体的代码片段．
    2. 其中涉及到的Scheduler、Job、Trigger　３个关键对象　　（后续会专门介绍这３个对象）
      1. 其中Scheduler调度器对象，它的方法有start()、shutdown()等方法，负责管理整个调度作业．
      2. Job 又与几个对象有关 Job、JobDetail、JobDataMap
        1. 通过类图来看他们之间的关系
        3. 通过类图可以很明显的看出由JobExecutionContext来组装各个子组件，我们看看JobExecutionContextImpl的源代码，它保存着所有上下文信息
          1. private transient Scheduler scheduler ;
          3. private Trigger trigger;
          5. private JobDetail jobDetail;
          7. private JobDataMap jobDataMap;
          9. private transient Job job;
          11. private Calendar calendar;
          13. private boolean recovering = false;
          15. private int numRefires = 0;
          17. private Date fireTime;
          19. private Date scheduledFireTime;
          21. private Date prevFireTime;
          23. private Date nextFireTime;
          25. private long jobRunTime = -1;
          27. private Object result;
          29. private HashMap<Object, Object> data=new HashMap<Object, Object>();
        5. 关于JobDetail
          1. JobDetail不存储具体的实例，但它允许你定义一个实例，JobDetail 又指向JobDataMap
          2. JobDetail持有Job的详细信息，如它所属的组，名称等信息
        6. 关于JobDataMap
          1. JobDataMap保存着任务实例的对象，并保持着他们状态信息，它是Ｍap接口的实现，即你可以往里面put和get一些你想存储和获取的信息．
      3. 关于Trigger
        1. 即根据具体约定的触发器，具体的如：SimpleTrigger、CronTrigger　等