如何使用决策器终止Spring批次分割流中的步骤

Question

我在Spring Batch中发现了以下设计缺陷。

1. 步骤必须具有Next属性，除非它是拆分流的最后一步或最后一步。
2. 决定器块必须处理决定器返回的所有情况。

因此，在分割流中，最后一步不会有下一个属性，如果有决策者保护它，那么它必须有下一个属性。所以它不应该有这个属性，但它也需要它。第22条。

示例：

<!-- Process parallel steps -->
<split id="split01">
    <flow>
        <step id="step1" next="step02">
            <!-- Do something -->
        </step>
        <step id="step02">
            <!-- Do something else -->
        </step>
    </flow>
    <flow>
        <step id="step03">
            <!-- Do something -->
        </step>

        <!-- Only run under specific conditions -->
        <decision id="decideToRunStep04" decider="isStepNeededDecider" >
            <next on="RUN" to="step04"/>
            <!-- Other state is "SKIP" -->
        </decision>
        <step id="step04">
            <!-- Conditionally do something-->
        </step>
    </flow>
</split>

<step id="step05" >
    <!-- Some more stuff -->
</step>

这似乎是Spring的人会想到的，所以很好奇，实现这一点的正确、非黑客方式是什么。谢谢

Answer 1

在XML中

<batch:decision id="customerDecision" decider="customerDecider">
            <batch:next on="FILE_FAILURE" to="fileFailureStep" />
            <batch:next on="FILE_GENERATION" to="loadData" /> 
</batch:decision>

在customerDecider类中

public class CustomerDecider implements JobExecutionDecider {    
@Override
public FlowExecutionStatus decide(JobExecution jobExecution, StepExecution stepExecutionStatus) {
If(x)
    return new FlowExecutionStatus("FILE_FAILURE") ;
else
    return new FlowExecutionStatus("FILE_GENERATION") ;
}
}

Answer 2

Spring是城里最美的代码。也就是说：

<step id="step1" parent="s1">
    <end on="FAILED" />
    <next on="COMPLETED WITH SKIPS" to="errorPrint1" />
    <next on="*" to="step2" />
</step>

正如在http://docs.spring.io/spring-batch/reference/html/configureStep.html.

Answer 3

如果没有人回答这个问题，我将提供我正在使用的黑客。它不美，但Spring也不美。

创建一个无操作Tasklet，用于无操作步骤。

public class NoopTasklet implements Tasklet {
    @Override
    public RepeatStatus execute(final StepContribution contribution,
            final ChunkContext chunkContext) throws Exception {
        return RepeatStatus.FINISHED;
    }
}

将NOOP tasklet添加到原始示例中的决策块

<!-- Does nothing -->
<bean id="noopTasklet" class="com.foo.NoopTasklet" />

<!-- From example in question
<decision id="decideToRunStep04" decider="isStepNeededDecider" >
    <next on="RUN" to="step04"/>
    <next on="SKIP" to="noop01"/>
</decision>
<step id="step04">
    <!-- Conditionally do something-->
</step>
<step id="noop01">
    <!-- Does nothing in the SKIP case
    <tasklet ref="noopTasklet" />
</step>