Laravel中如何使用消息队列Queue_Laravel异步任务队列配置与运行【实战】

11次阅读

laravel队列需手动配置驱动、创建任务类、分发任务并持续运行queue:work进程;开发用database驱动,生产首选redis;任务类须实现ShouldQueue接口构造函数只存依赖、耗时操作放handle();dispatch()后需显式设置delay()、onQueue()和tries;queue:work必须由Supervisor等进程管理器常驻守护,且代码更新后需手动重启worker。

Laravel中如何使用消息队列Queue_Laravel异步任务队列配置与运行【实战】

直接说结论: Laravel 队列不是“开箱即用”的异步魔法,它需要你明确选择驱动、创建任务类、分发任务,并**持续运行一个独立的 queue:work 进程**——漏掉任何一环,任务就只会数据库redis 里,永远不会执行。

怎么选队列驱动?别被文档带偏

开发阶段用 database 最省事,但别在生产环境用它扛流量;redis 是绝大多数项目的实际首选,性能高、支持延迟、重试、优先级队列都原生可用。

  • database:只需两行命令,适合本地验证逻辑是否走队列
    php artisan queue:table
    php artisan migrate

    然后改 .envQUEUE_CONNECTION=database

  • redis:确保已装 predis/prediscomposer require predis/predis),再改 .envQUEUE_CONNECTION=redis;Redis 连接参数(REDIS_HOST 等)必须和 config/database.php 中一致,否则 queue:work 启动就报 “Connection refused”
  • 千万别用 sync 上生产——它只是“假装”进队列,实际还是同步执行,handle() 一卡,整个 http 请求就卡死

任务类怎么写?重点不是逻辑,是接口和构造函数

生成命令是 php artisan make:job SendWelcomeEmail,但关键不在名字,而在三件事:实现 ShouldQueue 接口、把依赖存进属性、别在 __construct 里做耗时操作。

  • 必须实现 ShouldQueue 接口,否则 dispatch() 不会进队列,而是立刻同步执行
  • 所有外部数据(比如 $user)必须通过构造函数传入并赋值给属性,不能在 handle() 里现场查库——因为任务可能几小时后才执行,模型可能已失效
  • 避免在 __construct 中调用 mail::raw()Storage::put(),这些操作应严格放在 handle()

正确示例(简化):

class SendWelcomeEmail implements ShouldQueue {     use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;      protected $user;      public function __construct($user)     {         $this->user = $user; // 只存,不操作     }      public function handle()     {         Mail::to($this->user['email'])->send(new WelcomeMail()); // 执行放这里     } }

任务怎么发?dispatch() 不是万能的,延迟和队列名得手动加

SendWelcomeEmail::dispatch($user) 是最常用写法,但它默认走 default 队列、无延迟、无限重试。真实业务中这三者几乎都要调整。

  • 延迟执行:用 delay(),参数是 DateTimeInterface,别传秒数——->delay(now()->addMinutes(5)) ✅,->delay(300) ❌(Laravel 9+ 已弃用整数秒)
  • 指定队列名:用 onQueue('emails'),这样你可以为邮件、短信、通知分别起不同队列,再用 Supervisor 起多个 queue:work 进程按需消费,避免低优任务挤占高优资源
  • 控制重试:在 Job 类里加 public $tries = 3;,或启动 worker 时加 --tries=3;没设的话默认无限重试,失败任务会一直卡在 jobs 表里占位

怎么让任务真正跑起来?queue:work 必须常驻,且不能裸跑

只在终端敲一次 php artisan queue:work,关掉终端或 ssh 断连,进程就死了——任务永远不执行。生产环境必须用进程管理器守护。

  • 开发调试可临时用:php artisan queue:work --once(只处理一个任务就退出),方便断点调试 handle()
  • 生产环境必须配 Supervisor,核心配置项不能少:autorestart=true(崩溃自动拉起)、numprocs=4(起 4 个 worker 并行)、--tries=3 --timeout=60(防单任务卡死)
  • 别用 queue:listen:它是旧版命令,性能差、不支持 Redis 的阻塞读,官方已弃用多年

最容易被忽略的一点:queue:work 进程启动后,**不会自动感知代码更新**。改了 handle() 方法?必须手动 supervisorctl restart laravel-worker: 或 kill 进程重启,否则跑的还是旧逻辑。

text=ZqhQzanResources