最省心的集成方式是yii2-queue+AMQP驱动,但需正确配置bootstrap、QueueController、--verbose参数,合理设置ttr(≤45秒)和attempts(2–5),启用durable队列与消息持久化,并为生产环境配置非guest用户及合规vhost权限。

直接用 yii2-queue + AMQP 驱动是最省心的集成方式,不用自己封装连接、信道、重连逻辑,也不用手动管理队列声明和 ACK。但配置错一个地方,yii queue/listen 就静默失败,任务卡住不执行,查日志还看不到报错。
yii2-queue 的 AMQP 配置必须放对位置
很多人把 'queue' 组件写在 components 里就以为完事了,其实不够:
-
'bootstrap' => ['queue']必须加在console/config/main.php的根级别(和components同级),否则命令行无法自动注册队列服务 -
console/controllers/QueueController.php必须存在——它不是可选的,是yii2-queue自带的,删了或路径不对,yii queue/listen命令根本识别不了 - 如果用 Supervisor 管理消费者,命令必须带
--verbose参数:php yii queue/listen --verbose,否则超时或异常时进程不退出、也不打错误日志,看起来像“卡住”了
ttr 和 attempts 不是重试次数,是投递生命周期控制
这两个参数被误解最多:
-
ttr(Time To Run)单位是秒,表示单次execute()方法允许运行的**最长耗时**;超时后进程会被强制 kill,当前任务标记为失败,并计入attempts计数 -
attempts => 3表示该任务**最多被投递 3 次(含首次)**,每次失败后默认约 1 秒后重新入队,这个间隔由驱动内部硬编码,不能调 -
ttr别设太大,比如设成 600(10 分钟),但 RabbitMQ 默认heartbeat=60,TCP 连接可能被服务端主动断开,导致任务中断且无提示 - 建议值:
ttr设为业务平均耗时的 1.5–2 倍,且 ≤ 45 秒;attempts按业务容忍度设 2–5,别盲目设高
消息持久化和队列声明要靠配置驱动,别手写 declare
用 yii2-queue 时,别在 job 类里手动调 $channel->queue_declare() 或 $channel->exchange_declare():
- AMQP 驱动会自动在首次 push 时声明队列,前提是
'durable' => true(默认开启),否则重启 RabbitMQ 后队列消失,消息全丢 - 消息体默认走
delivery_mode = 2(持久化),但前提是队列本身也 durable —— 两者缺一不可 - 如果你改过
queueName或启用了exchange,记得确认驱动是否支持对应交换机类型(如topic或fanout);yii\queue\amqp_interop\Queue默认只走默认交换机(""),不支持自定义 exchange 路由
生产环境必须关掉 guest 用户,且检查 vhost 权限
本地开发用 guest/guest 很方便,但上线立刻失效:
- RabbitMQ 3.3+ 默认禁止
guest用户从远程 IP 登录,必须新建用户并分配vhost权限:rabbitmqctl add_user myuser mypass→rabbitmqctl set_permissions -p /myvhost myuser ".*" ".*" ".*" -
vhost名称不能含下划线(_)或点(.),某些版本会解析失败,报AMQPConnectionException - PHP 的
amqp扩展(非php-amqplib)在高并发下偶现连接泄漏,生产建议统一用php-amqplib+yii2-queue的amqp_lib驱动,更可控
真正容易出问题的不是“怎么发消息”,而是消费者进程挂了没人知道、ttr 设置和实际耗时不匹配、vhost 权限没配全却只报“connection refused”。这些地方不提前踩一遍,上线后排查成本远高于初始化多花十分钟。











