Laravel数据库查询故障实时报警可通过五种方法实现:一、启用DB_DEBUG配合日志通道捕获异常;二、使用DB::listen监听并触发通知;三、集成Sentry捕获PDO异常;四、自定义中间件统计失败率并企业微信报警;五、通过队列任务异步分发告警。

当Laravel应用在数据库查询过程中发生异常、超时或失败时,系统可能未主动通知开发者,导致问题延迟发现。以下是设置查询故障实时报警的多种方法:
一、启用DB_DEBUG并配合日志通道捕获查询异常
开启数据库调试模式可记录所有SQL执行详情(含错误语句与耗时),再通过日志处理器将特定错误关键词(如“QueryException”、“timeout”、“deadlock”)路由至告警通道。
1、编辑.env文件,设置:DB_DEBUG=true
2、在config/logging.php中新增自定义通道,匹配查询失败日志:
3、在channels数组内添加名为db_alert的stack通道,其via指向自定义日志处理器类
4、创建app/Logging/DbQueryExceptionHandler.php,在handle()方法中检测日志消息是否含"SQLSTATE"或"QueryException"
5、若匹配成功,调用Mail::to('admin@example.com')->send(new DbQueryFailureNotification($context))
二、使用DB监听器注入异常钩子
通过Laravel的DB::listen()全局监听所有查询,在闭包中判断执行状态,对失败或超长查询触发即时通知。
1、在AppServiceProvider::boot()中注册监听器:
2、调用DB::listen(function ($query) { ... })
3、在闭包内检查$query->time > 2000(毫秒)或$query->exception !== null
4、满足任一条件时,实例化Notification::route('mail', 'alert@example.com')->notify(new SlowOrFailedQueryAlert($query))
5、确保SlowOrFailedQueryAlert类继承Notification并实现toMail()方法
三、集成Sentry捕获底层PDO异常
Sentry可自动上报未被捕获的底层数据库异常(如连接中断、权限拒绝),无需修改业务代码,直接定位驱动层故障。
1、执行composer require sentry/sentry-laravel
2、运行php artisan sentry:publish --dsn=https://xxx@oxxx.ingest.sentry.io/xxx
3、在.env中配置SENTRY_LARAVEL_DSN为项目DSN
4、修改config/sentry.php,将traces_sample_rate设为1.0以捕获全部SQL上下文
5、在app/Exceptions/Handler.php的report()方法中,对PDOException和QueryException添加if (app()->bound('sentry')) { app('sentry')->captureException($exception); }
四、自定义查询中间件拦截高频失败请求
针对因慢查询引发的HTTP请求超时或500响应,可在路由中间件中统计单IP/路由维度的查询失败率,并达阈值后触发企业微信报警。
1、创建中间件app/Http/Middleware/TrackDbFailureRate.php
2、在handle()中调用DB::transaction()包裹后续逻辑,并使用DB::getPdo()->getAttribute(PDO::ATTR_ERRMODE)确认异常抛出模式
3、捕获Throwable后,使用Cache::increment("db_failures:{$request->ip()}:{$request->route()->getName()}", 1)
4、若缓存值≥5且60秒内,调用Http::post('https://qyapi.weixin.qq.com/cgi-bin/webhook/send?key=xxx', [...])
5、在app/Providers/RouteServiceProvider.php中将该中间件注册为全局中间件
五、利用队列任务异步发送失败查询摘要
将查询异常信息推入队列,由独立worker处理格式化与多通道分发,避免阻塞主请求流程。
1、定义任务类app/Jobs/SendDbFailureAlert.php,实现ShouldQueue接口
2、在__construct()中接收$queryInfo、$exception、$backtrace等参数
3、重写failed()方法:当任务重试耗尽后,向Slack Webhook、邮件、短信网关并行发送结构化报告
4、在查询异常捕获点(如Repository层)调用SendDbFailureAlert::dispatch($data)->delay(now()->addSeconds(5))
5、确保queue:work进程持续运行,并配置--tries=3与--delay=3


















