开发笔记:redispipeset发布订阅

#!/usr/bin/env python
# Author:Zhangmingda
import redis,time
pool = redis.ConnectionPool(host=\'192.168.11.5\',port=6379,db=2)
r = redis.Redis(connection_pool=pool)
pipe = r.pipeline(transaction=True)
pipe.set(\'age\',\'22\')
time.sleep(15)
pipe.execute() #如果不执行，则不会执行pipe.set 即不会真正存值

#!/usr/bin/env python
# Author:Zhangmingda
#!/usr/bin/env python
# Author:Zhangmingda
import redis
class RedisHelper:
def __init__(self):
self.__conn = redis.Redis(host=\'192.168.11.5\',port=6379)
self.chan_sub = \'fm104.5\'
self.chan_pub = \'fm104.5\'
def public(self, msg): #发布消息用函数
self.__conn.publish(self.chan_pub, msg)
return True
def subscribe(self): #接收消息用函数
pub = self.__conn.pubsub()
pub.subscribe(self.chan_sub)
pub.parse_response()
return pub
obj = RedisHelper()
redis_sub = obj.subscribe()
while True:
msg = redis_sub.parse_response()
print(msg)

#!/usr/bin/env python
# Author:Zhangmingda
import redis
class RedisHelper:
def __init__(self):
self.__conn = redis.Redis(host=\'192.168.11.5\',port=6379)
self.chan_sub = \'fm104.5\'
self.chan_pub = \'fm104.5\'
def public(self, msg): #发布消息用函数
self.__conn.publish(self.chan_pub, msg)
return True
server = RedisHelper()
server.public(\'hehe\')