python redis订阅发布示例代码

可以使用pip install redis安装python的redis客户端。

python 实现redis订阅发布功能,pythonredis

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

import  redis
class 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 RedisSubscri
if __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

订阅端

图片 2

 

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

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

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

 

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

人生苦短我用python。

 

实现redis订阅发布功能,pythonredis redis是一个key-value存储系统。和Memcached类似,它支持存储的value类型相对更多,包括string(字符串)、...

python redis 的发布端:

import redis  

rc = redis.Redis(host='127.0.0.1')  
ps = rc.pubsub()  
ps.subscribe(['foo', 'bar'])  //订阅两个频道,分别是foo,或bar  
for item in ps.listen():  
    if item['type'] == 'message':  
        print item['data']  

python redis的发布端:

本文由太阳集团所有网址16877发布于太阳集团城网址送彩金,转载请注明出处:python redis订阅发布示例代码

您可能还会对下面的文章感兴趣: