Laravel队列任务时长统计方法分析

想精准掌握 Laravel 队列任务的实际运行效率？本文系统剖析了四种实用且可落地的耗时统计方案：从低侵入性的自定义队列中间件（基于 Redis 分桶计数），到针对关键任务的手动计时写库；从 Horizon 原生事件监听自动提取 `started_at`/`finished_at` 的生产友好方式，再到通过基类 `__destruct` 统一日志+SQL 聚合分析的全量追踪策略——无论你是否已接入 Horizon，处于开发调试还是高负载生产环境，总有一种方法能帮你快速定位慢任务、量化性能瓶颈，并为容量规划和优化决策提供真实数据支撑。

如果您需要了解 Laravel 应用中各队列任务的实际执行耗时分布情况，则需在任务执行前后采集时间戳并进行归类统计。以下是实现该目标的多种方法：

一、使用中间件方式在任务执行前后记录时间

通过自定义队列中间件，在任务 handle 方法调用前获取起始时间，调用后获取结束时间，计算差值并写入统计存储（如 Redis 或数据库）。该方式侵入性低，适用于所有基于 Illuminate\Bus\Queueable 的任务。

1、创建中间件类：运行 php artisan make:queue:middleware LogExecutionTime。

2、在中间件 handle 方法中，使用 microtime(true) 获取执行前时间戳，并存入 $job->payload()['start_time']。

3、调用 $next($job) 执行原任务逻辑。

4、再次调用 microtime(true)，与起始时间相减得出耗时（单位：秒），四舍五入保留三位小数。

5、将耗时按区间归类（例如 0–100ms、101–500ms、501–2000ms、>2000ms），使用 Redis 的 HINCRBY 统计各区间频次。

二、重写 Job 类的 fire 或 handle 方法

针对特定任务类，可在 handle 方法开头记录开始时间，在末尾记录结束时间并完成统计。该方式粒度细、可控性强，适合对关键任务单独分析。

1、在任务类的 handle 方法第一行插入 $start = microtime(true)。

2、在 handle 方法最后一行前插入 $duration = round((microtime(true) - $start) * 1000)。

3、根据 $duration 值判断所属毫秒区间：0–99 对应“超快”，100–499 对应“较快”，500–1999 对应“一般”，2000+ 对应“缓慢”。

4、调用 DB::table('queue_duration_logs')->insert([...]) 写入结构化日志。

三、利用 Laravel Horizon 的事件监听机制

Horizon 提供了 TaskProcessed 和 TaskFailed 事件，可在事件监听器中提取任务元数据与执行耗时信息，适用于已启用 Horizon 的生产环境。

1、注册监听器：在 EventServiceProvider 的 $listen 数组中添加 'Laravel\Horizon\Events\TaskProcessed' => [ProcessDurationListener::class]。

2、在监听器 handle 方法中，从 $event->payload 获取 'started_at' 和 'finished_at' 字段（Horizon 自动注入）。

3、计算差值：$ms = ($event->payload['finished_at'] - $event->payload['started_at']) * 1000。

4、使用 Cache::increment("queue:duration:bucket:{$this->getBucket($ms)}") 累加对应区间的计数。

5、注意：需确保 Horizon 配置中 enable_fast_termination = true 且 supervisor 的 timeout 值合理，否则 finished_at 可能失真。

四、通过数据库日志表聚合分析

在任务基类中统一注入日志行为，将每次执行的队列名称、任务类名、开始时间、结束时间、耗时（ms）、是否失败等字段写入专用数据表，后续用 SQL 进行分桶统计。

1、执行 php artisan make:migration create_queue_task_durations_table 创建日志表。

2、迁移中定义字段：queue（string）、job (string)、started_at (datetime)、ended_at (datetime)、duration_ms (integer)、failed (boolean)。

3、在 app/Jobs/Job.php 基类构造函数中调用 static::$logStart = microtime(true)。

4、重写 __destruct 方法，检测 static::$logStart 是否存在，若存在则计算耗时并调用 DB::table(...)->insert() 写入。

5、使用如下 SQL 查询分布：SELECT COUNT(*) AS cnt, CASE WHEN duration_ms 。

今天带大家了解了的相关知识，希望对你有所帮助；关于文章的技术知识我们会一点点深入介绍，欢迎大家关注golang学习网公众号，一起学习编程~