在弹簧批处理中重试处理逻辑

Question

我正在开发一个spring批处理应用程序。我想重试处理器逻辑。在处理器中，我有一些数据库表要监视，我想根据这些监视的表更新一些其他表。有什么方法可以做到这一点？

Answer 1

您可以使用fault tolerant step重试项目。您可以配置重试的异常和重试限制。这是一个例子：

@Bean
public Step faultTolerantStep() {
    return stepBuilderFactory.get("faultTolerantStep")
                            .<String, String>chunk(2)
                            .reader(itemReader())
                            .processor(itemProcessor())
                            .writer(itemWriter())
                            .faultTolerant()
                            .retryLimit(3)
                            .retry(MyTransientException.class)
                            .build();
}

在此示例中，当从处理器或编写器抛出MyTransientException时，该项目最多将重试3次。

希望这可以帮助。