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 会捕获异常并进行重试。