0

0

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

冰火之心

冰火之心

发布时间:2025-11-19 11:05:02

|

622人浏览过

|

来源于php中文网

原创

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

也可以控制延迟执行:

PixVerse
PixVerse

PixVerse是一款强大的AI视频生成工具,可以轻松地将多种输入转化为令人惊叹的视频。

下载
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 持续运行。

相关专题

更多
php文件怎么打开
php文件怎么打开

打开php文件步骤:1、选择文本编辑器;2、在选择的文本编辑器中,创建一个新的文件,并将其保存为.php文件;3、在创建的PHP文件中,编写PHP代码;4、要在本地计算机上运行PHP文件,需要设置一个服务器环境;5、安装服务器环境后,需要将PHP文件放入服务器目录中;6、一旦将PHP文件放入服务器目录中,就可以通过浏览器来运行它。

2593

2023.09.01

php怎么取出数组的前几个元素
php怎么取出数组的前几个元素

取出php数组的前几个元素的方法有使用array_slice()函数、使用array_splice()函数、使用循环遍历、使用array_slice()函数和array_values()函数等。本专题为大家提供php数组相关的文章、下载、课程内容,供大家免费下载体验。

1620

2023.10.11

php反序列化失败怎么办
php反序列化失败怎么办

php反序列化失败的解决办法检查序列化数据。检查类定义、检查错误日志、更新PHP版本和应用安全措施等。本专题为大家提供php反序列化相关的文章、下载、课程内容,供大家免费下载体验。

1508

2023.10.11

php怎么连接mssql数据库
php怎么连接mssql数据库

连接方法:1、通过mssql_系列函数;2、通过sqlsrv_系列函数;3、通过odbc方式连接;4、通过PDO方式;5、通过COM方式连接。想了解php怎么连接mssql数据库的详细内容,可以访问下面的文章。

952

2023.10.23

php连接mssql数据库的方法
php连接mssql数据库的方法

php连接mssql数据库的方法有使用PHP的MSSQL扩展、使用PDO等。想了解更多php连接mssql数据库相关内容,可以阅读本专题下面的文章。

1417

2023.10.23

html怎么上传
html怎么上传

html通过使用HTML表单、JavaScript和PHP上传。更多关于html的问题详细请看本专题下面的文章。php中文网欢迎大家前来学习。

1234

2023.11.03

PHP出现乱码怎么解决
PHP出现乱码怎么解决

PHP出现乱码可以通过修改PHP文件头部的字符编码设置、检查PHP文件的编码格式、检查数据库连接设置和检查HTML页面的字符编码设置来解决。更多关于php乱码的问题详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1447

2023.11.09

php文件怎么在手机上打开
php文件怎么在手机上打开

php文件在手机上打开需要在手机上搭建一个能够运行php的服务器环境,并将php文件上传到服务器上。再在手机上的浏览器中输入服务器的IP地址或域名,加上php文件的路径,即可打开php文件并查看其内容。更多关于php相关问题,详情请看本专题下面的文章。php中文网欢迎大家前来学习。

1306

2023.11.13

高德地图升级方法汇总
高德地图升级方法汇总

本专题整合了高德地图升级相关教程,阅读专题下面的文章了解更多详细内容。

9

2026.01.16

热门下载

更多
网站特效
/
网站源码
/
网站素材
/
前端模板

精品课程

更多
相关推荐
/
热门推荐
/
最新课程
Laravel---API接口
Laravel---API接口

共7课时 | 0.6万人学习

PHP自制框架
PHP自制框架

共8课时 | 0.6万人学习

PHP面向对象基础课程(更新中)
PHP面向对象基础课程(更新中)

共12课时 | 0.7万人学习

关于我们 免责申明 举报中心 意见反馈 讲师合作 广告合作 最新更新
php中文网:公益在线php培训,帮助PHP学习者快速成长!
关注服务号 技术交流群
PHP中文网订阅号
每天精选资源文章推送

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