Redis供应了Pub/Sub(发布/订阅)模式的机制。
发布者向指定频道发布,订阅了该频道的订阅者就可以获取消息。
通过该机制,我们可以完成谈天室、公告牌等功能。

首先,来先容下关于pub/sub的几个命令。

发布

php公告牌Redis完成聊天室功效 HTML

publish channel message 向指定频道发布

假如有一个车友群,此时有位用户发布了条

127.0.0.1:6379> publish car:fans hello,everyone

(integer) 0

该命令的返回值是订阅了此频道的订阅者数量。
可以看到,目前还没有人订阅该频道。

订阅

subscribe channel [channel] 订阅者可以订阅一个或多个用户

127.0.0.1:6379> subscribe car:fans

Reading messages... (press Ctrl-C to quit)

1) "subscribe"

2) "car:fans"

3) (integer) 1

此时,已经有一个用户加入了车友群。
逐渐的,加群的人越来越多。

当一个用户发布了后,其他群职员都能看到该。

127.0.0.1:6379> publish car:fans 'How are you'

(integer) 2127.0.0.1:6379> subscribe car:fans

Reading messages... (press Ctrl-C to quit)

1) "subscribe"

2) "car:fans"

3) (integer) 1

1) "message"

2) "car:fans"

3) "How are you"

把稳:当客户端实行了订阅命令后,即进入订阅状态,只能实行pub/sub干系命令了。
其余,新加群的用户是看不到之前的的,由于此种机制不会对进行持久化。
虽然功能受限,但胜在足够大略。

多说一句,功能不是越多越好,紧张看适不适宜场景。
如果能胜任的话,肯定越大略越好。

查看订阅数

pubsub numsub [channel ...]

想要查看群里有多少用户

127.0.0.1:6379> pubsub numsub car:fans

1) "car:fans"

2) (integer) 2

该群目前有2个用户。

取消订阅

unsubscribe [channel [channel ...]]

redis-cli UNSUBSCRIBE

1) "unsubscribe"

2) (nil)

3) (integer) 0

实战

先容完上面的知识后,我们就能完成一个谈天室的功能了。

发布的伪代码十分大略,发布的伪代码如下:

function publist ($chanel, $message)

{

$redis->publist($channel, $message);

}

获取消息的伪代码如下:

//设置php脚本实行韶光

set_time_limit(0);

//设置socket连接超时时间

ini_set('default_socket_timeout', -1);

//声明频道名称

$channelName = "testpubsub";

try {

$redis = new \Redis();

$redis->pconnect('localhost', 6379);

$redis->subscribe([$channelName], function ($redis, $channel, $msg)

{

echo 'channel:' . $channel . ',message:' . $msg . PHP_EOL;

});

} catch (\Exception $e) {

echo $e->getMessage();

}

这里有几个把稳点:

消费者须要创建redis长连接,设置set_time_limit和default_socket_timeout,以确保壅塞获取消息过程php不超时,socket连接不超时

目前,Redis供应了新的Stream类型,它的功能更加强大的多。
有兴趣的朋友可以自己查阅干系信息。