首页 > php框架 > Laravel > 正文

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

冰火之心
发布: 2025-11-19 11:05:02
原创
592人浏览过
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队列系统如何配置和处理异步任务

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);

也可以控制延迟执行:

GAIPPT
GAIPPT

AI PPT制作和美化神器

GAIPPT 1129
查看详情 GAIPPT
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 持续运行。

以上就是Laravel队列系统如何配置和处理异步任务的详细内容,更多请关注php中文网其它相关文章!

最佳 Windows 性能的顶级免费优化软件
最佳 Windows 性能的顶级免费优化软件

每个人都需要一台速度更快、更稳定的 PC。随着时间的推移,垃圾文件、旧注册表数据和不必要的后台进程会占用资源并降低性能。幸运的是,许多工具可以让 Windows 保持平稳运行。

下载
来源:php中文网
本文内容由网友自发贡献,版权归原作者所有,本站不承担相应法律责任。如您发现有涉嫌抄袭侵权的内容,请联系admin@php.cn
最新问题
开源免费商场系统广告
热门教程
更多>
最新下载
更多>
网站特效
网站源码
网站素材
前端模板
关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新 English
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送
PHP中文网APP
随时随地碎片化学习

Copyright 2014-2025 https://www.php.cn/ All Rights Reserved | php.cn | 湘ICP备2023035733号