首页 文章

在运行时更改Laravel 5.1中的队列驱动程序？

提问于
浏览 次
3

我使用beanstalkd作为我的队列驱动程序：

# /.env
QUEUE_DRIVER=beanstalkd

# /config/queue.php
'default' => env('QUEUE_DRIVER', 'sync'),

和一个可排队的工作

# /app/Jobs/MyJob.php
class MyJob extends Job implements SelfHandling, ShouldQueue
{
    use InteractsWithQueue, SerializesModels;
    ....
    ....
}

当我通过控制器调度作业时，这很有用，但我想在调度作业时使用同步驱动程序而不是beanstalkd驱动程序 . 中间件似乎就是这里的答案

# /app/Http/Controllers/MyController.php
public function create(Request $request)
{
    $this->dispatch(new \App\Jobs\MyJob());
}

# /app/Http/routes.php
Route::post('/create', ['middleware' => 'no_queue', 'uses' => 'MyController@create']);

# /app/Http/Middleware/NoQueue.php
public function handle($request, Closure $next)
{
    $response = $next($request);
    config(['queue.default'=>'sync']);
    return $response;
}

但是，该作业仍然被推送到beanstalkd队列 .

换句话说，在从控制器调度作业时，如何在运行时更改队列驱动程序？

编辑：调用 config(['queue.default'=>'sync']) 似乎在Artisan命令中工作，而不是来自Http控制器......

# /app/Conosle/Commands/MyCommand.php

class ScrapeDrawing extends Command
{
    use DispatchesJobs;
    ...
    ...
    public function handle()
    {
        config(['queue.default'=>'sync'])
        $this->dispatch(new \App\Jobs\MyJob());
    }
}
php laravel laravel-5 laravel-5.1

2 回答

  • 2

    通过我的控制器方法使用此解决：

    # /app/Http/Controllers/MyController.php
public function create(Request $request, QueueManager $queueManager)

    $defaultDriver = $queueManager->getDefaultDriver();

    $queueManager->setDefaultDriver('sync');

    \Queue::push(new \App\Jobs\MyJob());

    $queueManager->setDefaultDriver($defaultDriver);
}

    在我的例子中，\ Queue：push（）似乎注意到运行时的驱动程序更改，而$ this-> dispatch（）则没有 .

    回复于
  • 1

    看看你的中间件做了什么 - $next($request); 是执行请求的代码 . 如您所见，您正在处理请求后更改配置 . 更改

    public function handle($request, Closure $next)
{
  $response = $next($request);
  config(['queue.default'=>'sync']);
  return $response;
}

    至

    public function handle($request, Closure $next)
{
  config(['queue.default'=>'sync']);
  $response = $next($request);
  return $response;
}
    回复于

相关问题