Redis訂閱釋出模式
阿新 • • 發佈:2021-06-15
採用訂閱釋出模式可以將訊息分發給所有訂閱者,實現訊息通知的功能
redis提供訂閱釋出模式可供使用,基於redis的連結串列結構
程式碼如下:
釋出者
1 from redis import StrictRedis 2 import time 3 4 5 redis = StrictRedis(host="192.168.1.1", db=10, password="xxx") 6 7 while True: 8 msg = str(time.time())+"=msg=" 9 redis.publish("information.important", msg)10 print("publish one ===") 11 time.sleep(1)
訂閱者
1 from redis import StrictRedis 2 3 4 redis = StrictRedis(host="192.168.1.1", db=10, password="xxx") 5 6 sub = redis.pubsub() 7 sub.subscribe("information.important") 8 9 10 for msg in sub.listen(): 11 print(msg)
訂閱到的資訊為:
1{'type': 'subscribe', 'pattern': None, 'channel': b'information.important', 'data': 1} 2 {'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753168.7148438=msg='} 3 {'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753169.7158203=msg='} 4 {'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753170.7167969=msg='} 5 {'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753171.7177732=msg='} 6 {'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753172.71875=msg='} 7 {'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753173.7197266=msg='} 8 {'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753174.720703=msg='} 9 {'type': 'message', 'pattern': None, 'channel': b'information.important', 'data': b'1623753175.7216797=msg='}
可以通過訂閱相應的通道,來獲取相應的訊息