Laravel队列怎么使用_Laravel队列系统配置与任务调度方法

Laravel队列可延后执行耗时任务以提升响应速度。首先配置QUEUE_CONNECTION=redis并安装predis/predis，接着使用php artisan make:job创建任务类，在handle()中编写逻辑如发邮件。通过SendWelcomeEmail::dispatch($user)分发任务，支持delay()延迟和onQueue()指定队列。生产环境用php artisan queue:work配合Supervisor持续处理，开发可用queue:listen自动重载。结合任务调度，于Kernel.php的schedule()中设置$schedule->job(new ClearExpiredRecords)->daily()，再配置crontab每分钟运行php artisan schedule:run，实现定时触发队列任务。

Laravel 队列系统能帮助你将耗时任务延后执行，比如发送邮件、处理图片、调用外部 API 等，从而提升应用响应速度。合理使用队列可以显著改善用户体验和服务器负载。下面介绍 Laravel 队列的基本使用、配置方式以及如何结合任务调度实现定时执行。

配置队列驱动

Laravel 支持多种队列驱动：sync（同步）、database（数据库）、redis、beanstalkd、sqs 等。生产环境推荐使用 redis 或 database。

在 .env 文件中设置默认队列连接：

QUEUE_CONNECTION=redis

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

composer require predis/predis

然后确认 config/queue.php 中的 redis 连接配置正确，包括主机、端口、密码等。

创建可队列化任务

使用 Artisan 命令创建任务类：

php artisan make:job SendWelcomeEmail

生成的任务类位于 app/Jobs/SendWelcomeEmail.php。你需要在 handle() 方法中写入实际逻辑：

public function handle()
{
// 发送欢迎邮件逻辑
Mail::to($this->user)->send(new WelcomeMail());
}

构造函数中传入必要数据，如用户对象或 ID，便于任务执行时使用。

分发任务到队列

在控制器或其他业务逻辑中，使用 dispatch() 方法推送任务：

SendWelcomeEmail::dispatch($user);

也可以控制延迟执行：

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

如果想指定队列名称（如 high、default），可使用：

endWelcomeEmail::dispatch($user)->onQueue('emails');

启动队列监听器

运行以下命令启动队列处理器：

php artisan queue:work

这个命令会持续监听队列并处理任务。建议配合进程管理工具如 Supervisor 在生产环境运行，防止中断。

开发调试时可使用：

php artisan queue:listen

它会在每次执行前重新加载代码，适合调试阶段。

结合任务调度自动执行

Laravel 的任务调度功能允许你定时触发任务分发。比如每天凌晨清理过期数据：

先创建一个任务：

php artisan make:job ClearExpiredRecords

然后在 app/Console/Kernel.php 的 schedule() 方法中添加调度：

protected function schedule(Schedule $schedule)
{
$schedule->job(new ClearExpiredRecords)->daily();
}

再配置系统 crontab，确保 Laravel 调度器每分钟运行一次：

* * * * * cd /path-to-your-project && php artisan schedule:run >> /dev/null 2>&1

这样 Laravel 会根据设定自动分发任务到队列中执行。

基本上就这些。Laravel 队列与调度配合使用，能高效管理后台任务，避免阻塞请求流程。关键是选对驱动、正确分发任务，并用 Supervisor 或 cron 保证运行稳定。

# php # laravel # redis # composer # 处理器 # app # 端口 # 工具 # ai # red # talk # NULL # 构造函数 # require # mail # public # protected # console # function # 对象 # default # this # database # 数据库 # 每分钟 # 延后 # 推荐使用 # 会在 # 或其他 # 应在 # 你将 # 创建一个 # 发邮件 # 发送邮件

返回目录在线咨询

上一篇：jQuery实现火车票买票城市选择切换功能
下一篇：PHP实现的链式队列结构示例

您的项目需求

*请认真填写需求信息，我们会在24小时内与您取得联系。