生产环境Hyperf异步队列必须稳定扛峰、不丢任务、可监控、快恢复；需隔离消费者进程、启用独立协程池、分级多队列、禁用数据库驱动、闭环处理失败任务，并上线前完成三项验证。
生产环境Hyperf异步队列必须稳定扛住峰值流量、不丢任务、可监控、能快速故障恢复，不能靠重启硬扛或手动清队列补数据。
配置消费者进程与资源隔离
在 config/autoload/processes.php 中，只保留 Hyperf\AsyncQueue\Process\ConsumerProcess 类路径，禁止混入其他自定义 Process —— 多个消费者进程共用同一通道会引发竞争，导致任务重复消费或漏消费。
为避免主服务进程被队列消费拖垮，必须启用独立协程池：编辑 config/autoload/async_queue.php，在 default 配置块中显式声明 【'concurrent' => ['limit' => 5]】，该值需根据单任务平均耗时和服务器 CPU 核数反推，例如 4 核机器上单任务平均 800ms，则 limit 设为 5 是安全上限；设为 20 将直接触发协程饥饿，后续任务无限排队。
删除 config/autoload/processes.php 中所有非 ConsumerProcess 的进程引用，确保队列消费完全脱离 HTTP/WebSocket 主进程生命周期。
多队列分级与驱动选型
方法一：按业务优先级拆分队列通道
在 config/autoload/async_queue.php 中定义三个独立队列配置：high（订单支付回调）、default（用户通知）、low（日志归档），每个配置使用不同 Redis channel 和独立的 processes 数量。
方法二：关键队列绑定专用 Redis 实例
将 high 队列的 【'redis' => ['pool' => 'queue_high']】 指向独立 Redis 连接池，该池独占一个 Redis 实例，避免与缓存、Session 等共享实例造成阻塞或超时抖动。
禁止在生产环境使用数据库驱动（如 PDO）作为异步队列主通道——MySQL 写入吞吐低、连接易打满、死锁风险高，仅可用于极低频且允许丢失的调试任务。
失败任务闭环处理
第一步：启用自动重试机制
在 async_queue.php 的 default 配置中设置 'retry_seconds' => [1, 3, 10, 30]，表示失败后分别等待 1s、3s、10s、30s 后重试，最多尝试 4 次。
第二步：配置失败任务落库
执行 php bin/hyperf.php migrate:create create_failed_jobs_table 生成迁移文件，确保 failed_jobs 表存在；再将 'failed_job_database' => true 加入队列配置，使每次重试失败的任务自动写入数据库。
第三步：部署定时清理脚本
编写 shell 脚本 daily_clean_failed.sh，内容为 php bin/hyperf.php async-queue:clean --days=7，通过 crontab 每日凌晨 2 点执行，清除 7 天前的失败记录。
注意：failed_jobs 表必须添加索引 INDEX (created_at)，否则 clean 命令执行时会全表扫描，高峰期可能拖垮数据库。
上线前必验的三项检查
运行 php bin/hyperf.php async-queue:status，确认输出中 【processes: running】 且 pending 数值持续低于 100；若显示 stopped 或 pending > 500，说明消费者未启动或并发配置严重失衡。
向队列投递一条测试任务，立即执行 redis-cli -n 0 LLEN queue:default（channel 名需与配置一致），验证任务是否真实入队；若返回 0，检查 Job 类是否正确继承 Hyperf\AsyncQueue\Job 且未遗漏 handle() 方法。
触发一次人为异常（如在 handle() 中 throw new RuntimeException('test')），等待 30 秒后执行 SELECT COUNT(*) FROM failed_jobs WHERE exception LIKE '%test%'，确认失败记录已落库且 message 字段含原始堆栈。
