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

Question

我在Spring中设置了几个线性步骤。如果在任何一点上，一个步骤失败了，作业应该失败。

这些步骤包括多个微线程，然后是一个基于块的步骤。即。：

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

  如果出现问题，最明显的做法就是抛出异常。Spring Batch将处理此问题并记录所有内容。这种行为，尤其是打印堆栈跟踪，是不可取的，如果作业可以优雅地结束，并将状态设置为FAILED。

  Tasklet当前直接在Step贡献上设置Exitstatus。它们也是使用流构建的（这并不理想，但步骤可以不受阻碍地继续进行）。然后可以直接在Tasklet中处理这些问题。

  然而，在基于块的方法中，我们无法访问步骤贡献。我们只有步执行。使用setExitStatus在这里什么都不做。

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

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




Answer 1

在我的例子中，我最终添加了条件，并在读卡器和处理器中抛出了JobInterruptedException

import org.springframework.batch.core.BatchStatus;
import org.springframework.batch.core.JobInterruptedException;

public class CustomReader implements ItemReader<String> {

  @Override
  public String read() throws Exception {
    // ...

    // if ("condition to stop job") {
      throw new JobInterruptedException("Aborting Job", BatchStatus.ABANDONED);
    // }
  }

}

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) 

****选项2**：**您可以在步骤完成后将退出状态设置为FAILED以获取错误流

public class MyStepExecutionListener implements StepExecutionListener {

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {


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

        return ExitStatus.FAILED;
    }
 }

 }

希望这能有所帮助

Answer 3

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

虽然不是原始问题的直接解决方案，但可以使用。exceptionHandler（）是一个StepBuilder的，可以更好地控制抛出的异常，例如记录它们。

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生成的堆栈跟踪，但仍然显示错误消息。