Spring重试模板不能使用@org.springframework.transaction.annotation.transactional

Question

@Configuration
public class RetryTemplateConfig {

    @Bean
    public  RetryTemplate createRetryTemplate(){
        RetryTemplate retryTemplate = new RetryTemplate();

        FixedBackOffPolicy fixedBackOffPolicy = new FixedBackOffPolicy();
        fixedBackOffPolicy.setBackOffPeriod(5000l);
        retryTemplate.setBackOffPolicy(fixedBackOffPolicy);

        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
        retryPolicy.setMaxAttempts(5);
        retryTemplate.setRetryPolicy(retryPolicy);

        return retryTemplate;
    }

}


@Service
public class MessageService {

    @Autowired
    private RetryTemplate retryTemplate;

    @Autowired
    MessageRepo messageRepo;

    @Transactional
    public void sendMessage(Message message) throws RuntimeException{

        retryTemplate.execute(retryContext -> {
            log.info("Executing for {}  " ,  retryContext.getRetryCount());
            Message model = new Message();
            messageRepo.save(model);
            return "";
        });
    }
}

@Service
@EnableRetry
public class MessageService {

    @Autowired
    private RetryTemplate retryTemplate;

    @Autowired
    MessageRepo messageRepo;

    @Retryable(
            value = {RuntimeException.class},
            backoff = @Backoff(delay = 2000),
            maxAttempts = 5
    )
    @Transactional
    public void sendMessage(Message message) throws RuntimeException{
        Message model = new Message();
        messageRepo.save(model);
    }
}


    @Recover
    public void recover(){
        log.info("Recover is called ");
    }
}

有人能解释这两种不同行为的原因并建议我重新尝试的最佳方法吗？（我使用的是JPA数据）

Answer 1

在第一种情况下，当使用retryTemplate时，甚至在执行到达retryTemplate.execute(...)调用之前就会发生异常，因为spring无法打开所需的事务（通过@transactional注释，因为打开事务需要一个DB连接），

所以异常发生在spring framework级别，而不是在您的方法中，因此您的重试模板在这种情况下是无用的。

在第二种情况下，打开事务发生在重试范围内，因此重试捕获异常，一切正常。