Quartz 调度程序未启动

Question

我正在创建一个使用 Quartz 的 Spring Boot 应用程序，这是我的quartz.yaml 文件，

org:
  quartz:
    dataSource:
      mySql:
        maxIdleTime: '60'
        idleConnectionValidationSeconds: '50'
        password: test2
        user: test2
        URL: jdbc:mysql://localhost:3306/schedules?useSSL=false
        driver: com.mysql.jdbc.Driver
        maxConnections: '10'
        validationQuery: select 0 from dual
    plugin:
      jobHistory:
        class: org.quartz.plugins.history.LoggingJobHistoryPlugin
        jobToBeFiredMessage: 'Job [{1}.{0}] to be fired by trigger [{4}.{3}], re-fire:
          {7}'
        jobFailedMessage: 'Job [{1}.{0}] execution failed with exception: {8}'
        jobWasVetoedMessage: 'Job [{1}.{0}] was vetoed. It was to be fired by trigger
          [{4}.{3}] at: {2, date, dd-MM-yyyy HH:mm:ss.SSS}'
        jobSuccessMessage: 'Job [{1}.{0}] execution complete and reports: {8}'
      triggerHistory:
        class: org.quartz.plugins.history.LoggingTriggerHistoryPlugin
        triggerFiredMessage: 'Trigger [{1}.{0}] fired job [{6}.{5}] scheduled at:
          {2, date, dd-MM-yyyy HH:mm:ss.SSS}, next scheduled at: {3, date, dd-MM-yyyy
          HH:mm:ss.SSS}'
        triggerCompleteMessage: 'Trigger [{1}.{0}] completed firing job [{6}.{5}]
          with resulting trigger instruction code: {9}. Next scheduled at: {3, date,
          dd-MM-yyyy HH:mm:ss.SSS}'
        triggerMisfiredMessage: 'Trigger [{1}.{0}] misfired job [{6}.{5}]. Should
          have fired at: {3, date, dd-MM-yyyy HH:mm:ss.SSS}'
    jobStore:
      maxMisfiresToHandleAtATime: '10'
      dataSource: mySql
      isClustered: 'false'
      class: org.quartz.impl.jdbcjobstore.JobStoreTX
      useProperties: 'true'
      misfireThreshold: '60000'
      driverDelegateClass: org.quartz.impl.jdbcjobstore.StdJDBCDelegate
      tablePrefix: QRTZ_
    threadPool:
      threadPriority: '5'
      class: org.quartz.simpl.SimpleThreadPool
      threadCount: '4'
    scheduler:
      instanceId: AUTO
      instanceName: SampleJobScheduler
      idleWaitTime: '10000'

我正在尝试使用 SQL 数据库，但它使用 ram。这是我收到的错误

调度程序类：'org.quartz.core.QuartzScheduler' - 正在运行 本地。未开始。目前处于待机模式。职位数量 执行：0 使用线程池“org.quartz.simpl.SimpleThreadPool”- 有 10 个线程。使用作业存储“org.quartz.simpl.RAMJobStore”- 这不支持持久化。并且不是聚类的。

这是我的配置

@Configuration
public class Config {

  @Value("${library.file-path.quartz}")
  Resource quartsPath;

  @Autowired private ApplicationContext applicationContext;

  @Bean
  public SchedulerFactoryBean scheduler(JobFactory factory) throws IOException {
    SchedulerFactoryBean schedulerFactory = new SchedulerFactoryBean();
    schedulerFactory.setQuartzProperties(quartzProperties());
    schedulerFactory.setJobFactory(factory);
    return schedulerFactory;
  }

  @Bean
  public SpringBeanJobFactory springBeanJobFactory() {
    AutoWiringSpringBeanJobFactory jobFactory = new AutoWiringSpringBeanJobFactory();
    jobFactory.setApplicationContext(applicationContext);
    return jobFactory;
  }

  public Properties quartzProperties() throws IOException {
    PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
    propertiesFactoryBean.setLocation(quartsPath);
    propertiesFactoryBean.afterPropertiesSet();
    return propertiesFactoryBean.getObject();
  }
}

Answer 1

我可以在 SchedulerFactoryBean 中设置数据源。
dataSource 是应用程序使用的 DataSource，并由 Spring 在该配置类中注入：

@Bean
public SchedulerFactoryBean schedulerFactoryBean() throws IOException {
    SchedulerFactoryBean factory = new SchedulerFactoryBean();
    factory.setJobFactory(springBeanJobFactory());
    factory.setQuartzProperties(quartzProperties());
    factory.setDataSource(dataSource);
    return factory;
}