队列与事件

这一课你将能做到

1. 把发邮件、调外部接口等慢操作改写为队列任务（Job），并配置重试、延迟、链式与批量执行
2. 用事件（Event）与监听器（Listener）做领域解耦，区分同步监听器与队列化监听器
3. 安装 Horizon 监控队列，掌握 worker 的部署守护与发版后的正确重启

为什么要学

一个 HTTP 请求应在几百毫秒内返回。但下单后要发邮件、调 ERP、生成 PDF、推送消息——同步做这些，用户就要等十几秒，任一外部接口超时都会拖垮整个接口。队列把工作「扔到请求之外」：Spring 阵营对应的是 @Async+线程池或 RabbitMQ+@RabbitListener，Laravel 用 Job+队列驱动统一二者，开发时用 sync、上线切 Redis/SQS，业务代码不改。

事件解决耦合：支付成功后的积分、通知、统计会不断增多，全写在支付方法里只会持续膨胀。事件让支付方喊一嗓子「订单已支付」，谁关心谁监听，新增动作不改老代码——对应 Spring 的 ApplicationEventPublisher+@EventListener。

先建立图像

控制器 ──> SendReceipt::dispatch($order)
              ▼
   队列后端（jobs 表 / Redis / SQS）
              ▼
   queue:work（常驻进程）──> Job::handle() 真正干活

event(new OrderPaid($order))
   ├── SendReceipt（同步 Listener）
   ├── AwardPoints（ShouldQueue，自动入队）
   └── NotifyRisk（ShouldQueue，可重试）

Laravel	Spring Boot
ShouldQueue+dispatch	发 MQ / @Async
queue:work	@RabbitListener 消费者
Bus::chain	消息顺序编排（自行实现）
Event+Listener	ApplicationEvent+@EventListener
Horizon	rabbitmq-management 控制台

跟着做

步骤 1：准备队列与任务类

.env 设 QUEUE_CONNECTION=database（生产推荐 redis，学习期 database 最直观）：

php artisan queue:table
php artisan migrate
php artisan make:job SendOrderReceipt

步骤 2：编写 Job

app/Jobs/SendOrderReceipt.php：

<?php

namespace App\Jobs;

use App\Mail\OrderReceipt;
use App\Models\Order;
use Illuminate\Contracts\Queue\ShouldQueue;
use Illuminate\Foundation\Queue\Queueable;
use Illuminate\Queue\SerializesModels;
use Illuminate\Support\Facades\Mail;

class SendOrderReceipt implements ShouldQueue
{
    use Queueable, SerializesModels;

    public int $tries = 3;
    public array $backoff = [10, 30, 60]; // 重试间隔（秒）
    public int $timeout = 60;

    public function __construct(public readonly Order $order) {}

    public function handle(): void
    {
        Mail::to($this->order->user->email)->send(new OrderReceipt($this->order));
    }
}