返回到 Spring Batch 中的上一步

Question

我想使用 Spring Batch 实现一个类似于以下的 Job：

Step1 -----> Step2 --> End
  ^            |
  |            |
   ------------

在 Step2 中的某些条件下，由 Step2 的自定义 ExitCode 确定，要么再次启动 Step1，然后再启动 Step2，要么再次启动 Step2，否则处理将结束。

我的想象是这样的：

return jobBuilderFactory.get("jobName").incrementer(new RunIdIncrementer())
                .start(step1()).next(step2())
                    .on("condition1").end()
                .from(step1())
                    .on("condition2").to(step1()).end().build();

但是很明显，Step1经过Step2的condition2处理后，Step2就不会再启动了。

如何实现这样的递归批处理？

编辑：我设法找到了一个解决方案，但是，我还不知道它是否只是一个肮脏的解决方案，因为它似乎很简单：

jobBuilderFactory.get("jobName")
            .flow(step1())
            .next(step2())
                .on("launchStep1Again")
                    .to(step1())
            .from(step2())
                .on("endJobExecution")
                    .end().build().build();

因此，从使用 Fluent API 的 .start() 方法到其 .flow() 方法的简单更改似乎可以解决问题。

Answer 1

SpringBatch 不适用于处理递归循环。虽然您可以绕过它，但在失败和重新启动时会遇到问题。

SpringBatch 在其执行上下文中存储步骤的读取器和写入器的当前“位置”；为了能够在上次崩溃的位置重新启动作业。

因此，在作业重新启动的情况下，SpringBatch 将假定这是作业的第一次执行。

根据您的工作结构，这可能不是问题，但您必须牢记这一点。

在我看来，更好的解决方案是在工作之外实现处理循环，在一个单独的类中处理启动工作。

以下两个问题的答案可能有助于提出这样的解决方案：

Make a spring-batch job exit with non-zero code if an exception is thrown

Reset state before each Spring scheduled (@Scheduled) run

Answer 2

我认为你可以扩展 StepExecutionListenerSupport 类并修改你的配置如下：

<step id="step1" next="step2">
    <tasklet ref="step1Tasklet" allow-start-if-complete="true"/>
</step>
<step id="step2">
    <tasklet ref="step2Tasklet"/>
    <listeners>
        <listener ref="myListener"/>
    </listeners>
    <next on="Back" to="step1"/>
</step>

public class MyListener extends StepExecutionListenerSupport {
    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {
        if(wantToLoop) {
            return new ExitStatus("Back");
        } else {
            return stepExecution.getExitStatus();
        }
    }
}