信息发布→ 登录 注册 退出

Laravel队列系统如何配置和处理异步任务

发布时间:2025-11-19

点击量:
Laravel 队列通过异步处理耗时任务提升性能,需配置 QUEUE_CONNECTION=redis 等驱动,使用 php artisan make:job 创建任务类并实现 handle() 方法,分发任务用 SendWelcomeEmail::dispatch($user),延迟执行可加 delay(),运行 php artisan queue:work 启动监听器,生产环境配合 Supervisor 管理进程,失败任务通过 php artisan queue:failed-table 记录并用 queue:retry 重试,任务类中可定义 failed() 方法处理异常。

Laravel 队列系统让你能将耗时任务延后执行,比如发送邮件、处理图片或调用外部 API。通过配置队列,你可以把这类操作放到后台异步处理,提升应用响应速度和用户体验。

选择并配置队列驱动

Laravel 支持多种队列驱动:sync(同步)、database、redis、beanstalkd、sqs 等。开发阶段常用 database 或 redis。

.env 文件中设置默认驱动:

QUEUE_CONNECTION=redis

对应在 config/queue.php 中配置连接信息。例如使用 Redis 时确保已安装 predis/predis:

'redis' => [ 'driver' => 'redis', 'connection' => 'default', 'queue' => env('REDIS_QUEUE', 'default'), 'retry_after' => 90, ],

创建队列任务类

使用 Artisan 命令生成任务:

php artisan make:job SendWelcomeEmail

在生成的类中编写逻辑,重点是 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($this->user));
}

}

实现 ShouldQueue 接口后,该任务会自动异步执行。

分发任务到队列

在控制器或其他位置分发任务:

use App\Jobs\SendWelcomeEmail;

// 分发任务 SendWelcomeEmail::dispatch($user);

也可以控制延迟执行:

SendWelcomeEmail::dispatch($user)->delay(now()->addMinutes(10));

启动队列监听器

运行以下命令启动消费者处理任务:

php artisan queue:work

推荐使用 queue:work 而非 queue:listen,前者性能更好。生产环境建议配合进程管理工具如 Supervisor,防止进程意外退出。

Supervisor 配置示例:

[program:laravel-worker] process_name=%(program_name)s_%(process_num)02d command=php /path/to/artisan queue:work redis --sleep=3 --tries=3 autostart=true autorestart=true user=www-data numprocs=4 redirect_stderr=true stdout_logfile=/path/to/logs/worker.log

处理失败任务

创建失败任务记录表:

php artisan queue:failed-table php artisan migrate

启用失败任务捕获后,Laravel 会自动记录失败任务。可通过以下命令查看和重试:

php artisan queue:failed # 查看失败任务 php artisan queue:retry all # 重试所有 php artisan queue:forget 1 # 删除某条记录

在任务类中还可定义 failed() 方法,用于自定义失败后的处理逻辑,比如发送告警。

基本上就这些。配置好驱动、创建任务、分发并运行 worker,就能让 Laravel 高效处理异步任务。关键是选对驱动并保证 worker 持续运行。

标签:# 异步  # 自定义  # 或其他  # 能让  # 这类  # 推荐使用  # 你可以  # 让你  # 发送邮件  # 类中  # 重试  # database  # table  # laravel  # default  # class  # 接口  # talk  # red  # 异步任务  # ai  # 工具  # app  # redis  # php  
在线客服
服务热线

服务热线

4008888355

微信咨询
二维码
返回顶部
×二维码

截屏,微信识别二维码

打开微信

微信号已复制,请打开微信添加咨询详情!