Laravel 5.2 中的独特工作

Question

我在 laravel 5.2 中有一个遗留应用程序，我们使用队列来处理作业。我们观察到，队列有时会获取太多作业，这会导致重复作业被调度，因为之前的作业未完成处理，并且调度此类作业的 cron 会再次运行并最终一遍又一遍地调度它们。

一个简单的解决方案是使这些作业变得独特，如果是 Laravel 8，这将是一个非常简单的更改。但是，我们处于 Laravel 5.2 领域，所以我必须自己实现独特的作业。或者如果有人可以提出更好的选择？

另外，如果你要自己实施独特的工作，你会怎么做？我想到的方法是：

将作业的唯一键添加到缓存或数据库表中（意味着获得了锁） 处理作业后清除该条目（释放锁） 在分派作业之前，检查该键是否存在于缓存中（锁定）可以达到也可以不达到）

Answer 1

根据评论中的讨论和互联网上的更多帮助，我继续进行以下操作：

1. 为作业创建唯一的 ID
2. 使用唯一id获取锁并将其存储在缓存中
3. 如果获取了锁，则分派作业
4. 作业完成后，从缓存中释放锁

可能不是最好的实现，但绝对满足我们的要求。

代码：

在分派作业之前获取锁的常用辅助函数：

/**
 * Acquires a lock but storing a key on the cache for the provided duration
 * the `$jobInstance` must have a `jobId()` function that provides a unique id
 * for the job used to prevent duplicacy
 *
 * @var  Job  $jobInstance  a Job instance to acquire a lock for
 * @var  int  $minutes  number of minutes to hold the lock for (default: 1 day)
 *
 * @return  bool
 */
function acquireLock($jobInstance, $minutes = 1440)
{
    $lockAcquired = false;
    try {
        DB::beginTransaction();
        /**
         * If the job instance does not provide a `jobId` function do not
         * attempt to acquire a lock for it
         */
        $jobId = method_exists($jobInstance, 'jobId') ? $jobInstance->jobId() : null;
        if (!is_null($jobId)) {
            $isLockAvailable = is_null(Cache::get($jobId));
            if ($isLockAvailable) {
                Cache::put($jobId, true, $minutes);
                $lockAcquired = true;
            }
        }
        DB::commit();
    } catch (\Throwable $th) {
        DB::rollback();
        Log::error("Unable to acquire lock");
        Log::error($th);
    }
    return $lockAcquired;
}

/**
 * Attempts to acquires a lock for the job and dispatches it
 * if the lock was successfull acquired
 *
 * @var  Job  $jobInstance  Job instance to dispatch
 *
 * @return void
 */
function dispatchWithLock($jobInstance)
{
    $isLockAcquired = acquireLock($jobInstance);
    if ($isLockAcquired) {
        dispatch($jobInstance);
    }
}

添加监听器AppServiceProvider以释放锁

Queue::after(function (JobProcessed $event) {
    /**
     * Check if the job has a `jobId` function and release the lock used to
     * maintain job uniqueness
     */
    $jobInstance = unserialize($event->data['data']['command']);
    $jobId = method_exists($jobInstance, 'jobId')
            ? $jobInstance->jobId()
            : null;
    if (!is_null($jobId)) {
        Cache::forget($jobId);
    }
});

jobId为需要唯一的作业添加了一个功能

/**
 * Get a unique id for the job to prevent duplicates
 *
 * @return str
 */
public function jobId()
{
    return str_slug(get_class($this)) . $this->myModel->id;
}

最后使用辅助函数调度作业

dispatchWithLock(new myJob($this));