Quartz 和 Spring：动态调度

Question

我有一个 Web 服务，可以对某个作业进行 动态调度 。该作业是一个 Java class 扩展了 Quartz Job 接口

public class StartJob implements Job {
    private String jobId;
    private DAO dao;

    public void execute(JobExecutionContext context) throws JobExecutionException {

        JobDataMap dataMap = context.getMergedJobDataMap();

        //some logic here
    }

    // getters and setters
}

我还公开了一个 API，它接收一个 cron 表达式的 jobId，并安排一个将具有接收到的 ID 的新 StartJob。这是我的 Spring 配置:

@Configuration
@EnableTransactionManagement
@EnableJpaRepositories(basePackages = { "persistence.dao" })
@ImportResource({"spring-quartz-context.xml"})
public class BeanConfig {
    //wired from the xml
    @Autowired JobDetailFactoryBean jobDetailFactory;
    @Autowired CronTriggerFactoryBean cronTriggerFactory;

    @Bean
    public SchedulerFactoryBean schedulerFactoryBean() {
        SchedulerFactoryBean bean = new SchedulerFactoryBean();
        bean.setApplicationContextSchedulerContextKey("applicationContext");
        bean.setSchedulerName("MyScheduler");
        Map<String, Object> schedulerContextAsMap = new HashMap<String, Object>();
        bean.setSchedulerContextAsMap(schedulerContextAsMap);
        // quartzproperties not reported
        bean.setQuartzProperties(quartzProperties());

        return bean;
    }

    //other bean definitions

}

和spring-石英-config.xml

<bean name="complexJobDetail"
    class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
    <property name="jobClass" value="jobs.StartJob" />
    <property name="durability" value="true" />
</bean>

<bean id="cronTrigger" class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
    <property name="jobDetail" ref="complexJobDetail" />
    <property name="cronExpression" value="0/5 * * ? * SAT-SUN" />
</bean>

我想做的是这样的（伪代码）

JobDetail job = jobDetailFactory.getObject();
job.setName(aGeneratedUUID);
CronTrigger trigger = cronTriggerFactory.getObject();
trigger.setCronExpression(aDynamicCronExpression);

scheduler.schedule(job, trigger);

但问题是我无法更改作业名称，因此，仅安排了第一个作业。第一个作业使用 JobDetailFactoryBean 的名称 (complexJobDetail) 作为名称。

我在这里错过了什么？这个配置正确吗？作业和触发器是从工厂中检索到相同 class 的新实例还是它们是相同的 class 实例？

Answer 1

问题是我没有调用方法 afterPropertiesSet()。所以

jobDetailFactory.setName(generatedUUID);
jobDetailFactory.afterPropertiesSet();
JobDetail job = jobDetailFactory.getObject();

有效，创建的作业具有新名称。

Quartz 和 Spring：动态调度

Quartz and Spring: dynamic scheduling

java

spring

quartz-scheduler