在执行 job=[job] 时检测到重复的步骤 [step2]。如果任一步骤失败，则重启时将再次执行这两个步骤

Spring Batch 决策程序将进入 forloop。我有以下要求。

If Step1执行，检查决策者()是否"NO"然后结束作业，如果"Yes"然后执行Step2，如果 Step2 已完成，则执行 Decisionr() f"NO"然后结束作业，如果"Yes"然后执行Step3.

有什么指导如何批量配置吗？

2020-12-08 11:41:11.473  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [step1]
step1
2020-12-08 11:41:11.493  INFO 16800 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [step1] executed in 20ms
2020-12-08 11:41:11.508  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [step2]
step2
2020-12-08 11:41:11.513  INFO 16800 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [step2] executed in 5ms
2020-12-08 11:41:11.568  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Duplicate step [step2] detected in execution of job=[job]. If either step fails, both will be executed again on restart.
2020-12-08 11:41:11.571  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [step2]
step2
2020-12-08 11:41:11.577  INFO 16800 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [step2] executed in 6ms
2020-12-08 11:41:11.585  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Duplicate step [step2] detected in execution of job=[job]. If either step fails, both will be executed again on restart.
2020-12-08 11:41:11.589  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [step2]
step2
2020-12-08 11:41:11.594  INFO 16800 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [step2] executed in 5ms
2020-12-08 11:41:11.601  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Duplicate step [step2] detected in execution of job=[job]. If either step fails, both will be executed again on restart.
2020-12-08 11:41:11.604  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [step2]
step2
2020-12-08 11:41:11.608  INFO 16800 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [step2] executed in 3ms
2020-12-08 11:41:11.616  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Duplicate step [step2] detected in execution of job=[job]. If either step fails, both will be executed again on restart.
2020-12-08 11:41:11.618  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [step2]
step2
2020-12-08 11:41:11.623  INFO 16800 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [step2] executed in 5ms
2020-12-08 11:41:11.630  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Duplicate step [step2] detected in execution of job=[job]. If either step fails, both will be executed again on restart.
2020-12-08 11:41:11.634  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [step2]
step2
2020-12-08 11:41:11.638  INFO 16800 --- [           main] o.s.batch.core.step.AbstractStep         : Step: [step2] executed in 4ms
2020-12-08 11:41:11.646  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Duplicate step [step2] detected in execution of job=[job]. If either step fails, both will be executed again on restart.
2020-12-08 11:41:11.648  INFO 16800 --- [           main] o.s.batch.core.job.SimpleStepHandler     : Executing step: [step2]
step2

Java代码

@Configuration
public class Config {
    @Autowired
    private JobBuilderFactory jobs;

    @Autowired
    private StepBuilderFactory steps;

    @Bean
    public Step step1() {
        return steps.get("step1")
                .tasklet((contribution, chunkContext) -> {
                    System.out.println("step1");
                    return RepeatStatus.FINISHED;
                })
                .build();
    }

    @Bean
    public JobExecutionDecider decider() {
        return (jobExecution, stepExecution) -> new FlowExecutionStatus("SUCCESS"); // or NO
    }

    @Bean
    public Step step2() {
        return steps.get("step2")
                .tasklet((contribution, chunkContext) -> {
                    System.out.println("step2");
                    return RepeatStatus.FINISHED;
                })
                .build();
    }

    @Bean
    public Step step3() {
        return steps.get("step3")
                .tasklet((contribution, chunkContext) -> {
                    System.out.println("step3");
                    return RepeatStatus.FINISHED;
                })
                .build();
    }
    
    
    @Bean
    public Step step5() {
        return steps.get("step5")
                .tasklet((contribution, chunkContext) -> {
                    System.out.println("Step 5");
                    return RepeatStatus.FINISHED;
                })
                .build();
    }
    
    
    @Bean
    public Step step4() {
        return steps.get("step4")
                .tasklet((contribution, chunkContext) -> {
                    System.out.println("Step 4");
                    return RepeatStatus.FINISHED;
                })
                .build();
    }

    @Bean
    public Job job() {
        return jobs.get("job")
                .incrementer(new RunIdIncrementer())
                .start(step1())
                .next(decider())
                .from(decider()).on("SUCCESS").to(step2())
                .from(decider()).on("NO").end()
                .from(step2()).on("COMPLETED").to(decider())
                        .from(decider()).on("SUCCESS").to(step3())
                        .from(decider()).on("NO").end()
                .end()
                .build();
    }
}

注意 - 由于安全限制，我无法从办公室工作站加载流程图:(

您的流程定义中有错误。这SUCCESS决策者的结果分为两个不同的步骤：

.from(decider()).on("SUCCESS").to(step2())

...

.from(decider()).on("SUCCESS").to(step3())

此外，转换定义来自step2是不完整的。您只定义了从第 2 步开始的转换COMPLETED:

.from(step2()).on("COMPLETED").to(decider())

你应该定义从step2对于其他情况也是如此。