Redis实现消息队列最易上手且可立即运行的方式是List的LPUSH+BRPOP组合,它天然支持FIFO和阻塞等待,无需额外服务端,PHP启用redis扩展后,生产者用lPush入队、消费者用brPop(设超时)出队即可快速验证异步逻辑。

别从理论开始学,直接选一种能跑通的实现方式上手,否则三个月还在查“什么是Exchange”。
先用 Redis 实现一个可运行的队列
这是最快看到效果的方式,适合刚接触队列、想验证业务逻辑是否能异步拆解的人。Redis 的 LPUSH + BRPOP 组合天然支持 FIFO 和阻塞等待,不用装额外服务端(Docker 里一条命令就能起)。
- 确保 PHP 已启用
redis扩展,php -m | grep redis能看到输出 - 生产者脚本里用
$redis->lPush('task_queue', json_encode($data))入队 - 消费者脚本必须用
$redis->brPop(['task_queue'], 10),超时设为 10 秒,避免空转 CPU - 消费者不能放在 Web 请求里执行——
brPop是阻塞调用,会卡住整个 HTTP 响应 - 消息体建议控制在 100KB 以内,
BRPOP对大 payload 的序列化/反序列化开销明显
RabbitMQ 不要一上来就配 Exchange 和 Binding
新手最容易卡在“消息发出去但收不到”,90% 是因为 routing_key 拼错、队列没声明成 durable、或 consumer 启动前 producer 已经把消息发完了(而队列还没建)。
- 先跳过 Exchange,直接用
basic_publish往队列名(如order_notify)发消息,consumer 也直连同名队列 - 声明队列时务必加参数
['durable' => true],否则 RabbitMQ 重启后队列消失 - 发消息时设置
delivery_mode = 2,否则消息只存在内存,宕机即丢 - 不要用
guest/guest登录线上环境,哪怕本地测试也建议改密码或新建用户 - 用
php-amqplib而不是amqp扩展——后者要编译,容易和 PHP 版本冲突
MySQL 队列只在强一致性场景下才值得用
它慢、锁表风险高、轮询浪费资源,但如果你的业务要求“每条任务必须成功且可审计”,比如财务对账、发票生成,那它反而是最省心的选择。
立即学习“PHP免费学习笔记(深入)”;
- 表结构至少含
id、payload(TEXT)、status(TINYINT)、created_at、updated_at - 出队必须用
SELECT ... FOR UPDATE SKIP LOCKED(MySQL 8.0+),老版本只能靠乐观锁重试 - 状态流转要严格:INSERT → SELECT FOR UPDATE → UPDATE status=1 → 执行 → UPDATE status=2,中间任何一步失败都要回滚事务
- 别用
sleep(1)轮询,改成每秒最多查一次,且加WHERE status = 0 LIMIT 1减少扫描行数
真正难的不是怎么写代码把消息塞进去,而是消费者挂了怎么办、重复消费怎么防、消息堆积怎么告警——这些在 Redis 和 MySQL 方案里得自己补,RabbitMQ 有 ACK、死信、TTL 等机制,但前提是得先让基础链路稳定跑起来。



















