quartz 配置动态定时任务

阳光穿透心脏的1/2处 2022-08-14 04:44 279阅读 0赞

Spring3.2  + quartz 1.7 先上配置文件

负责设置的类

public class ScheduleConfigManager \{  
 private static Logger log = Logger.getLogger(ScheduleConfigManager.class);

private Scheduler scheduler;  
   
 // 设值注入，通过setter方法传入被调用者的实例scheduler  
 public void setScheduler(Scheduler scheduler) \{  
  this.scheduler = scheduler;  
 \}  
   
 /\*\*  
  \* @return  
  \*/  
 public Scheduler getScheduler() \{  
  return scheduler;  
 \}  
 /\*\*  
  \* 重新设置表达式  
  \*  
  \* @param newExpression  
  \* @throws SchedulerException  
  \* @throws ParseException  
  \*/  
 public void reScheduleJob(String newExpression, String cronTrigger) throws SchedulerException,ParseException \{  
  log.info("\[newExpression="+ newExpression + ": cronTrigger=" +cronTrigger +"\]");  
  try \{  
   CronTriggerBean trigger = (CronTriggerBean)scheduler.getTrigger(cronTrigger,Scheduler.DEFAULT\_GROUP);     
   String originConExpression = trigger.getCronExpression();  
   if (!originConExpression.equalsIgnoreCase(newExpression)) \{  
    trigger.setCronExpression(newExpression);  
    scheduler.rescheduleJob(cronTrigger, Scheduler.DEFAULT\_GROUP, trigger);  
   \}  
  \} catch (java.text.ParseException e) \{  
   e.printStackTrace();  
  \}  
 \}

另一个累一面动态算出的时间

log.info("\[日落开灯定时任务时间表达式："+ time2.toString()+"\]");  
   manager.reScheduleJob(time2.toString(),"oncronTrigger");  
   log.info("\[日出关灯定时任务时间表达式："+ time1.toString()+"\]");  
   manager.reScheduleJob(time1.toString(),"offcronTrigger");

\----------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------------

Spring 3.2 + quartz 2.1.6 配置文件

主类

private StdScheduler scheduler;  
   
 // 设值注入，通过setter方法传入被调用者的实例scheduler  
 public void setScheduler(StdScheduler  scheduler) \{  
  this.scheduler = scheduler;  
 \}  
   
 /\*\*  
  \* @return  
  \*/  
 public StdScheduler  getScheduler() \{  
  return scheduler;  
 \}  
 /\*\*  
  \* 重新设置表达式  
  \*  
  \* @param newExpression  
  \* @throws SchedulerException  
  \* @throws ParseException  
  \*/  
 public void reScheduleJob(String newExpression, String cronTrigger) throws SchedulerException,ParseException \{  
  log.info("\[newExpression="+ newExpression + ": cronTrigger=" +cronTrigger +"\]");  
  TriggerKey triggerKey = TriggerKey.triggerKey(cronTrigger,Scheduler.DEFAULT\_GROUP);  
  //获取trigger，即在spring配置文件中定义的 bean id="myTrigger"  
  CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);  
  //表达式调度构建器  
  CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(newExpression);  
  //按新的cronExpression表达式重新构建trigger  
  trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();  
  //按新的trigger重新设置job执行  
  scheduler.rescheduleJob(triggerKey, trigger);  
 \}