Redis的發佈與訂閱,有點相似於消息隊列,發送者往頻道發送消息,頻道的訂閱者接收消息。java
首先,在本機開啓第1個Redis客戶端,執行以下命令訂閱blog.redis
頻道:redis
SUBSCRIBE "blog.redis"
複製代碼
而後,在本機開啓第2個Redis客戶端,執行相同的命令訂閱blog.redis
頻道:shell
而後,開啓第3個Redis客戶端,執行以下命令往blog.redis
頻道發送消息:服務器
PUBLISH blog.redis "redis-in-action-01"
複製代碼
查看客戶端1和客戶端2,分別看到以下信息:微信
3個客戶端與頻道的關係以下圖所示:spa
能夠經過INFO clients
命令查看鏈接的客戶端數:設計
Redis的SUBSCRIBE
命令用來訂閱頻道,使用方式以下所示:3d
SUBSCRIBE "blog.redis"
複製代碼
若是是訂閱多個頻道,可使用以下所示命令:code
SUBSCRIBE "blog.redis" "blog.rocketmq"
複製代碼
Redis將全部頻道的訂閱關係保存在服務器狀態的pubsub_channels
字典裏,字典的鍵是某個被訂閱的頻道,鍵對應的值是1個鏈表,鏈表裏記錄了全部訂閱這個頻道的客戶端。cdn
以上圖爲例,說明客戶端一、客戶端2正在訂閱頻道"blog.redis",客戶端三、客戶端4正在訂閱頻道「blog.rocketmq」。
若是此時有1個客戶端5,執行了以下命令:
SUBSCRIBE "blog.rocketmq" "blog.java"
複製代碼
那麼服務器狀態保存的頻道訂閱關係將變爲以下圖所示:
Redis的UNSUBSCRIBE
命令用來退訂頻道,使用方式以下所示:
UNSUBSCRIBE "blog.redis"
複製代碼
若是是退訂多個頻道,可使用以下所示命令:
UNSUBSCRIBE "blog.redis" "blog.rocketmq"
複製代碼
假設如今服務器狀態保存的頻道訂閱關係以下圖所示:
若是此時客戶端5,執行了以下命令:
UNSUBSCRIBE "blog.rocketmq" "blog.java"
複製代碼
那麼服務器狀態保存的頻道訂閱關係將變爲以下圖所示:
首先,啓動1個Redis客戶端,執行以下命令訂閱模式「blog.r*」:
PSUBSCRIBE "blog.r*"
複製代碼
而後,啓動另1個Redis客戶端,執行PUBLISH
命令往頻道發送消息:
PUBLISH "blog.redis" "redis-in-action-01"
PUBLISH "blog.rocketmq" "rocketmq-in-action-01"
PUBLISH "blog.java" "java-in-action-01"
複製代碼
能夠看到,第1次啓動的客戶端能夠接收到前2條消息,由於頻道"blog.redis"、"blog.rocketmq"匹配模式「blog.r*」:
但頻道"blog.java"不匹配該模式,因此最後1次發送的消息,該客戶端未接收到。
Redis的PSUBSCRIBE
命令用來訂閱模式,使用方式以下所示:
PSUBSCRIBE "blog.r*"
複製代碼
若是是訂閱多個模式,可使用以下所示命令:
PSUBSCRIBE "blog.r*" "blog.j?va" "blog.j[ae]va"
複製代碼
Redis將全部模式的訂閱關係保存在服務器狀態的pubsub_patterns
屬性裏。
pubsub_patterns
屬性是1個鏈表,鏈表中的每一個節點是1個pubsub_Pattern
結構,這個結構的pattern
屬性記錄被訂閱的模式,client
屬性記錄訂閱模式的客戶端。
以上圖爲例,說明客戶端1正在訂閱模式"blog.r*,客戶端2正在訂閱模式「blog.j?va」。
若是此時有1個客戶端3,執行了以下命令:
PSUBSCRIBE "blog.j[ae]va"
複製代碼
那麼服務器狀態保存的模式訂閱關係將變爲以下圖所示:
Redis的PUNSUBSCRIBE
命令用來退訂模式,使用方式以下所示:
PUNSUBSCRIBE "blog.r*"
複製代碼
若是是退訂多個模式,可使用以下所示命令:
PUNSUBSCRIBE "blog.j?va" "blog.j[ae]va"
複製代碼
假設如今服務器狀態保存的模式訂閱關係以下圖所示:
若是此時客戶端3,執行了以下命令:
PUNSUBSCRIBE "blog.j[ae]va"
複製代碼
那麼服務器狀態保存的模式訂閱關係將變爲以下圖所示:
若是,服務器狀態保存的頻道訂閱關係以下圖所示:
服務器狀態保存的模式訂閱關係以下圖所示:
此時,若是1個Redis客戶端執行了如下PUBLISH命令:
PUBLISH blog.redis "redis-in-action-01"
複製代碼
那麼,服務器會執行如下2個動做:
也就是說,消息"redis-in-action-01"不只會發送給頻道「blog.redis」的訂閱者客戶端一、客戶端2,也會發送給與頻道「blog.redis」相匹配的模式「blog.r*」的訂閱者客戶端5。
可使用Redis的PUBSUB
命令來查看頻道或者模式的相關信息。
若是想要查看被訂閱的頻道信息,可使用命令PUBSUB CHANNELS [pattern]
,其中pattern參數是可選的:
這個命令的實現原理是經過遍歷服務器狀態保存的pubsub_channels
字典來實現的。
舉個具體的例子,若是服務器狀態保存的pubsub_channels
字典以下所示:
那麼執行命令PUBSUB CHANNELS
的返回結果以下所示:
執行命令PUBSUB CHANNELS r*
的返回結果以下所示:
若是想要查看頻道的訂閱者數量,可使用命令PUBSUB NUMSUB [channel1 channel2 ... channeln]
。
這個命令的實現原理是經過遍歷服務器狀態保存的pubsub_channels
字典來實現的,頻道對應的訂閱者鏈表的長度就是該頻道的訂閱者數量。
舉個具體的例子,若是服務器狀態保存的pubsub_channels
字典以下所示:
那麼執行命令PUBSUB NUMSUB blog.redis blog.rocketmq blog.java
的返回結果以下所示:
若是想要查看被訂閱模式的數量,可使用命令PUBSUB NUMPAT
。
這個命令的實現原理是返回服務器狀態保存的pubsub_patterns
鏈表的長度。
舉個具體的例子,若是服務器狀態保存的pubsub_patterns
鏈表以下所示:
那麼執行命令PUBSUB NUMPAT
的返回結果以下所示:
Redis的發佈與訂閱有點相似於消息隊列的發佈與訂閱,主要包含如下7個命令:
這7個命令的核心都是基於存儲在服務器狀態的pubsub_channels
字典和pubsub_patterns
鏈表實現的。
黃健宏 《Redis設計與實現》
注:若是以爲本篇博客有任何錯誤或者更好的建議,歡迎留言,我會及時跟進並更正博客內容!
文章持續更新,歡迎關注微信公衆號「申城異鄉人」第一時間閱讀!