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==
(2)redis服务器监听
redis-cli连接redis后,可以使用==monitor==查看队列情况。
参考 https://segmentfault.com/a/1190000011787353
以上是关于laravel redis消息队列的主要内容,如果未能解决你的问题,请参考以下文章