【问题标题】:Pop message from channel in Redis从 Redis 中的频道弹出消息
【发布时间】: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


    【解决方案1】:

    Pub/Sub 不适合这种模式 - 考虑使用 List 并改为在处理程序中调用阻塞弹出操作。

    【讨论】:

      猜你喜欢
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2013-08-07
      • 1970-01-01
      • 1970-01-01
      • 1970-01-01
      • 2021-06-12
      • 1970-01-01
      相关资源
      最近更新 更多