在第一个作业执行完毕后运行第二个批处理作业

Question

我想一个接一个地运行两个工作。是的，我确实在网上搜索过，但他们有解决方案，包括在第一份工作中增加第二份工作。但我有不同的要求。我会在第一批作业执行完成后得到一个通知，而第二批作业只有在收到这个通知后才会运行。是否有可能在Spring Boot中一个接一个地运行两个作业。请救命！

Answer 1

最简单的解决方案是添加JobExecutionListener以便在FirstJob完成后进行回调。并且在afterjob回调中启动第二个作业。由于获得了第一个作业的executionContext，因此可以基于作业应用作业运行策略。

public class KpJobListener implements JobExecutionListener {

    private final static Logger LOG = LoggerFactory.getLogger(KpJobListener.class);

    private Job job;
    private JobLauncher jobLauncher;

    public KpJobListener(final Job job, final JobLauncher jobLauncher) {
        this.job = job;
        this.jobLauncher = jobLauncher;
    }

    @Override
    public void beforeJob(JobExecution jobExecution) {
        LOG.info("Starting job {}");
    }

    @Override
    public void afterJob(JobExecution jobExecution) {
        LOG.info("Job is completed job");
        CompletableFuture.runAsync(()->{
            try {
                jobLauncher.run(job, new JobParametersBuilder().toJobParameters());
            } catch (JobExecutionAlreadyRunningException | JobRestartException | JobInstanceAlreadyCompleteException
                    | JobParametersInvalidException e) {
                // TODO Auto-generated catch block
                e.printStackTrace();
            }
        });
    }

}

示例spring-batch.xml

<batch:job id="kpJob1" incrementer="jobIncrementer"
        restartable="true">
        <batch:listeners>
            <batch:listener>
                <bean class="com.kp.job.KpJobListener">
                    <constructor-arg name="job" ref="kpJob2" />
                    <constructor-arg name="jobLauncher" ref="jobLauncher" />
                </bean>
            </batch:listener>
        </batch:listeners>
        <batch:step id="kpJob1.step1" allow-start-if-complete="true">
            <batch:tasklet>
                <bean class="com.kp.job.step.task.KpTasklet" />
            </batch:tasklet>
        </batch:step>
    </batch:job>

您可以为消息传递服务增强这种方法，这可能是一个整洁的设计。