在Laravel 8中需启用Batchable特性：任务类必须use Batchable和Queueable trait，并推荐显式声明public $batchable = true；分发时用Bus::batch()绑定then/catch回调，且队列驱动须为database或redis，运行queue:batches-table迁移并指定--queue参数监听。
你需要在 Laravel 8 中为一批并行执行的队列任务设置统一的成功完成通知和任意一个失败时的中断回调，而不是等所有任务跑完再查日志——这要求你启用 Batchable 特性并正确注册监听器，否则回调不会触发。
启用 Batchable 并创建可批处理任务类
第一步是让任务类支持批处理能力，必须显式 use Illuminate\Bus\Batchable；否则 dispatch(new Job)->batch() 会报错，且后续所有回调均无效。
运行命令生成新任务类：php artisan make:job ProcessWebhookBatch
打开生成的 app/Jobs/ProcessWebhookBatch.php，在类声明前添加两行关键 trait：
use Illuminate\Bus\Batchable;use Illuminate\Bus\Queueable;
在类体顶部声明 【public $batchable = true;】 —— 这个属性不是必需但强烈建议显式写出，避免未来升级时因隐式行为变更导致回调静默失效。
在 handle() 方法中写入实际业务逻辑，例如解析 webhook 数据并存入数据库。
分发任务并绑定批处理回调
在控制器或服务中调用 dispatch() 时，不能直接 new 实例后 dispatch，必须使用 Bus::batch() 或链式 dispatch()->allOnQueue('webhook') 启动批处理上下文。
方法一：使用 Bus::batch() 手动构造批次（推荐）
引入命名空间：use Illuminate\Support\Facades\Bus;
构建任务数组：$jobs = collect($payloads)->map(fn($p) => new ProcessWebhookBatch($p))->toArray();
提交批次并绑定回调：Bus::batch($jobs)
→ ->then(function (Batch $batch) {
// 所有任务成功完成才执行
Log::info("Batch {$batch->id} completed successfully");
Mail::to('ops@example.com')->send(new BatchSuccessNotification($batch));
})
→ ->catch(function (Batch $batch, Throwable $e) {
// 任一任务失败立即触发，$e 是第一个抛出的异常
Log::error("Batch {$batch->id} failed at job {$batch->failedJobId()}", ['exception' => $e]);</p>
<p> <code>// 注意：此处无法获取全部失败任务详情，只返回首个失败 ID
})
→ ->dispatch();
方法二：链式 dispatch + batch()（仅限单个任务实例重复使用）
ProcessWebhookBatch::dispatch($payload)->onQueue('webhook')->batch()->then(...)->catch(...)->dispatch();
⚠️ 这种写法仅适用于同一任务类型重复执行，且不支持传入不同参数的混合任务数组。
配置批处理存储与监听机制
第一步：确认队列驱动支持批处理。Database 驱动需 Laravel 8.55+，Redis 驱动需 Horizon v5.0+；若用 SQS 或 Beanstalkd，批处理功能不可用。
第二步：发布批处理迁移：php artisan queue:batches-table && php artisan migrate
第三步：检查 config/queue.php 中 default 连接是否已设为 database 或 redis —— 【sync 驱动完全不支持批处理回调】，强行使用会导致 then/catch 完全不执行。
第四步：启动队列监听器时，必须启用 --queue 参数指定批次所用队列名，例如：php artisan queue:work redis --queue=webhook --tries=3。若漏掉 --queue，批次任务会被分配到默认队列，回调监听器收不到事件。
