python - 从 Redis 中的 channel 弹出消息

Question

我需要在特定 channel 的一台机器( setter )上发布消息，并在其他机器(处理程序)上获取它。问题是每个处理程序都应该处理唯一的消息。

正如我在 documentation 中看到的那样, 没有从 channel 弹出消息的标准方法，也许我尝试以错误的方式使用它？

处理程序代码如下:

 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')

Answer 1

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