Laravel 9 + PHP 8批量任务取消异常及执行中断问题求助

我正在使用Laravel 9与PHP 8.0开发，需要依次执行数百个任务。将任务存入recognitionsBus后启动批量任务，但每个任务执行时都会触发批量已取消的判断，任务执行到一定数量就中断，且批量任务的then/catch/finally回调都未执行，请求帮忙排查原因。

控制器代码 #

foreach ($recognitions as $recognition) {
    $test = Test::create([...]);

    $recognitionsBus->push(new TestJob($test);
}

Bus::batch($recognitionsBus->toArray())
    ->then(function (Batch $batch) use ($test) {
        Log::info("success");
    })->catch(function (Batch $batch, \Throwable $e) use ($test) {
        Log::error("error");

        throw $e;
    })->finally(function (Batch $batch) use ($test) {
        Log::info("finish");
    })
    ->dispatch();

任务代码 #

namespace App\Jobs;

use Illuminate\Bus\Batchable;
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 Throwable;

class TestJob implements ShouldQueue
{
    use Batchable, Dispatchable, InteractsWithQueue, Queueable, SerializesModels;

    protected $test;

    /**
     * Create a new job instance.
     *
     * @return void
     */
    public function __construct($test)
    {
        $this->test = $test;
    }

    /**
     * Execute the job.
     *
     * @return void
     */
    public function handle()
    {
        if ($this->batch()->cancelled()) {
            Log::info('canceled');

            return;
        }

        Log::info($this->test->id);
    }

    /**
     * Handle a job failure.
     */
    public function failed(Throwable $exception)
    {
        Log::info($exception->getMessage());
    }
}

执行命令 #

php artisan queue:work

排查方向 #

• 批量任务关联丢失：你将任务转为数组传递给Bus::batch()，但Batchable trait需要任务实例保留批量关联信息，序列化数组会丢失这些关联，导致任务无法识别所属批量，误判为已取消。应直接传递任务实例数组：

  // 替换原批量调度代码
  Bus::batch($recognitionsBus->all())
      ->then(...)
      ->catch(...)
      ->finally(...)
      ->dispatch();
  

• 批量状态存储异常：Laravel批量任务默认依赖数据库存储状态，若job_batches表缺失或权限不足，会导致批量状态无法正常更新，触发任务取消判断。执行以下命令确保表存在：

  php artisan queue:batches-table
  php artisan migrate
  

• 任务序列化问题：任务中直接持有模型实例，即使使用SerializesModels，若模型存在不可序列化属性，可能导致任务执行异常，间接标记批量为取消。建议改为传递模型ID，在handle方法中重新查询：

  // 任务构造函数修改
  public function __construct(int $testId)
  {
      $this->testId = $testId;
  }
  
  // handle方法修改
  public function handle()
  {
      if ($this->batch()->cancelled()) {
          Log::info('canceled');
          return;
      }
      $test = Test::findOrFail($this->testId);
      Log::info($test->id);
  }
  

• Worker内存溢出：执行数百个任务时，worker进程可能因内存耗尽中断，导致批量任务未完成、回调不触发。启动worker时增加内存限制并设置自动重启：

  php artisan queue:work --memory=512 --timeout=60 --tries=3
  

• 批量超时配置：若批量任务默认超时时间过短，总执行时间超出后会被标记为取消。调度时手动设置超时：

  Bus::batch(...)
      ->timeout(3600) // 设置1小时超时
      ->dispatch();
  

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