python 实现redis订阅发布功能-白红宇的个人博客

发布日期：2021-05-09 04:20:10 浏览次数：16 分类：博客文章

本文共 1349 字，大约阅读时间需要 4 分钟。

redis是一个key-value存储系统。和Memcached类似，它支持存储的value类型相对更多，包括string(字符串)、list(链表)、set(集合)、zset(sorted set --有序集合)和hash（哈希类型）。也能实现订阅发布系统，我们来看看怎样用redis和python结合起来进行订阅发布的，

import  redisclass RedisSubscri():    def __init__(self,host):        self.coon=redis.Redis(host="127.0.0.1")    def publish(self,message,channel):#发布        self.coon.publish(channel,message)    def subscribe(self,channel):#订阅        pub=self.coon.pubsub()        pub.subscribe(channel)        pub.parse_response()        return  pub    def unsubsceribe(self,channel):#取消订阅        self.coon.pubsub().unsubscribe(channel)

核心的代码就是上面的简单封装后就可以使用。

发布端redisd=RedisSubscri(host='127.0.0.1')while True:n=input("请输入你要发布的频道:")m=input("请输入你要发布的消息:")redisd.publish(m,n)

订阅端from  dingyue import RedisSubscriif __name__=="__main__":    resad = RedisSubscri(host='127.0.0.1')    meaaag = resad.subscribe('1')    while True:        print('监听开始')        meaaage=meaaag.parse_response()        print(meaaage[2].decode('utf-8'))        if meaaage[2].decode('utf-8')=='1':            m=meaaag.unsubscribe('fm9.01')            print(m)            print('取消订阅成功')            break

那么我们来运行下，上述的代码，看是否能够实现登录订阅功能，并且实现退订功能。

发布端：

订阅端

我们在上面的代码中定义了，当接受消息为1的时候，我们就取消订阅，

取消订阅后就无法订阅系统的消息了，所以输出来是None。

这样就利用python 和redis实现了订阅发布的功能，其实在很多地方都可以用到redis的，深入研究在后续的文章中会介绍。

一点一滴，学习python，点点滴滴，记录python之路。

人生苦短我用python。

个人公众号

上一篇：flask + Python3 实现的的API自动化测试平台---- IAPTest接口测试平台（总结感悟篇）

下一篇：python装饰器实现对异常代码出现进行监控

发表评论

关于作者

喝酒易醉，品茶养心，人生如梦，品茶悟道，何以解忧？唯有杜康！

-- 愿君每日到此一游！

发表评论

最新留言

关于作者

推荐文章