Spring使用Quartz的顺序作业计划

Question

Spring使用Quartz的顺序作业计划

我有三个或更多的工作，这取决于他们各自以前的工作，他们将按顺序运行。如果作业1完成作业2运行，当作业2完成作业3运行。如果在上一个作业中发生任何错误，则不会激发下一个触发的作业。我试图了解工作链使用石英，但无法通过它。

作业顺序如下所示

Job 1 -> Job 2 -> Job 3

<beans ...>
    <bean name="scheduler1"
            class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
                <property name="jobClass"
                    value="com.abc.xyz.schedular.Scheduler1" />
                <property name="durability" value="true" />
            </bean>
            <bean id="trigger1"
            class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
                <property name="jobDetail" ref="scheduler1" />
                <property name="cronExpression" value="${scheduler1.cronExpression}" />
            </bean>
          <bean name="scheduler2"
            class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
                <property name="jobClass"
                    value="com.abc.xyz.schedular.Scheduler2" />
                <property name="durability" value="true" />
            </bean>
            <bean id="trigger2"
            class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
                <property name="jobDetail" ref="scheduler2" />
                <property name="cronExpression" value="${scheduler2.cronExpression}" />
            </bean>
            <bean name="scheduler3"
            class="org.springframework.scheduling.quartz.JobDetailFactoryBean">
                <property name="jobClass"
                    value="com.abc.xyz.schedular.Scheduler3" />
                <property name="durability" value="true" />
            </bean>
            <bean id="trigger3"
            class="org.springframework.scheduling.quartz.CronTriggerFactoryBean">
                <property name="jobDetail" ref="scheduler3" />
                <property name="cronExpression" value="${scheduler3.cronExpression}" />
            </bean>
        <bean name="jobScheduler"
            class="org.springframework.scheduling.quartz.SchedulerFactoryBean">
            <property name="triggers">
                <list>
                    <ref bean="trigger1" />
                    <ref bean="trigger2" />
                    <ref bean="trigger3" />
                </list>
            </property>
            <property name="autoStartup" value="${jobScheduler.autoStartup}" />
        </bean>
</beans>

public class Scheduler1 implements Job {

    private static final Logger log = (Logger) LogManager
            .getLogger(Scheduler.class.getName());

    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        try {
            SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);
            /*
             *  doing my heavy Process
             */
        } catch (Exception e) {
            log.error("Error in setExpiredAllPlans Schedular1 ");
        }
    }
}


public class Scheduler2 implements Job {

    private static final Logger log = (Logger) LogManager
            .getLogger(Scheduler.class.getName());

    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        try {
            SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);
            /*
             *  doing my heavy Process
             */
        } catch (Exception e) {
            log.error("Error in Schedular2 ");
        }
    }
}


public class Scheduler3 implements Job {

    private static final Logger log = (Logger) LogManager
            .getLogger(Scheduler.class.getName());

    @Override
    public void execute(JobExecutionContext arg0) throws JobExecutionException {
        try {
            SpringBeanAutowiringSupport.processInjectionBasedOnCurrentContext(this);
            /*
             *  doing my heavy Process
             */
        } catch (Exception e) {
            log.error("Error in setExpiredAllPlans Schedular3 ");
        }
    }
}

提前谢了。

Answer 1

为了将作业的执行链起来，您需要实现一个JobListener。在它的jobWasExecuted事件处理程序中，您需要定义作业链接逻辑，以便无论单个作业的执行需要多长时间，作业都按顺序执行。在这种情况下，您只需要第一个作业（作业1）的触发器，因为链接作业（作业2和作业3）将从事件处理程序“手动”触发。

您还可以使用JobChainingJobListener实现，该实现使您能够以编程方式在应用程序中定义简单的作业链。要定义作业链，您将使用addJobChainLink方法。

如果您想要一个健壮的解决方案，该解决方案将允许您避免在应用程序代码中硬编码作业链接逻辑，同时允许您在运行时通过GUI修改作业链接规则，而无需触摸、重新部署和重新启动应用程序，您可以考虑使用我们的产品QuartzDesk。QuartzDesk提供了一个强大的作业链接引擎，允许您实现各种常见的作业链接场景，包括调度（即，不是立即）执行链接（目标）作业、多个目标作业、本地/远程目标作业等。