#!/usr/bin/env python# Author:Zhangmingdaimport redis,timepool = 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:Zhangmingdaimport redisclass 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 pubobj = RedisHelper()redis_sub = obj.subscribe()while True: msg = redis_sub.parse_response() print(msg)
#!/usr/bin/env python# Author:Zhangmingdaimport redisclass 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 Trueserver = RedisHelper()server.public('hehe') http://www.cnblogs.com/lianzhilei/p/5983673.html