前言
發布訂閱在設計模式中也可以說是觀察者模式,針對這個模式是處理對象間一對多的依賴關系的,當一個對象發生變化,其它依賴他的對象都要得到通知並更新。
然而它也有自己的缺點,就是當主題發生一系列的變化時,觀察者都要做批量的更新,如果這樣的更新成本很高,那麼解決方法就是根據種類需求通知,而不能盲目的通知所有的觀察者。
那針對這個缺點,一般的情況下,你沒有需求誰訂閱一個跟自己無關的消息推送呢?這也正好說明推送的消息需要整理而不能一窩蜂的什麼消息都往一個通道裡面拋,要分而治之,合理的設計發布通道的用途,也合理的訂閱通道。
那麼如此一來,升級到系統項目級別,他別給我們又帶來啦,莫大的好處,便是:剝離系統耦合,減少單線功能的依賴關系,又正迎合啦高內聚,松耦合的系統架構設計。
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 !
到此為止,自己玩去吧。
總結
以上就是這篇文章的全部內容了,希望本文的內容對大家的學習或者工作能帶來一定的幫助,如果有疑問大家可以留言交流,謝謝大家對的支持。