RabbitMQ 延迟队列插件的下载、安装及启用方法，并通过 Spring Boot 示例代码演示了如何声明延迟交换机、队列及绑定关系。内容涵盖生产消息设置延迟时间、消费消息接收逻辑，以及对比死信队列实现方式的优缺点，适用于订单超时取消等场景。
RabbitMQ 官方提供了一个延迟插件来实现延迟功能。
插件下载地址：GitHub Releases
根据自己的 RabbitMQ 版本选择相应版本的延迟插件，下载后上传到服务器。
查看 RabbitMQ 版本的命令：
rabbitmqctl status | grep "RabbitMQ"
/usr/lib/rabbitmq/plugins 是一个附加目录，RabbitMQ 包本身不会在此安装任何内容。如果没有这个路径，可以自己进行创建。
把下载好的 .ez 文件上传到 /usr/lib/rabbitmq/plugins 这个路径下。
查看 RabbitMQ 插件的命令：
rabbitmq-plugins list
启用延迟队列插件的命令：
rabbitmq-plugins enable rabbitmq_delayed_message_exchange
spring:
application:
微信公众号「极客日志」，在微信中扫描左侧二维码关注。展示文案：极客日志 zeeklog
查找任何按下的键的javascript键代码、代码、位置和修饰符。 在线工具，Keycode 信息在线工具，online
JavaScript 字符串转义/反转义；Java 风格 \uXXXX（Native2Ascii）编码与解码。 在线工具，Escape 与 Native 编解码在线工具，online
使用 Prettier 在浏览器内格式化 JavaScript 或 HTML 片段。 在线工具，JavaScript / HTML 格式化在线工具，online
Terser 压缩、变量名混淆，或 javascript-obfuscator 高强度混淆（体积会增大）。 在线工具，JavaScript 压缩与混淆在线工具，online
将字符串编码和解码为其 Base64 格式表示形式即可。 在线工具，Base64 字符串编码/解码在线工具，online
将字符串、文件或图像转换为其 Base64 表示形式。 在线工具，Base64 文件转换器在线工具，online
public class Constants {
// 延迟队列
public static final String DELAY_QUEUE = "delay.queue";
public static final String DELAY_EXCHANGE = "delay.exchange";
}
import org.springframework.amqp.core.*;
import org.springframework.beans.factory.annotation.Qualifier;
import org.springframework.context.annotation.Bean;
import org.springframework.context.annotation.Configuration;
import rabbitextensionsdemo.constant.Constants;
@Configuration
public class DelayConfig {
@Bean("delayQueue")
public Queue delayQueue() {
return QueueBuilder.durable(Constants.DELAY_QUEUE).build();
}
@Bean("delayExchange")
public Exchange delayExchange() {
return ExchangeBuilder.directExchange(Constants.DELAY_EXCHANGE).delayed().build();
}
@Bean("delayBinding")
public Binding delayBinding(@Qualifier("delayQueue") Queue queue, @Qualifier("delayExchange") Exchange exchange) {
return BindingBuilder.bind(queue).to(exchange).with("delay").noargs();
}
}
@RequestMapping("/delay2")
public String delay2() {
System.out.println("delay2...");
rabbitTemplate.convertAndSend(Constants.DELAY_EXCHANGE, "delay", "delay test 30s...", message -> {
message.getMessageProperties().setDelayLong(30000L); // 单位：毫秒，过期时间为 30s
return message;
});
rabbitTemplate.convertAndSend(Constants.DELAY_EXCHANGE, "delay", "delay test 10s...", message -> {
message.getMessageProperties().setDelayLong(10000L); // 单位：毫秒，延迟时间为 10s
return message;
});
System.out.printf("%tc 消息发送成功 \n", new Date());
return "消息发送成功";
}
import com.rabbitmq.client.Channel;
import org.springframework.amqp.core.Message;
import org.springframework.amqp.rabbit.annotation.RabbitListener;
import org.springframework.stereotype.Component;
import rabbitextensionsdemo.constant.Constants;
import java.util.Date;
@Component
public class DelayListener {
@RabbitListener(queues = Constants.DELAY_QUEUE)
public void delayHandMessage(Message message, Channel channel) throws Exception {
// 消费者逻辑
System.out.printf("[delay.queue] %tc 接收到消息：%s \n", new Date(), new String(message.getBody(), "UTF-8"));
}
}
此时我们可以看到，哪怕把 TTL 为 30 秒的消息先于 TTL 为 10 秒的消息进行发送，也不会影响根据延迟时间进行消息的发送。
1. 介绍下 RabbitMQ 的延迟队列
延迟队列是一个特殊的队列，消息发送之后，并不立即给消费者，而是等待特定的时间，才发送给消费者。
延迟队列的应用场景有很多，比如：
但 RabbitMQ 本身并没直接实现延迟队列，通常有两种方法：
2. 上面两种实现方法二者对比