laravel redis消息队列

Posted Уy。

tags:

篇首语:本文由小常识网(cha138.com)小编为大家整理,主要介绍了laravel redis消息队列相关的知识,希望对你有一定的参考价值。

1、首先安装redis扩展包

composer require "predis/predis:~1.0"

2、配置redis参数 、修改队列驱动

.env文件   QUEUE_DRIVER=redis

3、config/database.php配置redis的连接参数

‘redis‘ => [

        ‘cluster‘ => false,

        ‘default‘ => [

            ‘host‘     => env(‘REDIS_HOST‘, ‘127.0.0.1‘),

            ‘port‘     => 6379,

            ‘database‘ => 0,

            ‘password‘ => env(‘REDIS_PASSWORD‘, ‘123456‘)

        ],

    ],

4、appJobs中创建任务类,当队列处理该任务时执行的handle方法。

 

<?php

 

namespace App\Jobs;

 

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

 

class Queue extends Job implements SelfHandling,ShouldQueue
{
use InteractsWithQueue, SerializesModels;
/**
* 用户id
* @var int
*/
protected $customer_id;
/**
* Create a new job instance.
*
* @return void
*/
public function __construct($customer_id)
{
$this->customer_id = $customer_id;
}

 

/**
* Execute the job.
*
* @return void
*/
public function handle()
{
//具体业务
}
}

 

5、推送任务到队列

<?php

namespace App\Http\Controllers;

use App\Http\Controllers\Controller;
use App\Jobs\Queue;
class IndexController extends Controller
{

/**
* Create a new authentication controller instance.
*
* @return void
*/
public function __construct()
{

}

 


protected function index()
{
$job = (new Queue(543574))->delay(60);//延迟60s执行

$this->dispatch($job);
}
}

6、运行队列监听

 

1)应用服务器监听

 

如果之前有 php artisan config:cache 缓存配置,最好先把配置缓存清除:php artisan config:clear

 

测试过程中,可以使用 ==php artisan queue:listen==进行监听。

 

线上可以使用 ==php artisan queue:work --daemon==

 

2redis服务器监听

 

redis-cli连接redis后,可以使用==monitor==查看队列情况。

 

 

 

 

参考 https://segmentfault.com/a/1190000011787353















































以上是关于laravel redis消息队列的主要内容,如果未能解决你的问题,请参考以下文章

redis怎么做消息队列

Laravel Redis 发布订阅消息

redis消息队列有没有

Redis(五)-特性-消息队列

Redis的基本使用(二) 消息队列

Laravel 集成 RabbitMQ 消息队列