如何使用 Java 配置在 Spring 批处理中配置 RetryTemplate

Question

我正在尝试在 Spring 批处理中设置 RetryTemplate，但我找不到有关如何将 RetryTemplate 添加到 StepBuilderFactory 的示例。我发现这个例子是在 Spring 启动应用程序中设置它，https://dzone.com/articles/how-to-use-spring-retry-template 但在 Spring 批处理上没有运气。

我尝试使用 RetryTemplate 的原因是设置指数 BackOffPolicy (Spring Batch how to configure retry period for failed jobs)。

我想连接 RetryTemplate 就像设置 RetryTemplate Bean 一样简单，类似于它（来自@Mahmoud Ben Hassine 回答 Spring Batch how to configure retry period for failed jobs 的修改代码）：

@Bean
public RetryTemplate testExponentialBackoff() throws Exception {
        // configure backoff policy
        ExponentialBackOffPolicy exponentialBackOffPolicy = new ExponentialBackOffPolicy();
        exponentialBackOffPolicy.setInitialInterval(1000);
        exponentialBackOffPolicy.setMultiplier(2.0);
        exponentialBackOffPolicy.setMaxInterval(10000);

        // configure retry policy
        SimpleRetryPolicy simpleRetryPolicy = new SimpleRetryPolicy();
        simpleRetryPolicy.setMaxAttempts(5);

        // configure retry template
        RetryTemplate retryTemplate = new RetryTemplate();
        retryTemplate.setBackOffPolicy(exponentialBackOffPolicy);
        retryTemplate.setRetryPolicy(simpleRetryPolicy);
        return retryTemplate;
    }

我找不到将它连接到 StepBuilderFactory 的方法。 我想这会类似于“标准”重试：

  .faultTolerant()
  .retryLimit(3)
  .retry(ConnectTimeoutException.class)

有人 example/template 了解如何使用 Java 配置进行设置吗？

任何 help/example 表示赞赏。谢谢，马库斯。

Answer 1

如果您的目标是设置自定义退避策略，则无需为此提供完整的 RetryTemplate，您可以使用 FaultTolerantStepBuilder#backOffPolicy 方法来实现，例如：

// configure backoff policy
ExponentialBackOffPolicy exponentialBackOffPolicy = new ExponentialBackOffPolicy();
// customize exponentialBackOffPolicy as needed

Step step = stepBuilderFactory.get("step")
        .chunk(5)
        // configure reader/writer etc
        .faultTolerant()
        .backOffPolicy(exponentialBackOffPolicy)
        // set other properties
        .build();

现在，如果您真的想提供自定义 RetryOperations 对象，则需要扩展 FaultTolerantStepBuilder 并重写 createRetryOperations 方法。