1、安裝
composer require webman/redis-queue
2、配置好redis
3、投遞好消息
use Webman\RedisQueue\Redis;
class Index
{
public function queue(Request $request)
{
// 隊(duì)列名
$queue = 'send-mail';
// 數(shù)據(jù),可以直接傳數(shù)組,無需序列化
$data = ['to' => 'tom@gmail.com', 'content' => 'hello'];
// 投遞消息
Redis::send($queue, $data);
// 投遞延遲消息,消息會在60秒后處理
$r=Redis::send($queue, $data, 60);
return response('redis queue test:'.$r);
}
4、消費(fèi)者寫好
<?php
namespace app\queue\redis;
use Webman\RedisQueue\Consumer;
class MyMailSend implements Consumer
{
// 要消費(fèi)的隊(duì)列名
public $queue = 'send-mail';
// 連接名,對應(yīng) plugin/webman/redis-queue/redis.php 里的連接`
public $connection = 'default';
// 消費(fèi)
public function consume($data)
{
// 無需反序列化
var_export($data); // 輸出 ['to' => 'tom@gmail.com', 'content' => 'hello']
}
}
接下來windows下如何消費(fèi)呀 新手 麻煩了 實(shí)在是抱歉
啟動webman就消費(fèi)了啊,windows系統(tǒng)啟動webman用命令 php windows.php
或者 雙擊 windows.bat
linux系統(tǒng)用 php start.php start