Redis的發布訂閱及.NET客戶端實現
序言
發布訂閱在設計模式中也可以說是觀察者模式,針對這個模式是處理對象間一對多的依賴關系的,當一個對象發生變化,其它依賴他的對象都要得到通知並更新。
然而它也有自己的缺點,就是當主題發生一系列的變化時,觀察者都要做批量的更新,如果這樣的更新成本很高,那麽解決方法就是根據種類需求通知,而不能盲目的通知所有的觀察者。
那針對這個缺點,一般的情況下,你沒有需求誰訂閱一個跟自己無關的消息推送呢?這也正好說明推送的消息需要整理而不能一窩蜂的什麽消息都往一個通道裏面拋,要分而治之,合理的設計發布通道的用途,也合理的訂閱通道。
那麽如此一來,升級到系統項目級別,他別給我們又帶來啦,莫大的好處,便是:剝離系統耦合,減少單線功能的依賴關系,又正迎合啦高內聚,松耦合的系統架構設計。
扯拉這麽多,只當廢話啦,因為我這一篇的序言裏面也不知道寫什麽段子啦,就這樣吧。
Redis中的發布/訂閱功能
這一節參考官方文檔:https://redis.io/topics/pubsub
首先我準備啦1個redis服務,3個客戶端,如下圖所示:
然後打開官方文檔,首先可以看到以下6個命令,對,就只有這6個命令,只要你能掌握理解,發散思維靈活運用。吐納,吐納,那麽道於此,生一,生二、生三,生萬物,根本不在話下!!C,C,C,WC, 小夥,以後拯救世界就看你啦。
下面我們使用這幾個命令,做一個演示,便於你理解。
1、2個客戶端訂閱order.create通道消息,如下:
2、最後一個客戶端發布往order.create通道發布消息。如下:
3、你會立馬發現訂閱此通道的另外2個客戶端有信息輸出出來,如下:
簡單不,一個發布訂閱的基礎功能以及完事啦。
那如果你對其他一些發布訂閱管理系統比較了解的話,你立馬會想到一個功能,類似rabbitmq中的topic類型的匹配功能。那redis中有嗎,就這6個命令,答案是有的。使用的命令為psubscribe。
127.0.0.1:6379> psubscribe * ---訂閱所有通道 127.0.0.1:6379> psubscribe order.* ---訂閱通道名稱以order.開頭的所有通道消息
那又如何取消訂閱過的通道呢?
127.0.0.1:6379> unsubscribe order.create ---取消訂閱 127.0.0.1:6379> punsubscribe order.* ---取消訂閱通道名稱以order.開頭的所有通道消息
如何查看訂閱信息呢?
127.0.0.1:6379> pubsub channels ---查看當前服務器訂閱的所有通道 127.0.0.1:6379> pubsub channels order.* ---查看訂閱通道名稱以order.開頭的所有通道 127.0.0.1:6379> pubsub numsub order.create user ---查看訂閱order.create 和user 通道的訂閱者數量,支持查詢多個通道
呀,到此為止,6個命令已經用完啦。就是這麽任性,對,你潛心修煉10多分鐘已經學會啦redis中最上層的發布訂閱技能。你可以出關,打敗天下無敵手啦。
StackExchange.Redis實現redis中的發布訂閱功能
那這一節呢,我也實在說不出怎麽講更合理點,我就上一個示例,你自己把代碼拷貝去,玩玩吧。上代碼。
static void Main(string[] args) { Console.WriteLine("請輸入發布訂閱類型?"); var type = Console.ReadLine(); if (type == "publish") { while (true) { Console.WriteLine("請輸入要發布向哪個通道?"); var channel = Console.ReadLine(); Console.WriteLine("請輸入要發布的消息內容."); var message = Console.ReadLine(); sub.Publish(channel, message); } } else { Console.WriteLine("請輸入您要訂閱哪個通道的信息?"); var channelKey = Console.ReadLine(); sub.Subscribe(channelKey, (channel, message) => { Console.WriteLine("接受到發布的內容為:" + message); }); Console.WriteLine("您訂閱的通道為:<< "+ channelKey + " >> ! 一切就緒,等待發布消息!勿動,一動就沒啦!!"); Console.ReadKey(); } }
運行起來幾個實例,來玩一玩。如下,5個,1個發布信息,4個訂閱信息,其中2個訂閱zhanglonghao通道,2個訂閱bokeyuan通道。
第一次我發布消息到zhanglonghao通道,發布的消息為:hello shuaige !!如下:
可以看出只有訂閱zhanglonghao通道的才接受到啦消息。
那再往bokeyuan通道裏面發送,hello bokeyuan !
到此為止,自己玩去吧。
總結
接下來是大家最喜歡的總結內容啦,內容有二,如下:
1、希望能關註我其他的文章。
2、博客裏面有沒有很清楚的說明白,或者你有更好的方式,那麽歡迎加入左上方的2個交流群,我們一起學習探討。
Redis的發布訂閱及.NET客戶端實現