Spring boot quartz 2.2.1编译错误

Question

这是我用来将新的 cron 作业保存到 postgresql 的代码 database.But 它显示了一些编译时间 exceptions.I 最初使用 [= 将 quartz 1.8.6 迁移到 2.2.1 25=] 启动 web app.see 附件。

private static final String JOBNAME = "sampleJobRunner";
    private static final String JOB_GROUPNAME = "sampleGroup";

    public void saveScheduledTime(String name) throws SchedulerException, ParseException {
        Scheduler scheduler;
        CronTrigger trigger;
        String cronExp = null;
        scheduler = this.quartzScheduler.getObject();
        trigger = (CronTrigger) scheduler.getTrigger(name, JOB_GROUPNAME);
        if (scheduler != null) {
                cronExp = "0 0 12 ? 1 MON#1 *";
            if (trigger != null) {
                rescheduleJob(scheduler, trigger.getName(), cronExp);
            } else {
                createNewCronTrigger(scheduler, cronExp, name);
            }
        }
    }
    private void rescheduleJob(Scheduler scheduler, String triggerName, String cronExp)
            throws SchedulerException, ParseException {
        CronTrigger trigger = (CronTrigger) scheduler.getTrigger(triggerName, JOB_GROUPNAME);
        trigger.setCronExpression(cronExp);
        scheduler.rescheduleJob(triggerName, JOB_GROUPNAME, trigger);
    }

    private void createNewCronTrigger(Scheduler scheduler, String cronExp, String sentType)
            throws SchedulerException, ParseException {
        CronTrigger trigger = new CronTrigger(sentType, JOB_GROUPNAME, JOBNAME, JOB_GROUPNAME, cronExp);
        scheduler.scheduleJob(trigger);
        scheduler.start();
    }

Spring 开机石英配置

@Configuration
@ConditionalOnProperty(name = "quartz.enabled")
public class SchedulerConfig {
    @Bean
    public JobFactory jobFactory(ApplicationContext applicationContext) {
        AutowiringSpringBeanJobFactory jobFactory = new AutowiringSpringBeanJobFactory();
        jobFactory.setApplicationContext(applicationContext);
        return jobFactory;
    }
    @Bean
    public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource, JobFactory jobFactory,
            @Qualifier("sampleJobTrigger") Trigger sampleJobTrigger) throws IOException {
        SchedulerFactoryBean factory = new SchedulerFactoryBean();
        // this allows to update triggers in DB when updating settings in config
        // file:
        factory.setOverwriteExistingJobs(true);
        factory.setDataSource(dataSource);
        factory.setJobFactory(jobFactory);
        factory.setQuartzProperties(quartzProperties());
        // factory.setTriggers(sampleJobTrigger);
        return factory;
    }

    @Bean
    public Properties quartzProperties() throws IOException {
        PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
        propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
        propertiesFactoryBean.afterPropertiesSet();
        return propertiesFactoryBean.getObject();
    }
    @Bean
    public JobDetailFactoryBean sampleJobDetail() {
        return createJobDetail(SampleJob.class);
    }
    @Bean(name = "sampleJobTrigger")
    public SimpleTriggerFactoryBean sampleJobTrigger(@Qualifier("sampleJobDetail") JobDetail jobDetail,
            @Value("${samplejob.frequency}") long frequency) {
        return createTrigger(jobDetail, frequency);
    }
    private static JobDetailFactoryBean createJobDetail(Class jobClass) {
        JobDetailFactoryBean factoryBean = new JobDetailFactoryBean();
        factoryBean.setJobClass(jobClass);
        // job has to be durable to be stored in DB:
        factoryBean.setDurability(true);
        return factoryBean;
    }
    private static SimpleTriggerFactoryBean createTrigger(JobDetail jobDetail, long pollFrequencyMs) {
        SimpleTriggerFactoryBean factoryBean = new SimpleTriggerFactoryBean();
        factoryBean.setJobDetail(jobDetail);
        factoryBean.setStartDelay(0L);
        factoryBean.setRepeatInterval(pollFrequencyMs);
        factoryBean.setRepeatCount(SimpleTrigger.REPEAT_INDEFINITELY);
        // in case of misfire, ignore all missed triggers and continue :
        factoryBean.setMisfireInstruction(SimpleTrigger.MISFIRE_INSTRUCTION_RESCHEDULE_NEXT_WITH_REMAINING_COUNT);
        return factoryBean;
    }
}

Answer 1

修复代码中的编译错误：

使用scheduler.getTrigger(new TriggerKey(name, JOB_GROUPNAME));
使用scheduler.rescheduleJob(new TriggerKey(name, JOB_GROUPNAME), trigger);
将 CronTrigger 转换为具有 setCronExpression() 方法的 CronTriggerImpl

在 github 上查看我的 Spring Boot + Quartz 示例项目：https://github.com/davidkiss/spring-boot-quartz-demo。我用新的 createCronTrigger 辅助方法更新了 SchedulerConfig class，该方法允许在 Spring Boot:

中创建 cron 触发器

  private static CronTriggerFactoryBean createCronTrigger(JobDetail jobDetail, String cronExpression) {
    CronTriggerFactoryBean factoryBean = new CronTriggerFactoryBean();
    factoryBean.setJobDetail(jobDetail);
    factoryBean.setCronExpression(cronExpression);
    factoryBean.setMisfireInstruction(SimpleTrigger.MISFIRE_INSTRUCTION_FIRE_NOW);
    return factoryBean;
  }

如果您在项目中使用 Spring Boot，我相信使用 SchedulerConfig class 是在 Spring Boot 中配置石英作业然后调用 saveScheduledTime() 方法的一种更简洁的方法.

为了创建任何 cron 触发器，我会在 SchedulerConfig class 中添加其他方法来创建类似于 sampleJobTrigger 的适当触发器 bean。

Answer 2

这纯粹是从 Quartz 1.8.6 迁移到 2.2.1 的结果。 Quartz 对 2.x 版本做了一些代码更改。您需要在应用程序中进行更改以尊重这一点。看看这个：http://www.quartz-scheduler.org/documentation/quartz-2.x/migration-guide.html

Spring boot quartz 2.2.1编译错误

Spring boot quartz 2.2.1 compilation error

postgresql

spring

quartz-scheduler

spring-boot