Redis订阅发布模式

采用订阅发布模式可以将消息分发给所有订阅者，实现消息通知的功能

redis提供订阅发布模式可供使用，基于redis的链表结构

代码如下：

发布者

from redis import StrictRedis
import time


redis = StrictRedis(host="192.168.1.1", db=10, password="xxx")

while True:
    msg = str(time.time())+"=msg="
    redis.publish("information.important", msg)
    print("publish one ===")
    time.sleep(1)

订阅者

from redis import StrictRedis


redis = StrictRedis(host="192.168.1.1", db=10, password="xxx")

sub = redis.pubsub()
sub.subscribe("information.important")


for msg in sub.listen():
    print(msg)

订阅到的信息为：

{'type': 'subscribe', 'pattern': None, 'channel': b'information.important', 'data': 1}
{'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753168.7148438=msg='}
{'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753169.7158203=msg='}
{'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753170.7167969=msg='}
{'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753171.7177732=msg='}
{'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753172.71875=msg='}
{'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753173.7197266=msg='}
{'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753174.720703=msg='}
{'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753175.7216797=msg='}

可以通过订阅相应的通道，来获取相应的消息