webman redis队列积压需检查重启消费者、扩展并发数、修复阻塞任务、手动清理分流、监控失败队列。1. 用ps查进程并php webman restart；2. 调整process.php中count值；3. 加耗时监控与超时设置；4. redis-cli导出截断后分批重投；5. 定期检查redis-queue-failed并手动重试。
如果您在Webman框架中使用Redis队列时发现消息持续积压、消费延迟或消费者进程无响应，则可能是由于消费者进程异常退出、并发能力不足、任务处理阻塞或Redis连接不稳定所致。以下是针对该问题的多种运维与积压处理方法：
一、检查并重启消费者进程
Webman的Redis队列消费者以常驻Worker进程形式运行，若进程崩溃或被误杀，将导致消息停止消费，队列持续增长。需确认消费者是否处于活跃状态，并执行标准化启停操作。
1、进入Webman项目根目录，执行命令查看当前运行的Worker进程：php webman start -d 后使用 ps aux | grep redis-queue 筛选相关进程。
2、若未发现消费者进程，或进程状态为 defunct 或 CPU 占用为 0，说明已异常终止。
3、执行 php webman stop 停止全部Worker，再执行 php webman start -d 重新拉起，确保 plugin/webman/redis-queue 插件已启用且配置正确。
二、横向扩展消费者并发数
单个消费者进程处理能力存在上限，当消息生产速率超过其消费吞吐量时，必然引发积压。通过增加消费者Worker数量可线性提升整体消费能力，无需修改业务逻辑。
1、编辑 config/plugin/webman/redis-queue/process.php 文件。
2、将 'count' => 1 修改为更高值，例如 'count' => 4，表示启动4个独立消费者进程协同消费同一队列。
3、保存后执行 php webman restart 使配置生效，观察 redis-cli llen {queue_name} 返回值是否呈下降趋势。
三、定位并修复阻塞型任务逻辑
单条消息处理耗时过长（如同步HTTP调用、未加超时的数据库查询、大文件IO）会导致整个消费者进程卡住，后续消息无法被拉取。必须识别并改造此类“慢任务”为非阻塞形态。
1、在消费者代码中添加毫秒级执行时间监控，例如在 app/queue/Handler.php 的 handle() 方法开头记录 microtime(true)。
Redis 8.2.3 是一款安全优先的高性能键值存储系统。该版本紧急修复了可能引发远程代码执行（RCE）的高危漏洞（CVE-2025-62507），并解决了 HyperLogLog 及 Cuckoo Filter 等数据结构在特定场景下的崩溃问题。建议所有用户立即升级，以保障生产环境的系统稳定与数据安全。
2、处理完成后计算耗时，若超过 3000ms，记录日志并触发告警。
3、对网络请求类操作，强制使用 curl_setopt($ch, CURLOPT_TIMEOUT_MS, 5000) 或改用异步HTTP客户端（如 GuzzleHttp\Ring\Client\CurlMultiHandler）。
四、手动清理积压消息并分流重投
当积压量极大（如超过10万条）且无法快速消化时，可临时隔离故障消息，优先保障新消息流转，再分批回溯处理历史积压。
1、使用 redis-cli --raw lrange {queue_name} 0 9999 > backup_queue_dump.txt 导出前1万条原始消息内容（注意替换 {queue_name} 为实际队列名）。
2、执行 redis-cli ltrim {queue_name} 10000 -1 截断队列，仅保留尾部消息，释放前端压力。
3、编写独立脚本，读取 backup_queue_dump.txt，按每批500条调用 Webman\RedisQueue\Redis::send() 重投至新队列（如 {queue_name}_recovery），并启用单独的低频消费者处理。
五、启用失败队列监控与人工干预机制
Webman Redis队列在达到 max_attempts 重试次数后，会将消息转入 {redis-queue}-failed 队列。该队列不自动重试，需主动干预，否则形成隐性积压源。
1、定期执行 redis-cli llen "redis-queue-failed" 检查失败队列长度。
2、若长度非零，使用 redis-cli --raw lrange "redis-queue-failed" 0 -1 查看具体失败消息结构。
3、分析失败原因（如数据格式错误、依赖服务不可用），修正后通过脚本调用 Webman\RedisQueue\Redis::retryFailed($messageId) 手动重试，或直接 lpush 回原队列。
