RocketMQ 异步发送消息失败使用RetryTemplate做重试实现

如果RocketMQ异步发送消息失败，可以使用Spring Retry框架提供的RetryTemplate来实现重试机制。RetryTemplate是一个工具类，它提供了一种简单的方式来实现重试逻辑。

首先，需要在Spring配置文件中配置RetryTemplate：

<bean id="retryTemplate" class="org.springframework.retry.support.RetryTemplate">
    <property name="backOffPolicy">
        <bean class="org.springframework.retry.backoff.ExponentialBackOffPolicy">
            <property name="initialInterval" value="1000"/>
            <property name="maxInterval" value="10000"/>
            <property name="multiplier" value="2"/>
        </bean>
    </property>
    <property name="retryPolicy">
        <bean class="org.springframework.retry.policy.SimpleRetryPolicy">
            <property name="maxAttempts" value="3"/>
        </bean>
    </property>
</bean>

上面的配置中，backOffPolicy定义了重试间隔策略，retryPolicy定义了重试次数策略。这里的配置表示最多重试3次，每次重试间隔时间递增，初始间隔为1秒，最大间隔为10秒，间隔时间递增因子为2。

接下来，可以在代码中使用RetryTemplate来实现重试：

@Autowired
private RetryTemplate retryTemplate;

@Autowired
private RocketMQTemplate rocketMQTemplate;

public void sendMessage(final String message) {
    retryTemplate.execute(new RetryCallback<Void, Exception>() {
        @Override
        public Void doWithRetry(RetryContext retryContext) throws Exception {
            try {
                SendResult sendResult = rocketMQTemplate.asyncSend("topic", "tag", message, new SendCallback() {
                    @Override
                    public void onSuccess(SendResult sendResult) {
                        //发送成功处理逻辑
                    }
                    @Override
                    public void onException(Throwable throwable) {
                        //发送失败处理逻辑
                    }
                });
                if (sendResult != null && sendResult.getSendStatus() == SendStatus.SEND_OK) {
                    return null;
                } else {
                    throw new Exception("发送消息失败");
                }
            } catch (Exception e) {
                throw e;
            }
        }
    });
}

上面的代码中，使用了RetryTemplate的execute方法来执行异步发送消息的逻辑。如果发送消息失败，RetryTemplate会根据配置的重试策略进行重试。如果重试次数达到了最大次数，RetryTemplate会抛出RetryException异常，可以在异常处理中进行相应的处理逻辑。

注意，在异步发送消息的回调函数中，如果发送成功，需要返回null，否则RetryTemplate会认为发送失败并进行重试。如果发送失败，可以抛出异常，RetryTemplate会捕获异常并进行重试