1、安装
composer require webman/redis-queue
2、配置好redis
3、投递好消息
use Webman\RedisQueue\Redis;
class Index
{
public function queue(Request $request)
{
// 队列名
$queue = 'send-mail';
// 数据,可以直接传数组,无需序列化
$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、消费者写好
<?php
namespace app\queue\redis;
use Webman\RedisQueue\Consumer;
class MyMailSend implements Consumer
{
// 要消费的队列名
public $queue = 'send-mail';
// 连接名,对应 plugin/webman/redis-queue/redis.php 里的连接`
public $connection = 'default';
// 消费
public function consume($data)
{
// 无需反序列化
var_export($data); // 输出 ['to' => 'tom@gmail.com', 'content' => 'hello']
}
}
接下来windows下如何消费呀 新手 麻烦了 实在是抱歉
启动webman就消费了啊,windows系统启动webman用命令
php windows.php
或者 双击 windows.batlinux系统用 php start.php start
刚才没重启
再次感谢大佬