码迷，mamicode.com
首页 > 其他好文 > 详细

根据SimpleScheduleBuilder配置不同的SimpleTrigger触发器

时间：2014-11-17 19:15:29      阅读：512      评论：0      收藏：0      [点我收藏+]

标签：des   blog   http   io   ar   java   for   on   2014   

Job代码：

[java] view plaincopy

  1. package cn.zto.job; 
  3. import java.text.SimpleDateFormat; 
  4. import java.util.Date; 
  6. import org.quartz.Job; 
  7. import org.quartz.JobDetail; 
  8. import org.quartz.JobExecutionContext; 
  9. import org.quartz.JobExecutionException; 
  10. import org.quartz.JobKey; 
  11. import org.slf4j.Logger; 
  12. import org.slf4j.LoggerFactory; 
  14. public class SimpleJob 
  15. implements Job 
  16. { 
  17. public void execute(JobExecutionContext context) 
  18. throws JobExecutionException 
  19.   { 
  20. //通过上下文获取
  21.     JobKey jobKey = context.getJobDetail().getKey(); 
  23.     SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy年MM月dd日 HH时mm分ss秒");   
  24.     System.out.println("SimpleJob类 ："+ jobKey + " 在 " + dateFormat.format(new Date())+" 时运行"); 
  25.   } 
  26. } 

SimpleTriggerExample.java

[java] view plaincopy

  1. package cn.zto.app; 
  3. import java.text.SimpleDateFormat; 
  4. import java.util.Date; 
  6. import org.quartz.DateBuilder; 
  7. import org.quartz.JobBuilder; 
  8. import org.quartz.JobDetail; 
  9. import org.quartz.JobKey; 
  10. import org.quartz.Scheduler; 
  11. import org.quartz.SchedulerFactory; 
  12. import org.quartz.SchedulerMetaData; 
  13. import org.quartz.SimpleScheduleBuilder; 
  14. import org.quartz.SimpleTrigger; 
  15. import org.quartz.TriggerBuilder; 
  16. import org.quartz.TriggerKey; 
  17. import org.quartz.impl.StdSchedulerFactory; 
  19. import cn.zto.job.SimpleJob; 
  21. public class SimpleTriggerExample 
  22. { 
  23. public void run() 
  24. throws Exception 
  25.   { 
  26.     System.out.println("------- 初始化 -------------------"); 
  28.     SchedulerFactory sf = new StdSchedulerFactory(); 
  29.     Scheduler sched = sf.getScheduler(); 
  31.     System.out.println("------- 初始化完成 --------"); 
  33.     System.out.println("------- 向Scheduler加入Job ----------------"); 
  34.     SimpleDateFormat dateFormat = new SimpleDateFormat("yyyy年MM月dd日 HH时mm分ss秒");   
  35. //设置任务触发的时间，时间为下方15的倍数  会在任意时间段的  15S 30S 45S 60S 开始会触发一次
  36.     Date startTime = DateBuilder.nextGivenSecondDate(null, 15); 
  38.     JobDetail job = JobBuilder.newJob(SimpleJob.class).withIdentity("job1", "group1").build(); 
  40.     SimpleTrigger trigger = (SimpleTrigger)TriggerBuilder.newTrigger() 
  41.             .withIdentity("trigger1", "group1") 
  42.             .startAt(startTime) 
  43.             .build(); 
  45.     Date ft = sched.scheduleJob(job, trigger); 
  46.     System.out.println(job.getKey() + " 将会在: " + dateFormat.format(ft) + "时运行，"
  47.             + "重复: " + trigger.getRepeatCount() + " 次, " //获取重复的次数
  48.             + "每 " + trigger.getRepeatInterval() / 1000L + " s 重复一次"); 
  50.     job = JobBuilder.newJob(SimpleJob.class).withIdentity("job2", "group1").build(); 
  52.     trigger = (SimpleTrigger)TriggerBuilder.newTrigger() 
  53.             .withIdentity("trigger2", "group1") 
  54.             .startAt(startTime) 
  55. //设置一个用于触发的时间
  56.             .withSchedule(SimpleScheduleBuilder//SimpleScheduleBuilder是简单调用触发器，它只能指定触发的间隔时间和执行次数；
  57.                         .simpleSchedule()//创建一个SimpleScheduleBuilder
  58.                         .withIntervalInSeconds(10)//指定一个重复间隔,以毫秒为单位。
  59.                         .withRepeatCount(10))//指定反复的次数
  60.             .build(); 
  62.     ft = sched.scheduleJob(job, trigger); 
  63.     System.out.println(job.getKey() + " 将会在: " + dateFormat.format(ft) + "时运行，"
  64.             + "重复: " + trigger.getRepeatCount() + " 次, "
  65.             + "每 " + trigger.getRepeatInterval() / 1000L + " s 重复一次"); 
  67.     trigger = (SimpleTrigger)TriggerBuilder.newTrigger() 
  68. //将触发器放入  group2 里面
  69.             .withIdentity("trigger2", "group2") 
  70.             .startAt(startTime) 
  71.             .withSchedule(SimpleScheduleBuilder 
  72.                         .simpleSchedule() 
  73.                         .withIntervalInSeconds(10) 
  74.                         .withRepeatCount(2)) 
  75.             .forJob(job) 
  76.             .build(); 
  78.     ft = sched.scheduleJob(trigger); 
  79.     System.out.println(job.getKey() + " 也会在: " + dateFormat.format(ft) + "时运行，"
  80.             + "重复: " + trigger.getRepeatCount() + " 次, "
  81.             + "每 " + trigger.getRepeatInterval() / 1000L + " s 重复一次"); 
  83.     job = JobBuilder.newJob(SimpleJob.class).withIdentity("job3", "group1").build(); 
  85.     trigger = (SimpleTrigger)TriggerBuilder.newTrigger() 
  86.             .withIdentity("trigger3", "group1") 
  87.             .startAt(startTime) 
  88.             .withSchedule(SimpleScheduleBuilder 
  89.                         .simpleSchedule() 
  90.                         .withIntervalInSeconds(10) 
  91.                         .withRepeatCount(5)) 
  92.             .build(); 
  94.     ft = sched.scheduleJob(job, trigger); 
  95.     System.out.println(job.getKey() + " 将会在: " + dateFormat.format(ft) + "时运行，"
  96.             + "重复: " + trigger.getRepeatCount() + " 次, "
  97.             + "每 " + trigger.getRepeatInterval() / 1000L + " s 重复一次"); 
  99.     job = JobBuilder.newJob(SimpleJob.class).withIdentity("job4", "group1").build(); 
  102.     System.out.println("当前时间为："+dateFormat.format(new Date())); 
  103.     trigger = (SimpleTrigger)TriggerBuilder.newTrigger() 
  104.             .withIdentity("trigger4", "group1") 
  105. //设定时间为5分钟后运行
  106.             .startAt(DateBuilder.futureDate(5, DateBuilder.IntervalUnit.MINUTE)) 
  107.             .build(); 
  109.     ft = sched.scheduleJob(job, trigger); 
  110.     System.out.println(job.getKey() + " 将会在: " + dateFormat.format(ft) + "时运行，"
  111.             + "重复: " + trigger.getRepeatCount() + " 次, "
  112.             + "每 " + trigger.getRepeatInterval() / 1000L + " s 重复一次"); 
  114.     job = JobBuilder.newJob(SimpleJob.class).withIdentity("job5", "group1").build(); 
  116.     trigger = (SimpleTrigger)TriggerBuilder.newTrigger() 
  117.             .withIdentity("trigger5", "group1") 
  118.             .startAt(startTime) 
  119.             .withSchedule(SimpleScheduleBuilder 
  120.                         .simpleSchedule() 
  121.                         .withIntervalInSeconds(40) 
  122. //触发器会一直重复执行下去
  123.                         .repeatForever()) 
  124.             .build(); 
  126.     ft = sched.scheduleJob(job, trigger); 
  127.     System.out.println(job.getKey() + " 将会在: " + dateFormat.format(ft) + "时运行，"
  128.             + "重复: " + trigger.getRepeatCount() + " 次, "
  129.             + "每 " + trigger.getRepeatInterval() / 1000L + " s 重复一次"); 
  131.     System.out.println("------- 开始Scheduler ----------------"); 
  133.     sched.start(); 
  135.     System.out.println("------- Scheduler调用job结束 -----------------"); 
  137.     job = JobBuilder.newJob(SimpleJob.class).withIdentity("job6", "group1").build(); 
  139.     trigger = (SimpleTrigger)TriggerBuilder.newTrigger() 
  140.             .withIdentity("trigger6", "group1") 
  141.             .startAt(startTime) 
  142.             .withSchedule(SimpleScheduleBuilder 
  143.                         .simpleSchedule() 
  144.                         .withIntervalInMinutes(1) 
  145.                         .withRepeatCount(20)) 
  146.             .build(); 
  148.     ft = sched.scheduleJob(job, trigger); 
  149.     System.out.println(job.getKey() + " 将会在: " + dateFormat.format(ft) + "时运行，"
  150.             + "重复: " + trigger.getRepeatCount() + " 次, "
  151.             + "每 " + trigger.getRepeatInterval() / 1000L + " s 重复一次"); 
  153.     job = JobBuilder.newJob(SimpleJob.class).withIdentity("job7", "group1") 
  154.             .storeDurably()//该job没有触发器，该方法将durability设置为true
  155.             .build(); 
  156. //添加一个没有出发器的job
  157.     sched.addJob(job, true); 
  159.     System.out.println("手动触发job7..."); 
  160. //jobKey用来唯一的标识一个JobDetail
  161. //执行Job
  162.     sched.triggerJob(JobKey.jobKey("job7", "group1")); 
  164.     System.out.println("------- 等待10S... --------------"); 
  165. try
  166.     { 
  167.       Thread.sleep(10000L); 
  168.     } 
  169. catch (Exception e) 
  170.     { 
  171.     } 
  173.     System.out.println("------- 改变触发器6 --------------------"); 
  174.     trigger = (SimpleTrigger)TriggerBuilder.newTrigger() 
  175.             .withIdentity("trigger10", "group1") 
  176.             .startAt(startTime) 
  177.             .withSchedule(SimpleScheduleBuilder 
  178.                     .simpleSchedule() 
  179.                     .withIntervalInMinutes(1) 
  180.                     .withRepeatCount(20)) 
  181.             .build(); 
  182. //根据触发器获取指定的Job然后更改此Job的触发器
  183. //新的触发器不需要旧的触发器的名称相同
  184.     ft = sched.rescheduleJob(new TriggerKey("trigger6","group1")//获取TriggerKey（用来标识唯一的Trigger）
  185.             , trigger); 
  186.     System.out.println("job6 重新在 " + dateFormat.format(ft)+ "时运行 ，"
  187.             + "重复: " + trigger.getRepeatCount() + " 次, "
  188.             + "每 " + trigger.getRepeatInterval() / 1000L + " s 重复一次"); 
  190.     System.out.println("------- 等待5分钟... ------------"); 
  191. try
  192.     { 
  193.       Thread.sleep(300000L); 
  194.     } 
  195. catch (Exception e) 
  196.     { 
  197.     } 
  199.     System.out.println("------- 关闭Scheduler ---------------------"); 
  201.     sched.shutdown(true); 
  203.     System.out.println("------- 关闭完成 -----------------"); 
  205.     SchedulerMetaData metaData = sched.getMetaData(); 
  206.     System.out.println("Executed " + metaData.getNumberOfJobsExecuted() + " jobs."); 
  207.   } 
  209. public static void main(String[] args) 
  210. throws Exception 
  211.   { 
  212.     SimpleTriggerExample example = new SimpleTriggerExample(); 
  213.     example.run(); 
  214.   } 
  215. } 

运行结果：

[plain] view plaincopy

  1. ------- 初始化 ------------------- 
  2. SLF4J: Failed to load class "org.slf4j.impl.StaticLoggerBinder". 
  3. SLF4J: Defaulting to no-operation (NOP) logger implementation 
  4. SLF4J: See http://www.slf4j.org/codes.html#StaticLoggerBinder for further details. 
  5. ------- 初始化完成 -------- 
  6. ------- 向Scheduler加入Job ---------------- 
  7. group1.job1 将会在: 2014年07月31日 13时51分45秒时运行，重复: 0 次, 每 0 s 重复一次 
  8. group1.job2 将会在: 2014年07月31日 13时51分45秒时运行，重复: 10 次, 每 10 s 重复一次 
  9. group1.job2 也会在: 2014年07月31日 13时51分45秒时运行，重复: 2 次, 每 10 s 重复一次 
  10. group1.job3 将会在: 2014年07月31日 13时51分45秒时运行，重复: 5 次, 每 10 s 重复一次 
  11. 当前时间为：2014年07月31日 13时51分41秒 
  12. group1.job4 将会在: 2014年07月31日 13时56分41秒时运行，重复: 0 次, 每 0 s 重复一次 
  13. group1.job5 将会在: 2014年07月31日 13时51分45秒时运行，重复: -1 次, 每 40 s 重复一次 
  14. ------- 开始Scheduler ---------------- 
  15. ------- Scheduler调用job结束 ----------------- 
  16. group1.job6 将会在: 2014年07月31日 13时51分45秒时运行，重复: 20 次, 每 60 s 重复一次 
  17. 手动触发job7... 
  18. ------- 等待10S... -------------- 
  19. SimpleJob类 ：group1.job7 在 2014年07月31日 13时51分41秒 时运行 
  20. SimpleJob类 ：group1.job1 在 2014年07月31日 13时51分45秒 时运行 
  21. SimpleJob类 ：group1.job2 在 2014年07月31日 13时51分45秒 时运行 
  22. SimpleJob类 ：group1.job3 在 2014年07月31日 13时51分45秒 时运行 
  23. SimpleJob类 ：group1.job5 在 2014年07月31日 13时51分45秒 时运行 
  24. SimpleJob类 ：group1.job6 在 2014年07月31日 13时51分45秒 时运行 
  25. SimpleJob类 ：group1.job2 在 2014年07月31日 13时51分45秒 时运行 
  26. ------- 改变触发器6 -------------------- 
  27. job6 重新在 2014年07月31日 13时51分45秒时运行 ，重复: 20 次, 每 60 s 重复一次 
  28. ------- 等待5分钟... ------------ 
  29. SimpleJob类 ：group1.job6 在 2014年07月31日 13时51分51秒 时运行 
  30. SimpleJob类 ：group1.job2 在 2014年07月31日 13时51分55秒 时运行 
  31. SimpleJob类 ：group1.job3 在 2014年07月31日 13时51分55秒 时运行 
  32. SimpleJob类 ：group1.job2 在 2014年07月31日 13时51分55秒 时运行 
  33. SimpleJob类 ：group1.job2 在 2014年07月31日 13时52分05秒 时运行 
  34. SimpleJob类 ：group1.job3 在 2014年07月31日 13时52分05秒 时运行 
  35. SimpleJob类 ：group1.job2 在 2014年07月31日 13时52分05秒 时运行 
  36. SimpleJob类 ：group1.job2 在 2014年07月31日 13时52分15秒 时运行 
  37. SimpleJob类 ：group1.job3 在 2014年07月31日 13时52分15秒 时运行 
  38. SimpleJob类 ：group1.job2 在 2014年07月31日 13时52分25秒 时运行 
  39. SimpleJob类 ：group1.job3 在 2014年07月31日 13时52分25秒 时运行 
  40. SimpleJob类 ：group1.job5 在 2014年07月31日 13时52分25秒 时运行 
  41. SimpleJob类 ：group1.job2 在 2014年07月31日 13时52分35秒 时运行 
  42. SimpleJob类 ：group1.job3 在 2014年07月31日 13时52分35秒 时运行 
  43. SimpleJob类 ：group1.job6 在 2014年07月31日 13时52分45秒 时运行 
  44. SimpleJob类 ：group1.job2 在 2014年07月31日 13时52分45秒 时运行 
  45. SimpleJob类 ：group1.job2 在 2014年07月31日 13时52分55秒 时运行 
  46. SimpleJob类 ：group1.job2 在 2014年07月31日 13时53分05秒 时运行 
  47. SimpleJob类 ：group1.job5 在 2014年07月31日 13时53分05秒 时运行 
  48. SimpleJob类 ：group1.job2 在 2014年07月31日 13时53分15秒 时运行 
  49. SimpleJob类 ：group1.job2 在 2014年07月31日 13时53分25秒 时运行 
  50. SimpleJob类 ：group1.job6 在 2014年07月31日 13时53分45秒 时运行 
  51. SimpleJob类 ：group1.job5 在 2014年07月31日 13时53分45秒 时运行 
  52. SimpleJob类 ：group1.job5 在 2014年07月31日 13时54分25秒 时运行 
  53. SimpleJob类 ：group1.job6 在 2014年07月31日 13时54分45秒 时运行 
  54. SimpleJob类 ：group1.job5 在 2014年07月31日 13时55分05秒 时运行 
  55. SimpleJob类 ：group1.job6 在 2014年07月31日 13时55分45秒 时运行 
  56. SimpleJob类 ：group1.job5 在 2014年07月31日 13时55分45秒 时运行 
  57. SimpleJob类 ：group1.job5 在 2014年07月31日 13时56分25秒 时运行 
  58. SimpleJob类 ：group1.job4 在 2014年07月31日 13时56分41秒 时运行 
  59. SimpleJob类 ：group1.job6 在 2014年07月31日 13时56分45秒 时运行 
  60. ------- 关闭Scheduler --------------------- 
  61. ------- 关闭完成 ----------------- 

根据SimpleScheduleBuilder配置不同的SimpleTrigger触发器

标签：des   blog   http   io   ar   java   for   on   2014   

原文地址：http://www.cnblogs.com/wych/p/4104054.html
踩
(0)
赞
(0)
   
举报
评论 一句话评论（0）
登录后才能评论！
分享档案
更多>
2021年07月29日 (22)
2021年07月28日 (40)
2021年07月27日 (32)
2021年07月26日 (79)
2021年07月23日 (29)
2021年07月22日 (30)
2021年07月21日 (42)
2021年07月20日 (16)
2021年07月19日 (90)
2021年07月16日 (35)
周排行
mamicode.com排行更多图片
更多
友情链接
兰亭集智   国之画   百度统计   站长统计   阿里云   chrome插件   新版天听网
关于我们 - 联系我们 - 留言反馈
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码！