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

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

虽然不是原始问题的直接解决方案,但可以使用 .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批处理生成的堆栈跟踪,但仍然显示错误消息。

我认为你可以探索以下两种选择。

选项1: 您可以使用 noSkip 例外 .

这明确防止跳过某些异常(和子类) 抛出一些您希望作业失败的特定异常。

这是如何配置hat的

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

****选项2**:*您可以使用将退出状态设置为 失败 对于步骤完成后的错误流

public class MyStepExecutionListener implements StepExecutionListener {

    @Override
    public ExitStatus afterStep(StepExecution stepExecution) {


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

        return ExitStatus.FAILED;
    }
 }

 }

希望这有帮助

在我的例子中,我最终添加了条件并抛出 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);
    // }
  }

}