当 laravel 队列积压导致任务延迟时，可通过 horizon 实时指标、redis llen 命令、事件监听器、prometheus+grafana 或数据库查询五种方式监控并告警，覆盖不同技术栈与实时性需求。
如果您发现 Laravel 应用中后台任务响应变慢、延迟升高或用户反馈“操作已提交但无后续”，则可能是队列积压导致的处理滞后。以下是通过指标触发告警来监控队列积压的多种方法：
一、基于 Horizon 实时指标 + 自定义阈值告警
Horizon 提供了每 5 秒采样的 Redis 队列长度（Waiting）、处理中（Processing）、失败（Failed）等核心指标，可直接读取其内部统计缓存或通过 Horizon API 获取原始数据，结合定时脚本判断是否超过预设阈值并触发通知。
1、确保 Horizon 已正确安装并运行：执行 php artisan horizon 启动服务，并确认 /horizon/api/metrics 接口可返回 JSON 数据。
2、创建自定义 Artisan 命令用于轮询队列长度：运行 php artisan make:command CheckQueueBacklog，在 handle() 方法中调用 Horizon::stats()->waiting() 获取 default 队列等待数。
3、设定积压阈值（例如 > 100）：当 waiting > 100 时，调用 Notification::route('mail', config('admin.email'))->notify(new QueueBacklogAlert($waiting)); 发送邮件。
4、将该命令加入系统 crontab 每分钟执行一次：添加 * * * * * cd /var/www/project && php artisan queue:backlog:check >> /dev/null 2>&1。
二、直接读取 Redis 键值 + Shell 脚本告警
Horizon 的统计存在轻微滞后，而 Redis 原生命令 LLEN 可瞬时获取队列底层列表长度，绕过 Horizon 缓存层，适用于对实时性要求极高的场景。此方法不依赖 PHP 运行环境，可在服务器级快速部署。
1、确认队列前缀与键名：默认为 queues:default，可通过 HORIZON_PREFIX 环境变量或 config/horizon.php 中的 prefix 配置确认。
2、编写 shell 脚本检查积压：使用 redis-cli -h 127.0.0.1 -p 6379 LLEN queues:default 获取当前长度。
3、判断并触发告警：若返回值大于 200，则执行 curl -X POST https://oapi.dingtalk.com/robot/send?access_token=xxx --data '{"msgtype":"text","text":{"content":"⚠️ 队列积压超200：queues:default = '"$(redis-cli -h 127.0.0.1 -p 6379 LLEN queues:default)"'"} }' 向钉钉机器人发送提醒。
4、设置 systemd timer 或 crontab 每 30 秒执行该脚本，避免高频轮询影响 Redis 性能。
三、利用 Laravel 事件监听器捕获积压信号
Laravel 并未内置“积压”事件，但可通过周期性检测 + 事件广播机制模拟：当连续 N 次检测到 waiting 数持续高于阈值时，手动触发自定义事件，交由监听器统一处理告警逻辑，实现解耦与复用。
1、定义自定义事件类：运行 php artisan make:event QueueBacklogDetected，事件类中携带 $queueName 和 $count 属性。
2、在定时命令中检测并广播：当 Horizon::stats()->waiting() > 150 && Cache::get('backlog_streak', 0) >= 3 时，执行 event(new QueueBacklogDetected('default', $count))。
3、注册监听器并绑定到事件：在 EventServiceProvider 的 $listen 数组中添加 QueueBacklogDetected::class => [SendBacklogNotification::class]。
4、在监听器 handle() 方法中调用多通道通知：同时触发 Mail::to(config('alert.email'))->send(new BacklogReport($count)) 和 Notification::route('slack', config('services.slack.hook'))->notify(new SlackBacklogAlert($count))。
四、集成 Prometheus + Grafana 构建可视化告警闭环
Prometheus 可通过 Exporter 抓取 Laravel 应用暴露的队列指标端点，Grafana 展示趋势图，并由 Alertmanager 根据 PromQL 表达式触发多通道告警，适合中大型生产环境的标准化监控体系。
1、在 Laravel 中暴露指标端点：安装 laravel/prometheus-exporter 包，配置中间件使 /metrics 返回文本格式指标，其中包含 laravel_queue_waiting{connection="redis",queue="default"}。
2、配置 Prometheus 抓取 job：在 prometheus.yml 中添加 scrape_config，target 指向应用地址与 /metrics 路径，interval 设为 15s。
3、在 Grafana 中创建面板：使用 PromQL 查询 rate(laravel_queue_waiting{queue="default"}[5m]) > 0 判断是否持续增长，并叠加阈值线。
4、配置 Alertmanager 规则：定义告警规则 IF laravel_queue_waiting{queue="default"} > 120 FOR 2m，触发后自动投递至邮件、Slack、Webhook 等接收器。
五、基于数据库 jobs 表的积压探测（适配非 Redis 驱动）
当使用 database 或 mongodb 驱动时，无法依赖 Redis LLEN，需直接查询任务表中 status 字段或 reserved/available_at 时间戳组合，识别出“应就绪但未被消费”的任务数量，作为积压依据。
1、针对 database 驱动：执行原生 SQL 查询 SELECT COUNT(*) FROM jobs WHERE reserved = 0 AND available_at 获取待处理积压数。
2、针对 mongodb 驱动：使用 MongoDB 查询 DB::connection('mongodb')->table('jobs')->where('reserved', 0)->where('available_at', 'getTimestamp())->count()。
3、将该查询封装为 Artisan 命令，并在 crontab 中每 2 分钟执行一次；当结果 > 80 时，写入日志并调用 Log::warning('Database queue backlog detected', ['count' => $count])。
4、配合日志采集工具（如 Filebeat + ELK）将 warning 日志转发至告警系统，或在日志中匹配关键字 "queue backlog detected" 并触发外部通知。
