可通过自定义队列中间件实现请求驱动的队列路由：一、创建并注册中间件，在任务推入前动态设置队列；二、基于类名、属性或构造参数识别任务类型并绑定队列；三、结合事件监听器按上下文条件路由；四、根据配置自动切换队列连接。
如果您希望在Laravel中避免手动为每个任务指定队列名称或连接，而是根据业务上下文自动将任务分发至对应队列，则可通过自定义队列中间件实现请求驱动的队列路由。以下是实现此目标的具体方法：
一、创建并注册队列路由中间件
该中间件在任务被推入队列前介入，依据任务类名、业务标识或运行时上下文动态设置其目标队列，从而解耦分发逻辑与业务代码。
1、执行Artisan命令生成中间件类：php artisan make:middleware RouteToBusinessQueue
2、打开app/Http/Middleware/RouteToBusinessQueue.php，在handle方法中注入$next并返回，不修改HTTP生命周期；此中间件仅用于队列任务路由，**不应用于HTTP请求链**。
3、在app/Providers/AppServiceProvider.php的boot方法中注册该中间件为全局队列中间件：$this->app->resolving(Dispatcher::class, function ($dispatcher) { $dispatcher->before(function ($job, $data) { if ($job instanceof ShouldQueue) { (new RouteToBusinessQueue)->handle($job, function () {}); } }); });
4、确保IlluminateBusDispatcher已正确绑定，且任务类实现了ShouldQueue接口。
二、在中间件中实现任务类型识别与队列绑定
通过反射获取任务实例的类名或属性，匹配预设规则，将任务路由至对应队列，避免硬编码分发逻辑。
1、在RouteToBusinessQueue的handle方法中，判断$job是否为订单处理类：if (str_starts_with(get_class($job), 'App\Jobs\ProcessOrder')) { $job->onQueue('orders'); }
2、添加用户通知类匹配分支：elseif (str_starts_with(get_class($job), 'App\Jobs\SendNotification')) { $job->onQueue('notifications'); }
3、支持基于任务属性路由：若任务含$businessType公共属性，可读取其值并映射队列：if (isset($job->businessType)) { $job->onQueue($job->businessType); }
4、确保所有匹配分支后调用$next($job)以继续任务推入流程，否则任务将被丢弃。
三、使用任务构造参数触发动态路由
在任务初始化阶段传入业务标识，使中间件无需依赖类名即可完成精准路由，提升可测试性与扩展性。
1、在任务类构造函数中接收$routeTo参数：public function __construct(public string $routeTo = 'default')
2、实例化任务时显式指定队列目标：ProcessOrder::dispatch($order, routeTo: 'orders');
3、中间件中直接读取该属性并应用：if (property_exists($job, 'routeTo') && !empty($job->routeTo)) { $job->onQueue($job->routeTo); }
4、保留默认回退机制：当$routeTo为空时，使用配置文件中定义的config('queue.default')作为兜底队列。
四、结合事件监听器增强路由能力
利用Laravel事件系统，在任务即将分发前触发自定义事件，由监听器完成队列决策，实现更灵活的条件路由策略。
1、定义事件类：php artisan make:event JobAboutToBeDispatched
2、在任务分发前手动触发事件：event(new JobAboutToBeDispatched($job));
3、创建监听器并注册到EventServiceProvider，在handle方法中检查$job的上下文（如当前请求IP段、用户角色、环境配置）：if (app()->environment('production') && auth()->check() && auth()->user()->isPremium()) { $job->onQueue('premium'); }
4、监听器内禁止抛出异常，确保不影响主任务流程；所有队列设置必须在事件处理结束前完成。
五、基于队列连接配置的自动路由
通过解析任务所属模块的配置键，自动切换底层队列连接，实现存储隔离与失败策略分离，适用于多租户或高SLA场景。
1、在config/queue.php中预定义多个连接，如'orders_redis'、'notifications_sqs'，分别指向不同驱动与参数。
2、中间件中根据任务类命名空间匹配连接名：if (str_contains(get_class($job), 'Orders')) { $job->onConnection('orders_redis'); }
3、对连接名进行规范化处理，移除命名空间中的反斜杠并转为小写下划线格式：$connection = strtolower(str_replace(['\', 'Jobs'], ['_', ''], get_class($job))); $job->onConnection($connection);
4、验证连接是否存在：if (!array_key_exists($connection, config('queue.connections'))) { $job->onConnection('sync'); }
