Laravel队列工作者？队列如何监听处理？

34次阅读

要确保Laravel队列工作者在生产环境中稳定运行，必须使用Supervisor等进程管理工具监控worker进程，防止崩溃后服务中断；通过配置max-jobs和max-time参数避免内存泄漏；结合Sentry或日志系统实现错误监控；部署新代码时执行php artisan queue:restart实现平滑重启；同时利用failed()方法处理任务失败，并借助failed_jobs表和重试命令管理失败任务。生产环境应优先使用高性能的queue:work命令，开发环境可选用自动加载代码的queue:listen。

Laravel队列工作者，简单来说，就是你应用背后那个默默无闻的执行者。它不是一次性脚本，而是一个常驻进程，专门负责监听你的队列，一旦有新任务进来，它就会立即抓取并处理。这就像你把一堆待办事项扔进一个收件箱，而工作者就是那个盯着收件箱，然后逐一处理这些事项的人。它把那些耗时、需要异步执行的任务从用户请求的响应流程中抽离出来，让你的应用响应更快，用户体验更好。

解决方案

要让Laravel队列工作者真正跑起来，我们首先得搞清楚它的核心机制和配置。最直接的启动方式就是通过Artisan命令，

php artisan queue:work

是你最常用的指令。这个命令会启动一个工作者进程，它会持续地从你配置的队列连接中拉取任务并执行。

在配置文件

config/queue.php

里，你可以定义不同的队列连接，比如

redis

、

database

甚至

sync

（同步执行，通常用于开发或测试）。选择哪个驱动，取决于你的应用规模和需求。Redis通常是生产环境的首选，因为它速度快、性能好。

当你通过

dispatch(new MyJob($data))

将一个任务推入队列时，这个任务实际上是被序列化并存储在选定的队列驱动中。工作者进程会不断地轮询这个存储位置。一旦发现新任务，它会反序列化任务实例，然后调用任务类中的

handle()

方法来执行具体的业务逻辑。

对于生产环境，你几乎肯定需要一个进程管理器，比如Supervisor，来确保你的队列工作者持续运行。Supervisor能监控你的工作者进程，如果它们因为某种原因崩溃了，它会自动重启它们，保证队列服务的韧性。这是非常关键的一步，否则你的异步任务就可能因为工作者挂掉而停摆。

别忘了，当你部署了新的代码时，由于

queue:work

进程会将应用状态加载到内存中，它不会自动加载新的代码。这时你需要执行

php artisan queue:restart

。这个命令会温柔地告诉所有正在运行的工作者，在完成当前任务后优雅地退出，然后Supervisor（或者你使用的其他进程管理器）就会启动新的工作者进程，加载最新的代码。

// 示例：一个简单的队列任务 namespace appJobs;  use IlluminateBusQueueable; use IlluminateContractsQueueShouldQueue; use IlluminateFoundationBusDispatchable; use IlluminateQueueInteractsWithQueue; use IlluminateQueueSerializesModels; use IlluminateSupportFacadesLog;  class ProcessPodcast implements ShouldQueue {     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;      protected $podcast;      /**      * 创建一个新的任务实例。      *      * @param  AppModelsPodcast  $podcast      * @return void      */     public function __construct($podcast)     {         $this->podcast = $podcast;     }      /**      * 执行任务。      *      * @return void      */     public function handle()     {         // 假设这里有一些耗时的操作，比如处理音频文件         Log::info("正在处理播客: " . $this->podcast->title);         sleep(5); // 模拟耗时操作         Log::info("播客处理完成: " . $this->podcast->title);          // 可以在这里更新数据库状态，发送通知等     } }

要分发这个任务：

ProcessPodcast::dispatch($somePodcastInstance);

如何确保Laravel队列工作者在生产环境中稳定运行？

在生产环境里，队列工作者的稳定性是核心，因为它直接影响到异步任务的可靠性。我个人觉得，最关键的就是要有一个健壮的进程管理策略。Supervisor 几乎是标配，它能监控

php artisan queue:work

进程的生命周期。当工作者因为任何原因（比如内存溢出、未捕获的异常）崩溃时，Supervisor能立即将其重启，确保服务不中断。这比你手动去检查和重启要靠谱得多。

除了进程管理，资源管理也至关重要。长时间运行的PHP进程可能会有内存泄漏的风险，虽然现代PHP和Laravel已经做得很好，但也不能完全忽视。所以，给工作者设置

max-jobs

和

max-time

参数是个好习惯。例如：

php artisan queue:work --tries=3 --max-time=3600 --max-jobs=1000

。这意味着一个工作者在处理1000个任务或运行1小时后，会优雅地退出。Supervisor会负责重启一个新的工作者，这样就避免了单个进程长时间运行可能带来的潜在问题。

错误监控是另一个不可或缺的环节。仅仅知道工作者在运行还不够，你还需要知道任务是否成功执行，或者有没有遇到错误。集成Sentry、Bugsnag这类错误追踪工具，或者至少配置好Laravel的日志系统，确保所有队列任务中的异常都能被捕获并记录下来。这样，一旦有任务失败，你就能及时收到通知并进行排查。我遇到过不少情况，任务失败了但没人知道，直到用户反馈问题才发现，那体验可太差了。

最后，部署策略也需要考虑。每次代码更新后，你都需要让现有的工作者进程加载新的代码。最简单有效的方式就是运行

php artisan queue:restart

。这个命令会在你的应用根目录创建一个

queue.restart

文件，所有正在运行的工作者在完成当前任务后会检测到这个文件并优雅退出。然后，Supervisor会启动新的工作者进程，加载最新的代码。这是一个非常平滑的更新方式，避免了任务中断。

队列任务失败了怎么办？Laravel的失败任务处理机制是怎样的？

任务失败是常有的事，网络波动、外部API错误、数据异常都可能导致队列任务执行失败。Laravel在这方面做得相当周到，提供了一套相对完善的失败任务处理机制。

首先，当一个队列任务抛出异常且没有被捕获时，Laravel会将其标记为失败。默认情况下，它会将失败任务的相关信息，包括任务类名、连接、队列、负载（payload）以及错误信息，记录到

failed_jobs

数据库表中。这个表是你在运行

php artisan queue:table

和

php artisan migrate

后创建的。有了这个表，你就能清晰地看到哪些任务失败了，以及失败的具体原因。

任务类本身可以定义

tries

和

timeout

属性。

public $tries = 3;

意味着这个任务在失败后会最多尝试重试3次。每次重试之间会有一个指数退避的延迟，以避免立即重试再次失败。

public $timeout = 60;

则表示如果任务执行超过60秒，就会被工作者终止，并被标记为失败。这些配置对于处理那些偶发性错误或长时间运行的任务非常有用。

Spacely AI

为您的房间提供AI室内设计解决方案，寻找无限的创意

32

查看详情

当任务最终失败（即达到最大重试次数或超时）时，你可以在任务类中定义一个

failed()

方法。这个方法会在任务最终失败时被调用，你可以在这里执行一些清理工作，比如回滚数据库事务、发送失败通知（邮件、Slack等），或者记录更详细的错误日志。这是一个非常强大的钩子，能让你对任务失败做出更精细的响应。

// 示例：带失败处理的队列任务 namespace AppJobs;  use IlluminateBusQueueable; use IlluminateContractsQueueShouldQueue; use IlluminateFoundationBusDispatchable; use IlluminateQueueInteractsWithQueue; use IlluminateQueueSerializesModels; use IlluminateSupportFacadesLog; use Throwable; // 引入Throwable  class ProcessOrder implements ShouldQueue {     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;      public $tries = 5; // 最多尝试5次     public $timeout = 120; // 任务超时时间120秒      protected $orderId;      public function __construct($orderId)     {         $this->orderId = $orderId;     }      public function handle()     {         // 模拟一个可能失败的操作         if (rand(1, 10) < 3) { // 30%的几率失败             throw new Exception("订单处理失败，可能是外部服务不可用。订单ID: " . $this->orderId);         }          Log::info("订单处理成功: " . $this->orderId);     }      /**      * 任务失败时调用的方法。      *      * @param  Throwable  $exception      * @return void      */     public function failed(Throwable $exception)     {         // 发送通知给管理员         // Mail::to('admin@example.com')->send(new OrderFailedNotification($this->orderId, $exception->getMessage()));         Log::error("订单任务最终失败: " . $this->orderId . " 错误: " . $exception->getMessage());         // 可以在这里更新订单状态为“失败”     } }

对于那些已经被记录在

failed_jobs

表中的任务，你可以使用

php artisan queue:retry {id}

命令来手动重试单个任务，或者

php artisan queue:retry all

来重试所有失败任务。这在修复了底层问题后，非常有用地恢复之前失败的任务。

queue:work

和

queue:listen

有什么区别？什么时候应该选择哪一个？

queue:work

和

queue:listen

都是用来启动队列工作者的Artisan命令，但它们的工作方式有着本质的区别，这直接影响到你在不同场景下的选择。

php artisan queue:work

这是我个人在生产环境中最推荐使用的命令。它的核心特点是：

长驻进程，一次性加载应用： 当你运行
```
queue:work
```
时，Laravel应用会被完全加载到内存中，并且会一直保持这个状态。它会持续地从队列中拉取任务并执行，而无需每次都重新启动应用。
高性能： 由于不需要反复启动Laravel框架，
```
queue:work
```
的性能开销非常小，处理任务的速度更快。
内存驻留： 优点是快，缺点是如果你的代码有内存泄漏，或者需要加载新的代码，就需要手动重启工作者。
需要

php artisan queue:restart

：每当你部署了新的代码，为了让工作者加载最新的业务逻辑，你必须执行
```
php artisan queue:restart
```
。

php artisan queue:listen

这个命令的工作方式则完全不同：

每次任务都重新启动应用：
```
queue:listen
```
在处理每个队列任务之前，都会重新引导（bootstrap）整个Laravel应用。这意味着它会重新加载所有代码、配置和容器。
自动加载代码变更： 正因为每次都重新启动应用，
```
queue:listen
```
会自动检测到代码的变更，无需手动重启工作者。
性能开销大： 反复引导应用会带来显著的性能开销，处理任务的速度会比
```
queue:work
```
慢很多。
内存管理相对简单： 因为每次都重新启动，所以不会有
```
queue:work
```
那种长期运行可能带来的内存泄漏问题。

什么时候选择哪一个？

选择

queue:work

（生产环境首选）：
- 追求高性能和低延迟： 你的应用需要快速处理大量队列任务。
- 代码部署频率不高，或有完善的CI/CD流程： 你可以轻松地在部署后执行
```
php artisan queue:restart
```
  。
- 使用进程管理器（如Supervisor）： 确保工作者进程的稳定性和自动重启。
选择

queue:listen

（开发环境或特定场景）：
- 开发阶段： 你在本地开发时，频繁修改代码，
```
queue:listen
```
  能让你立即看到代码变更的效果，而无需手动重启工作者。这大大提升了开发效率。
- 对性能要求不高，但要求代码变更即时生效的场景： 比如一些非关键的、任务量很小的后台服务。
- 不使用进程管理器： 如果你没有Supervisor等工具，
```
queue:listen
```
  至少能保证在代码更新后，新的逻辑能被执行到。