RocketMQ 消息发送失败自动重试：使用 Spring RetryTemplate 实现

RetryTemplate 是 Spring Framework 中的一个重试模板，可以用来在出现异常时自动重试。在 RocketMQ 中，我们可以使用 RetryTemplate 来实现消息发送失败后的自动重试。

首先，需要在 pom.xml 中添加依赖：

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

在使用 RetryTemplate 之前，需要定义一个 RetryPolicy，用来决定重试的条件。例如，我们可以定义一个简单的 RetryPolicy，只在出现 RuntimeException 时重试：

public class SimpleRetryPolicy implements RetryPolicy {

    private int maxAttempts = 3;

    public SimpleRetryPolicy() {
    }

    public SimpleRetryPolicy(int maxAttempts) {
        this.maxAttempts = maxAttempts;
    }

    @Override
    public boolean canRetry(RetryContext context) {
        Throwable lastThrowable = context.getLastThrowable();
        if (lastThrowable instanceof RuntimeException && context.getRetryCount() < maxAttempts) {
            return true;
        } else {
            return false;
        }
    }

    @Override
    public RetryContext open(RetryContext parent) {
        return new DefaultRetryContext(parent);
    }

    @Override
    public void close(RetryContext context) {
    }

    @Override
    public void registerThrowable(RetryContext context, Throwable throwable) {
    }
}

然后，我们需要定义一个 RetryTemplate 对象，并设置 RetryPolicy 和 BackOffPolicy。BackOffPolicy 是用来决定重试间隔的策略，例如，我们可以定义一个固定的间隔时间：

RetryTemplate retryTemplate = new RetryTemplate();
retryTemplate.setRetryPolicy(new SimpleRetryPolicy());
FixedBackOffPolicy backOffPolicy = new FixedBackOffPolicy();
backOffPolicy.setBackOffPeriod(1000); // 1s
retryTemplate.setBackOffPolicy(backOffPolicy);

最后，我们可以将 RetryTemplate 对象传递给 RocketMQ 的 DefaultMQProducer 对象，以实现消息发送失败后的自动重试：

DefaultMQProducer producer = new DefaultMQProducer('producerGroup');
producer.setRetryTimesWhenSendFailed(0); // 关闭 RocketMQ 的自动重试
producer.setRetryTemplate(retryTemplate); // 使用 Spring 的 RetryTemplate
producer.start();

Message message = new Message('topic', 'tag', 'body'.getBytes());
producer.send(message);

producer.shutdown();

在这个例子中，我们关闭了 RocketMQ 的自动重试，并使用 Spring 的 RetryTemplate 来实现消息发送失败后的自动重试。当发送消息失败时，RetryTemplate 会根据 RetryPolicy 和 BackOffPolicy 的定义来决定是否重试以及重试间隔的时间。