SpringBoot RetryTemplate 实现 RockMq 异步消息发送失败重试

RockMq 是一个分布式消息中间件，它可以在不同的应用程序之间传递消息。然而，在异步发送消息时，可能会发生发送失败的情况。为了解决这个问题，我们可以使用 SpringBoot RetryTemplate 来实现消息发送的重试。

1. 引入依赖

在 pom.xml 文件中引入 SpringBoot RetryTemplate 的依赖：

<dependency>
    <groupId>org.springframework.retry</groupId>
    <artifactId>spring-retry</artifactId>
</dependency>

2. 配置 RetryTemplate

在 SpringBoot 配置文件中，配置 RetryTemplate 的 bean：

@Configuration
public class RetryConfig {
    @Bean
    public RetryTemplate retryTemplate() {
        RetryTemplate retryTemplate = new RetryTemplate();

        // 设置重试策略
        SimpleRetryPolicy retryPolicy = new SimpleRetryPolicy();
        retryPolicy.setMaxAttempts(3); // 最大重试次数
        retryTemplate.setRetryPolicy(retryPolicy);

        // 设置重试间隔
        FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
        backOffPolicy.setBackOffPeriod(1000); // 重试间隔 1 秒
        retryTemplate.setBackOffPolicy(backOffPolicy);

        return retryTemplate;
    }
}

3. 使用 RetryTemplate 进行重试

在发送 RockMq 消息的方法中，加入 RetryTemplate 进行重试：

@Autowired
private RetryTemplate retryTemplate;

public void sendMessage(final String message) {
    try {
        retryTemplate.execute(new RetryCallback() {
            @Override
            public Object doWithRetry(RetryContext context) throws Exception {
                // 发送消息的代码
                send(message);
                return null;
            }
        });
    } catch (Exception e) {
        // 重试 3 次后仍然发送失败，抛出异常
        throw new RuntimeException('发送消息失败：' + message, e);
    }
}

在上面的代码中，我们使用 RetryTemplate 的 execute 方法执行一个 RetryCallback，RetryCallback 中封装了发送消息的代码。如果发送失败，RetryTemplate 会根据我们配置的重试策略和重试间隔进行重试，直到达到最大重试次数为止。

如果重试 3 次后仍然发送失败，我们就抛出一个异常。这样，我们就可以在上层代码中捕获异常并进行处理了。