ffogarasi/laravel-database-queue

0.5.8 2017-09-14 05:29 UTC

README

将函数/闭包推送到数据库队列。

这是一个真正的队列驱动程序,类似于beanstalkd或redis。您需要一个像supervisor或类似的守护进程来监听您的队列。

安装

将此包添加到composer.json的require部分,并运行composer update

"ffogarasi/laravel-database-queue": ">0.5"

将服务提供者添加到config/app.php中的providers数组

'Davelip\Queue\DatabaseServiceProvider'

建议发布迁移,以便它们被复制到您的常规迁移

$ php artisan migrate:publish davelip/laravel-database-queue

然后运行迁移

$ php artisan migrate 

建议在此刻创建failed_jobs表,如下所示

$ php artisan queue:failed-table

现在您应该能够使用config/queue.php中的数据库驱动程序

'default' => 'database',

'connections' => array(
    ...
    'database' => array(
        'driver' => 'database',
        'queue' => 'queue-name', // optional, can be null or any string
        'lock_type' => 0, // optional, can be 0, 1 or 2
    ),
    ...
}

它与beanstalkd或redis队列监听器的工作方式相同。

监听新任务

$ php artisan queue:listen

并发由queues表中的status列管理,因此您可以并行化queue:listen

状态更改的原子性由数据库事务保证,如果您遇到竞争条件问题,可以将选项lock_type设置为

  • 'lock_type' => 1 // 队列系统将使用sharedLock
  • 'lock_type' => 2 // 队列系统将使用lockForUpdate

有关更多信息,请参阅https://laravel.net.cn/docs/4.2/queries#pessimistic-locking

Laravel 队列系统

更多信息请参阅https://laravel.net.cn/docs/queues

谢谢

基于https://github.com/barryvdh/laravel-async-queue进行开发