java - 如果出现某种类型的异常，请重新启动批处理作业/步骤

Question

我在步骤/读取器中进行了操作，它可以抛出一些扩展 RuntimeException 的异常。我需要重新启动此步骤，以防引发此异常。我尝试过类似的事情:

@Bean
public SimpleRetryPolicy createSimpleRetryPolicy() {
    Map<Class<? extends Throwable>, Boolean> map = new HashMap<>();
    map.put(Exception.class, true);
    return new SimpleRetryPolicy(3, map, true);
}

@Bean
public Step statisticsImportStep(StepBuilderFactory stepBuilderFactory, PageStatusFetcherReader reader, PageStatusFetcherProcessor processor, PageStatusFetcherWriter writer, TaskExecutor taskExecutor, SimpleRetryPolicy simpleRetryPolicy) {
    return stepBuilderFactory.get("statisticsImportStep")
            .<String, String>chunk(10)
            .reader(reader)
            .processor(processor)
            .writer(writer)
            .faultTolerant()
            .retryPolicy(simpleRetryPolicy)
            .taskExecutor(taskExecutor)
            .throttleLimit(20)
            .build();
}

但是这样我收到了:

org.springframework.batch.core.step.skip.NonSkippableReadException: Non-skippable exception during read

知道如何重新启动此作业吗？(我无法在阅读器中尝试 catch() 异常)upd:它不想重新启动任何类型的异常。

Answer 1

我认为您需要添加一个ExceptionHandler来重试托管Exception。似乎默认实现已经存在:SimpleRetryExceptionHandler .

这应该像 XML 一样工作:

<skippable-exception-classes>
    <include class="xx.xx.xx.Exception"/>
</skippable-exception-classes>

您可以尝试使用以下命令添加它:exceptionHandler(ExceptionHandler exceptionHandler)

我找不到任何如何实际使用它的示例:(