麻豆小视频在线观看_中文黄色一级片_久久久成人精品_成片免费观看视频大全_午夜精品久久久久久久99热浪潮_成人一区二区三区四区

首頁 > 數據庫 > Redis > 正文

Redis發布訂閱和實現.NET客戶端詳解

2020-10-28 21:37:38
字體:
來源:轉載
供稿:網友

前言

發布訂閱在設計模式中也可以說是觀察者模式,針對這個模式是處理對象間一對多的依賴關系的,當一個對象發生變化,其它依賴他的對象都要得到通知并更新。

然而它也有自己的缺點,就是當主題發生一系列的變化時,觀察者都要做批量的更新,如果這樣的更新成本很高,那么解決方法就是根據種類需求通知,而不能盲目的通知所有的觀察者。

那針對這個缺點,一般的情況下,你沒有需求誰訂閱一個跟自己無關的消息推送呢?這也正好說明推送的消息需要整理而不能一窩蜂的什么消息都往一個通道里面拋,要分而治之,合理的設計發布通道的用途,也合理的訂閱通道。

那么如此一來,升級到系統項目級別,他別給我們又帶來啦,莫大的好處,便是:剝離系統耦合,減少單線功能的依賴關系,又正迎合啦高內聚,松耦合的系統架構設計。

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 !

 

到此為止,自己玩去吧。

總結

以上就是這篇文章的全部內容了,希望本文的內容對大家的學習或者工作能帶來一定的幫助,如果有疑問大家可以留言交流,謝謝大家對武林網的支持。

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: omofun 动漫在线观看 | 久久欧美亚洲另类专区91大神 | 国产xxxxx在线观看 | 久久久久一本一区二区青青蜜月 | 国产成人视屏 | 国产欧美亚洲精品a | 精品国产精品久久 | 综合网日日天干夜夜久久 | 国产精品一区在线观看 | a级高清免费毛片av在线 | 国产亚洲精品影达达兔 | 免费久久久久 | 欧美一级毛片特黄黄 | 国产精品久久99精品毛片三a | 国产精品18久久久久久久 | 亚洲精品动漫在线观看 | av色偷偷 | 亚洲午夜精品视频 | 国产一区二区三区四区精 | 色诱亚洲精品久久久久久 | 成人精品免费在线观看 | 久久精品亚洲国产奇米99 | 欧美成在线视频 | 7m视频成人精品分类 | 国产成人高清成人av片在线看 | 欧美成人毛片 | 蜜桃av鲁一鲁一鲁一鲁 | 久草欧美 | 免费在线观看毛片视频 | 国产午夜精品久久久久 | 久久丝袜脚交足黄网站免费 | 精品国产成人 | 黄色片在线观看网站 | 日本免费中文字幕 | 免费激情视频网站 | 亚洲五码在线观看视频 | 精品一区二区三区电影 | 免费a视频在线观看 | 中文字幕在线网 | 毛片小网站 | av资源在线天堂 |