Linux系统下安装和配置RabbitMQ延迟队列插件实现定时任务-LINUX-PHP中文网

必须先确认rabbitmq版本，插件需与主版本号严格匹配；下载对应版本的rabbitmq_delayed_message_exchange.ez文件；正确复制到plugins目录并设置权限；启用插件后声明x-delayed-message交换机并用x-delay header发送消息。

linux系统下安装和配置rabbitmq延迟队列插件实现定时任务

必须先确认 RabbitMQ 版本，插件版本不匹配会导致 rabbitmq-plugins enable 失败、服务无法启动，甚至容器直接崩溃。

延迟插件 rabbitmq_delayed_message_exchange 与 RabbitMQ 主版本号（如 3.11.x、3.12.x）严格绑定，小版本（如 3.12.0 vs 3.12.1）通常兼容，但大版本跨升（如 3.11 → 3.12）必须换插件。

执行 rabbitmqctl version 获取准确版本号（注意不是 rabbitmq-server --version，后者可能不显示补丁号）
去 GitHub Releases 页面：rabbitmq-delayed-message-exchange/releases
找和你 rabbitmqctl version 输出完全一致的 .ez 文件，例如输出是 3.12.0，就下 rabbitmq_delayed_message_exchange-3.12.0.ez
别信“最新版通用”——3.12.x 插件在 3.11.x 上会报 missing dependency: rabbitmq_server-3.12.0

插件文件必须放在 RabbitMQ 自身识别的 plugins 目录里，且属主属组要设对，否则启用时静默失败。

Linux installer

先解析安全源，运行本地CLI安装、启动、卸载Linux桌面应用。用户请求时使用。

下载

用 rabbitmq-plugins directories 查真实插件路径（常见但非绝对路径：/usr/lib/rabbitmq/lib/rabbitmq_server-3.12.0/plugins/）
sudo cp rabbitmq_delayed_message_exchange-3.12.0.ez /usr/lib/rabbitmq/lib/rabbitmq_server-3.12.0/plugins/
sudo chown rabbitmq:rabbitmq /usr/lib/rabbitmq/lib/rabbitmq_server-3.12.0/plugins/rabbitmq_delayed_message_exchange-3.12.0.ez
sudo chmod 644 /usr/lib/rabbitmq/lib/rabbitmq_server-3.12.0/plugins/*.ez
执行 sudo rabbitmq-plugins enable rabbitmq_delayed_message_exchange（注意命令里不带版本号和 .ez）
重启服务：sudo systemctl restart rabbitmq-server

把宿主机目录 -v /host/plugins:/plugins 挂载进容器，会覆盖掉 RabbitMQ 自带的核心插件（如 rabbitmq_management），导致启动时报 Failed to load module 'rabbit'。

推荐方式一（构建镜像）：Dockerfile 中 COPY 插件到 /opt/rabbitmq/plugins/，再 RUN rabbitmq-plugins enable ...
推荐方式二（运行时注入）：docker cp rabbitmq_delayed_message_exchange-3.12.0.ez container_name:/opt/rabbitmq/plugins/，再 docker exec -it container_name rabbitmq-plugins enable rabbitmq_delayed_message_exchange
验证是否生效：docker exec container_name rabbitmq-plugins list | grep delayed，看到 [E*] rabbitmq_delayed_message_exchange 才算成功
Web 管理界面中，Exchanges → Add a new exchange → Type 下拉框出现 x-delayed-message 是最终确认点

插件启用后不会自动创建交换机，必须显式声明；延迟时间必须通过 x-delay header 传，不是 expiration，也不是队列 TTL。

声明交换机（命令行）：rabbitmqadmin declare exchange name=delayed_exchange type=x-delayed-message arguments='{"x-delayed-type":"direct"}'
发送消息（命令行）：rabbitmqadmin publish exchange=delayed_exchange routing_key=test_queue payload="timeout" properties='{"headers":{"x-delay":60000}}'（60 秒后投递）
Spring Boot 中要用 CustomExchange，type 设为 "x-delayed-message"，并设置 argument("x-delayed-type", "direct")
Java 生产者发消息时，必须用 MessageProperties 设置 header：messageProperties.getHeaders().put("x-delay", 60000)，不能设 setExpiration("60000") —— 那是 TTL 方案用的