1. 程式人生 > 其它 >Redis訂閱釋出模式

Redis訂閱釋出模式

採用訂閱釋出模式可以將訊息分發給所有訂閱者,實現訊息通知的功能

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='}

可以通過訂閱相應的通道,來獲取相應的訊息