要让ThinkPHP6稳定扛住1万并发消息处理，需协同优化队列选型（Redis用于通知类、RabbitMQ用于订单/支付类）、消费者吞吐（Supervisor多进程或Swoole协程）、失败容错（Redis存储failed jobs、maxAttempts控制重试、定时清理）及进程守护（Redis连接池、队列监控、平滑重启）。
要让ThinkPHP6稳定扛住1万并发的消息处理，不能只靠“配好就能跑”，得从队列选型、消费者吞吐、失败容错和进程守护四个关键环节协同优化。Redis适合轻量高频任务，RabbitMQ更适合作为核心链路的高可靠场景；单个CLI监听器撑不住万级压力，必须横向扩展+常驻协程化；失败任务不及时清理会拖垮整个队列。
选对队列驱动：Redis快但要防堆积，RabbitMQ稳但需调优
1万并发下，Redis作为后端速度快，但LIST结构无ACK机制，任务失败容易丢失。建议按业务分级使用：
- 通知类（短信、站内信）用Redis：配置timeout=0避免连接超时，select=1单独DB隔离，防止与其他缓存混用
- 订单/支付类核心流程用RabbitMQ：开启持久化（durable queue + persistent message），设置prefetch_count=10防消费者过载，vhost按环境划分（如prod-order）
- 别直接用
QUEUE_CONNECTION=redis就完事——在config/queue.php里显式指定'retry_after' => 90，避免长任务被误判失败
提升消费吞吐：别只跑一个php think queue:listen
单个CLI进程每秒最多处理200~300个任务，1万并发需至少30~50个消费者并行。推荐两种方式：
-
Supervisor多进程管理：配置5组worker，每组10个进程，共50个监听实例
command=php /var/www/tp6/think queue:listen --queue=default --sleep=1 --max-jobs=1000
注意加--sleep=1减少空轮询CPU占用，--max-jobs=1000防内存泄漏 -
Swoole协程消费者（推荐）：改用
Swoole\Coroutine\Redis+brpop阻塞监听，单进程轻松支撑3000+ QPS
关键点：连接复用、任务内不阻塞IO、错误时continue而非break，避免整条协程挂死
失败任务必须闭环：否则越积越多，最终卡死
默认失败任务进failed_jobs表，但1万并发下这张表可能成性能瓶颈。实际部署要分三步：
立即学习“PHP免费学习笔记（深入）”；
- 在
config/queue.php中把'failed' => ['type' => 'database']改为'type' => 'redis'，利用Redis的zset按时间排序失败任务，读写更快 - 为每个Job类定义
maxAttempts = 3，并在fire()里用$job->attempts() > 3判断是否永久失败，失败后推送到告警队列或写入ES日志 - 每天定时执行
php think queue:flush清空已确认失败的任务，别等手动删表
生产环境必须加的三道保险
光跑起来不够，上线前检查这三项：
-
Redis连接池：在
config/redis.php里启用'pool' => ['min' => 10, 'max' => 50]，避免消费者争抢连接 -
队列监控埋点：用
Redis::llen('queues:default')每30秒上报长度，配合Prometheus+Grafana设阈值告警（如>5000持续2分钟） -
平滑重启机制：Supervisor配置
stopwaitsecs=30，确保正在执行的任务有足够时间完成，不强制kill
