在基于块的步骤中中止批处理作业

Question

我在 Spring Batch 中设置了一个有点线性的作业，它由几个步骤组成。如果在任何时候，单个步骤失败，则作业应该失败。

这些步骤由多个 tasklet 和一个基于块的步骤组成。即：

• 步骤 1
  • 小任务 1
• 步骤 2
  • 小任务 2
• 步骤 3
  • 读者
  • 处理器
  • 作家

如果出现问题，显而易见的做法是抛出异常。 Spring Batch 将处理此问题并记录所有内容。这种行为，尤其是打印堆栈跟踪，是不可取的，如果可以优雅地结束 Job 并将 Status 设置为 FAILED 会更好。

Tasklet 当前直接在StepContribution 上设置ExitStatus。它们也是使用流程构建的（这并不理想，但这些步骤会继续畅通无阻）。然后可以直接在 Tasklet 中处理问题。

但是，在基于块的方法中，我们无法访问StepContribution。我们只有StepExecution。在这里使用 setExitStatus 什么都不做。

我们使用的是构建器（JobBuilerFactory 和 StepBuilderFactory），而不是 XML 设置。

可能的解决方案：

1. 告诉或配置 Batch 如何处理异常（而不是打印堆栈跟踪）。
2. 在侦听器中捕获异常。不幸的是，Spring Batch 在到达@AfterStep 时已经捕获了异常。
3. 告诉步骤/作业我们不想继续（例如，在执行上下文中设置一个值或 StepContribution 的替代项。

Answer 1

据我所知，停止工作的唯一方法是抛出异常。没有其他优雅的方式告诉 Spring Batch “这个工作完成了，它失败了，直接进入 Failed，不要通过 GO 等等。”

虽然不是对原始问题的直接解决方案，但可以使用StepBuilder 的.exceptionHandler() 来获得对您抛出的异常的更多控制，例如记录它们。

public class LogAndRethrowExceptionHandler implements ExceptionHandler {
    private static final Logger LOGGER = Logger.getLogger(...);

    @Override
    public void handleException(RepeatContext repeatContext, Throwable throwable) throws Throwable {
        LOGGER.error(throwable.getMessage());
        throw throwable;
    }
}

这样，理论上你可以隐藏 Spring Batch 产生的堆栈跟踪，但仍然显示错误消息。

Answer 2

我认为您可以探索以下两个选项。

选项1：您可以使用noSkip 例外。

这明确防止某些异常（和子类）被跳过 抛出一些你想让工作失败的特定异常。

这是你可以配置帽子的方法

stepBuilderFactory.get("myStep")
                .<POJO, POJO> chunk(1000)
                .reader(reader)
                .processor(processor)
                .writer(writer)
                .faultTolerant()
                .noSkip(YourCustomException.class)
                .skip(Exception.class)
                .skipLimit(100) 

****Option 2** :** 您可以使用将退出状态设置为FAILED，以便在步骤完成后出现错误流

public class MyStepExecutionListener implements StepExecutionListener {

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {


    if(allIsGood()) // 
    {
         return ExitStatus.COMPLETED;
    }
    else if (someExceptionOrErrorCase()){   

        return ExitStatus.FAILED;
    }
 }

 }

希望对你有帮助