Laravel通过任务链和批处理实现有序队列管理，任务链使用withChain或Bus::chain按序执行任务，前任务成功后才执行下一个；批处理通过Bus::batch将多个任务分组，支持then、catch回调监控状态，并可通过批处理ID查询进度与结果。

如果您希望在 Laravel 中执行一系列有序的队列任务，或对多个任务进行分组管理与状态追踪，则可以使用任务链和任务批处理功能。这些特性能够帮助您更好地组织异步任务的执行流程。

本文运行环境：MacBook Pro，macOS Sonoma

一、任务链的实现方法

任务链允许您将多个队列任务按顺序连接起来，前一个任务完成后自动执行下一个任务。这适用于需要依次执行的操作流程。

1、定义一组要链接的任务类，例如 SendNotificationJob 和 LogActivityJob，它们都应实现 ShouldQueue 接口。

2、在控制器或服务中使用 dispatch 方法，并通过 withChain 方法串联任务：

SendNotificationJob::dispatch()->withChain([new LogActivityJob, new UpdateStatusJob]);

3、确保配置了正确的队列驱动（如 database、redis），并启动队列监听器：php artisan queue:work。

二、使用静态链方法简化任务链调用

Laravel 提供了 chain 静态方法，用于更简洁地创建任务链，避免重复调用对象实例。

1、使用 Job 类的 chain 静态方法直接传入任务数组：

Bus::chain([new ProcessPodcast, new OptimizePodcast, new ReleasePodcast])->dispatch();

2、该方式会自动按顺序调度任务，只有当前一个任务成功完成时，下一个任务才会被执行。

3、若其中一个任务失败，后续任务将不会运行，且异常会被记录到日志中。

三、任务批处理的实现方法

任务批处理允许您将多个任务组合为一个批次，并可监听整个批次的执行进度与完成状态，适合大规模任务管理。

1、引入 Illuminate\Support\Facades\Bus 来支持批处理操作。

2、使用 Bus::batch 方法包装任务数组：

$batch = Bus::batch([new ImportUserRecord, new ImportOrderRecord, new SendWelcomeEmails])->dispatch();

3、每个任务都会被推送到队列中，并归属于同一个批处理标识符，便于后续查询状态。

四、为批处理添加回调函数

您可以为批处理设置成功或失败时的回调逻辑，以实现通知、记录或其他清理操作。

1、在定义批处理时使用 then、catch、finally 方法注册回调：

Bus::batch([new TaskA, new TaskB])->then(function (Batch $batch) { \Log::info('批处理成功完成'); })->catch(function (Batch $batch, Throwable $e) { \Log::error('批处理出错: ' . $e->getMessage()); })->dispatch();

2、then 回调在所有任务成功完成后触发。

3、catch 回调在任一任务抛出未捕获异常时调用。

五、查询与监控批处理状态

通过批处理的唯一 ID 可以在后续请求中检查其执行进度和结果。

1、保存批处理实例的 ID 到数据库或缓存中以便追踪：

$batchId = $batch->id;

2、在其他地方使用 Bus::findBatch($batchId) 获取批处理信息：

$batch = Bus::findBatch($batchId); if ($batch?->finished()) { // 执行后续操作 }

3、可通过 $batch->processedJobs() / $batch->totalJobs 获取已完成和总任务数，用于进度展示。