Quartz實(shí)現(xiàn)JAVA定時(shí)任務(wù)的動(dòng)態(tài)配置的方法

<!-- quartz -->
<dependency>
 <groupId>org.quartz-scheduler</groupId>
 <artifactId>quartz</artifactId>
 <version>2.2.1</version>
</dependency>
<dependency>
 <groupId>org.springframework</groupId>
 <artifactId>spring-context-support</artifactId>
</dependency>

CREATE TABLE `sys_task` (
 `id` bigint(20) NOT NULL AUTO_INCREMENT,
 `job_name` varchar(255) DEFAULT NULL COMMENT '任務(wù)名',
 `description` varchar(255) DEFAULT NULL COMMENT '任務(wù)描述',
 `cron_expression` varchar(255) DEFAULT NULL COMMENT 'cron表達(dá)式',
 `bean_class` varchar(255) DEFAULT NULL COMMENT '任務(wù)執(zhí)行時(shí)調(diào)用哪個(gè)類的方法 包名+類名',
 `job_status` varchar(255) DEFAULT NULL COMMENT '任務(wù)狀態(tài)',
 `job_group` varchar(255) DEFAULT NULL COMMENT '任務(wù)分組',
 `create_user` varchar(64) DEFAULT NULL COMMENT '創(chuàng)建者',
 `create_time` datetime DEFAULT NULL COMMENT '創(chuàng)建時(shí)間',
 `update_user` varchar(64) DEFAULT NULL COMMENT '更新者',
 `update_time` datetime DEFAULT NULL COMMENT '更新時(shí)間',
 PRIMARY KEY (`id`)
) ENGINE=MyISAM AUTO_INCREMENT=32 DEFAULT CHARSET=utf8;

@Configuration
public class QuartzConfigration {

 @Autowired
 private JobFactory jobFactory;

 @Bean
 public SchedulerFactoryBean schedulerFactoryBean() {
  SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
  try {
   schedulerFactoryBean.setOverwriteExistingJobs(true);
   schedulerFactoryBean.setQuartzProperties(quartzProperties());
   schedulerFactoryBean.setJobFactory(jobFactory);
  } catch (Exception e) {
   e.printStackTrace();
  }
  return schedulerFactoryBean;
 }

 // 指定quartz.properties，可在配置文件中配置相關(guān)屬性
 @Bean
 public Properties quartzProperties() throws IOException {
  PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
  propertiesFactoryBean.setLocation(new ClassPathResource("/config/quartz.properties"));
  propertiesFactoryBean.afterPropertiesSet();
  return propertiesFactoryBean.getObject();
 }

 // 創(chuàng)建schedule
 @Bean(name = "scheduler")
 public Scheduler scheduler() {
  return schedulerFactoryBean().getScheduler();
 }
}

@Component
@Order(value = 1)
public class ScheduleJobInitListener implements CommandLineRunner {

 @Autowired
 TaskService scheduleJobService;

 @Override
 public void run(String... arg0) throws Exception {
  try {
   scheduleJobService.initSchedule();
  } catch (Exception e) {
   e.printStackTrace();
  }

 }

}

@Override
 public void initSchedule() throws SchedulerException {
  // 這里獲取任務(wù)信息數(shù)據(jù)
  List<TaskDO> jobList = taskMapper.list();
  for (TaskDO task : jobList) {
   if (JobStatusEnum.RUNNING.getCode().equals(task.getJobStatus())) {
    quartzManager.addJob(task);
   }
  }
 }

/**
  * 添加任務(wù)*/ 
 @SuppressWarnings("unchecked")
 public void addJob(TaskDO task) {
  try {
   // 創(chuàng)建jobDetail實(shí)例，綁定Job實(shí)現(xiàn)類
   // 指明job的名稱，所在組的名稱，以及綁定job類
   Class<? extends Job> jobClass = (Class<? extends Job>) (Class.forName(task.getBeanClass()).newInstance()
     .getClass());
   JobDetail jobDetail = JobBuilder.newJob(jobClass).withIdentity(task.getJobName(), task.getJobGroup())// 任務(wù)名稱和組構(gòu)成任務(wù)key
     .build();
   // 定義調(diào)度觸發(fā)規(guī)則
   // 使用cornTrigger規(guī)則
   Trigger trigger = TriggerBuilder.newTrigger().withIdentity(task.getJobName(), task.getJobGroup())// 觸發(fā)器key
     .startAt(DateBuilder.futureDate(1, IntervalUnit.SECOND))
     .withSchedule(CronScheduleBuilder.cronSchedule(task.getCronExpression())).startNow().build();
   // 把作業(yè)和觸發(fā)器注冊(cè)到任務(wù)調(diào)度中
   scheduler.scheduleJob(jobDetail, trigger);
   // 啟動(dòng)
   if (!scheduler.isShutdown()) {
    scheduler.start();
   }
  } catch (Exception e) {
   e.printStackTrace();
  }
 }

@Component
public class JobFactory extends AdaptableJobFactory {
 //這個(gè)對(duì)象Spring會(huì)幫我們自動(dòng)注入進(jìn)來(lái),也屬于Spring技術(shù)范疇.
 //為什么需要這個(gè)類呢，在我寫的這個(gè)demo中，大家可以將此類刪掉，發(fā)現(xiàn)程序也可以正確運(yùn)行，可是我為什么還是加上呢。
 //大家可以看下我們的任務(wù)類，大家可以看到Job對(duì)象的實(shí)例化過(guò)程是在Quartz中進(jìn)行的，這時(shí)候我們將spring的東西注入進(jìn)來(lái)，肯定是行不通的，所以需要這個(gè)類
 @Autowired
 private AutowireCapableBeanFactory capableBeanFactory;

 @Override
 protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
  //調(diào)用父類的方法
  Object jobInstance = super.createJobInstance(bundle);
  //進(jìn)行注入
  capableBeanFactory.autowireBean(jobInstance);
  return jobInstance;
 }
}

@DisallowConcurrentExecution //作業(yè)不并發(fā)
@Component
public class HelloWorldJob implements Job{

 @Override
 public void execute(JobExecutionContext arg0) throws JobExecutionException {
  
  System.out.println("歡迎使用yyblog,這是一個(gè)定時(shí)任務(wù) --小賣鋪的老爺爺!"+ DateUtils.fullTime(new Date()));
  
 }

}

public void pauseJob(TaskDO task) throws SchedulerException {
  JobKey jobKey = JobKey.jobKey(task.getJobName(), task.getJobGroup());
  scheduler.pauseJob(jobKey);
 }

 public void resumeJob(TaskDO task) throws SchedulerException {
  JobKey jobKey = JobKey.jobKey(task.getJobName(), task.getJobGroup());
  scheduler.resumeJob(jobKey);
 }

 public void deleteJob(TaskDO task) throws SchedulerException {
  JobKey jobKey = JobKey.jobKey(task.getJobName(), task.getJobGroup());
  scheduler.deleteJob(jobKey);
 }

public void runJobNow(TaskDO task) throws SchedulerException {
  JobKey jobKey = JobKey.jobKey(task.getJobName(), task.getJobGroup());
  scheduler.triggerJob(jobKey);
 }

public void updateJobCron(TaskDO task) throws SchedulerException {

  TriggerKey triggerKey = TriggerKey.triggerKey(task.getJobName(), task.getJobGroup());

  CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerKey);

  CronScheduleBuilder scheduleBuilder = CronScheduleBuilder.cronSchedule(task.getCronExpression());

  trigger = trigger.getTriggerBuilder().withIdentity(triggerKey).withSchedule(scheduleBuilder).build();

  scheduler.rescheduleJob(triggerKey, trigger);
 }