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消息隊列