Laravel队列使用案例

1、配置数据库和Redis
	//编辑config/database.php
	'mysql' => [
            'driver' => 'mysql',
            'host' => 'localhost',
            'port' => 3306,
            'database' => 'demo_laravel',
            'username' => 'demo',
            'password' => '123456',
            'charset' => 'utf8',
            'collation' => 'utf8_unicode_ci',
            'prefix' => '',
            'strict' => false,
            'engine' => null,
        ],
	'queue' => [
            'host' => '192.168.56.101',
            'password' => null,
            'port' => 6379,
            'database' => 0,
        ],
	//config/queue.php
	'default' => 'redis',
	'connections' => [
        'redis' => [
            'driver' => 'redis',
            'connection' => 'queue',
            'queue' => 'default',
            'expire' => 3600,//队列有效期
        ],

    ],
	'failed' => [
        'database' => 'mysql',
        'table' => 'failed_jobs',
    ],
2、添加failed-table
执行:php artisan queue:failed-table
执行:php artisan migrate:install
执行:php artisan migrate
3、生产者
将数据丢入队列
执行:php artisan make:console Demo/Test
<?php

namespace App\Console\Commands\Demo;

use App\Jobs\Demo\HandleTest;
use Illuminate\Console\Command;
use Illuminate\Foundation\Bus\DispatchesJobs;

class Test extends Command
{
    use DispatchesJobs;
    /**
     * 将数据丢入队列
     */
    protected $signature = 'demo:test {--num=}';
    protected $description = '将数据丢入队列';
    public function __construct()
    {
        parent::__construct();
    }
    public function handle()
    {
        $num = $this->option('num');
        for($i = 0; $i <= $num; $i++) {
            $queueName = 'demo_1';//这里可以按照业务取模之后启动多个队列
            $job = (new HandleTest($i))->onConnection('redis')->onQueue($queueName);
            $this->dispatch($job);
        }
    }
}


4、消费者
将消费队列内容
php artisan make:job Demo/HandleTest
app/Jobs/Demo/HandleTest.php
<?php

namespace App\Jobs\Demo;

use App\Jobs\Job;
use Illuminate\Queue\SerializesModels;
use Illuminate\Queue\InteractsWithQueue;
use Illuminate\Contracts\Queue\ShouldQueue;

class HandleTest extends Job implements ShouldQueue
{
    use InteractsWithQueue, SerializesModels;
    //初始化数据
    public function __construct($data)
    {
        $this->data = $data;
    }
    public function handle()
    {
        echo $this->data . PHP_EOL;
    }
}
5、启动生产者
php artisan demo:test --num=2
//这样可以看到redis的queues:demo_1
在redis执行:LRANGE queues:demo_1 0 -1
可以看到3个元素
6、启动消费队列(可以使用supervisor管理消费队列)
php artisan queue:work redis --queue=demo_1 --daemon --tries=10
7、队列失败
如果队列执行失败则会将任务存入failed_jobs表
重试JOB可以执行 php artisan queue:retry	1

本文参与腾讯云自媒体分享计划,欢迎正在阅读的你也加入,一起分享。

发表于

我来说两句

0 条评论
登录 后参与评论

相关文章

来自专栏python3

windows和linux格式转换

742
来自专栏Laoqi's Linux运维专列

mycat实现MySQL读写分离

4645
来自专栏xcywt

《Linux命令行与shell脚本编程大全》第十章 使用编辑器

主要介绍vim, nano, emacs,KWrite,Kate,GNOME 10.1 vim Unix系统最初的编辑器 10.1.1检查vim软件包 先搞明白...

2068
来自专栏云计算教程系列

如何在Ubuntu 14.04上使用Pydio托管文件共享服务器

随着云的采用增加,越来越多的数据被远程存储。从音乐到图片再到个人文档,很多人都将文件上传到他们不管理的服务器上。如果您希望将文件保存在您控制的服务器上,则可以使...

3630
来自专栏木子昭的博客

nodejs爬虫获取漫威超级英雄电影海报

1643
来自专栏openshift持续集成

openshift镜像构建-s2i环境变量设置

源码构建的时候我们可以在应用程序内设置环境变量的值(每行一个),方法是在源码库的.s2i / environment文件中指定它们。这个文件中指定的环境变量在构...

5027
来自专栏黄子玥的专栏

Websocket 基础篇

WebSocket 规范定义了一种API,可在网络浏览器和服务器之间建立“套接字”连接。简单地说,客户端和服务器之间存在持久的连接,而且双方都可以随时开始发送数...

2.3K1
来自专栏三杯水

系统重启后nginx reload不生效原因分析

这是一种比较少见,困扰我很久的问题,虽然这个问题很简单,但是找到根本原因还是费了不少时间,现在把分析过程分享如下。

3422
来自专栏FreeBuf

如何在安卓移动终端进行一次渗透实验?

下面的实验将通过使用一个虚拟Android系统作为实验主体来进行展示。在这个实验中,通过使用虚拟Android系统,模拟移动终端的操作,来帮助我们逐步实现使用一...

3246
来自专栏运维

系统重启后ngix reload不生效原因分析

这是一种比较少见,困扰我很久的问题,虽然这个问题很简单,但是找到根本原因还是费了不少时间,现在把分析过程分享如下。

872

扫码关注云+社区

领取腾讯云代金券