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

RetryTemplate是Spring Framework提供的一个重试机制模板类，它可以帮助我们在代码中实现异常重试的逻辑。

在使用RockMq发送消息时，可能会遇到网络波动、消息队列服务宕机等情况导致消息发送失败。这时候，我们可以使用RetryTemplate来实现消息发送失败后的重试逻辑。

以下是使用RetryTemplate实现RockMq消息发送失败重试的示例代码：

@Autowired
private DefaultMQProducer defaultMQProducer;

@Autowired
private RetryTemplate retryTemplate;

public void sendMessage(final Message message) {
    retryTemplate.execute(new RetryCallback<Void, Exception>() {
        @Override
        public Void doWithRetry(RetryContext context) throws Exception {
            try {
                SendResult sendResult = defaultMQProducer.send(message);
                if (sendResult.getSendStatus() != SendStatus.SEND_OK) {
                    throw new Exception("消息发送失败");
                }
                return null;
            } catch (Exception e) {
                if (context.getRetryCount() >= 3) { // 最多重试3次
                    throw new RuntimeException("消息发送失败，已达最大重试次数");
                }
                throw e;
            }
        }
    });
}

上述代码中，我们首先注入了RockMq的DefaultMQProducer对象和RetryTemplate对象。sendMessage方法中，我们调用了retryTemplate的execute方法，传入了一个RetryCallback回调函数。在回调函数中，我们可以编写重试逻辑。

在doWithRetry方法中，我们首先尝试发送消息，如果发送成功，则直接返回null。如果发送失败，则抛出异常。在异常处理中，我们判断当前重试次数是否超过了3次，如果超过了，则抛出RuntimeException，表示消息发送失败，已达到最大重试次数。如果没有超过，则重新抛出异常，让RetryTemplate继续重试。

使用RetryTemplate可以方便地实现RockMq消息发送失败的重试逻辑，提高消息发送的可靠性