redis 訂閱與發布
阿新 • • 發佈:2017-07-29
mat 技術 ima 工作 clas image 代碼 定位 屬性
訂閱subscribe,可以讓客戶端訂閱任意數量的頻道, 每當有新信息發送到被訂閱的頻道時,信息就會被發送給所有訂閱指定頻道的客戶端:
訂閱頻道
每個 Redis 服務器進程都維持著一個表示服務器狀態的 redis.h/redisServer 結構,結構的
pubsub_channels 屬性是一個字典,這個字典就用於保存訂閱頻道的信息:
UNSUBSCRIBE 命令可以退訂指定的頻道, 它從pubsub_channels 字典的給定頻道(鍵)中,刪除關於當前客戶端的信息,這樣被退訂頻道的信息就不會再發送給這個客戶端。
模式的訂閱與信息發送
當使用 PUBLISH 命令發送信息到某個頻道時,不僅所有訂閱該頻道的客戶端會收到信息,如
果有某個/某些模式和這個頻道匹配的話,那麽所有訂閱這個/這些頻道的客戶端也同樣會收到 信息。 帶頻道和模式的例子, 其中 tweet.shop.* 模式匹配了 tweet.shop.kindle 頻道和 tweet.shop.ipad 頻道,並且有不同的客戶端分別訂閱它們三個:
當有信息發送到 tweet.shop.kindle 頻道時,信息除了發送給 clientX 和 clientY 之外,還
會發送給訂閱 tweet.shop.* 模式的 client123 和 client256 :
如果這時客戶端 client10086 執行 PSUBSCRIBE broadcast.list.* ,那麽 pubsub_patterns
鏈表將被更新成這樣:
通過遍歷整個 pubsub_patterns 鏈表,程序可以檢查所有正在被訂閱的模式,以及訂閱這些模式的客戶端。
發送信息到模式
發送信息到模式的工作也是由 PUBLISH 命令進行的,在前面講解頻道的時候,我們給出了這
樣一段偽代碼,說它定義了 PUBLISH 命令的行為:
會刪除 redisServer.pubsub_patterns 鏈表中,所有和被退訂模式相關聯的 pubsubPattern 結構,這樣客戶端就不會再收到和模式相匹配的頻道發來的信息。 小結
- PUBLISH,SUBSCRIBE,等命令實現訂閱與發布
- 訂閱/發布到頻道
- 訂閱/發布到模式
訂閱subscribe,可以讓客戶端訂閱任意數量的頻道, 每當有新信息發送到被訂閱的頻道時,信息就會被發送給所有訂閱指定頻道的客戶端:
![技術分享](http://images2017.cnblogs.com/blog/820365/201707/820365-20170729130624175-111199473.png)
當有新消息通過publish命令發送給頻道channel1時,這個消息就會被發送給訂閱它的三個客戶端:
![技術分享](http://images2017.cnblogs.com/blog/820365/201707/820365-20170729130624222-1228362169.png)
struct redisServer { // ... dict *pubsub_channels; // ... };
其中字典的鍵為正在被訂閱的頻道,而字典的值則是一個鏈表,鏈表中保存了所有訂閱這個頻道的客戶端。 例如:
![技術分享](http://images2017.cnblogs.com/blog/820365/201707/820365-20170729130634597-837331925.png)
當客戶端調用subscribe命令時,程序將客戶端和要訂閱的頻道在pubsub_channels字典中關聯起來。 舉個例子,如果客戶端 client10086 執行命令 SUBSCRIBE channel1 channel2 channel3 , 那麽前面展示的 pubsub_channels 將變成下面這個樣子:
![技術分享](http://images2017.cnblogs.com/blog/820365/201707/820365-20170729130650066-259102632.png)
發送信息到頻道 當調用 PUBLISH channel message 命令,程序首先根據 channel 定位到字典的鍵,然後將信息發 送給字典值鏈表中的所有客戶端。 如果某個客戶端執行命令 PUBLISH channel1 "hello moto" ,上圖中那麽 client2 、 client5 ,client1,client10086 4個客戶端都將接收到 "hello moto" 退訂頻道
當使用 PUBLISH 命令發送信息到某個頻道時,不僅所有訂閱該頻道的客戶端會收到信息,如
果有某個/某些模式和這個頻道匹配的話,那麽所有訂閱這個/這些頻道的客戶端也同樣會收到 信息。 帶頻道和模式的例子, 其中 tweet.shop.* 模式匹配了 tweet.shop.kindle 頻道和 tweet.shop.ipad 頻道,並且有不同的客戶端分別訂閱它們三個:
![技術分享](http://images2017.cnblogs.com/blog/820365/201707/820365-20170729130728691-938655012.png)
![技術分享](http://images2017.cnblogs.com/blog/820365/201707/820365-20170729130738941-836388995.png)
訂閱模式 redisServer.pubsub_patterns 屬性是一個鏈表,鏈表中保存著所有和模式相關的信息:
struct redisServer { // ... list *pubsub_patterns; // ... };
鏈表中的每個節點都包含一個 redis.h/pubsubPattern 結構:
typedef struct pubsubPattern { redisClient *client; robj *pattern; } pubsubPattern;
client 屬性保存著訂閱模式的客戶端,而 pattern 屬性則保存著被訂閱的模式。 每當調用 PSUBSCRIBE 命令訂閱一個模式時,程序就創建一個包含客戶端信息和被訂閱模式的 pubsubPattern 結構,並將該結構添加到 redisServer.pubsub_patterns 鏈表中。
![技術分享](http://images2017.cnblogs.com/blog/820365/201707/820365-20170729130751941-792819754.png)
![技術分享](http://images2017.cnblogs.com/blog/820365/201707/820365-20170729130802925-867334080.png)
def PUBLISH(channel, message): # 遍歷所有訂閱頻道 channel 的客戶端 for client in server.pubsub_channels[channel]: # 將信息發送給它們 send_message(client, message) # 取出所有模式,以及訂閱模式的客戶端 for pattern, client in server.pubsub_patterns: # 如果 channel 和模式匹配 if match(channel, pattern): # 那麽也將信息發給訂閱這個模式的客戶端 send_message(client, message)
退訂模式 使用 PUNSUBSCRIBE 命令可以退訂指定的模式,這個命令執行的是訂閱模式的反操作:程序
會刪除 redisServer.pubsub_patterns 鏈表中,所有和被退訂模式相關聯的 pubsubPattern 結構,這樣客戶端就不會再收到和模式相匹配的頻道發來的信息。 小結
- 訂閱信息由服務器進程維持的 redisServer.pubsub_channels 字典保存,
- 字典的鍵為被訂閱的頻道,字典的值為訂閱頻道的所有客戶端。
- 當有新消息發送到頻道時,程序遍歷頻道(鍵)所對應的(值)所有客戶端,
- 然後將消息發送到所有訂閱頻道的客戶端上。
- 訂閱模式的信息由服務器進程維持的 redisServer.pubsub_patterns 鏈表保存,
- 鏈表的每個節點都保存著一個pubsubPattern結構,結構中保存著被訂閱的模式,
- 以及訂閱該模式的客戶端。程序通過遍歷鏈表來查找某個頻道是否和某個模式匹配。
- 當有新消息發送到頻道時,除了訂閱頻道的客戶端會收到消息之外,
- 所有訂閱了匹配頻、道的模式的客戶端,也同樣會收到消息。
- 退訂頻道和退訂模式分別是訂閱頻道和訂閱模式的反操作。
redis 訂閱與發布