如何让指定Laravel队列任务达到重试次数后取消而非进入失败队列

要实现这个需求，你可以针对需要特殊处理的任务类，通过重写Laravel队列任务的内置方法来控制重试逻辑和失败行为，其他任务保持默认逻辑即可。以下是具体实现方案：

方案一：重写任务类的shouldBeRetried和failed方法 #

这种方式直接在目标任务类内自定义重试规则和失败处理，逻辑清晰且针对性强：

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\Log;
   use Exception;
   
   class SpecialRetryJob implements ShouldQueue
   {
       use Dispatchable, InteractsWithQueue, Queueable, SerializesModels;
   
       // 自定义该任务的最大重试次数
       protected int $maxCustomRetries = 3;
   
       public function handle()
       {
           // 这里编写你的任务业务逻辑，执行失败时抛出异常
           throw new Exception('任务执行失败，触发重试');
       }
   
       /**
        * 重写是否继续重试的判断逻辑
        */
       public function shouldBeRetried($exception): bool
       {
           // 仅当当前尝试次数小于自定义最大次数时，允许重试
           return $this->attempts() < $this->maxCustomRetries;
       }
   
       /**
        * 重写失败处理方法，避免任务进入失败队列
        */
       public function failed($exception): void
       {
           // 可添加自定义的失败日志记录（可选）
           Log::warning('特殊任务达到最大重试次数，已取消，未进入失败队列', [
               'job' => self::class,
               'attempts' => $this->attempts(),
               'error' => $exception->getMessage()
           ]);
   
           // 不要调用 parent::failed($exception)，这样任务就不会被记录到失败队列
       }
   }
   

2. 关键逻辑说明

   • shouldBeRetried方法：Laravel会在任务执行失败后调用此方法，判断是否需要重试。我们通过$this->attempts()获取当前已尝试次数，与自定义次数对比，控制重试触发。
   • failed方法：默认情况下，父类的failed方法会将任务记录到失败队列。我们重写此方法但不调用父类实现，即可阻止任务进入失败队列，同时可自行添加日志等处理。

方案二：在handle方法中手动控制重试与结束 #

如果你更倾向于在任务执行逻辑内直接控制流程，可以采用这种方式：

<?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\Log;
use Exception;

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

    protected int $maxCustomRetries = 3;

    public function handle()
    {
        try {
            // 执行任务业务逻辑
            $this->executeTask();
        } catch (Exception $e) {
            if ($this->attempts() < $this->maxCustomRetries) {
                // 未达到最大重试次数，延迟5秒后重试
                $this->release(5);
            } else {
                // 达到最大次数，直接结束任务，不抛出异常则不会进入失败队列
                Log::warning('特殊任务已取消，未进入失败队列', [
                    'job' => self::class,
                    'attempts' => $this->attempts(),
                    'error' => $e->getMessage()
                ]);
            }
        }
    }

    private function executeTask()
    {
        // 实际任务逻辑，失败时抛出异常
        throw new Exception('任务执行失败');
    }
}

这种方式通过捕获执行异常，手动判断重试次数：未达到次数则调用release()延迟重试，达到次数则直接结束任务（不抛出异常，Laravel会认为任务执行完成，不会进入失败队列）。

其他任务的处理 #

对于不需要特殊逻辑的任务，无需做任何修改，Laravel会按照默认规则执行：当任务达到全局或自身设置的tries次数后，自动进入失败队列。

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