技术百科

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

作者:冰火之心2025-11-19 00:00:00

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 配置示例：

[pro

gram: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