码迷，mamicode.com
首页 > 编程语言 > 详细

Spring4整合quartz2.2.3，quartz动态任务

时间：2017-09-06 15:37:08      阅读：227      评论：0      收藏：0      [点我收藏+]

标签：tick   resume   delegate   分组   实体   tac   计划   存在   name   

Spring4整合quartz2.2.3，quartz动态任务

 

>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>

?Copyright 蕃薯耀 2017年9月6日

http://www.cnblogs.com/fanshuyao/

 

可以直接看总结篇： http://www.cnblogs.com/fanshuyao/p/7484843.html

 

 quartz下载

http://www.quartz-scheduler.org/downloads/

 

一、quartz动态任务管理类：

 

Java代码  技术分享
  1. import java.util.ArrayList;  
  2. import java.util.List;  
  3. import java.util.Set;  
  4.   
  5. import org.quartz.CronScheduleBuilder;  
  6. import org.quartz.CronTrigger;  
  7. import org.quartz.Job;  
  8. import org.quartz.JobBuilder;  
  9. import org.quartz.JobDetail;  
  10. import org.quartz.JobExecutionContext;  
  11. import org.quartz.JobKey;  
  12. import org.quartz.Scheduler;  
  13. import org.quartz.SchedulerException;  
  14. import org.quartz.Trigger;  
  15. import org.quartz.TriggerBuilder;  
  16. import org.quartz.TriggerKey;  
  17. import org.quartz.impl.matchers.GroupMatcher;  
  18. import org.slf4j.Logger;  
  19. import org.slf4j.LoggerFactory;  
  20. import org.springframework.beans.factory.annotation.Autowired;  
  21.   
  22. import cn.imovie.common.utils.CC;  
  23. import cn.imovie.common.utils.JasonUtils;  
  24. import cn.imovie.common.utils.SpringUtils;  
  25. import cn.imovie.entity.task.ScheduleJob;  
  26. import cn.imovie.service.ScheduleJobService;  
  27.   
  28. public class SchedulerManage {  
  29.   
  30.     private Logger log = LoggerFactory.getLogger(SchedulerManage.class);  
  31.       
  32.     private Scheduler scheduler = (Scheduler) SpringUtils.getBeanById("scheduler");  
  33.       
  34.     @Autowired  
  35.     private ScheduleJobService scheduleJobService;  
  36.       
  37.     /** 
  38.      * 新增任务 
  39.      * @param scheduleJob 
  40.      */  
  41.     @SuppressWarnings("unchecked")  
  42.     public void addJob(ScheduleJob scheduleJob){  
  43.         TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());  
  44.         try {  
  45.             //任务触发  
  46.             CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);  
  47.             if (null == trigger) {  
  48.                 JobDetail jobDetail = JobBuilder.newJob((Class<? extends Job>) Class.forName(scheduleJob.getClazz()))  
  49.                   .withIdentity(scheduleJob.getJobName(), scheduleJob.getJobGroup()).build();  
  50.                 jobDetail.getJobDataMap().put("scheduleJob", scheduleJob);  
  51.                   
  52.                 CronScheduleBuilder cronScheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob.getCronExpression());  
  53.                 /*withMisfireHandlingInstructionDoNothing 
  54.                 ——不触发立即执行 
  55.                 ——等待下次Cron触发频率到达时刻开始按照Cron频率依次执行 
  56.  
  57.                 withMisfireHandlingInstructionIgnoreMisfires 
  58.                 ——以错过的第一个频率时间立刻开始执行 
  59.                 ——重做错过的所有频率周期后 
  60.                 ——当下一次触发频率发生时间大于当前时间后，再按照正常的Cron频率依次执行 
  61.  
  62.                 withMisfireHandlingInstructionFireAndProceed 
  63.                 ——以当前时间为触发频率立刻触发一次执行 
  64.                 ——然后按照Cron频率依次执行*/  
  65.                 trigger = TriggerBuilder.newTrigger().withIdentity(scheduleJob.getJobName(), scheduleJob.getJobGroup()).withSchedule(cronScheduleBuilder.withMisfireHandlingInstructionDoNothing()).build();  
  66.                 scheduler.scheduleJob(jobDetail, trigger);  
  67.                 log.info(CC.LOG_PREFIX + "新增任务："+JasonUtils.Object2String(scheduleJob));  
  68.             }else {  
  69.                 // Trigger已存在，那么更新相应的定时设置  
  70.                 //表达式调度构建器  
  71.                 CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob.getCronExpression());  
  72.                 //按新的cronExpression表达式重新构建trigger  
  73.                 trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder.withMisfireHandlingInstructionDoNothing()).build();  
  74.                 //按新的trigger重新设置job执行  
  75.                 scheduler.rescheduleJob(triggerKey, trigger);  
  76.                 log.info(CC.LOG_PREFIX + "任务"+JasonUtils.Object2String(scheduleJob)+"已经存在，更新trigger");  
  77.             }  
  78.             //scheduleJobService.save(req, sysUserInSession, scheduleJob);  
  79.         } catch (Exception e) {  
  80.             e.printStackTrace();  
  81.         }  
  82.     }  
  83.       
  84.     /** 
  85.      * 暂停任务 
  86.      * @param scheduleJob 
  87.      */  
  88.     public void pauseJob(ScheduleJob scheduleJob){  
  89.         JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());  
  90.         try {  
  91.             scheduler.pauseJob(jobKey);  
  92.             log.info(CC.LOG_PREFIX + "暂停任务："+JasonUtils.Object2String(scheduleJob));  
  93.         } catch (SchedulerException e) {  
  94.             e.printStackTrace();  
  95.         }  
  96.     }  
  97.       
  98.     /** 
  99.      * 暂停全部任务 
  100.      */  
  101.     public void pauseAll(){  
  102.         try {  
  103.             scheduler.pauseAll();  
  104.             log.info(CC.LOG_PREFIX + "暂停所有任务");  
  105.         } catch (SchedulerException e) {  
  106.             e.printStackTrace();  
  107.         }  
  108.     }  
  109.       
  110.     /** 
  111.      * 恢复任务 
  112.      * @param scheduleJob 
  113.      */  
  114.     public void resumeJob(ScheduleJob scheduleJob){  
  115.         JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());  
  116.         try {  
  117.             scheduler.resumeJob(jobKey);  
  118.             log.info(CC.LOG_PREFIX + "恢复任务："+JasonUtils.Object2String(scheduleJob));  
  119.         } catch (SchedulerException e) {  
  120.             e.printStackTrace();  
  121.         }  
  122.     }  
  123.       
  124.       
  125.     /** 
  126.      * 恢复所有任务 
  127.      */  
  128.     public void resumeAll(){  
  129.         try {  
  130.             scheduler.resumeAll();  
  131.             log.info(CC.LOG_PREFIX + "恢复所有任务");  
  132.         } catch (SchedulerException e) {  
  133.             e.printStackTrace();  
  134.         }  
  135.     }  
  136.       
  137.     /** 
  138.      * 删除任务后，所对应的trigger也将被删除 
  139.      * @param scheduleJob 
  140.      */  
  141.     public void deleteJob(ScheduleJob scheduleJob){  
  142.         JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());  
  143.         try {  
  144.             scheduler.pauseJob(jobKey);//先暂停任务  
  145.             scheduler.deleteJob(jobKey);//再删除任务  
  146.             log.info(CC.LOG_PREFIX + "删除任务："+JasonUtils.Object2String(scheduleJob));  
  147.         } catch (SchedulerException e) {  
  148.             e.printStackTrace();  
  149.         }  
  150.     }  
  151.       
  152.     /** 
  153.      * 立即运行任务 
  154.      * @param scheduleJob 
  155.      */  
  156.     public void triggerJob(ScheduleJob scheduleJob){  
  157.         JobKey jobKey = JobKey.jobKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());  
  158.         try {  
  159.             scheduler.triggerJob(jobKey);  
  160.             log.info(CC.LOG_PREFIX + "运行任务："+JasonUtils.Object2String(scheduleJob));  
  161.         } catch (SchedulerException e) {  
  162.             e.printStackTrace();  
  163.         }  
  164.     }  
  165.       
  166.     /** 
  167.      * 更新任务的时间表达式 
  168.      * @param scheduleJob 
  169.      */  
  170.     public void updateJob(ScheduleJob scheduleJob){  
  171.         try {  
  172.             TriggerKey triggerKey = TriggerKey.triggerKey(scheduleJob.getJobName(), scheduleJob.getJobGroup());  
  173.   
  174.             //获取trigger，即在spring配置文件中定义的 bean id="myTrigger"  
  175.             CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);  
  176.   
  177.             //表达式调度构建器  
  178.             CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(scheduleJob.getCronExpression());  
  179.   
  180.             //按新的cronExpression表达式重新构建trigger  
  181.             trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder.withMisfireHandlingInstructionDoNothing()).build();  
  182.             //按新的trigger重新设置job执行  
  183.             scheduler.rescheduleJob(triggerKey, trigger);  
  184.             log.info(CC.LOG_PREFIX + "更新任务："+JasonUtils.Object2String(scheduleJob));  
  185.         } catch (SchedulerException e) {  
  186.             e.printStackTrace();  
  187.         }  
  188.     }  
  189.       
  190.       
  191.     /** 
  192.      * 获取quartz调度器的计划任务 
  193.      * @return 
  194.      */  
  195.     public List<ScheduleJob> getScheduleJobList(){  
  196.         List<ScheduleJob> jobList = null;  
  197.         try {  
  198.             GroupMatcher<JobKey> matcher = GroupMatcher.anyJobGroup();  
  199.             Set<JobKey> jobKeys = scheduler.getJobKeys(matcher);  
  200.             jobList = new ArrayList<ScheduleJob>();  
  201.             for (JobKey jobKey : jobKeys) {  
  202.                 List<? extends Trigger> triggers = scheduler.getTriggersOfJob(jobKey);  
  203.                 for (Trigger trigger : triggers) {  
  204.                     ScheduleJob job = new ScheduleJob();  
  205.                     job.setJobName(jobKey.getName());  
  206.                     job.setJobGroup(jobKey.getGroup());  
  207.                     job.setClazz(jobKey.getClass().toString());  
  208.                     job.setJobDesc("触发器:" + trigger.getKey());  
  209.                     Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());  
  210.                     job.setJobStatus(triggerState.name());  
  211.                     if (trigger instanceof CronTrigger) {  
  212.                         CronTrigger cronTrigger = (CronTrigger) trigger;  
  213.                         String cronExpression = cronTrigger.getCronExpression();  
  214.                         job.setCronExpression(cronExpression);  
  215.                     }  
  216.                     jobList.add(job);  
  217.                 }  
  218.             }  
  219.         } catch (Exception e) {  
  220.             e.printStackTrace();  
  221.         }  
  222.         return jobList;  
  223.     }  
  224.       
  225.     /** 
  226.      * 获取quartz调度器的运行任务 
  227.      * @return 
  228.      */  
  229.     public List<ScheduleJob> getScheduleJobRunningList(){  
  230.         List<ScheduleJob> jobList = null;  
  231.         try {  
  232.             List<JobExecutionContext> executingJobs = scheduler.getCurrentlyExecutingJobs();  
  233.             jobList = new ArrayList<ScheduleJob>(executingJobs.size());  
  234.             for (JobExecutionContext executingJob : executingJobs) {  
  235.               ScheduleJob job = new ScheduleJob();  
  236.               JobDetail jobDetail = executingJob.getJobDetail();  
  237.               JobKey jobKey = jobDetail.getKey();  
  238.               Trigger trigger = executingJob.getTrigger();  
  239.               job.setJobName(jobKey.getName());  
  240.               job.setJobGroup(jobKey.getGroup());  
  241.               job.setClazz(jobKey.getClass().toString());  
  242.               job.setJobDesc("触发器:" + trigger.getKey());  
  243.               Trigger.TriggerState triggerState = scheduler.getTriggerState(trigger.getKey());  
  244.               job.setJobStatus(triggerState.name());  
  245.               if (trigger instanceof CronTrigger) {  
  246.                 CronTrigger cronTrigger = (CronTrigger) trigger;  
  247.                 String cronExpression = cronTrigger.getCronExpression();  
  248.                 job.setCronExpression(cronExpression);  
  249.               }  
  250.               jobList.add(job);  
  251.             }  
  252.         } catch (Exception e) {  
  253.             e.printStackTrace();  
  254.         }  
  255.         return jobList;  
  256.     }  
  257.   
  258.     public Scheduler getScheduler() {  
  259.         return scheduler;  
  260.     }  
  261.   
  262.     public void setScheduler(Scheduler scheduler) {  
  263.         this.scheduler = scheduler;  
  264.     }  
  265.   
  266.       
  267.       
  268. }  

 注意事项：

1、SchedulerFactoryBean 在spring.xml配置了，但不能直接注入，就算加上@Component注解也不行，所以使用SpringUtils 工具类获取。

Xml代码  技术分享
  1. <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">    

 

2、获取到的SchedulerFactoryBean 并不是SchedulerFactoryBean，而是scheduler

Java代码  技术分享
  1. private Scheduler scheduler = (Scheduler) SpringUtils.getBeanById("scheduler");  

 

 

 

二、ScheduleJob 类：可以保存计划任务的信息，也可以做为实体参数

Java代码  技术分享
  1. public class ScheduleJob implements Serializable{  
  2.       
  3.     private Long scheduleJobId;  
  4.       
  5.     /** 任务名称 */  
  6.     private String jobName;  
  7.       
  8.     /** 任务分组 */  
  9.     private String jobGroup;  
  10.       
  11.     /** 定时任务对应的类（包括包路径），如：cn.imovie.manage.task.job.TicketMoneyLessThanNormalWarn */  
  12.     private String clazz;  
  13.       
  14.     /** 任务状态：1禁用 2启用 3删除*/  
  15.     private String jobStatus;  
  16.       
  17.     /** 任务运行时间表达式 */  
  18.     private String cronExpression;  
  19.       
  20.     /** 任务描述 */  
  21.     private String jobDesc;  
  22.       
  23.     private Long createMan;  
  24.     private Date createTime;  
  25.     private Long updateMan;  
  26.     private Date updateTime;  
  27.       
  28.     // 非持久化属性  
  29.     private String createManText;  
  30.     private String updateManText;  
  31.   
  32.       
  33.     public Long getScheduleJobId() {  
  34.         return scheduleJobId;  
  35.     }  
  36.   
  37.     public void setScheduleJobId(Long scheduleJobId) {  
  38.         this.scheduleJobId = scheduleJobId;  
  39.     }  
  40.   
  41.     public String getJobName() {  
  42.         return jobName;  
  43.     }  
  44.   
  45.     public void setJobName(String jobName) {  
  46.         this.jobName = jobName;  
  47.     }  
  48.   
  49.     public String getJobGroup() {  
  50.         return jobGroup;  
  51.     }  
  52.   
  53.     public void setJobGroup(String jobGroup) {  
  54.         this.jobGroup = jobGroup;  
  55.     }  
  56.   
  57.     public String getClazz() {  
  58.         return clazz;  
  59.     }  
  60.   
  61.     public void setClazz(String clazz) {  
  62.         this.clazz = clazz;  
  63.     }  
  64.   
  65.     public String getJobStatus() {  
  66.         return jobStatus;  
  67.     }  
  68.   
  69.     public void setJobStatus(String jobStatus) {  
  70.         this.jobStatus = jobStatus;  
  71.     }  
  72.   
  73.     public String getCronExpression() {  
  74.         return cronExpression;  
  75.     }  
  76.   
  77.     public void setCronExpression(String cronExpression) {  
  78.         this.cronExpression = cronExpression;  
  79.     }  
  80.   
  81.     public String getJobDesc() {  
  82.         return jobDesc;  
  83.     }  
  84.   
  85.     public void setJobDesc(String jobDesc) {  
  86.         this.jobDesc = jobDesc;  
  87.     }  
  88.   
  89.     public Long getCreateMan() {  
  90.         return createMan;  
  91.     }  
  92.   
  93.     public void setCreateMan(Long createMan) {  
  94.         this.createMan = createMan;  
  95.     }  
  96.   
  97.     public Date getCreateTime() {  
  98.         return createTime;  
  99.     }  
  100.   
  101.     public void setCreateTime(Date createTime) {  
  102.         this.createTime = createTime;  
  103.     }  
  104.   
  105.     public Long getUpdateMan() {  
  106.         return updateMan;  
  107.     }  
  108.   
  109.     public void setUpdateMan(Long updateMan) {  
  110.         this.updateMan = updateMan;  
  111.     }  
  112.   
  113.     public Date getUpdateTime() {  
  114.         return updateTime;  
  115.     }  
  116.   
  117.     public void setUpdateTime(Date updateTime) {  
  118.         this.updateTime = updateTime;  
  119.     }  
  120.   
  121.     @Transient  
  122.     public String getCreateManText() {  
  123.         return createManText;  
  124.     }  
  125.   
  126.     public void setCreateManText(String createManText) {  
  127.         this.createManText = createManText;  
  128.     }  
  129.   
  130.     @Transient  
  131.     public String getUpdateManText() {  
  132.         return updateManText;  
  133.     }  
  134.   
  135.     public void setUpdateManText(String updateManText) {  
  136.         this.updateManText = updateManText;  
  137.     }  
  138.   
  139.       
  140.       
  141. }  

 

三、Spring.xml 文件配置

Xml代码  技术分享
  1. <!-- 定时任务配置 start -->  
  2.     <bean id="scheduler" class="org.springframework.scheduling.quartz.SchedulerFactoryBean">    
  3.         <property name="dataSource" ref="dataSource"></property>      
  4.         <!--可选，QuartzScheduler 启动时更新己存在的Job，这样就不用每次修改targetObject后删除qrtz_job_details表对应记录了 -->        
  5.         <property name="overwriteExistingJobs" value="true" />        
  6.          <!--必须的，QuartzScheduler 延时启动，应用启动完后 QuartzScheduler 再启动 -->      
  7.         <property name="startupDelay" value="10" />      
  8.         <!-- 设置自动启动 -->      
  9.         <property name="autoStartup" value="true" />    
  10.         <property name="applicationContextSchedulerContextKey" value="applicationContextKey" />  
  11.         <property name="configLocation" value="classpath:spring-quartz.properties" />        
  12.     </bean>  
  13.       
  14.     <bean id="schedulerManage" class="cn.imovie.manage.task.SchedulerManage"></bean>  
  15.     <!-- 定时任务配置 end -->  

 

四、spring-quartz.properties 文件配置：

Java代码  技术分享
  1. #配置见：http://www.quartz-scheduler.org/documentation/quartz-2.2.x/configuration/ConfigJDBCJobStoreClustering.html  
  2. #============================================================================  
  3. # Configure Main Scheduler Properties    
  4. #============================================================================  
  5.   
  6. org.quartz.scheduler.instanceName = MyClusteredScheduler  
  7. org.quartz.scheduler.instanceId = AUTO  
  8.   
  9. #============================================================================  
  10. # Configure ThreadPool    
  11. #============================================================================  
  12.   
  13. org.quartz.threadPool.class = org.quartz.simpl.SimpleThreadPool  
  14. org.quartz.threadPool.threadCount = 25  
  15. org.quartz.threadPool.threadPriority = 5  
  16.   
  17. #============================================================================  
  18. # Configure JobStore    
  19. #============================================================================  
  20.   
  21. org.quartz.jobStore.misfireThreshold = 60000  
  22.   
  23. org.quartz.jobStore.class = org.quartz.impl.jdbcjobstore.JobStoreTX  
  24. org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate  
  25. org.quartz.jobStore.useProperties = false  
  26. org.quartz.jobStore.dataSource = myDS  
  27. org.quartz.jobStore.tablePrefix = QRTZ_  
  28.   
  29. org.quartz.jobStore.isClustered = true  
  30. org.quartz.jobStore.clusterCheckinInterval = 20000  

 

>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>>

?Copyright 蕃薯耀 2017年9月6日

http://www.cnblogs.com/fanshuyao/

Spring4整合quartz2.2.3，quartz动态任务

标签：tick   resume   delegate   分组   实体   tac   计划   存在   name   

原文地址：http://www.cnblogs.com/fanshuyao/p/7484784.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
迷上了代码！