【发布时间】:2017-11-20 10:30:34
【问题描述】:
我需要在一台机器(setter)上的特定通道中发布消息,并在其他机器(处理程序)上获取它。问题是每个处理程序都应该处理唯一的消息。
正如我在documentation 中看到的,没有标准的方法来从频道弹出消息,也许我尝试以错误的方式使用它?
这是处理程序的代码:
import redis
r=redis.Redis()
pubsub = r.pubsub()
pubsub.subscribe('test_channel')
for item in self.pubsub.listen():
...
这里是setter的代码:
import redis
r = redis.Redis()
r.publish('test_channel', 'test message')
【问题讨论】:
标签: python python-3.x redis publish-subscribe