RabbitTemplate 发送延迟消息

RabbitTemplate 在实现发送延迟消息的功能时，需要借助 RabbitMQ 的插件 —— RabbitMQ Delayed Message Exchange。该插件可以实现基于消息的延迟投递，即将消息发送到一个特定的交换机（Delayed Exchange），在该交换机中指定一个延迟时间后，再将消息路由到目标队列中。

下面是一个示例代码，演示如何使用 RabbitTemplate 发送延迟消息：

首先，需要在 RabbitMQ 中安装 RabbitMQ Delayed Message Exchange 插件。可以通过以下命令进行安装：

rabbitmq-plugins enable rabbitmq_delayed_message_exchange

然后，在 RabbitTemplate 中通过设置消息属性来指定消息的延迟时间。在发送消息之前，可以先创建一个 MessagePostProcessor 对象，设置消息的 headers 属性，具体代码如下：

MessagePostProcessor messagePostProcessor = message -> {
    message.getMessageProperties().setHeader("x-delay", 5000); // 设置延迟时间为 5 秒
    return message;
};
rabbitTemplate.convertAndSend("delayed_exchange", "routing_key", "message", messagePostProcessor);

在上述代码中，我们创建了一个 MessagePostProcessor 对象，并设置了消息的 headers 属性，将延迟时间设置为 5 秒。然后将其传递给 RabbitTemplate 的 convertAndSend 方法，这样发送的消息就会被发送到名为 delayed_exchange 的交换机中，交换机会根据 headers 属性中的 x-delay 值，将消息延迟 5 秒后再路由到目标队列中。

需要注意的是，RabbitMQ Delayed Message Exchange 插件只能在 RabbitMQ 3.5.0 或更新版本中使用。