package org.quartz.examples.example1;

 import java.util.Date;

 import org.slf4j.Logger;

 import org.slf4j.LoggerFactory;

 import org.quartz.Job;

 import org.quartz.JobExecutionContext;

 import org.quartz.JobExecutionException;

 /**

  * 一个向问候世界的简单job 实现的是Job接口

  */

 public class HelloJob implements Job {

     private static Logger _log = LoggerFactory.getLogger(HelloJob.class);

     /**

      * Quartz需要一个空参构造方法以便在需要的时候对其实例化.

      */

     public HelloJob() {

     }

     /**

      * 当org.quartz.Trigger对关联的Job点火的时候, org.quartz.Scheduler会调用这个方法.

      * 这就是说我们在调度的时候, 时机一到我们其实是执行HelloJob中的方法.

      */

     public void execute(JobExecutionContext context) throws JobExecutionException {

         // Say Hello to the World and display the date/time

         _log.info("Hello World! - " + new Date());

     }

 }

 package org.quartz.examples.example1;

 import static org.quartz.DateBuilder.evenMinuteDate;

 import static org.quartz.JobBuilder.newJob;

 import static org.quartz.TriggerBuilder.newTrigger;

 import org.junit.Test;

 import org.quartz.JobDetail;

 import org.quartz.Scheduler;

 import org.quartz.SchedulerFactory;

 import org.quartz.Trigger;

 import org.quartz.impl.StdSchedulerFactory;

 import org.slf4j.Logger;

 import org.slf4j.LoggerFactory;

 import java.util.Date;

 /**

  * 这个实例演示了如何启动和关闭Quartz的调度器. 以及调度器是如何调度任务的.

  */

 public class SimpleExample {

     public void run() throws Exception {

         // 看看别人从不用System.out.println()

         Logger log = LoggerFactory.getLogger(SimpleExample.class);

         log.info("------- Initializing ----------------------");

         // 首先必须获得一个调度器的引用, 这里傻子都知道是工厂模式, 目前不知道是哪种

         // 看起来像抽象工厂

         SchedulerFactory sf = new StdSchedulerFactory();

         Scheduler sched = sf.getScheduler();

         log.info("------- Initialization Complete -----------");

         // 计算下一个整数分钟的时间

         Date runTime = evenMinuteDate(new Date());

         log.info("现在的时间是：" + new Date());

         log.info("rumTime计算出来的时间是：" + runTime);

         log.info("------- Scheduling Job  -------------------");

         // 定义任务并将其绑定到我们的HelloJob类上, 任务详情

         JobDetail job = newJob(HelloJob.class).withIdentity("job1", "group1").build();

         // 在下一轮的时候触发我们的任务, 触发器, 从runTime开始

         Trigger trigger = newTrigger().withIdentity("trigger1", "group1").startAt(runTime).build();

         // 告诉quartz使用我们的触发器来调度任务

         sched.scheduleJob(job, trigger);

         log.info(job.getKey() + " will run at: " + runTime);

         // 启动调度器(如果不启动调度器的话什么都不会发生)

         sched.start();

         log.info("------- Started Scheduler -----------------");

         // 等待足够长的时间以便调度器来调度任务执行

         log.info("------- Waiting 65 seconds... -------------");

         try {

             // 等待65秒

             Thread.sleep(65L * 1000L);

             // 执行中......

         } catch (Exception e) {

             //

         }

         // 关闭调度器

         log.info("------- Shutting Down ---------------------");

         sched.shutdown(true);

         log.info("------- Shutdown Complete -----------------");

     }

     @Test

     public void test1() {

         SimpleExample example = new SimpleExample();

         try {

             example.run();

         } catch (Exception e) {

             // TODO Auto-generated catch block

             e.printStackTrace();

         }

     }

 }