应使用 Laravel 内置 sync 驱动、多连接配置、Bus::fake()、内存 SQLite database 驱动或 QueueManager Mock 五种方法验证多队列任务分发、路由与隔离执行逻辑。

如果您在 Laravel 测试环境中需要验证多队列任务的分发、路由与隔离执行逻辑,但又无法启动真实 Redis 或数据库队列服务,则需借助框架内置的同步驱动与模拟机制实现行为复现。以下是实现此目标的多种方法:
一、使用 sync 驱动并手动触发队列事件
sync 驱动将任务立即同步执行,不经过后台队列系统,但保留完整的任务分发链路(如 onQueue()、onConnection() 调用),适合验证任务是否被正确分配至指定队列名称或连接。该方式可捕获任务构造、元数据设置及路由逻辑是否生效。
1、在 phpunit.xml 或测试用例中临时覆盖 QUEUE_CONNECTION 环境变量为 sync。
2、在测试 setUp() 方法中调用 Queue::fake() 以禁用实际推送,并允许后续断言。
3、分发多个不同队列的任务:ProcessInvoice::dispatch()->onQueue('invoices'); ProcessNotification::dispatch()->onQueue('notifications');。
4、使用 Queue::assertPushedOn('invoices', ProcessInvoice::class) 和 Queue::assertPushedOn('notifications', ProcessNotification::class) 分别验证任务是否进入对应队列名。
二、为不同队列配置独立的 sync 连接
Laravel 允许定义多个 sync 连接,每个连接可绑定唯一名称,从而在测试中模拟“多队列并行”的路由效果。虽然仍为同步执行,但能完整覆盖 config/queue.php 中的多连接配置逻辑与任务分发时的连接选择行为。
1、在 config/queue.php 的 connections 数组中新增两个 sync 连接:'sync_invoices' => ['driver' => 'sync'], 'sync_notifications' => ['driver' => 'sync']。
2、在测试中调用 Queue::fake(['sync_invoices', 'sync_notifications']) 显式伪造这两个连接。
3、分发任务时显式指定连接:ProcessInvoice::dispatch()->onConnection('sync_invoices'); ProcessNotification::dispatch()->onConnection('sync_notifications');。
4、分别断言:Queue::assertPushedOn('default', ProcessInvoice::class, false) 确保未落入默认队列;再使用 Queue::assertPushed(ProcessInvoice::class, function ($job) { return $job->connectionName === 'sync_invoices'; }) 验证连接名匹配。
三、结合 Bus::fake() 与自定义任务处理器
当测试涉及多模态或多通道任务(如 Laravel 12 的 multimodal 队列)且需验证路由决策逻辑时,Bus::fake() 可拦截所有通过 Bus::dispatch() 派发的任务,配合闭包断言实现对任务类型、元数据、mode() 或 viaQueue() 返回值的精确校验,无需依赖真实队列驱动。
1、在测试开始前调用 Bus::fake()。
2、构造一个带模态标识的任务实例,例如 new ProcessImageJob($data)->onConnection('multimodal')->mode('vision')。
Laravel Cloud(cloud.laravel.com)。此技能用于处理所有 Laravel Cloud 请求,包括搜索和读取数据。只要任务涉及 Laravel Cloud,即使用此技能。
3、执行 Bus::dispatch($job)。
4、使用 Bus::assertDispatched(ProcessImageJob::class, function ($job) { return $job->mode === 'vision' && $job->connectionName === 'multimodal'; }) 进行结构化断言。
四、使用 Database 驱动配合内存 SQLite 数据库
在测试中启用 database 驱动并指向内存 SQLite(:memory:),可真实写入 jobs 表,从而验证队列名称(queue 字段)、连接配置、延迟时间等持久化行为。该方式支持 assertDatabaseHas() 断言,适用于需验证队列底层存储逻辑的场景。
1、在 phpunit.xml 中为测试环境设置 DB_CONNECTION=sqlite 和 DB_DATABASE=:memory:。
2、确保 tests/TestCase.php 的 setUp() 中调用 Artisan::call('migrate') 并加载队列表结构。
3、配置 queue.php 中的 database 连接使用 sqlite,并设置 queue 字段索引以加速查询。
4、分发任务:ProcessReport::dispatch()->onQueue('reports');。
5、执行 $this->assertDatabaseHas('jobs', ['queue' => 'reports', 'attempts' => 0]); 验证任务已写入指定队列名。
五、Mock QueueManager 实例进行细粒度行为控制
当需模拟特定队列驱动的异常响应(如 Redis 连接失败、pop 超时)或验证 worker 启动参数时,可直接 Mock Illuminate\Queue\QueueManager,接管 resolve() 和 connection() 方法返回定制化的 FakeQueue 实例,从而控制 push、pop、release 等底层行为。
1、在测试中通过 Application::instance() 替换 QueueManager 绑定。
2、创建 FakeQueue 类,实现 push() 记录参数,pop() 返回预设任务,fail() 触发重试逻辑。
3、在 FakeQueue 的 pop() 方法中,根据传入的 $queue 参数(如 'high_priority' 或 'bulk')返回不同结构的任务负载。
4、运行 dispatch() 后,检查 FakeQueue 实例内部记录的 push 调用次数与队列名参数,确认多队列分发路径正确。

















