redis pubsub非阻塞接口(带线程)。
redis-pubsub-helper的Python项目详细描述
在某些情况下,阻止pyredis的订阅实现是很烦人的。 它是可以用某种技术控制的,但是这里有一个快速的方法 一条Python线。
注意:此实现只适用于少数情况。
示例
>>> import redis >>> redisc = redis.Redis() >>> import redispubsub >>> pubsub = redispubsub.RedisPubsub(redisc.pubsub()) >>> pubsub.subscribe('1') # You SHOULD subscribe before starting thread. >>> pubsub.start() # Start the router >>> pubsub.dequeue('1') {'pattern': None, 'type': 'subscribe', 'channel': '1', 'data': 1L} >>> redisc.publish('1', 'test') >>> pubsub.dequeue('1') # None returned >>> pubsub.dequeue('1') {'pattern': None, 'type': 'message', 'channel': '1', 'data': 'test'} >>> pubsub.dequeue('1') # None returned