1 Publish / Subscribe 发布/订阅
Redis 的 SUBSCRIBE 命令可以让客户端订阅任意数量的频道，每当有新信息发送到被订阅的频道时， 信息就会被发送给所有订阅指定频道的客户端。
作为例子， 下图展示了频道 channel1 ， 以及订阅这个频道的三个客户端 —— client2 、 client5 和 client1 之间的关系：
当有新消息通过 PUBLISH 命令发送给频道channel1 时， 这个消息就会被发送给订阅它的三个客户端：
上面描述了订阅与发布的关系。
2 example 实例演示
发布端：
# -*- coding: UTF-8 -*- import redis redis_client = redis.StrictRedis(host=‘localhost‘, port=6379, db=0) # 建立PubSub对象订阅通道和侦听新消息 p = redis_client.pubsub() # 订阅两个频道，分别是my-first-channel，和my-second-channel p.subscribe(‘my-first-channel‘, ‘my-second-channel‘) # 使用publish推送消息,注意是StrictRedis类的方法 redis_client.publish(‘my-first-channel‘, ‘nihvdfdao‘)
订阅端A：
# -*- coding: UTF-8 -*- import redis redis_server = redis.StrictRedis(host=‘localhost‘, port=6379, db=0) # 建立PubSub对象订阅通道和侦听新消息 p = redis_server.pubsub() # 订阅两个频道，分别是my-first-channel，和my-second-channel p.subscribe(‘my-first-channel‘, ‘my-second-channel‘) # 使用p.listen()方法监听频道 for item in p.listen(): # 如果订阅的频道存储的项目是‘message‘ if item[‘type‘] == ‘message‘: # 则打印这个项目 print item[‘data‘]
订阅端B：
# -*- coding: UTF-8 -*- import redis redis_server = redis.StrictRedis(host=‘localhost‘, port=6379, db=0) # 建立PubSub对象订阅通道和侦听新消息 p = redis_server.pubsub() # 订阅两个频道，分别是my-first-channel，和my-second-channel p.subscribe(‘my-first-channel‘, ‘my-second-channel‘) whileTrue: data =msg_queue.parse_response() print pickle.loads(data[2])
本文部分内容和图片引用以下网址：
http://zc985552943.iteye.com/blog/2037535
时间： 2024-12-28 21:21:44