1. 实现一个简单的定时任务

设定一个简单任务（job）
让Quartz 定时运行这个任务

1. 创建配置文件

创建自己的quartz.properties文件 放到应用的classpath下

  1. # 调度器的名称为 MyScheduler
  2. org.quartz.scheduler.instanceName = MyScheduler
  4. # 线程池中有3个线程，这意味着最多可以同时运行3个job
  5. org.quartz.threadPool.threadCount = 3
  7. # RamJobStore: 所有数据，包括job和trigger的配置，都会存储在内存中（而不是数据库里）
  8. # 使用quartz的数据库存储功能（校对注：设置成另外一个类）
  9. org.quartz.jobStore.class = org.quartz.simpl.RAMJobStore

2. 创建一个简单job

  1. public class HelloJob implements Job {
  3.     @Override
  4.     public void execute(JobExecutionContext jobExecutionContext) throws JobExecutionException {
  5.         System.out.println("Hello World");
  6.     }
  8. }


3. 获取调度器并注册job

  2. /**
  3.  * 关于 Quartz 的一个快速应用
  4.  */
  5. public class QuickStart {
  7.     public static void main(String[] args) {
  8.         try {
  9.             //获取调度器
  10.             Scheduler scheduler = StdSchedulerFactory.getDefaultScheduler();
  11.             //启动
  12.             scheduler.start();
  14.             //创建一个简单任务
  15.             JobDetail jobDetail = JobBuilder.newJob(HelloJob.class)
  16.                     .withIdentity("job1", "group1")
  17.                     .build();
  19.             //创建触发器
  20.             Trigger trigger= TriggerBuilder.newTrigger()
  21.                     .withIdentity("trigger1","trigger1")
  22.                     .startNow()
  23.                     .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever())
  24.                     .build();
  26.             //注册该任务到调度器中
  27.             scheduler.scheduleJob(jobDetail, trigger);
  29.             Thread.sleep(30000);
  30.             //关闭
  31.             scheduler.shutdown();
  32.         } catch (SchedulerException | InterruptedException e) {
  33.             e.printStackTrace();
  34.         }
  35.     }
  37. }

2. 触发任务时，携带数据

2.1 插入数据

job 和 Trigger 都能携带数据
可以在bulid的时候插入数据 也可以根据实例获取到 JobDataMap 插入数据

  1.   //创建一个简单任务
  2.   JobDetail jobDetail = JobBuilder.newJob(HelloJob.class)
  3.           .withIdentity("job1", "group1")
  4.           .usingJobData("j1","jv1")
  5.           .build();
  6.   jobDetail.getJobDataMap().put("j2","jv2");
  8.   //创建触发器
  9.   Trigger trigger= TriggerBuilder.newTrigger()
  10.           .withIdentity("trigger1","trigger1")
  11.           .usingJobData("t1","tv1")
  12.           .withSchedule(SimpleScheduleBuilder.simpleSchedule().withIntervalInSeconds(5).repeatForever())
  13.           .build();
  14.   trigger.getJobDataMap().put("t2","tv2");

2.2 获取数据

在 job 中重写的 execute 方法中的 context 中获取

  1. @Slf4j
  2. public class HelloJob implements Job {
  4.     @Override
  5.     public void execute(JobExecutionContext context) throws JobExecutionException {
  6.         log.info("j1:{}", context.getJobDetail().getJobDataMap().get("j1") );
  7.         log.info("j2:{}", context.getJobDetail().getJobDataMap().get("j2") );
  8.         log.info("t1:{}", context.getTrigger().getJobDataMap().get("t1") );
  9.         log.info("t2:{}", context.getTrigger().getJobDataMap().get("t2") );
  10.         System.out.println("Hello World");
  11.     }
  13. }