Laravel 的作业（Jobs）和队列（Queues）功能是处理后台任务和延迟任务的强大工具。在 web 开发中，通常需要执行一些时间较长的操作，如发送电子邮件、处理上传文件、生成报告等。为了不阻塞用户的请求响应，Laravel 提供了队列系统来将这些任务推迟到后台处理。本文将详细介绍如何在 Laravel 中使用作业和队列。
1. 什么是作业与队列？
- 作业（Jobs）：是一个封装的后台任务，表示需要执行的具体操作。例如，发送电子邮件、生成 PDF 文件等。
- 队列（Queues）：队列是一个消息队列的概念，用于存储作业，并按顺序执行这些作业。Laravel 提供了多种队列驱动，例如数据库、Redis、Amazon SQS 等。
2. 设置队列驱动
Laravel 支持多种队列驱动。你可以在 config/queue.php 文件中设置队列驱动，默认情况下是使用数据库驱动。
2.1 配置队列驱动
- 打开
config/queue.php文件并设置你希望使用的队列驱动。例如，要使用 Redis 作为队列驱动，确保.env文件中有正确的配置：
QUEUE_CONNECTION=redis在 config/queue.php 中，确保相应的队列驱动配置正确：
'connections' => [
'redis' => [
'driver' => 'redis',
'connection' => 'default',
'queue' => env('REDIS_QUEUE', 'default'),
'retry_after' => 90,
],
],2.2 配置其他队列驱动
Laravel 还支持数据库、Beanstalkd、Amazon SQS 等驱动。你可以根据需要选择不同的队列驱动，并进行相应配置。
3. 创建作业（Job）
Laravel 提供了一个 Artisan 命令来生成作业类。作业类通常用于封装需要后台执行的任务。
3.1 创建作业
使用以下命令来生成一个新的作业类：
php artisan make:job SendWelcomeEmail生成的作业类位于 app/Jobs 目录下。例如，SendWelcomeEmail 作业类如下所示：
// app/Jobs/SendWelcomeEmail.php
namespace App\Jobs;
use App\Models\User;
use App\Mail\WelcomeEmail;
use Illuminate\Support\Facades\Mail;
use Illuminate\Contracts\Queue\ShouldQueue;
class SendWelcomeEmail implements ShouldQueue
{
protected $user;
// 构造函数，接收 User 对象
public function __construct(User $user)
{
$this->user = $user;
}
// 作业的处理方法
public function handle()
{
// 发送欢迎邮件
Mail::to($this->user->email)->send(new WelcomeEmail($this->user));
}
}在这个例子中，SendWelcomeEmail 作业需要发送一封欢迎电子邮件。handle 方法中实现了具体的业务逻辑，发送邮件的操作。
3.2 使作业队列化
为了将作业推送到队列中，作业类需要实现 ShouldQueue 接口。当实现了该接口后，作业会自动推送到指定的队列中，而不是直接执行。
4. 派发作业
要派发作业，可以使用 dispatch() 方法。例如，在控制器中派发作业：
use App\Jobs\SendWelcomeEmail;
public function register(Request $request)
{
$user = User::create($request->all());
// 派发作业到队列
SendWelcomeEmail::dispatch($user);
return response()->json(['message' => 'User registered and email queued.']);
}当用户注册时，SendWelcomeEmail 作业将被推送到队列中进行处理。
5. 队列监听与处理
Laravel 提供了 queue:work 命令来监听队列并处理其中的作业。你可以通过以下命令来启动队列处理程序：
php artisan queue:work该命令会一直运行并处理队列中的作业。你可以在生产环境中使用队列监听器，后台处理作业。
5.1 运行队列监听器
为了让队列始终在后台运行并处理作业，可以使用 Laravel 提供的 queue:work 命令配合 supervisor 或其他进程管理工具来保持队列监听器常驻后台。
例如，使用 Supervisor 来管理队列监听器：
- 安装 Supervisor：
sudo apt-get install supervisor- 配置 Supervisor 来监听队列：
sudo nano /etc/supervisor/conf.d/laravel-queue-worker.conf配置文件示例：
[program:laravel-queue-worker]
process_name=%(program_name)s
command=php /path/to/your/project/artisan queue:work
autostart=true
autorestart=true
user=www-data
redirect_stderr=true
stdout_logfile=/path/to/your/project/storage/logs/laravel-queue-worker.log- 更新 Supervisor 配置并启动队列监听器：
sudo supervisorctl reread
sudo supervisorctl update
sudo supervisorctl start laravel-queue-worker6. 延迟执行作业
Laravel 支持将作业延迟执行。你可以在派发作业时指定延迟时间：
// 延迟 10 分钟执行作业
SendWelcomeEmail::dispatch($user)->delay(now()->addMinutes(10));7. 作业失败与重试
作业可能会失败，Laravel 提供了失败作业处理机制。在作业类中，你可以定义失败时的处理方法：
// app/Jobs/SendWelcomeEmail.php
public function failed(\Exception $exception)
{
// 当作业失败时执行的操作，例如发送失败通知
\Log::error('Sending welcome email failed for user: ' . $this->user->email);
}Laravel 会自动处理失败的作业，并根据队列配置重试作业。你可以通过设置 retry_after 来指定每次作业重试的时间间隔。
8. 队列调度与优先级
Laravel 支持为不同的队列设置优先级。例如，某些作业可能需要高优先级，另一些作业则可以低优先级执行。你可以在派发作业时设置队列名称：
SendWelcomeEmail::dispatch($user)->onQueue('high');在 config/queue.php 文件中，可以配置多个队列连接并设置优先级。
9. API 触发队列
Laravel 还可以通过 API 来触发队列。通过接收 API 请求并将作业推送到队列，便可以执行后台任务。例如，可以通过 RESTful API 接收用户注册请求，并将邮件发送作业推送到队列中。