重庆小潘seo博客

当前位置:首页 > 重庆网络营销 > 小潘杂谈 >

小潘杂谈

使用Redis完成聊天室功能

时间:2020-09-22 15:00:07 作者:重庆seo小潘 来源:
Redis提供了Pub/Sub(发布/订阅)模式的消息机制。发布者向指定频道发布消息,订阅了该频道的订阅者就可以获取消息。通过该机制,我们可以完成聊天室、公告牌等功能。 首先,来介绍下关于pub/sub的几个命令。 发布消息 publish channel message 向指定频道发布

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

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

发布消息

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:fansReading 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:fansReading messages... (press Ctrl-C to quit)1) "subscribe"2) "car:fans"3) (integer) 11) "message"2) "car:fans"3) "How are you"注意:当客户端执行了订阅命令后,即进入订阅状态,只能执行pub/sub相关命令了。另外,新加群的用户是看不到之前的消息的,因为此种机制不会对消息进行持久化。虽然功能受限,但胜在足够简单。

多说一句,功能不是越多越好,主要看适不适合场景。如果能胜任的话,肯定越简单越好。

查看订阅数

pubsub numsub [channel ...]

想要查看群里有多少用户127.0.0.1:6379> pubsub numsub car:fans1) "car:fans"2) (integer) 2该群目前有2个用户。

取消订阅

unsubscribe [channel [channel ...]]redis-cli UNSUBSCRIBE1) "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类型,它的功能更加强大的多。有兴趣的朋友可以自己查阅相关信息。以上就是使用Redis完成聊天室功能的详细内容,更多请关注小潘博客其它相关文章!