使用石英调度程序在Spring启动中进行动态作业调度

Question

我想根据用户从UI提供的计划配置动态调度作业。当用户从UI保存新的计划配置时，该进程必须使用新的计划参数调用新作业。这样可以有n种配置来执行相同的工作。 Spring支持作业细节的实现和触发，如下所示。

定义jobdetail：

@Bean
public JobDetail jobDetail() {
    return JobBuilder.newJob().ofType(SampleJob.class)
      .storeDurably()
      .withIdentity("Qrtz_Job_Detail")  
      .withDescription("Invoke Sample Job service...")
      .build();
}

定义触发器：

@Bean
public Trigger trigger(JobDetail job) {
    return TriggerBuilder.newTrigger().forJob(job)
      .withIdentity("Qrtz_Trigger")
      .withDescription("Sample trigger")
      .withSchedule(simpleSchedule().repeatForever().withIntervalInHours(1))
      .build();
}

如何根据用户提供的参数传递作业详细信息的参数并动态触发？

Answer 1

最简单的方法是通过扩展SpringBeanJobFactory和@Override createJobInstance方法进行一些配置。然后你需要定义SchedulerFactoryBean，最后你的Scheduler：

@Configuration
public class SchedulerConfiguration {

    public class AutowireCapableBeanJobFactory extends SpringBeanJobFactory {

        private final AutowireCapableBeanFactory beanFactory;

        @Autowired
        public AutowireCapableBeanJobFactory(AutowireCapableBeanFactory beanFactory) {
            Assert.notNull(beanFactory, "Bean factory must not be null");
            this.beanFactory = beanFactory;
        }

        @Override
        protected Object createJobInstance(TriggerFiredBundle bundle) throws Exception {
            Object jobInstance = super.createJobInstance(bundle);
            this.beanFactory.autowireBean(jobInstance);
            this.beanFactory.initializeBean(jobInstance, null);
            return jobInstance;
        }
    }

    @Bean
    public SchedulerFactoryBean schedulerFactory(ApplicationContext applicationContext) {
        SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
        schedulerFactoryBean.setJobFactory(new AutowireCapableBeanJobFactory(applicationContext.getAutowireCapableBeanFactory()));
        return schedulerFactoryBean;
    }

    @Bean
    public Scheduler scheduler(ApplicationContext applicationContext) throws SchedulerException {
        Scheduler scheduler = schedulerFactory(applicationContext).getScheduler();
        scheduler.start();
        return scheduler;
    }
}

然后在应用程序的任何位置，例如在RestController中，您可以访问调度程序并安排新作业：

@RestController
public class ScheduleController {

    @Autowired
    private Scheduler scheduler;

    @GetMapping(value = "/schedule/{detail}/{desc}")
    public String scheduleJob(@PathVariable(value = "detail") String detail, @PathVariable(value = "desc") String desc) throws SchedulerException {
        JobDetail job = newJob(detail, desc);
        return scheduler.scheduleJob(job, trigger(job)).toString();
    }

    private JobDetail newJob(String identity, String description) {
        return JobBuilder.newJob().ofType(SimpleJob.class).storeDurably()
                .withIdentity(JobKey.jobKey(identity))
                .withDescription(description)
                .build();
    }

    private SimpleTrigger trigger(JobDetail jobDetail) {
        return TriggerBuilder.newTrigger().forJob(jobDetail)
                .withIdentity(jobDetail.getKey().getName(), jobDetail.getKey().getGroup())
                .withSchedule(SimpleScheduleBuilder.repeatSecondlyForever(1))
                .build();
    }
}

您可以从Scheduler控制所有日程安排（暂停，停止，重新启动，删除等...） - look at the documentation

Answer 2

这就是JobDataMap参数的用途。您可以使用这些参数将任意参数传递给作业和触发器。通常建议使用String参数值来避免各种序列化问题。 JobDataMap API提供了可用于将字符串值JobDataMap参数值转换为各种基本Java对象（Integer，Long，Double，Boolean等）的辅助方法。

请注意，可以在Trigger级别覆盖JobDetail级别上指定的JobDataMap参数。在JobDetail级别，您通常指定应该用于所有作业执行的公共参数和/或默认值，并覆盖这些默认值和/或在Trigger级别添加新参数。

有关详细信息，请参阅Quartz Javadoc：

JobBuilder.html#usingJobData

TriggerBuilder.html#usingJobData

JobDataMap.html