您的位置: 首页  >  IT文章  >  任务调度开源框架Quartz动态添加、修改和删除定时任务

任务调度开源框架Quartz动态添加、修改和删除定时任务

分类: IT文章 • 2023-10-31 11:17:16

   Quartz 是个开源的作业调度框架，为在 Java 应用程序中进行作业调度提供了简单却强大的机制。Quartz框架包含了调度器监听、作业和触发器监听。你可以配置作业和触发器监听为全局监听或者是特定于作业和触发器的监听。Quartz 允许开发人员根据时间间隔（或天）来调度作业。它实现了作业和触发器的多对多关系，还能把多个作业与不同的触发器关联。整合了 Quartz 的应用程序可以重用来自不同事件的作业，还可以为一个事件组合多个作业。并且还能和spring配置整合使用。Quartz在功能上远远超越了JDK自带的Timer，很好很强大！好啦，直接上代码：

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


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

[java] view plaincopy
 
  1. /** 
  2.  * @Description:  
  3.  * 
  4.  * @Title: QuartzJob.java 
  5.  * @Package com.joyce.quartz 
  6.  * @Copyright: Copyright (c) 2014 
  7.  * 
  8.  * @author Comsys-LZP 
  9.  * @date 2014-6-26 下午03:37:11 
  10.  * @version V2.0 
  11.  */  
  12. package com.joyce.quartz;  
  13.   
  14. import java.text.SimpleDateFormat;  
  15. import java.util.Date;  
  16.   
  17. import org.quartz.Job;  
  18. import org.quartz.JobExecutionContext;  
  19. import org.quartz.JobExecutionException;  
  20.   
  21. /** 
  22.  * @Description: 任务执行类 
  23.  * 
  24.  * @ClassName: QuartzJob 
  25.  * @Copyright: Copyright (c) 2014 
  26.  * 
  27.  * @author Comsys-LZP 
  28.  * @date 2014-6-26 下午03:37:11 
  29.  * @version V2.0 
  30.  */  
  31. public class QuartzJob implements Job {  
  32.   
  33.     @Override  
  34.     public void execute(JobExecutionContext arg0) throws JobExecutionException {  
  35.         System.out.println(new SimpleDateFormat("yyyy-MM-dd HH:mm:ss").format(new Date())+ "★★★★★★★★★★★");    
  36.     }  
  37. }  


Ok，我们来测试一下：

[java] view plaincopy
 
  1. package com.joyce.quartz.main;  
  2.   
  3. import com.joyce.quartz.QuartzJob;  
  4. import com.joyce.quartz.QuartzManager;  
  5.   
  6. /** 
  7.  * @Description: 测试类 
  8.  * 
  9.  * @ClassName: QuartzTest 
  10.  * @Copyright: Copyright (c) 2014 
  11.  * 
  12.  * @author Comsys-LZP 
  13.  * @date 2014-6-26 下午03:35:05 
  14.  * @version V2.0 
  15.  */  
  16. public class QuartzTest {  
  17.     public static void main(String[] args) {  
  18.         try {  
  19.             String job_name = "动态任务调度";  
  20.             System.out.println("【系统启动】开始(每1秒输出一次)...");    
  21.             QuartzManager.addJob(job_name, QuartzJob.class, "0/1 * * * * ?");    
  22.               
  23.             Thread.sleep(5000);    
  24.             System.out.println("【修改时间】开始(每2秒输出一次)...");    
  25.             QuartzManager.modifyJobTime(job_name, "10/2 * * * * ?");    
  26.             Thread.sleep(6000);    
  27.             System.out.println("【移除定时】开始...");    
  28.             QuartzManager.removeJob(job_name);    
  29.             System.out.println("【移除定时】成功");    
  30.               
  31.             System.out.println("【再次添加定时任务】开始(每10秒输出一次)...");    
  32.             QuartzManager.addJob(job_name, QuartzJob.class, "*/10 * * * * ?");    
  33.             Thread.sleep(60000);    
  34.             System.out.println("【移除定时】开始...");    
  35.             QuartzManager.removeJob(job_name);    
  36.             System.out.println("【移除定时】成功");  
  37.         } catch (Exception e) {  
  38.             e.printStackTrace();  
  39.         }  
  40.     }  
  41. }  

相关推荐