1.
<!-- 加载定时任务：容器启动时自动加载20140812添加 songzhanliang -->
<bean id="scheduleJobConfig" class="com.shz.base.init.ScheduleJobConfig"> <constructor-arg index="0"> <ref bean="scheduleJobService" /> </constructor-arg> <!-- 定时任务是否随容器一起启动 --> <constructor-arg index="1" type="java.lang.Boolean"> <value>true</value> </constructor-arg> </bean>2.
public class ScheduleJobConfig implements InitializingBean {
Logger logger = Logger.getLogger(ScheduleJobConfig.class); //@Autowired private IScheduleJobService scheduleJobService; private Boolean autoStart ; public IScheduleJobService getScheduleJobService() { return scheduleJobService; } public void setScheduleJobService(IScheduleJobService scheduleJobService) { this.scheduleJobService = scheduleJobService; } public Boolean getAutoStart() { return autoStart; } public void setAutoStart(Boolean autoStart) { this.autoStart = autoStart; } public ScheduleJobConfig(IScheduleJobService scheduleJobService,Boolean autoStart) { this.setScheduleJobService(scheduleJobService) ; this.setAutoStart(autoStart) ; } /** * * @Description： * * @param arg0 * * @author:songzhanliang * * @Date :2014-8-12 下午2:40:01 * */ public void initialize() { //如果没有配置自行启动，则跳出此代码段 if(!this.getAutoStart()){ return ; } //如果配置自行启动，查询系统参数，启动相关定时任务 List<TJob> jobs = null; try{ jobs = this.scheduleJobService.find("from TJob model where model.jobState=1"); }catch(Exception e){ logger.error("==数据库查询异常:{位置：任务配置 [TJob]}:" + e.getStackTrace()); } //把查询到的结果集加载到ScheduleManager的日程表中 for (TJob scheduleJob:jobs) { String groupName = scheduleJob.getExeClass() ; String jobName = scheduleJob.getExeMethod() ; QuartzManager .addJob(groupName,jobName, QuartzJobBeanFactory.class, scheduleJob.getExeTime()); } } /** * * @Description： * * @throws Exception * * @author:songzhanliang * * @Date :2014-8-12 下午2:40:01 * */ @Override public void afterPropertiesSet() throws Exception { // TODO Auto-generated method stub initialize(); }}
/** * Quartz调度管理器 * * @author Administrator * */public class QuartzManager { private static String JOB_GROUP_NAME = "EXTJWEB_JOBGROUP_NAME"; private static String TRIGGER_GROUP_NAME = "EXTJWEB_TRIGGERGROUP_NAME"; /** * @Description: 添加一个定时任务，使用默认的任务组名，触发器名，触发器组名 * * @param sched * 调度器 * * @param jobName * 任务名 * @param cls * 任务 * @param time * 时间设置，参考quartz说明文档 * * @Title: QuartzManager.java */ public static void addJob(Scheduler sched, String jobName, @SuppressWarnings("rawtypes") Class cls, String time) { try { JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, cls);// 任务名，任务组，任务执行类 // 触发器 CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);// 触发器名,触发器组 trigger.setCronExpression(time);// 触发器时间设定 sched.scheduleJob(jobDetail, trigger); // 启动 if (!sched.isShutdown()) { sched.start(); } } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description: 添加一个定时任务 * * @param sched * 调度器 * * @param jobName * 任务名 * @param jobGroupName * 任务组名 * @param triggerName * 触发器名 * @param triggerGroupName * 触发器组名 * @param jobClass * 任务 * @param time * 时间设置，参考quartz说明文档 * * @Title: QuartzManager.java */ public static void addJob(Scheduler sched, String jobName, String jobGroupName, String triggerName, String triggerGroupName, @SuppressWarnings("rawtypes") Class jobClass, String time) { try { JobDetail jobDetail = new JobDetail(jobName, jobGroupName, jobClass);// 任务名，任务组，任务执行类 // 触发器 CronTrigger trigger = new CronTrigger(triggerName, triggerGroupName);// 触发器名,触发器组 trigger.setCronExpression(time);// 触发器时间设定 sched.scheduleJob(jobDetail, trigger); } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description: 修改一个任务的触发时间(使用默认的任务组名，触发器名，触发器组名) * * @param sched * 调度器 * @param jobName * @param time * * @Title: QuartzManager.java */ @SuppressWarnings("rawtypes") public static void modifyJobTime(Scheduler sched, String jobName, String time) { try { CronTrigger trigger = (CronTrigger) sched.getTrigger(jobName, TRIGGER_GROUP_NAME); if (trigger == null) { return; } String oldTime = trigger.getCronExpression(); if (!oldTime.equalsIgnoreCase(time)) { JobDetail jobDetail = sched.getJobDetail(jobName, JOB_GROUP_NAME); Class objJobClass = jobDetail.getJobClass(); removeJob(sched, jobName); addJob(sched, jobName, objJobClass, time); } } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description: 修改一个任务的触发时间 * * @param sched * 调度器 * * @param sched * 调度器 * @param triggerName * @param triggerGroupName * @param time * * @Title: QuartzManager.java */ public static void modifyJobTime(Scheduler sched, String triggerName, String triggerGroupName, String time) { try { CronTrigger trigger = (CronTrigger) sched.getTrigger(triggerName, triggerGroupName); if (trigger == null) { return; } String oldTime = trigger.getCronExpression(); if (!oldTime.equalsIgnoreCase(time)) { CronTrigger ct = (CronTrigger) trigger; // 修改时间 ct.setCronExpression(time); // 重启触发器 sched.resumeTrigger(triggerName, triggerGroupName); } } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description: 移除一个任务(使用默认的任务组名，触发器名，触发器组名) * * @param sched * 调度器 * @param jobName * * @Title: QuartzManager.java */ public static void removeJob(Scheduler sched, String jobName) { try { sched.pauseTrigger(jobName, TRIGGER_GROUP_NAME);// 停止触发器 sched.unscheduleJob(jobName, TRIGGER_GROUP_NAME);// 移除触发器 sched.deleteJob(jobName, JOB_GROUP_NAME);// 删除任务 } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description: 移除一个任务 * * @param sched * 调度器 * @param jobName * @param jobGroupName * @param triggerName * @param triggerGroupName * * @Title: QuartzManager.java */ public static void removeJob(Scheduler sched, String jobName, String jobGroupName, String triggerName, String triggerGroupName) { try { sched.pauseTrigger(triggerName, triggerGroupName);// 停止触发器 sched.unscheduleJob(triggerName, triggerGroupName);// 移除触发器 sched.deleteJob(jobName, jobGroupName);// 删除任务 } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description:启动所有定时任务 * * @param sched * 调度器 * * @Title: QuartzManager.java */ public static void startJobs(Scheduler sched) { try { sched.start(); } catch (Exception e) { throw new RuntimeException(e); } } /** * @Description:关闭所有定时任务 * * * @param sched * 调度器 * * * @Title: QuartzManager.java */ public static void shutdownJobs(Scheduler sched) { try { if (!sched.isShutdown()) { sched.shutdown(); } } catch (Exception e) { throw new RuntimeException(e); } } }