python3 redis 订阅和发布demo示例

import redis
 
class RedisHelper:
 
    def __init__(self,host,port,db=0):
        self.__conn = redis.Redis(host,port,db=0)
 
    def public(self, channel, message):
	#开始发布消息
        self.__conn.publish(channel, message)
        return True
 
    def subscribe(self,channel):
	#开始订阅
        pub = self.__conn.pubsub()
	#订阅频道
        pub.subscribe(channel)
	#准备接收
        pub.parse_response()
        return  pub

发布

 
obj = RedisHelper()
 
obj.public('data','1111111')

订阅

 
obj= RedisHelper()
 
redis_sub = obj.subscribe('data')
 
 
while 1:
    msg =redis_sub.parse_response()
    # 接收到
    print(msg)

第二种方式订阅:

obj= RedisHelper()
 
redis_sub = obj.subscribe('data')
 
 
while 1:
    for item in pub.listen():
        # 接收到
        print(item['data'])


本文地址: http://www.chenxm.cc/article/1155.html
版权声明: 本文为原创文章,版权归  陈新明  所有,欢迎分享本文,转载请保留出处!
上一篇: Django 内建的模板标签和过滤器(html自动转义)
下一篇: python3 获取本机ip地址
发表评论

还没有留言,还不快点抢沙发?