无法从Spring Batch管理应用程序启动Spring TaskScheduler

Question

我有一个项目用于spring批处理管理，我有另一个项目与我的批处理作业。我可以通过管理控制台手动执行该作业（这意味着它加载良好并工作）。不过，该作业从不按照cron计划执行。

如果我使用main方法配置java类，并使用相同的作业xml文件将其作为java应用程序运行，则作业将按照cron调度运行（换句话说，在Spring batch管理控制台之外运行作业）。这还应该验证xml配置是否正常。

工作原理:project2 app.java

public static void main(String[] args) {
    String springConfig = "META-INF/spring/batch/jobs/scheduleTest.xml";
    ApplicationContext context = new ClassPathXmlApplicationContext(springConfig);
}

    <job id="test-job"
        xmlns="http://www.springframework.org/schema/batch">
        <step id="testJob">
            <tasklet transaction-manager="transactionManager" ref="testOutput"/>
        </step>
    </job>


    <bean id="testOutput" class="com.default.test.testOutput" />


    <task:scheduled-tasks>
        <task:scheduled ref="runIt" method="run" cron="30 * * * * ?" />
    </task:scheduled-tasks>

    <bean id="runIt" class="com.default.scheduler.RunScheduler">
        <property name="job" ref="test-job" />
        <property name="jobLauncher" ref="jobLauncher"/>
        <property name="runCron" value="true" />
    </bean>

有人看到我做错了什么吗？如有任何指示，将不胜感激。或者如果有人知道在SBA中使用Spring TaskScheduler（而不是quartz）的示例，这也会很有帮助。提前谢了。我的猜测是，cron表达式被存储到一个不再存在或SBA控制台不知道的应用程序上下文中。

Answer 1

我在SBA1.3.0.发行版中也遇到了同样的问题。它与手动加载上下文的main方法一起工作，但在SBA中它不运行TaskScheduler。

出于调试目的，我有一个ApplicationListener。在onApplicationEvent方法中，我手动创建并运行自己的TaskScheduler。

META-INF/spring/batch/jobs/sba-configuration.xml

<job id="test-job"
    xmlns="http://www.springframework.org/schema/batch">
    <step id="testJob">
        <tasklet transaction-manager="transactionManager" ref="testOutput"/>
    </step>
</job>

<bean id="testOutput" class="com.default.test.testOutput" />


<task:scheduled-tasks>
    <task:scheduled ref="runIt" method="run" cron="30 * * * * ?" />
</task:scheduled-tasks>

<bean id="runIt" class="com.default.scheduler.RunScheduler">
    <property name="job" ref="test-job" />
    <property name="jobLauncher" ref="jobLauncher"/>
    <property name="runCron" value="true" />
</bean>

<bean id="appContextListener" class="com.qmn.AppContextListener" />
<bean id="myJobRunner" class="com.qmn.MyJobRunner"/>
<task:scheduler id="scheduler" pool-size="10" />

public class AppContextListener implements ApplicationListener<ContextRefreshedEvent> {

    @Autowired
    private WebApplicationContext wac; //this context doesn't contain beans which are in sba-configuration.xml

    @Autowired
    private ThreadPoolTaskScheduler scheduler; //in sba-configuration.xml but doesn't have in wac. Spring still injects success.

    @Autowired
    private MyJobRunner myJobRunner; //in sba-configuration.xml but doesn't have in wac

    @Autowired
    private Job job; //in sba-configuration.xml but doesn't have in wac

    @Autowired
    private JobLauncher jobLauncher; // default jobLauncher of SBA

    @Override
    public void onApplicationEvent(ContextRefreshedEvent contextRefreshedEvent) {
        XmlWebApplicationContext context = contextRefreshedEvent.getSource() instanceof XmlWebApplicationContext ?
                (XmlWebApplicationContext) contextRefreshedEvent.getSource() : null;

        if(context != null && context.getNamespace().contains("Batch Servlet")) { // only work with my spring batch admin servlet
            myJobRunner.setJob(job);
            myJobRunner.setJobLauncher(jobLauncher);
            CronTrigger trigger = new CronTrigger("*/5 * * * * *");
            ScheduledFuture<?> scedulefuture = scheduler.schedule(myJobRunner, trigger);
        }
    }

}