• 定时任务quartz


    原文:https://www.cnblogs.com/rinack/p/7815272.html

    package com.common.util;
    import org.quartz.CronScheduleBuilder;
    import org.quartz.CronTrigger;
    import org.quartz.Job;
    import org.quartz.JobBuilder;
    import org.quartz.JobDetail;
    import org.quartz.JobKey;
    import org.quartz.Scheduler;
    import org.quartz.SchedulerException;
    import org.quartz.SchedulerFactory;
    import org.quartz.Trigger;
    import org.quartz.TriggerBuilder;
    import org.quartz.TriggerKey;
    import org.quartz.impl.StdSchedulerFactory;
      
    /** 
     *  
     * @Description 
     * @author qgw 
     * 2016 上午10:05:59 ^_^ 
     */  
    public class QuartzManager {  
        private static SchedulerFactory gSchedulerFactory = new StdSchedulerFactory();    
        private static String JOB_GROUP_NAME = "MY_JOBGROUP_NAME";    
        private static String TRIGGER_GROUP_NAME = "MY_TRIGGERGROUP_NAME";    
        
        /** 
         * @Description: 添加一个定时任务,使用默认的任务组名,触发器名,触发器组名 
         * @param jobName 任务名 
         * @param cls 任务 
         * @param time 时间设置,参考quartz说明文档  
         * qgw 2016年1月21日 下午3:30:10 ^_^ 
         */  
        public static void addJob(String jobName, Class cls, String time,Object param) {    
            try {    
                Scheduler sched = gSchedulerFactory.getScheduler();    
                JobDetail job = JobBuilder.newJob(cls)  
                        .withIdentity(jobName, JOB_GROUP_NAME)  
                        .build();  
                // 添加具体任务方法  
                job.getJobDataMap().put("param", param);  
                // 表达式调度构建器  
                CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(time);  
                // 按新的cronExpression表达式构建一个新的trigger  
                Trigger trigger = TriggerBuilder  
                        .newTrigger()  
                        .withIdentity(jobName, TRIGGER_GROUP_NAME)  
                                .withSchedule(scheduleBuilder).build();  
      
                //交给scheduler去调度  
                sched.scheduleJob(job, trigger);  
                  
                // 启动    
                if (!sched.isShutdown()) {    
                    sched.start();    
                }    
            } catch (Exception e) {    
                throw new RuntimeException(e);    
            }    
        }    
        /** 
         * @Description: 添加一个定时任务  
         * @param jobName 任务名 
         * @param jobGroupName 任务组名 
         * @param triggerName 触发器名  
         * @param triggerGroupName 触发器组名 
         * @param jobClass 任务 
         * @param time 时间设置,参考quartz说明文档 
         * qgw 2016年1月21日 下午3:27:00 ^_^ 
         */  
        public static void addJob(String jobName, String jobGroupName,    
                String triggerName, String triggerGroupName, Class jobClass,    
                String time,Object param) {    
            try {    
                Scheduler sched = gSchedulerFactory.getScheduler();    
                JobDetail job = JobBuilder.newJob(jobClass)  
                        .withIdentity(jobName, jobGroupName)  
                        .build();  
                
                job.getJobDataMap().put("param", param);
                // 表达式调度构建器  
                CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(time);  
                // 按新的cronExpression表达式构建一个新的trigger  
                Trigger trigger = TriggerBuilder  
                        .newTrigger()  
                        .withIdentity(triggerName, triggerGroupName)  
                                .withSchedule(scheduleBuilder).build();  
                sched.scheduleJob(job, trigger);   
                // 启动    
                if (!sched.isShutdown()) {    
                    sched.start();    
                }    
            } catch (Exception e) {    
                throw new RuntimeException(e);    
            }    
        }    
        
        /** 
         * @Description: 修改一个任务的触发时间(使用默认的任务组名,触发器名,触发器组名)  
         * @param jobName 
         * @param time 
         * qgw 2016年1月21日 下午3:28:34 ^_^ 
         */  
        public static void modifyJobTime(String jobName, String time) {   
            TriggerKey triggerKey = TriggerKey.triggerKey(  
                    jobName, TRIGGER_GROUP_NAME);  
              
            try {    
                Scheduler sched = gSchedulerFactory.getScheduler();    
                CronTrigger trigger =(CronTrigger) sched.getTrigger(triggerKey);  
                if (trigger == null) {    
                    return;    
                }    
                String oldTime = trigger.getCronExpression();    
                if (!oldTime.equalsIgnoreCase(time)) {  
                    CronScheduleBuilder scheduleBuilder =CronScheduleBuilder.cronSchedule(time);  
                    //按新的cronExpression表达式重新构建trigger  
                    trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)  
                    .withSchedule(scheduleBuilder).build();  
                    //按新的trigger重新设置job执行  
                    sched.rescheduleJob(triggerKey, trigger);  
                }    
            } catch (Exception e) {    
                throw new RuntimeException(e);    
            }    
        }    
        
        /** 
         * @Description: 修改一个任务的触发时间  
         * @param triggerName 
         * @param triggerGroupName 
         * @param time 
         * @author qgw  
         * @date 2016年1月27日 下午4:45:15 ^_^ 
         */  
        public static void modifyJobTime(String triggerName,    
                String triggerGroupName, String time) {   
            TriggerKey triggerKey = TriggerKey.triggerKey(  
                    triggerName, triggerGroupName);  
            try {    
                Scheduler sched = gSchedulerFactory.getScheduler();    
                CronTrigger trigger = (CronTrigger) sched.getTrigger(triggerKey);    
                if (trigger == null) {    
                    return;    
                }    
                String oldTime = trigger.getCronExpression();    
                if (!oldTime.equalsIgnoreCase(time)) {    
                    // trigger已存在,则更新相应的定时设置  
                    CronScheduleBuilder scheduleBuilder = CronScheduleBuilder  
                  .cronSchedule(time);  
                    // 按新的cronExpression表达式重新构建trigger  
                    trigger = trigger.getTriggerBuilder().withIdentity(triggerKey)  
                            .withSchedule(scheduleBuilder).build();  
                    // 按新的trigger重新设置job执行  
                    sched.resumeTrigger(triggerKey);  
                }    
            } catch (Exception e) {    
                throw new RuntimeException(e);    
            }    
        }    
        
        /** 
         * @Description 移除一个任务(使用默认的任务组名,触发器名,触发器组名) 
         * @param jobName 
         * @author qgw  
         * @date 2016年1月29日 下午2:21:16 ^_^ 
         */  
        public static void removeJob(String jobName) {   
            TriggerKey triggerKey = TriggerKey.triggerKey(  
                    jobName, TRIGGER_GROUP_NAME);  
            JobKey jobKey = JobKey.jobKey(jobName, JOB_GROUP_NAME);  
            try {    
                Scheduler sched = gSchedulerFactory.getScheduler();  
                Trigger trigger = (Trigger) sched.getTrigger(triggerKey);    
                if (trigger == null) {    
                    return;    
                }  
                sched.pauseTrigger(triggerKey);;// 停止触发器    
                sched.unscheduleJob(triggerKey);// 移除触发器    
                sched.deleteJob(jobKey);// 删除任务    
            } catch (Exception e) {    
                throw new RuntimeException(e);    
            }    
        }    
        
        /**  
         * @Description: 移除一个任务  
         * @param jobName  
         * @param jobGroupName  
         * @param triggerName  
         * @param triggerGroupName  
         * @author qgw  
         * @date 2016年1月29日 下午2:21:16 ^_^ 
         */    
        public static void removeJob(String jobName, String jobGroupName,    
                String triggerName, String triggerGroupName) {   
            TriggerKey triggerKey = TriggerKey.triggerKey(  
                    jobName, triggerGroupName);  
            JobKey jobKey = JobKey.jobKey(jobName, jobGroupName);  
            try {    
                Scheduler sched = gSchedulerFactory.getScheduler();   
                sched.pauseTrigger(triggerKey);// 停止触发器    
                sched.unscheduleJob(triggerKey);// 移除触发器    
                sched.deleteJob(jobKey);// 删除任务  
            } catch (Exception e) {    
                throw new RuntimeException(e);    
            }    
        }   
        /** 
         * @Description:暂停一个任务 
         * @param jobName 
         * @param jobGroupName 
         * qgw 2016年1月22日 下午4:24:55 ^_^ 
         */  
        public static void pauseJob(String jobName, String jobGroupName) {  
            JobKey jobKey =JobKey.jobKey(jobName, jobName);  
            try {  
                Scheduler sched = gSchedulerFactory.getScheduler();  
                sched.pauseJob(jobKey);  
            } catch (SchedulerException e) {  
                e.printStackTrace();  
            }  
        }  
        /** 
         * @Description:暂停一个任务(使用默认组名) 
         * @param jobName 
         * @param jobGroupName 
         * qgw 2016年1月22日 下午4:24:55 ^_^ 
         */  
        public static void pauseJob(String jobName) {  
            JobKey jobKey =JobKey.jobKey(jobName, JOB_GROUP_NAME);  
            try {  
                Scheduler sched = gSchedulerFactory.getScheduler();  
                sched.pauseJob(jobKey);  
            } catch (SchedulerException e) {  
                e.printStackTrace();  
            }  
        }  
        /**  
         * @Description:启动所有定时任务  
         * @author qgw  
         * @date 2016年1月29日 下午2:21:16 ^_^ 
         */  
        public static void startJobs() {    
            try {    
                Scheduler sched = gSchedulerFactory.getScheduler();    
                sched.start();    
            } catch (Exception e) {    
                throw new RuntimeException(e);    
            }    
        }    
        
        /** 
         * @Description 关闭所有定时任务  
         * @author qgw  
         * @date 2016年1月25日 下午2:26:54 ^_^ 
         */  
        public static void shutdownJobs() {    
            try {    
                Scheduler sched = gSchedulerFactory.getScheduler();    
                if (!sched.isShutdown()) {    
                    sched.shutdown();    
                }    
            } catch (Exception e) {    
                throw new RuntimeException(e);    
            }    
        }   
         
    }
    import java.util.ArrayList;  
    import java.util.HashMap;  
    import java.util.List;  
    import java.util.Map;  
      
    import net.sf.json.JSONObject;  
      
    import org.apache.log4j.Logger;  
    import org.quartz.DisallowConcurrentExecution;  
    import org.quartz.Job;  
    import org.quartz.JobExecutionContext;  
    import org.quartz.JobExecutionException;  
    import org.springframework.context.ApplicationContext;  
      
    /** 
     * 定时任务运行(反射出来的类) 
     * @Description 
     * @author qgw 
     * 2016 下午2:39:37 ^_^ 
     */  
    @DisallowConcurrentExecution  
    public class QuartzJobFactory implements Job {  
          
        private static final Logger log = Logger.getLogger("");  
        @Override  
        public void execute(JobExecutionContext context) throws JobExecutionException {  
              
            log.info("任务运行开始-------- start --------");   
            try {  
                //ScheduleJob任务运行时具体参数,可自定义  
                Object param =(Object) context.getMergedJobDataMap().get(  
                        "param");  
            }catch (Exception e) {  
                log.info("捕获异常==="+e);  
            }  
            log.info("任务运行结束-------- end --------");   
        }  
    }
  • 相关阅读:
    分布式系统学习一-概念篇
    JAVA多线程学习九-原子性操作类的应用
    JAVA多线程学习八-多个线程之间共享数据的方式
    JAVA多线程学习七-线程池
    vue 工作随笔
    智能云课堂整理
    mysql
    模板引挚 jade ejs
    node实战小例子
    昭山欢node资料学习笔记
  • 原文地址:https://www.cnblogs.com/BambooLamp/p/12400635.html
走看看 - 开发者的网上家园