java - 使用 Quartz 运行 Spring Boot 应用

Question

我有这个 Spring Boot 应用程序。使用 Quartz(一个功能丰富的开源作业调度库，几乎可以集成到任何 Java 应用程序中)在每月 10 日执行作业

@EnableScheduling
@SpringBootApplication
public class IberiaUtilsApplication implements CommandLineRunner {

public static void main(String[] args) {
        SpringApplication app = new SpringApplication(IberiaUtilsApplication.class);
        app.run(args);
    }

    @Override
    public void run(String... args) throws Exception {
    ..
}
}

以及配置包内部:

@Configuration
public class JobConfig {

    @Bean
    public JobDetail sampleJobDetail() {
        return JobBuilder.newJob(MonthlyIberiaMetrics.class).withIdentity("iberiaJob")
                .usingJobData("iberiaMetrics", "fleet").storeDurably().build();
    }

    @Bean
    public Trigger sampleJobTrigger() {

        return newTrigger()
                .forJob(sampleJobDetail())
                .withIdentity("iberiaTrigger")
                .withSchedule(cronSchedule("0 0 10 10 * ?"))
                .build();               

    }
}

我运行该应用程序。从命令行，使用 mvn spring-boot:run 但似乎 Quartz 未初始化:

...
    017-10-31 15:11  [main] INFO  com.zaxxer.hikari.HikariDataSource - HikariPool-1 - Starting...
    2017-10-31 15:11  [main] WARN  c.z.hikari.util.DriverDataSource - Registered driver with driverClassName=oracle.jdbc.driver.OracleDriver was not found, trying direct instantiation.
    2017-10-31 15:12  [main] INFO  com.zaxxer.hikari.HikariDataSource - HikariPool-1 - Start completed.
    2017-10-31 15:12  [main] INFO  org.quartz.impl.StdSchedulerFactory - Using default implementation for ThreadExecutor
    2017-10-31 15:12  [main] INFO  o.quartz.core.SchedulerSignalerImpl - Initialized Scheduler Signaller of type: class org.quartz.core.SchedulerSignalerImpl
    2017-10-31 15:12  [main] INFO  org.quartz.core.QuartzScheduler - Quartz Scheduler v.2.3.0 created.
    2017-10-31 15:12  [main] INFO  org.quartz.simpl.RAMJobStore - RAMJobStore initialized.
    2017-10-31 15:12  [main] INFO  org.quartz.core.QuartzScheduler - Scheduler meta-data: Quartz Scheduler (v2.3.0) 'quartzScheduler' with instanceId 'NON_CLUSTERED'
      Scheduler class: 'org.quartz.core.QuartzScheduler' - running locally.
      NOT STARTED.
      Currently in standby mode.
      Number of jobs executed: 0
      Using thread pool 'org.quartz.simpl.SimpleThreadPool' - with 10 threads.
      Using job-store 'org.quartz.simpl.RAMJobStore' - which does not support persistence. and is not clustered.

    2017-10-31 15:12  [main] INFO  org.quartz.impl.StdSchedulerFactory - Quartz scheduler 'quartzScheduler' initialized from an externally provided properties instance.
    2017-10-31 15:12  [main] INFO  org.quartz.impl.StdSchedulerFactory - Quartz scheduler version: 2.3.0
    2017-10-31 15:12  [main] INFO  org.quartz.core.QuartzScheduler - JobFactory set to: org.springframework.boot.autoconfigure.quartz.AutowireCapableBeanJobFactory@64ea8964
    2017-10-31 15:12  [main] INFO  o.s.j.e.a.AnnotationMBeanExporter - Registering beans for JMX exposure on startup
    2017-10-31 15:12  [main] INFO  o.s.j.e.a.AnnotationMBeanExporter - Bean with name 'dataSource' has been autodetected for JMX exposure
    2017-10-31 15:12  [main] INFO  o.s.j.e.a.AnnotationMBeanExporter - Located MBean 'dataSource': registering with JMX server as MBean [com.zaxxer.hikari:name=dataSource,type=HikariDataSource]
    2017-10-31 15:12  [main] INFO  o.s.c.s.DefaultLifecycleProcessor - Starting beans in phase 2147483647
    2017-10-31 15:12  [main] INFO  o.s.s.quartz.SchedulerFactoryBean - Starting Quartz Scheduler now
    2017-10-31 15:12  [main] INFO  org.quartz.core.QuartzScheduler - Scheduler quartzScheduler_$_NON_CLUSTERED started.
    2017-10-31 15:12  [Thread-3] INFO  o.s.c.a.AnnotationConfigApplicationContext - Closing org.springframework.context.annotation.AnnotationConfigApplicationContext@589ebb: startup date [Tue Oct 31 15:11:56 CET 2017]; root of context hierarchy
    2017-10-31 15:12  [Thread-3] INFO  o.s.c.s.DefaultLifecycleProcessor - Stopping beans in phase 2147483647
    2017-10-31 15:12  [Thread-3] INFO  org.quartz.core.QuartzScheduler - Scheduler quartzScheduler_$_NON_CLUSTERED paused.
    2017-10-31 15:12  [Thread-3] INFO  o.s.s.quartz.SchedulerFactoryBean - Shutting down Quartz Scheduler
    2017-10-31 15:12  [Thread-3] INFO  org.quartz.core.QuartzScheduler - Scheduler quartzScheduler_$_NON_CLUSTERED shutting down.
    2017-10-31 15:12  [Thread-3] INFO  org.quartz.core.QuartzScheduler - Scheduler quartzScheduler_$_NON_CLUSTERED paused.
    2017-10-31 15:12  [Thread-3] INFO  org.quartz.core.QuartzScheduler - Scheduler quartzScheduler_$_NON_CLUSTERED shutdown complete.
    2017-10-31 15:12  [Thread-3] INFO  o.s.j.e.a.AnnotationMBeanExporter - Unregistering JMX-exposed beans on shutdown
    2017-10-31 15:12  [Thread-3] INFO  o.s.j.e.a.AnnotationMBeanExporter - Unregistering JMX-exposed beans
    2017-10-31 15:12  [Thread-3] INFO  com.zaxxer.hikari.HikariDataSource - HikariPool-1 - Shutdown initiated...
    2017-10-31 15:12  [Thread-3] INFO  com.zaxxer.hikari.HikariDataSource - HikariPool-1 - Shutdown completed.
    MacBook-Pro-de-lopes:iberiaUtils lopes$ 

我还尝试将表达式更改为 0 * * * * ? (每分钟)，但结果相同

并且还创建了另一个具有相同结果的类:

public class ScheduledTasks1 {


    private static final SimpleDateFormat dateFormat = new SimpleDateFormat("HH:mm:ss");

    @Scheduled(cron = "0 * * * * ?")
    public void reportCurrentTime() {

        System.out.println("The time is now {}" +
                dateFormat.format(new Date()));

    }
}

供您引用，我有另一个类似的应用程序，没有 Quartz 属性 并且工作正常:

@SpringBootApplication
public class IberiaReservationsApplication {

    public static void main(String[] args) {
        SpringApplication.run(IberiaReservationsApplication.class, args);
    }

    @Bean
    public JobDetail sampleJobDetail() {
        return JobBuilder.newJob(CheckDBJobExecution.class).withIdentity("sampleJob")
                .usingJobData("name", "World").storeDurably().build();
    }

    @Bean
    public Trigger sampleJobTrigger() {
            return newTrigger()
                .forJob(sampleJobDetail())
                .withIdentity("sampleTrigger")
                .withSchedule(cronSchedule("0 0/2 8-17 * * ?"))
                .build();               

    }
}

Answer 1

您是否考虑过使用 Springs 自己的调度程序，它很容易配置，而且我一直发现它运行良好。 https://spring.io/guides/gs/scheduling-tasks/