如何在多租户Laravel应用中按团队和Webhook类型防止任务重叠？

你可以通过自定义缓存锁或者利用Laravel自带的Uniqueable特性，实现同团队同类型Webhook任务的串行执行，同时允许不同团队/类型的任务并发处理。以下是具体实现方式：

方案一：自定义缓存锁（灵活可控） #

利用Laravel的缓存锁机制，为每个团队+Webhook类型生成唯一锁键，只有获取到锁的任务才能执行，未获取到的任务放回队列稍后重试。

1. 编写任务类 #

<?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\Cache;

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

    protected int $teamId;
    protected string $webhookType;
    protected array $webhookData;

    public function __construct(int $teamId, string $webhookType, array $webhookData)
    {
        $this->teamId = $teamId;
        $this->webhookType = $webhookType;
        $this->webhookData = $webhookData;
    }

    public function handle()
    {
        // 生成唯一锁键：团队ID + Webhook类型
        $lockKey = "shopify_webhook:{$this->teamId}:{$this->webhookType}";

        // 尝试获取锁，有效期设为任务最长执行时间（示例为5分钟），避免死锁
        $lock = Cache::lock($lockKey, 300);
        if (!$lock->get()) {
            // 未获取到锁，10秒后重试
            $this->release(10);
            return;
        }

        try {
            // 这里编写Webhook处理逻辑（比如订单更新、创建等）
            // 示例：Order::updateFromShopify($this->teamId, $this->webhookData);
        } finally {
            // 无论执行成功/失败，都释放锁
            $lock->release();
        }
    }
}

2. 注意事项 #

• 确保缓存驱动为Redis或Memcached（file缓存不支持分布式锁，多服务器环境下无效）。
• 锁有效期需设置为比任务最长执行时间更长，防止任务未完成锁就过期，导致并发问题。
• 重试间隔可根据业务调整（比如10秒、30秒），避免频繁重试占用资源。

方案二：利用Laravel自带的Uniqueable特性（简洁） #

Laravel 8+提供了Uniqueable trait，可通过自定义唯一ID，确保同ID的任务不会并发执行。

1. 编写任务类 #

<?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\Queue\Middleware\Uniqueable;

class ProcessShopifyWebhook implements ShouldQueue
{
    use Dispatchable, InteractsWithQueue, Queueable, SerializesModels, Uniqueable;

    protected int $teamId;
    protected string $webhookType;
    protected array $webhookData;

    public function __construct(int $teamId, string $webhookType, array $webhookData)
    {
        $this->teamId = $teamId;
        $this->webhookType = $webhookType;
        $this->webhookData = $webhookData;
    }

    // 生成唯一标识：团队ID + Webhook类型
    public function uniqueId(): string
    {
        return "shopify_webhook:{$this->teamId}:{$this->webhookType}";
    }

    // 设置唯一任务的过期时间（示例为5分钟）
    public function uniqueFor(): int
    {
        return 300;
    }

    public function handle()
    {
        // 编写Webhook处理逻辑
        // ...
    }
}

特性说明 #

• 当同唯一ID的任务已在队列中等待或执行时，新调度的同ID任务会被自动拒绝（不会重复入队）。
• 若需要确保每个Webhook都被处理，建议结合release逻辑调整，或者使用方案一的重试机制。

额外建议 #

• 对于Webhook的重复触发问题，还可以在接收Webhook时先验证Shopify的签名，再记录Webhook的X-Shopify-Webhook-Id到数据库，避免重复处理相同的Webhook请求。
• 监控队列任务的执行情况，通过Laravel Horizon（若使用Redis队列）查看任务重试、失败情况，及时调整锁有效期和重试策略。

内容的提问来源于stack exchange，提问作者Shridip chandole