在 CentOS 上实现 RabbitMQ 延迟消息的可选方案
- 原生方式：利用 TTL（Time-To-Live）+ DLX（Dead Letter Exchange） 组合，让消息在过期后转入“死信交换机”，从而被延时消费。优点是无需插件，缺点是如果同一队列中不同消息的 TTL 不同，可能出现“队头阻塞”，导致短 TTL 消息被长 TTL 消息阻塞，时间不精确。
- 插件方式：安装 rabbitmq_delayed_message_exchange 插件，声明类型为 x-delayed-message 的交换机，发送时在消息头设置 x-delay（毫秒），时间更精准、使用更简单，适合作为通用延迟队列方案。
方案一 TTL + DLX 落地步骤（系统包或 Docker 均可）
- 声明死信交换机与队列（DLX）
- 交换机：例如 dlx.exchange（direct/topic）
- 队列：例如 dlx.queue，与 dlx.exchange 绑定
- 声明业务队列并配置 DLX 与 TTL
- 队列参数：
- x-dead-letter-exchange：指向 dlx.exchange
- 可选 x-dead-letter-routing-key：自定义路由键
- x-message-ttl：统一过期时间（毫秒）
- 示例（Java 伪代码）：
- Map<String,Object> args = new HashMap<>();
args.put(“x-dead-letter-exchange”, “dlx.exchange”);
args.put(“x-dead-letter-routing-key”, “dlx.rk”);
args.put(“x-message-ttl”, 60000);
channel.queueDeclare(“delay.queue”, true, false, false, args);
- 发送消息
- 方式 A（队列级 TTL）：所有消息统一延迟
- 方式 B（消息级 TTL）：为每条消息设置 expiration（字符串毫秒），如 “60000”
- 消费端
- 监听 dlx.queue，即为延迟到期后到达的实际消费队列
- 适用场景
- 固定延迟、可接受队头阻塞的场景；如需不同延迟粒度，可创建多个队列（不同 TTL）或采用插件方案。
方案二 延迟插件 rabbitmq_delayed_message_exchange 安装与使用示例（CentOS）
- 版本匹配
- 插件版本需与 RabbitMQ 大版本一致（如 3.12.x 对应插件 3.12.x）。可在插件页下载匹配版本：https://www.rabbitmq.com/community-plugins.html
- RPM 安装路径与启用（系统包）
- 查看版本：rpm -qa | grep rabbitmq
- 查找插件目录：rpm -ql rabbitmq-server- | grep plugins
- 将插件 .ez 放入插件目录（如：/usr/lib/rabbitmq/lib/rabbitmq_server-/plugins）
- 启用插件：rabbitmq-plugins enable rabbitmq_delayed_message_exchange
- 必要时重启服务：systemctl restart rabbitmq-server
- Docker 安装与启用
- 启动容器（含管理插件）：docker run -d --name rabbitmq -p 15672:15672 -p 5672:5672 rabbitmq:3.8.3-management
- 进入容器：docker exec -it rabbitmq bash
- 将 .ez 插件拷入容器：docker cp rabbitmq_delayed_message_exchange-.ez rabbitmq:/plugins
- 启用插件：rabbitmq-plugins enable rabbitmq_delayed_message_exchange
- 验证：rabbitmq-plugins list | grep delayed；管理界面应出现 x-delayed-message
- Spring AMQP 发送示例
- 声明交换机（x-delayed-message 类型，需指定 x-delayed-type）：
- 例如：CustomExchange delayedExchange = new CustomExchange(“delayed.ex”, “x-delayed-message”, true, false,
Collections.singletonMap(“x-delayed-type”, “direct”));
- 发送消息时在消息属性设置延迟：
- rabbitTemplate.convertAndSend(“delayed.ex”, “rk”, “hello”, m -> {
m.getMessageProperties().setDelay(30000); // 30 秒
return m;
});
- 适用场景
- 多延迟粒度、时间精度要求高、需要“发送即指定延迟”的业务（如 订单超时关闭、定时提醒 等）。
常见故障排查与优化建议
- 插件未生效或找不到类型
- 确认插件已启用（rabbitmq-plugins list 能看到 x-delayed-message），且交换机类型写成 x-delayed-message；声明时必须带参数 x-delayed-type（如 direct/topic）。
- 延迟不准或“看起来没延迟”
- 使用 TTL+DLX 时，若同一队列里先进入一条很大的 TTL 消息，会阻塞后续短 TTL 消息的过期与转发（队头阻塞）；改用插件方案可避免。
- 消息变成死信但未进入目标队列
- 核对 x-dead-letter-exchange / x-dead-letter-routing-key 是否配置正确；死信的路由键若不设置，默认沿用原消息的 routing key。
- 延迟范围与单位
- 插件方式 x-delay 单位为毫秒；TTL 队列/消息参数 x-message-ttl 为毫秒（消息级 expiration 为字符串毫秒）。
- 生产可靠性
- 建议开启 publisher confirm、队列与消息持久化、消费者 手动 ACK，并在业务侧实现 幂等（如唯一键、去重表/Redis setnx）。
