【问题标题】:Async Queues In LaravelLaravel 中的异步队列
【发布时间】:2016-03-14 21:26:32
【问题描述】:

我正在尝试实现队列,但结果不是异步的 我已经应用了以下内容

config/queue.php
'default' => env('QUEUE_DRIVER', 'database'),
    'connections' => [

    'sync' => [
        'driver' => 'sync',
    ],

    'database' => [
        'driver' => 'database',
        'table' => 'jobs',
        'queue' => 'default',
        'expire' => 60,
    ],
   ] 

然后应用以下命令 php工匠队列:表 php工匠迁移

然后运行

php artisan queue:listen

这里是功能

SomethingController.php
   $model1 = new \App\Model1;
public function store(){
     Log::debug('before dispatch');
     $this->dispatch(new SendGiftCommand($model1));
     Log::debug('before dispatch');
     return true;
}



SendGiftCommand.php
{
    Log::debug('handle');
    SendGift::SendGiftAgedBased($this->model1);
    sleep(4);
    Log::debug('SendGiftCommand end');
}
SendGift.php
public static function SendGiftAgedBased(Model1 $model1){
  Log::debug('inside SendGiftAgedBased');
} 

即使进程已经工作但它不是异步的,它等待命令完成以在控制器中返回响应

我按这个顺序 git 日志

 [2015-12-09 16:28:42] local.DEBUG: before dispatch  
 [2015-12-09 16:28:42] local.DEBUG: handle  
 [2015-12-09 16:28:42] local.DEBUG: inside SendGiftAgedBased   
 [2015-12-09 16:28:46] local.DEBUG: SendGiftCommand end  
 [2015-12-09 16:28:46] local.DEBUG: after dispatch 

它应该在 Localhost 上工作吗?

【问题讨论】:

    标签: php laravel asynchronous laravel-5 queue


    【解决方案1】:

    我遇到了同样的问题,工作不是异步的,这对我有用:

    1. 编辑 .env 并将 QUEUE_DRIVER 设置从 sync 更改为 database(编辑 config/ queue.php 还不够)
    2. 重新启动您的流程

    【讨论】:

    • 这对我帮助很大——不知道为什么这不在文档中
    • 另外,记得运行 php artisan config:clear 之后
    • 这个数据库驱动真的是异步的吗?我尝试运行它,但它看起来不像在运行异步操作。每个作业都是顺序的,而不是并行的。
    【解决方案2】:

    为了使 job 排队,job 类需要实现 Illuminate\Contracts\Queue\ShouldQueue 接口 - 确保它适用于您的类。

    您可以在此处找到有关排队工作的更多信息:http://laravel.com/docs/5.1/queues#writing-job-classes

    【讨论】:

    • 它已经实现了 ShouldQueue ,但它应该在 localhost 上异步执行吗?
    • 你怎么知道它是同步运行的?您有 queue:listen 正在运行,因此它可能仍会被异步处理,但您正在以正确的顺序获取日志,因为它可能会被处理为什么您的代码正在执行 sleep()。停止队列:监听进程,在没有运行的情况下调度作业,看看作业是否被执行。
    • 谢谢你的帮助,我的意思是它似乎是同步的,但我希望它是异步的,如何实现?
    • 当您停止“queue:listen”时 - 作业是否得到处理?
    • 是的,它可以工作,但是当 queue:listen 工作与否时,它的同步。虽然我希望它异步工作,但我正在使用 localhost ,这会影响排队的使用吗?
    【解决方案3】:

    使用此命令创建作业:

       php artisan make:job SendGiftCommand --queued    
    

    请参阅此链接以定义工作:

     https://laravel.com/docs/5.1/queues#writing-job-classes
    

    然后通过声明作业并以这种方式调度作业:

        $processGift = new sendGiftCommand($model1);
        $this->dispatch($processGift);
    

    还请进一步参考上述链接上的主管配置,以持续侦听队列或自动重新启动命令队列:如果它们失败则侦听。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 2019-07-17
      • 1970-01-01
      • 1970-01-01
      • 2012-12-31
      • 1970-01-01
      • 2017-10-22
      • 2021-10-06
      • 1970-01-01
      相关资源
      最近更新 更多