比尔云BierYun--阿里云最新优惠活动
阿里云优惠码丨阿里云代金券

任务调度开源框架石英动态添加,修改和删除定时任务

     Quartz是个开源的作业调度框架,为在Java应用程序中进行作业调度提供了简单却强大的机制.Quartz框架包含了调度器监听,作业和触发器监听。你可以配置作业和触发器监听为全局监听或者是特定于作业和触发器的监听.Quartz允许开发人员根据时间间隔(或天)来调度作业。

它实现了作业和触发器的多对多关系,还能把多个作业与不同的触发器关联。整合了Quartz的应用程序可以重用来自不同事件的作业,还可以作为一个事件组合多个作业。并且还能和Spring配置整合使用.Quartz在功能上远远超越了JDK自带的Timer,很好很强大好啦,直接上代码!

[java]  查看纯文本

  1. / **
  2.  * @说明: 
  3.  *
  4.  * @Title:QuartzManager.java
  5.  * @包com.joyce.quartz
  6.  * @版权:Copyright(c)2014
  7.  *
  8.  * @作者Comsys-LZP
  9.  * @date 2014-6-26下午03:15:52
  10.  * @version V2.0
  11.  * /
  12.  com.joyce.quartz;
  13. import  org.quartz.CronTrigger;
  14. import  org.quartz.JobDetail;
  15. 进口 org.quartz.Scheduler;
  16. import  org.quartz.SchedulerFactory;
  17. import  org.quartz.impl.StdSchedulerFactory;
  18. / **
  19.  * @Description:定时任务管理类
  20.  * 
  21.  * @ClassName:QuartzManager
  22.  * @版权:Copyright(c)2014
  23.  * 
  24.  * @作者Comsys-LZP
  25.  * @date 2014-6-26下午03:15:52
  26.  * @version V2.0
  27.  * /
  28. 公共 QuartzManager {
  29.     private static  SchedulerFactory gSchedulerFactory =  new  StdSchedulerFactory();
  30.     私人静态 字符串JOB_GROUP_NAME =  “EXTJWEB_JOBGROUP_NAME” ;
  31.     私人静态 字符串TRIGGER_GROUP_NAME =  “EXTJWEB_TRIGGERGROUP_NAME” ;
  32.     / **
  33.      * @Description:添加一个定时任务,使用默认的任务组名,触发器名,触发器组名
  34.      * 
  35.      * @参数jobName
  36.      *任务名
  37.      * @参数cls
  38.      *任务
  39.      * @参数时间
  40.      *时间设置,参考石英说明文档
  41.      * 
  42.      * @Title:QuartzManager.java
  43.      * @版权:Copyright(c)2014
  44.      * 
  45.      * @作者Comsys-LZP
  46.      * @date 2014-6-26下午03:47:44
  47.      * @version V2.0
  48.      * /
  49.     @SuppressWarnings “unchecked”
  50.     public static void  addJob(String jobName,Class cls,String time){
  51.         尝试 {
  52.             调度程序sched = gSchedulerFactory.getScheduler();
  53.             JobDetail jobDetail =  新的 JobDetail(jobName,JOB_GROUP_NAME,cls); //任务名,任务组,任务执行类
  54.             //触发器
  55.             CronTrigger触发器=  新的 CronTrigger(jobName,TRIGGER_GROUP_NAME); //触发器名,触发器组
  56.             trigger.setCronExpression(时间); //触发器时间设定
  57.             sched.scheduleJob(jobDetail,触发器);
  58.             //启动
  59.             如果 (!sched.isShutdown()){
  60.                 sched.start();
  61.             }
  62.         }  捕获 (例外五){
  63.             抛出新的 RuntimeException(e);
  64.         }
  65.     }
  66.     / **
  67.      * @Description:添加一个定时任务
  68.      * 
  69.      * @参数jobName
  70.      *任务名
  71.      * @参数jobGroupName
  72.      *任务组名
  73.      * @参数triggerName
  74.      *触发器名
  75.      * @参数triggerGroupName
  76.      *触发器组名
  77.      * @param jobClass
  78.      *任务
  79.      * @参数时间
  80.      *时间设置,参考石英说明文档
  81.      * 
  82.      * @Title:QuartzManager.java
  83.      * @版权:Copyright(c)2014
  84.      * 
  85.      * @作者Comsys-LZP
  86.      * @date 2014-6-26下午03:48:15
  87.      * @version V2.0
  88.      * /
  89.     @SuppressWarnings “unchecked”
  90.     public static void  addJob(String jobName,String jobGroupName,
  91.             字符串triggerName,字符串triggerGroupName,类jobClass,
  92.             字符串时间){
  93.         尝试 {
  94.             调度程序sched = gSchedulerFactory.getScheduler();
  95.             JobDetail jobDetail =  新的 JobDetail(jobName,jobGroupName,jobClass); //任务名,任务组,任务执行类
  96.             //触发器
  97.             CronTrigger trigger =  new  CronTrigger(triggerName,triggerGroupName); //触发器名,触发器组
  98.             trigger.setCronExpression(时间); //触发器时间设定
  99.             sched.scheduleJob(jobDetail,触发器);
  100.         }  捕获 (例外五){
  101.             抛出新的 RuntimeException(e);
  102.         }
  103.     }
  104.     / **
  105.      * @Description:修改一个任务的触发时间(使用默认的任务组名,触发器名,触发器组名)
  106.      * 
  107.      * @参数jobName
  108.      * @参数时间
  109.      * 
  110.      * @Title:QuartzManager.java
  111.      * @版权:Copyright(c)2014
  112.      * 
  113.      * @作者Comsys-LZP
  114.      * @date 2014-6-26下午03:49:21
  115.      * @version V2.0
  116.      * /
  117.     @SuppressWarnings “unchecked”
  118.     public static void  modifyJobTime(String jobName,String time){
  119.         尝试 {
  120.             调度程序sched = gSchedulerFactory.getScheduler();
  121.             CronTrigger触发器=(CronTrigger)sched.getTrigger(jobName,TRIGGER_GROUP_NAME);
  122.             if  (trigger ==  null ){
  123.                 返回;
  124.             }
  125.             String oldTime = trigger.getCronExpression();
  126.             if  (!oldTime.equalsIgnoreCase(time)){
  127.                 JobDetail jobDetail = sched.getJobDetail(jobName,JOB_GROUP_NAME);
  128.                 Class objJobClass = jobDetail.getJobClass();
  129.                 removeJob(JOBNAME);
  130.                 addJob(jobName,objJobClass,time);
  131.             }
  132.         }  捕获 (例外五){
  133.             抛出新的 RuntimeException(e);
  134.         }
  135.     }
  136.     / **
  137.      * @Description:修改一个任务的触发时间
  138.      * 
  139.      * @参数triggerName
  140.      * @参数triggerGroupName
  141.      * @参数时间
  142.      * 
  143.      * @Title:QuartzManager.java
  144.      * @版权:Copyright(c)2014
  145.      * 
  146.      * @作者Comsys-LZP
  147.      * @date 2014-6-26下午03:49:37
  148.      * @version V2.0
  149.      * /
  150.     public static void  modifyJobTime(String triggerName,
  151.             字符串triggerGroupName,字符串时间){
  152.         尝试 {
  153.             调度程序sched = gSchedulerFactory.getScheduler();
  154.             CronTrigger触发=(CronTrigger)sched.getTrigger(triggerName,triggerGroupName);
  155.             if  (trigger ==  null ){
  156.                 返回;
  157.             }
  158.             String oldTime = trigger.getCronExpression();
  159.             if  (!oldTime.equalsIgnoreCase(time)){
  160.                 CronTrigger ct =(CronTrigger)触发器;
  161.                 //修改时间
  162.                 ct.setCronExpression(时间);
  163.                 //重启触发器
  164.                 sched.resumeTrigger(triggerName,triggerGroupName);
  165.             }
  166.         }  捕获 (例外五){
  167.             抛出新的 RuntimeException(e);
  168.         }
  169.     }
  170.     / **
  171.      * @Description:移除一个任务(使用默认的任务组名,触发器名,触发器组名)
  172.      * 
  173.      * @参数jobName
  174.      * 
  175.      * @Title:QuartzManager.java
  176.      * @版权:Copyright(c)2014
  177.      * 
  178.      * @作者Comsys-LZP
  179.      * @date 2014-6-26下午03:49:51
  180.      * @version V2.0
  181.      * /
  182.     public static void  removeJob(String jobName){
  183.         尝试 {
  184.             调度程序sched = gSchedulerFactory.getScheduler();
  185.             sched.pauseTrigger(jobName,TRIGGER_GROUP_NAME); //停止触发器
  186.             sched.unscheduleJob(jobName,TRIGGER_GROUP_NAME); //移除触发器
  187.             sched.deleteJob(jobName,JOB_GROUP_NAME); //删除任务
  188.         }  捕获 (例外五){
  189.             抛出新的 RuntimeException(e);
  190.         }
  191.     }
  192.     / **
  193.      * @Description:移除一个任务
  194.      * 
  195.      * @参数jobName
  196.      * @参数jobGroupName
  197.      * @参数triggerName
  198.      * @参数triggerGroupName
  199.      * 
  200.      * @Title:QuartzManager.java
  201.      * @版权:Copyright(c)2014
  202.      * 
  203.      * @作者Comsys-LZP
  204.      * @date 2014-6-26下午03:50:01
  205.      * @version V2.0
  206.      * /
  207.     public static void  removeJob(String jobName,String jobGroupName,
  208.             字符串triggerName,字符串triggerGroupName){
  209.         尝试 {
  210.             调度程序sched = gSchedulerFactory.getScheduler();
  211.             sched.pauseTrigger(triggerName,triggerGroupName); //停止触发器
  212.             sched.unscheduleJob(triggerName,triggerGroupName); //移除触发器
  213.             sched.deleteJob(jobName,jobGroupName); //删除任务
  214.         }  捕获 (例外五){
  215.             抛出新的 RuntimeException(e);
  216.         }
  217.     }
  218.     / **
  219.      * @Description:启动所有定时任务
  220.      * 
  221.      * 
  222.      * @Title:QuartzManager.java
  223.      * @版权:Copyright(c)2014
  224.      * 
  225.      * @作者Comsys-LZP
  226.      * @date 2014-6-26下午03:50:18
  227.      * @version V2.0
  228.      * /
  229.     公共静态无效的 startJobs(){
  230.         尝试 {
  231.             调度程序sched = gSchedulerFactory.getScheduler();
  232.             sched.start();
  233.         }  捕获 (例外五){
  234.             抛出新的 RuntimeException(e);
  235.         }
  236.     }
  237.     / **
  238.      * @Description:关闭所有定时任务
  239.      * 
  240.      * 
  241.      * @Title:QuartzManager.java
  242.      * @版权:Copyright(c)2014
  243.      * 
  244.      * @作者Comsys-LZP
  245.      * @date 2014-6-26下午03:50:26
  246.      * @version V2.0
  247.      * /
  248.     public static void  shutdownJobs(){
  249.         尝试 {
  250.             调度程序sched = gSchedulerFactory.getScheduler();
  251.             如果 (!sched.isShutdown()){
  252.                 sched.shutdown();
  253.             }
  254.         }  捕获 (例外五){
  255.             抛出新的 RuntimeException(e);
  256.         }
  257.     }
  258. }

以上就是石英任务调度对于任务的常用操作,封装起来以便在外部调用这样我们就需要任务的执行了!

[java]  查看纯文本

  1. / **
  2.  * @说明: 
  3.  *
  4.  * @Title:QuartzJob.java
  5.  * @包com.joyce.quartz
  6.  * @版权:Copyright(c)2014
  7.  *
  8.  * @作者Comsys-LZP
  9.  * @date 2014-6-26下午03:37:11
  10.  * @version V2.0
  11.  * /
  12.  com.joyce.quartz;
  13. import  java.text.SimpleDateFormat;
  14. import  java.util.Date;
  15. 进口 org.quartz.Job;
  16. import  org.quartz.JobExecutionContext;
  17. import  org.quartz.JobExecutionException;
  18. / **
  19.  * @Description:任务执行类
  20.  *
  21.  * @ClassName:QuartzJob
  22.  * @版权:Copyright(c)2014
  23.  *
  24.  * @作者Comsys-LZP
  25.  * @date 2014-6-26下午03:37:11
  26.  * @version V2.0
  27.  * /
  28. 公共 QuartzJob  实现 作业{
  29.     @覆盖
  30.     public void  execute(JobExecutionContext arg0)  throws  JobExecutionException {
  31.         System.out.println(new  SimpleDateFormat(“yyyy-MM-dd HH:mm:ss” ).format(new Date())+  “★★★★★★★★★★★” );
  32.     }
  33. }

好吧,我们来测试一下:

[java]  查看纯文本

  1. / **
  2.  * @说明: 
  3.  *
  4.  * @Title:QuartzTest.java
  5.  * @包com.joyce.quartz.main
  6.  * @版权:Copyright(c)2014
  7.  *
  8.  * @作者Comsys-LZP
  9.  * @date 2014-6-26下午03:35:05
  10.  * @version V2.0
  11.  * /
  12.  com.joyce.quartz.main;
  13. import  com.joyce.quartz.QuartzJob;
  14. import  com.joyce.quartz.QuartzManager;
  15. / **
  16.  * @Description:测试类
  17.  *
  18.  * @ClassName:QuartzTest
  19.  * @版权:Copyright(c)2014
  20.  *
  21.  * @作者Comsys-LZP
  22.  * @date 2014-6-26下午03:35:05
  23.  * @version V2.0
  24.  * /
  25. 公共 QuartzTest {
  26.     public static void  main(String [] args){
  27.         尝试 {
  28.             String job_name =  “动态任务调度” ;
  29.             System.out.println(“【系统启动】开始(每1秒输出一次)…” );
  30.             QuartzManager.addJob(JOB_NAME,QuartzJob ,  “0/1 * * * *?” );
  31.             Thread.sleep(5000 );
  32.             System.out.println(“【修改时间】开始(每2秒输出一次)…” );
  33.             QuartzManager.modifyJobTime(job_name,  “10/2 * * * *?” );
  34.             Thread.sleep(6000 );
  35.             System.out.println(“【移除定时】开始…” );
  36.             QuartzManager.removeJob(JOB_NAME);
  37.             System.out.println(“【移除定时】成功” );
  38.             System.out.println(“【再次添加定时任务】开始(每10秒输出一次)…” );
  39.             QuartzManager.addJob(JOB_NAME,QuartzJob ,  “* / 10 * * * *?” );
  40.             Thread.sleep(60000 );
  41.             System.out.println(“【移除定时】开始…” );
  42.             QuartzManager.removeJob(JOB_NAME);
  43.             System.out.println(“【移除定时】成功” );
  44.         }  捕获 (例外五){
  45.             e.printStackTrace();
  46.         }
  47.     }
  48. }

 

未经允许不得转载:比尔云 » 任务调度开源框架石英动态添加,修改和删除定时任务
分享到: 更多 (0)

评论 抢沙发

  • 昵称 (必填)
  • 邮箱 (必填)
  • 网址

强烈推荐

高性能SSD云服务器ECS抗攻击,高可用云数据库RDS