Python_redis_订阅和发布

发布和订阅

首先定义一个RedisHelper类,连接Redis,定义频道为monitor,定义发布(publish)及订阅(subscribe)方法.

#!/usr/bin/env python
#-*- coding:utf-8 -*-
import redis

class RedisHelper(object):
def __init__(self):
    self.__conn = redis.Redis(host='192.16⑧0.110',port=6379)#连接Redis
    self.channel = 'monitor' #定义名称

def publish(self,msg):#定义发布方法
    self.__conn.publish(self.channel,msg)
    return True

def subscribe(self):#定义订阅方法
    pub = self.__conn.pubsub()
    pub.subscribe(self.channel)
    pub.parse_response()
    return pub

发布者

#!/usr/bin/env python
# -*- coding:utf-8 -*-
#发布
from RedisHelper import RedisHelper

obj = RedisHelper()
obj.publish('hello')#发布

订阅者

#!/usr/bin/env python
# -*- coding:utf-8 -*-
#订阅
from RedisHelper import RedisHelper

obj = RedisHelper()
redis_sub = obj.subscribe()#调用订阅方法

while True:
msg= redis_sub.parse_response()
print (msg)

以上就是土嘎嘎小编为大家整理的Python_redis_订阅和发布相关主题介绍,如果您觉得小编更新的文章只要能对粉丝们有用,就是我们最大的鼓励和动力,不要忘记讲本站分享给您身边的朋友哦！！