Laravel如何配置和使用队列处理异步任务_Laravel队列驱动与任务分发实例-Laravel-PHP中文网

Laravel如何配置和使用队列处理异步任务_Laravel队列驱动与任务分发实例

裘德小鎮的故事

发布： 2025-12-08 23:03:06

原创

959人浏览过

Laravel队列通过异步处理耗时任务提升应用性能，首先配置QUEUE_CONNECTION=database并生成jobs表，接着创建实现ShouldQueue接口的Job类如SendWelcomeEmail，最后在路由中使用dispatch分发任务，配合queue:work命令监听执行，支持延迟、重试及队列隔离等优化策略。

laravel如何配置和使用队列处理异步任务_laravel队列驱动与任务分发实例

Laravel 队列系统让耗时任务（如发送邮件、处理图片、调用外部 API）可以异步执行，避免阻塞用户请求。通过配置队列驱动和分发任务，能显著提升应用响应速度和用户体验。下面介绍如何配置 Laravel 队列，并以实际例子说明任务的创建与分发。

配置队列驱动

Laravel 支持多种队列驱动：sync（同步）、database（数据库）、redis、beanstalkd、sqs 等。开发阶段推荐使用 database 驱动，简单易用。

1. 修改 .env 文件指定队列连接：

QUEUE_CONNECTION=database

2. 创建数据表存储待处理任务：

运行以下命令生成迁移文件：

php artisan queue:table

然后执行迁移：

php artisan migrate

3. 启动队列监听器：

在终端运行：

php artisan queue:work

该进程会持续监听队列，处理新任务。注意：代码变更后需重启此进程。

创建队列任务类

使用 Artisan 命令创建任务类，例如创建一个发送欢迎邮件的任务：

php artisan make:job SendWelcomeEmail

生成的类位于 app/Jobs/SendWelcomeEmail.php，编辑内容如下：

魔术橡皮擦

智能擦除、填补背景内容

查看详情

<?php

namespace App\Jobs;

use Illuminate\Bus\Queueable;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Bus\Dispatchable;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Mail;

class SendWelcomeEmail implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    public $user;

    public function __construct($user)
    {
        $this->user = $user;
    }

    public function handle()
    {
        Mail::raw('欢迎加入我们！', function ($message) {
            $message->to($this->user['email'])
                    ->subject('欢迎');
        });
    }
}

登录后复制

该任务实现了 ShouldQueue 接口，意味着它会被推入队列异步执行。

分发任务到队列

在控制器或路由中，使用 dispatch() 方法推送任务：

use App\Jobs\SendWelcomeEmail;

Route::get('/register', function () {
    $user = ['name' => '张三', 'email' => 'zhangsan@example.com'];

    SendWelcomeEmail::dispatch($user);

    return '注册成功，欢迎邮件已加入队列';
});

登录后复制

访问 /register 路由后，任务被写入数据库的 jobs 表，queue:work 进程会自动取出并执行。