当前位置: 首页 > 知识库问答 >
问题:

Quartz和Spring:动态调度

陶智
2023-03-14

我有一个web服务,它对某个作业进行动态调度。job是一个Java类,它扩展了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,它接收一个jobId、cron表达式,并调度一个新的StartJob(它将具有接收到的ID)。下面是我的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

}
<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);

我错过了什么?这样的配置正确吗?从工厂中检索到的作业和触发器是同一个类的新实例还是同一个类实例?

共有1个答案

龙俊良
2023-03-14

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

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

工作,则创建的作业具有新名称。

 类似资料:
  • 我想使用Quartz、Spring和Hibernate创建动态作业。用户与web服务交互以创建此类作业: NoaJobInstancesDAO是一个简单的DAO类,它利用了Hibernate的EntityManager: 问题是,当这个作业触发时,会抛出一个异常: 我不明白为什么!在Manager类中,我以这种方式安排作业 其中排定程序作为 Edit1:应用程序上下文的实例似乎正确。问题不可能在那

  • 我是新的spring批处理框架和石英调度器。我的任务是使用quartz调度器动态调度一个新的spring批处理作业。所有新的spring批处理作业的条目都在我的数据库中,具有触发器表达式。问题是,对于每一个来自数据库的新的spring批处理作业,我们需要将其包装在Quartz的调度器作业中。这就意味着,当有许多spring批处理作业时,就应该有许多批处理作业类来包装它们,并由quartz调度程序运

  • 我想使用Quartz和Oracle作为JobStore来安排作业。我看到了大多数使用RAMjobstore的示例(当然它不是持久的),但几乎没有任何一个可以帮助我满足Spring boot Quartz Oracle开发的需求。 如有任何指向代码示例或github项目的链接或帮助,将不胜感激。

  • 我正在挖掘一个项目,使用骆驼路线与石英调度器。我对环境有点不熟悉,但试图弄清楚发生了什么,以及所有东西是如何结合在一起的,同时试图改变功能。只是不知道怎么做。 该组件是部署到Apache Karaf的作业管理器。如果我有活动作业的调度(quartz cron),那么当cron字符串匹配时,该作业将运行。该计划可以被禁用(这设置切换自动启动标志从我可以告诉)。这正像预期的那样工作。 如果禁用调度,等