主页 / coding / 问题 / 79574772
Accepted
nrkdrk
Asked: 2025-04-15 17:13:02 +0800 CST

如何确保链式 Laravel 作业在多工作器设置中的同一台服务器上运行？

  • 772

在我的 Laravel 项目中，我有 5 到 6 个不同的队列。每个队列都会按照严格的顺序触发下一个队列，形成如下的处理链：

工作 1 → 工作 2 → 工作 3 → 工作 4 → 工作 5

该流程始终由以 Job1 开头的外部请求触发。每个作业执行一个文件操作（创建/修改文件），这些文件存储在执行该作业的服务器本地。

当我尝试通过添加更多服务器来处理队列来实现水平扩展时，问题就出现了。由于 Laravel 队列是分布式的，因此无法保证 Job2 会由处理 Job1 的同一台服务器处理——这会中断流程，因为 Job2 需要访问 Job1 创建的本地文件。

我的需求：我想确保一旦 Job1 在特定服务器上启动，整个作业链（Job2 到 Job5）就会在同一服务器上继续运行 — — 即使在多服务器设置中也是如此。

我尝试过的方法：将“机器 ID”附加到作业有效负载 - 但这并不能保证该作业将被同一台机器接收。

在线搜索“粘性作业”或“将作业固定到同一个工作者/服务器” - 但找不到干净或官方的解决方案。

我的问题是：有人处理过类似的需求吗？在 Laravel 中，运行分布式队列系统时，有没有一种行之有效的方法可以将作业链固定到同一台服务器上？

laravel

1 个回答

  1. Best Answer

    这是我解决这个问题的概念证明。

    假设你有 3 台服务器。它们可以是物理机，也可以是虚拟机/容器。每台服务器都有自己的队列。

    Container A → php artisan queue:work --queue=queue1

Container B → php artisan queue:work --queue=queue2

Container C → php artisan queue:work --queue=queue3

    在你的 laravel 应用程序中，你可以执行以下操作：

    Route::get('/', function () {
    $available_queues = [
        'queue1',
        'queue2',
        'queue3',
    ];

    $random_queue = $available_queues[array_rand($available_queues)];

    dump($random_queue); // this will be used to process which queue.

    \Illuminate\Support\Facades\Bus::chain([
        new \App\Jobs\FirstProcess(),
        new \App\Jobs\SecondProcess(),
        new \App\Jobs\ThirdProcess(),
    ])->onQueue($random_queue)->dispatch(); // specify one of the queue.

    return gethostname();
});

    如果$random_queue的值为queue1，则容器 A 的工作程序将被执行。

    日志看起来如下。

    docker 日志输出

    这表明每个容器都按照正确的顺序运行自己的队列。

    当然，此设置的问题在于在命令--queue中指定选项queue:work。我仍然建议使用共享文件服务器（例如 S3 或 Minio）来轻松管理您的服务器。

    • 1

相关问题