rocketmq + RetryTemplate 实现MQ消息发送失败重试工具方法

RocketMQ是一款开源的分布式消息中间件。RetryTemplate是Spring框架提供的一种重试机制，它可以在发生异常时自动进行重试。这两者结合起来，可以实现MQ消息发送失败重试的工具方法。

具体实现步骤如下：

引入RocketMQ和Spring的依赖

在项目的pom.xml文件中引入RocketMQ和Spring的依赖，例如：

<dependency>
    <groupId>org.apache.rocketmq</groupId>
    <artifactId>rocketmq-client</artifactId>
    <version>4.8.0</version>
</dependency>

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

编写MQ消息发送方法

编写MQ消息发送方法，例如：

public void sendMessage(String topic, String message) throws Exception {
    DefaultMQProducer producer = new DefaultMQProducer("my_group");
    producer.setNamesrvAddr("localhost:9876");
    producer.start();
    Message msg = new Message(topic, message.getBytes("utf-8"));
    SendResult sendResult = producer.send(msg);
    System.out.println("消息发送结果：" + sendResult);
    producer.shutdown();
}

编写重试方法

编写重试方法，使用RetryTemplate进行重试，例如：

public void sendWithRetry(String topic, String message) throws Exception {
    RetryTemplate retryTemplate = new RetryTemplate();

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

    // 设置重试回调
    RocketMQOperationsCallback<Object> callback = new RocketMQOperationsCallback<Object>() {
        @Override
        public Object doInRocketMQ(RocketMQTemplate rocketMQTemplate) throws Exception {
            sendMessage(topic, message);
            return null;
        }
    };

    // 执行重试
    retryTemplate.execute(callback);
}

调用重试方法

在需要发送MQ消息的地方，调用重试方法即可，例如：

try {
    sendWithRetry("my_topic", "hello world");
} catch (Exception e) {
    e.printStackTrace();
}

这样，就可以实现MQ消息发送失败重试的工具方法。当消息发送失败时，RetryTemplate会自动进行重试，直到达到最大重试次数或者发送成功为止

rocketmq + RetryTemplate 实现MQ消息发送失败重试工具方法