Spring RetryTemplate 实现 RocketMQ 异步消息发送重试

RetryTemplate 是 Spring 提供的重试机制模板类，它可以帮助我们在出现异常时进行重试，提高程序的健壮性。在 RocketMQ 中，我们可以使用 RetryTemplate 实现异步发送消息重试。

以下是使用 RetryTemplate 实现 RocketMQ 异步发送消息重试的示例代码：

import org.apache.rocketmq.client.producer.DefaultMQProducer;
import org.apache.rocketmq.client.producer.SendCallback;
import org.apache.rocketmq.client.producer.SendResult;
import org.apache.rocketmq.common.message.Message;
import org.springframework.retry.RetryCallback;
import org.springframework.retry.RetryContext;
import org.springframework.retry.RetryPolicy;
import org.springframework.retry.backoff.ExponentialBackOffPolicy;
import org.springframework.retry.support.RetryTemplate;

public class RocketMqProducer {

    private DefaultMQProducer producer;

    private RetryTemplate retryTemplate;

    public RocketMqProducer(DefaultMQProducer producer) {
        this.producer = producer;
        this.retryTemplate = new RetryTemplate();

        // 设置重试策略
        RetryPolicy retryPolicy = new RetryPolicy() {
            @Override
            public boolean canRetry(RetryContext context) {
                return context.getRetryCount() < 3;
            }
        };
        this.retryTemplate.setRetryPolicy(retryPolicy);

        // 设置重试间隔
        ExponentialBackOffPolicy backOffPolicy = new ExponentialBackOffPolicy();
        backOffPolicy.setInitialInterval(1000);
        backOffPolicy.setMultiplier(2.0);
        backOffPolicy.setMaxInterval(5000);
        this.retryTemplate.setBackOffPolicy(backOffPolicy);
    }

    public void sendAsync(String topic, String body, SendCallback callback) {
        byte[] bytes = body.getBytes();
        Message message = new Message(topic, bytes);
        this.retryTemplate.execute(new RetryCallback<Void, Exception>() {
            @Override
            public Void doWithRetry(RetryContext context) throws Exception {
                producer.send(message, callback);
                return null;
            }
        });
    }
}

在上面的代码中，我们首先创建了一个 RetryTemplate 对象，并设置了重试策略和重试间隔。然后在 sendAsync 方法中，我们使用 retryTemplate.execute 方法执行异步发送消息的操作，并在其中实现了重试逻辑，当发送消息出现异常时，会根据重试策略进行重试。最后，我们将 SendMessageCallback 作为参数传入 producer.send 方法中，以实现异步发送消息的功能。

使用该 RocketMqProducer 类时，只需要调用 sendAsync 方法即可：

RocketMqProducer producer = new RocketMqProducer(new DefaultMQProducer());
producer.sendAsync('test_topic', 'hello world', new SendCallback() {
    @Override
    public void onSuccess(SendResult sendResult) {
        System.out.println('send success');
    }

    @Override
    public void onException(Throwable throwable) {
        System.out.println('send failed');
    }
});

这样，当发送消息出现异常时，会自动进行重试，直到达到最大重试次数或发送成功为止。