Spring 重试 CompositeRetryPolicy 无效

Question

我正在使用具有以下 RetryTemplate 配置的 spring-retry 模块：

@EnableRetry
@Configuration
public class RetryConfig {

    @Bean
    public RetryTemplate retryTemplate() {
        final FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
        backOffPolicy.setBackOffPeriod(500);

        final SimpleRetryPolicy attemptsPolicy = new SimpleRetryPolicy();
        attemptsPolicy.setMaxAttempts(2);
        final TimeoutRetryPolicy timeoutPolicy = new TimeoutRetryPolicy();
        timeoutPolicy.setTimeout(2000);
        final CompositeRetryPolicy retryPolicy = new CompositeRetryPolicy();
        retryPolicy.setPolicies(new RetryPolicy[] {timeoutPolicy, attemptsPolicy});

        final RetryTemplate template = new RetryTemplate();
        template.setBackOffPolicy(backOffPolicy);
        template.setRetryPolicy(retryPolicy);
        return template;
    }
}

但是 TimeoutRetryPolicy（在 CompositeRetryPolicy 实例中使用）显然没有工作。

我正在注入 RetryTemplate 以使用 SOAP 服务，在某些情况下，响应时间超过 10 秒。但是，通过配置我相信它不应该超过 4 秒（2 秒超时 * 2 次尝试）。非常感谢您！

Answer 1

我遇到了同样的问题，不幸的是无法使用 spring-retry 解决。因此，我实现了自己的通用 class：RetryTemplate.java (gist link)。

它的使用很简单：

try {
    final int attempts = 2;
    final long timeout = 2000;
    final String foo = new RetryTemplate<String>(attempts, timeout).execute(() -> {
        // Your retryable logic here!
        return "Lorem ipsum";
    });
} catch (RetryException retryExpectedError) {
    // Your logic if the re-attempts is exceeded.
    // Note: RetryException is a simple inheritance of RuntimeException.
}

虽然我还没有实现控制回退，但那将是微不足道的。希望对您有所帮助！

Answer 2

首先是测试服务

@Service
public class RetrySoapServiceImpl implements RetryCallback<YourClass, YourException>{
    static private int i = 0;
        @Retryable(
        value = { YourException.class }, 
        maxAttempts = 300 //Just an Example. Try it with 6.
        @Override
        public PartnerWertelistenResponse doWithRetry(RetryContext arg0) throws YourException {
            System.out.println("Attempt "+i);
            i++;
            if (i<300) throw new YourException();
            else {
                System.out.println("No Exception");
                return null;
            }
        }       
}

现在是主要代码。

RetryTemplate template = new RetryTemplate();
        FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
        backOffPolicy.setBackOffPeriod(5000); //You'll become mesages every 5 Seconds.
        TimeoutRetryPolicy policy = new TimeoutRetryPolicy();
        policy.setTimeout(50000L); //you'll be back in 50 Seconds, so you schould'nt wait 300*5 Sec.
        template.setRetryPolicy(policy); //It's the last point
        template.setBackOffPolicy(backOffPolicy); //It's the time to repeat an attempt

        try {
            YourClass result2 = template.execute(new RetrySoapServiceImpl());
        } catch (YourException e) {
            System.out.println("parent Catch Attempt "+e.getClass().getName());
        }
        System.out.println("ready to return");

Spring 重试 CompositeRetryPolicy 无效

Spring Retry CompositeRetryPolicy is not working

java

spring

soap

spring-retry