Spring批处理作业执行监听器-访问JobStep定义的子作业的详细信息

Question

我有一份工作（父母工作）的工作（孩子）。在父作业的jobexecution侦听器中，我希望访问每个子作业的所有细节（作业名、步骤名、读/写计数等）。我怎样才能做到这一点？

public class ParentJobConfig {

    @Bean
    public Job job1() {
        Job job = jobBuilderFactory.get("JOB1")
                .incrementer(new RunIdIncrementer())
                .start(step11())
                .next(step12())
                .build();
        return job;
    }

    @Bean
    public Job job2() {
        Job job = jobBuilderFactory.get("JOB2")
                .incrementer(new RunIdIncrementer())
                .start(step21())
                .next(step22())
                .build();
        return job;
    }

    @Bean
    public Step jobStep1() {
        Step step = stepBuilderFactory.get("JOB-STEP1")
                .job(job1())
                .parametersExtractor(new DefaultJobParametersExtractor())
                .build();
        return step;
    }

    @Bean
    public Step jobStep2() {
        Step step = stepBuilderFactory.get("JOB-STEP2")
                .job(job2())
                .parametersExtractor(new DefaultJobParametersExtractor())
                .build();
        return step;
    }

    @Bean
    public Job parentJob() {
        Job job = jobBuilderFactory.get("PARENT-JOB")
                .incrementer(new RunIdIncrementer())
                .start(jobStep1())
                .next(jobStep2())
                .listener(parentJobExecutionListener())
                .build();
        return job;
    }

    @Bean
    public JobExecutionListener parentJobExecutionListener() {
        return new ParentJobExecutionListener ();
    }
}

public class ParentJobExecutionListener extends JobExecutionListenerSupport {

    @Override
    public void afterJob(JobExecution jobExecution) {
        List<StepExecution> stepExecutions = (List<StepExecution>) jobExecution.getStepExecutions();
        Collection<StepExecution> stepExecutions = jobExecution.getStepExecutions();
        for (StepExecution stepExecution : stepExecutions) {
            System.out.println("Step Name: " + stepExecution.getStepName());
            System.out.println("Read Count: " + stepExecution.getReadCount());
            System.out.println("Skip Count: " + stepExecution.getSkipCount());
            System.out.println("Write Count: " + stepExecution.getWriteCount());
        }
    }
}

Answer 1

我没有看到一种明显的方法来访问这里创建的子作业执行:https://github.com/spring-projects/spring-batch/blob/d8fc58338d3b059b67b77adc132d2564d7402/spring-batch-core/src/main/java/org/springframework/batch/core/step/jobstep.java#l119（只有状态反映在步骤执行上）。

您所能做的就是在侦听器中使用作业资源管理器，并查询存储库中的子作业执行。