1 packagecom.sh.test;2

3 importorg.quartz.CronTrigger;4 importorg.quartz.JobDetail;5 importorg.quartz.Scheduler;6 importorg.quartz.SchedulerFactory;7 importorg.quartz.impl.StdSchedulerFactory;8

9 /**

10 * @Description: 定时任务管理类11 *12 * @ClassName: QuartzManager13 * @Copyright: Copyright (c) 201514 *15 *@authorSH16 *@versionV2.017 */

18 public classQuartzManager {19 private static SchedulerFactory gSchedulerFactory = newStdSchedulerFactory();20 private static String JOB_GROUP_NAME = "EXTJWEB_JOBGROUP_NAME";21 private static String TRIGGER_GROUP_NAME = "EXTJWEB_TRIGGERGROUP_NAME";22

23 /**

24 * @Description: 添加一个定时任务，使用默认的任务组名，触发器名，触发器组名25 *26 *@paramjobName27 * 任务名28 *@paramcls29 * 任务30 *@paramtime31 * 时间设置，参考quartz说明文档32 *33 * @Title: QuartzManager.java34 * @Copyright: Copyright (c) 201535 *36 *@authorSH37 *@versionV2.038 */

39 @SuppressWarnings("unchecked")40 public static voidaddJob(String jobName, Class cls, String time) {41 try{42 Scheduler sched =gSchedulerFactory.getScheduler();43 JobDetail jobDetail = new JobDetail(jobName, JOB_GROUP_NAME, cls);//任务名，任务组，任务执行类44 //触发器

45 CronTrigger trigger = new CronTrigger(jobName, TRIGGER_GROUP_NAME);//触发器名,触发器组

46 trigger.setCronExpression(time);//触发器时间设定

47 sched.scheduleJob(jobDetail, trigger);48 //启动

49 if (!sched.isShutdown()) {50 sched.start();51 }52 } catch(Exception e) {53 throw newRuntimeException(e);54 }55 }56

57 /**

58 * @Description: 添加一个定时任务59 *60 *@paramjobName61 * 任务名62 *@paramjobGroupName63 * 任务组名64 *@paramtriggerName65 * 触发器名66 *@paramtriggerGroupName67 * 触发器组名68 *@paramjobClass69 * 任务70 *@paramtime71 * 时间设置，参考quartz说明文档72 *73 * @Title: QuartzManager.java74 * @Copyright: Copyright (c) 201575 *76 *@authorSH77 *@versionV2.078 */

79 @SuppressWarnings("unchecked")80 public static voidaddJob(String jobName, String jobGroupName,81 String triggerName, String triggerGroupName, Class jobClass,82 String time) {83 try{84 Scheduler sched =gSchedulerFactory.getScheduler();85 JobDetail jobDetail = new JobDetail(jobName, jobGroupName, jobClass);//任务名，任务组，任务执行类86 //触发器

87 CronTrigger trigger = new CronTrigger(triggerName, triggerGroupName);//触发器名,触发器组

88 trigger.setCronExpression(time);//触发器时间设定

89 sched.scheduleJob(jobDetail, trigger);90 } catch(Exception e) {91 throw newRuntimeException(e);92 }93 }94

95 /**

96 * @Description: 修改一个任务的触发时间(使用默认的任务组名，触发器名，触发器组名)97 *98 *@paramjobName99 *@paramtime100 *101 * @Title: QuartzManager.java102 * @Copyright: Copyright (c) 2015103 *104 *@authorSH105 *@versionV2.0106 */

107 @SuppressWarnings("unchecked")108 public static voidmodifyJobTime(String jobName, String time) {109 try{110 Scheduler sched =gSchedulerFactory.getScheduler();111 CronTrigger trigger =(CronTrigger) sched.getTrigger(jobName,TRIGGER_GROUP_NAME);112 if (trigger == null) {113 return;114 }115 String oldTime =trigger.getCronExpression();116 if (!oldTime.equalsIgnoreCase(time)) {117 JobDetail jobDetail =sched.getJobDetail(jobName,JOB_GROUP_NAME);118 Class objJobClass =jobDetail.getJobClass();119 removeJob(jobName);120 addJob(jobName, objJobClass, time);121 }122 } catch(Exception e) {123 throw newRuntimeException(e);124 }125 }126

127 /**

128 * @Description: 修改一个任务的触发时间129 *130 *@paramtriggerName131 *@paramtriggerGroupName132 *@paramtime133 *134 * @Title: QuartzManager.java135 * @Copyright: Copyright (c) 2015136 *137 *@authorSH138 *@versionV2.0139 */

140 public static voidmodifyJobTime(String triggerName,141 String triggerGroupName, String time) {142 try{143 Scheduler sched =gSchedulerFactory.getScheduler();144 CronTrigger trigger =(CronTrigger) sched.getTrigger(triggerName,triggerGroupName);145 if (trigger == null) {146 return;147 }148 String oldTime =trigger.getCronExpression();149 if (!oldTime.equalsIgnoreCase(time)) {150 CronTrigger ct =(CronTrigger) trigger;151 //修改时间

152 ct.setCronExpression(time);153 //重启触发器

154 sched.resumeTrigger(triggerName, triggerGroupName);155 }156 } catch(Exception e) {157 throw newRuntimeException(e);158 }159 }160

161 /**

162 * @Description: 移除一个任务(使用默认的任务组名，触发器名，触发器组名)163 *164 *@paramjobName165 *166 * @Title: QuartzManager.java167 * @Copyright: Copyright (c) 2015168 *169 *@authorSH170 *@versionV2.0171 */

172 public static voidremoveJob(String jobName) {173 try{174 Scheduler sched =gSchedulerFactory.getScheduler();175 sched.pauseTrigger(jobName, TRIGGER_GROUP_NAME);//停止触发器

176 sched.unscheduleJob(jobName, TRIGGER_GROUP_NAME);//移除触发器

177 sched.deleteJob(jobName, JOB_GROUP_NAME);//删除任务

178 } catch(Exception e) {179 throw newRuntimeException(e);180 }181 }182

183 /**

184 * @Description: 移除一个任务185 *186 *@paramjobName187 *@paramjobGroupName188 *@paramtriggerName189 *@paramtriggerGroupName190 *191 * @Title: QuartzManager.java192 * @Copyright: Copyright (c) 2015193 *194 *@authorSH195 *@versionV2.0196 */

197 public static voidremoveJob(String jobName, String jobGroupName,198 String triggerName, String triggerGroupName) {199 try{200 Scheduler sched =gSchedulerFactory.getScheduler();201 sched.pauseTrigger(triggerName, triggerGroupName);//停止触发器

202 sched.unscheduleJob(triggerName, triggerGroupName);//移除触发器

203 sched.deleteJob(jobName, jobGroupName);//删除任务

204 } catch(Exception e) {205 throw newRuntimeException(e);206 }207 }208

209 /**

210 * @Description:启动所有定时任务211 *212 *213 * @Title: QuartzManager.java214 * @Copyright: Copyright (c) 2015215 *216 *@authorSH217 *@versionV2.0218 */

219 public static voidstartJobs() {220 try{221 Scheduler sched =gSchedulerFactory.getScheduler();222 sched.start();223 } catch(Exception e) {224 throw newRuntimeException(e);225 }226 }227

228 /**

229 * @Description:关闭所有定时任务230 *231 *232 * @Title: QuartzManager.java233 * @Copyright: Copyright (c) 2015234 *235 *@authorSH236 *@versionV2.0237 */

238 public static voidshutdownJobs() {239 try{240 Scheduler sched =gSchedulerFactory.getScheduler();241 if (!sched.isShutdown()) {242 sched.shutdown();243 }244 } catch(Exception e) {245 throw newRuntimeException(e);246 }247 }248 }