如何禁用 dev 和 stg 环境的 Quartz 调度程序

Question

我有三个环境 dev、stg 和 prod 服务器。我有一个微服务项目，它有石英调度程序，用于以电子邮件形式发送每日报告。石英配置如下：

现在的问题是我希望用于发送每日报告邮件的quartz调度程序仅在生产环境服务器上注册和运行。我不希望调度程序在 stg 和 dev 环境服务器下执行。

我正在使用 AWS ec2 实例作为环境服务器。

任何人都可以告诉我该怎么做吗？我们有什么简单的配置可以实现这一点吗？

自动装配SpringBeanJobFactory.java

public final class AutowiringSpringBeanJobFactory extends SpringBeanJobFactory implements ApplicationContextAware {

    private transient AutowireCapableBeanFactory beanFactory;

    @Override
    public void setApplicationContext(final ApplicationContext context) {
        beanFactory = context.getAutowireCapableBeanFactory();
    }

    @Override
    protected Object createJobInstance(final TriggerFiredBundle bundle) throws Exception {
        final Object job = super.createJobInstance(bundle);
        beanFactory.autowireBean(job);
        return job;
    }
}

QuartzConfiguration.java

@Configuration
@ConditionalOnProperty(name = "quartz.enabled")
public class QuartzConfiguration {
    
    @Autowired
    List<Trigger> listOfTrigger;

    @Bean
    public JobFactory jobFactory(ApplicationContext applicationContext) {
        AutowiringSpringBeanJobFactory jobFactory = new AutowiringSpringBeanJobFactory();
        jobFactory.setApplicationContext(applicationContext);
        return jobFactory;
    }

    @Bean
    public SchedulerFactoryBean schedulerFactoryBean(DataSource dataSource, JobFactory jobFactory) throws IOException {
        SchedulerFactoryBean factory = new SchedulerFactoryBean();
        factory.setOverwriteExistingJobs(true);
        factory.setDataSource(dataSource);
        factory.setJobFactory(jobFactory);
        factory.setQuartzProperties(quartzProperties());
        if (!ApplicationUtil.isObjectEmpty(listOfTrigger)) {
            factory.setTriggers(listOfTrigger.toArray(new Trigger[listOfTrigger.size()]));
        }

        return factory;
    }

    @Bean
    public Properties quartzProperties() throws IOException {
        PropertiesFactoryBean propertiesFactoryBean = new PropertiesFactoryBean();
        propertiesFactoryBean.setLocation(new ClassPathResource("/quartz.properties"));
        propertiesFactoryBean.afterPropertiesSet();
        return propertiesFactoryBean.getObject();
    }

    public CronTriggerFactoryBean createCronTrigger(JobDetail jobDetail, String cronExpression) {
        CronTriggerFactoryBean factoryBean = new CronTriggerFactoryBean();
        factoryBean.setJobDetail(jobDetail);
        factoryBean.setTimeZone(TimeZone.getTimeZone("America/Los_Angeles"));
        factoryBean.setCronExpression(cronExpression);
        factoryBean.setMisfireInstruction(SimpleTrigger.MISFIRE_INSTRUCTION_FIRE_NOW);
        return factoryBean;
    }

    @SuppressWarnings("rawtypes")
    public JobDetailFactoryBean createJobDetail(Class jobClass) {
        JobDetailFactoryBean factoryBean = new JobDetailFactoryBean();
        factoryBean.setJobClass(jobClass);
        factoryBean.setDurability(true);
        return factoryBean;
    }
    
    @Bean
    public JobDetailFactoryBean dailyEmailJobDetail() {
        return createJobDetail(DailyReportScheduleJob.class);
    }

    @Bean(name = "dailyReportEmailSyncJobTrigger")
    public CronTriggerFactoryBean dailyReportEmailSyncJobTrigger(@Qualifier("dailyEmailJobDetail") JobDetail jobDetail, @Value("${cron.frequency.daily-report-trigger}") String frequency) {
        return createCronTrigger(jobDetail, frequency);
    }
}

石英.属性

org.quartz.scheduler.instanceName=springBootQuartzApp
org.quartz.scheduler.instanceId=AUTO
org.quartz.threadPool.threadCount=5
org.quartz.jobStore.class=org.quartz.impl.jdbcjobstore.JobStoreTX
org.quartz.jobStore.driverDelegateClass = org.quartz.impl.jdbcjobstore.StdJDBCDelegate
org.quartz.jobStore.useProperties=true
org.quartz.jobStore.misfireThreshold=60000
org.quartz.jobStore.tablePrefix=quartz_
org.quartz.jobStore.isClustered=true
org.quartz.jobStore.clusterCheckinInterval=20000
org.quartz.plugin.shutdownHook.class=org.quartz.plugins.management.ShutdownHookPlugin
org.quartz.plugin.shutdownHook.cleanShutdown=TRUE

bootstrap.yml

quartz:
  enabled: true
  
cron:
  frequency:
    daily-report-trigger: 0 0 9 1/1 * ? *

Answer 1

从属性中设置的应用程序名称来看，我假设您将其作为 spring-boot 应用程序运行。

我会考虑使用不同的配置文件运行应用程序，每个配置文件都与您的环境（开发、暂存、生产）相匹配。

请参阅 spring-profiles 了解更多信息

设置完成后，您可以在quartz配置bean中使用

@Profile

注释来根据活动配置文件限制bean的加载。

Answer 2

解决方法可能是以这种方式使用 setAutoStartup 方法

@Bean
SchedulerFactoryBean schedulerFactoryBean() {
    SchedulerFactoryBean schedulerFactoryBean = new SchedulerFactoryBean();
    schedulerFactoryBean.setAutoStartup(settings.enabled);
    if (settings.enabled) {
        ...
        schedulerFactoryBean.setWaitForJobsToCompleteOnShutdown(true);
        schedulerFactoryBean.setQuartzProperties(quartzProperties);
    } else {
        log.warn("Can't initialize Quartz because it's not enabled");
    }
    return schedulerFactoryBean;
}

因此，如果 settings.enabled 为 false，石英将不会被初始化，除非您显式启动石英并调用 start 方法。