Laravel跨队列任务依赖需显式协调，常用五法：一、数据库状态表标记完成；二、Redis原子信号量；三、事件总线广播状态；四、任务链+动态队列路由；五、Horizon钩子拦截触发。
如果您在 Laravel 应用中需要让一个队列任务的执行依赖于另一个队列任务的成功完成，但二者被分发至不同队列（如 default、emails、notifications），则无法依靠单一队列的顺序性保障依赖关系。Laravel 原生不提供跨队列的原子性依赖调度机制，必须通过显式状态追踪与条件触发来协调。以下是实现此协调的多种方法：
一、使用数据库状态表标记前置任务完成
该方法通过中心化持久化状态，使后置任务在执行前主动轮询或校验前置任务是否已成功写入完成标记，从而实现松耦合依赖控制。
1、在数据库中创建 status_tracking 表，包含字段：task_id（UUID 或任务类+参数哈希）、dependency_of（可为空，指向依赖的任务标识）、status（enum: 'pending', 'processing', 'completed', 'failed'）、updated_at。
2、前置任务（如 SendInvoiceJob）在 handle() 执行末尾插入或更新对应 task_id 的 status 为 'completed'，并确保该操作与业务逻辑同事务（若使用 database 驱动）或通过 Redis SETNX + EXPIRE 保证幂等性。
3、后置任务（如 ArchiveInvoiceJob）在 handle() 开头调用 DB::table('status_tracking')->where('task_id', $this->invoiceId)->where('status', 'completed')->exists()；若返回 false，则抛出 Illuminate\Queue\MaxAttemptsExceededException 或使用 $this->release(60) 延迟重试。
4、为防止死锁或无限等待，在任务类中设置 public $tries = 5; public $backoff = 120; 并在重试超限后记录告警日志。
二、利用 Redis 原子操作构建依赖信号量
该方法借助 Redis 的 SETNX、EXPIRE 和 BLPOP 等原子指令，在内存中建立轻量级依赖信号，适用于高吞吐、低延迟场景，且不增加数据库负担。
1、前置任务在 handle() 结束时执行 Redis::setex("dep:{$this->jobKey}", 3600, 'done')，其中 jobKey 可为 md5(serialize([$this->invoiceId, 'SendInvoiceJob']))。
2、后置任务在 handle() 中调用 $signal = Redis::get("dep:{$this->jobKey}")；若为 null，则执行 Redis::blpop("queue:waiting:{$this->jobKey}", 30)，等待最多30秒。
3、若 blpop 返回值为空或超时，调用 $this->release(90) 并退出；否则继续执行归档逻辑。
4、为避免信号残留，所有任务类统一在构造函数中注册 shutdown 函数：register_shutdown_function(function () { Redis::del("dep:{$this->jobKey}"); }) —— 仅在失败或异常退出时清理。
三、通过事件总线桥接跨队列任务生命周期
该方法将队列任务的状态变更广播为事件，由监听器捕获并触发下游任务，从而解耦队列驱动差异，同时复用 Laravel 事件系统的中间件与重试能力。
1、前置任务类中，在 handle() 成功结束前 dispatch(new JobCompleted('SendInvoiceJob', $this->invoiceId))。
2、定义事件类 JobCompleted 实现 ShouldBroadcastNow（若需即时性）或 ShouldQueue（若允许轻微延迟），并确保其可序列化。
3、创建监听器 ProcessJobCompletionListener，并在 EventServiceProvider 中绑定：JobCompleted::class => [ProcessJobCompletionListener::class]。
4、监听器 handle() 方法中判断 $event->jobType === 'SendInvoiceJob' 且 $event->payload['invoice_id'] === $this->targetId，满足则执行 ArchiveInvoiceJob::dispatch($event->payload)。
5、关键保障：监听器类必须实现 ShouldQueue 接口，并配置 QUEUE_CONNECTION=redis，确保事件消费本身也走队列，避免阻塞事件分发进程。
四、采用任务链（Chain）配合多队列路由策略
该方法不真正“跨队列”，而是将逻辑上存在依赖的多个任务组织为链式结构，再通过自定义调度器将其按需分发至不同物理队列，兼顾语义清晰性与执行隔离性。
1、定义链式任务数组：$chain = [new SendInvoiceJob($id), new ArchiveInvoiceJob($id), new NotifyAdminJob($id)]。
2、使用 Bus::dispatch(new Chain($chain))，默认全部进入 default 队列；若需分流，需重写 Chain 类的 dispatch 方法，或在每个任务的 __construct() 中注入 queue_name 属性。
3、创建中间件 QueueRouterMiddleware，在任务 handle() 执行前读取 $this->queueName，调用 $this->onQueue($this->queueName) 动态切换目标队列。
4、在 config/queue.php 中为各队列配置独立的 retry_after 与 connection，例如 emails 队列设 retry_after=180，notifications 队列设 retry_after=60，防止因超时策略不一致导致链中断。
五、基于 Laravel Horizon 的任务事件钩子拦截与干预
该方法适用于已部署 Horizon 的生产环境，利用其提供的任务生命周期钩子（before, failing, success），在任务完成瞬间触发跨队列协调动作，无需修改业务任务类。
1、在 App\Providers\AppServiceProvider 的 boot() 方法中注册 Horizon::flowing(function ($connection, $job) { if ($job instanceof SendInvoiceJob && $job->isCompleted()) { ArchiveInvoiceJob::dispatch($job->invoiceId)->onQueue('archive'); } });
2、确保 Horizon 配置中 enabled: true 且 supervisor 进程运行正常；同时在 horizon.php 中启用 fast_termination = true，避免钩子执行阻塞主流程。
3、为防止重复触发，在钩子内添加 Redis 锁：$lockKey = 'horizon:chain:'.md5($job->invoiceId.':ArchiveInvoiceJob'); if (Redis::set($lockKey, 1, ['nx', 'ex' => 300])) { ArchiveInvoiceJob::dispatch(...); }。
4、注意：Horizon 的 success 钩子仅在任务未抛出异常且未被取消时触发，因此需同步监控 Horizon UI 中 failing tab，确认前置任务无 silent failure。
