前言

發(fā)布訂閱在設(shè)計(jì)模式中也可以說(shuō)是觀察者模式，針對(duì)這個(gè)模式是處理對(duì)象間一對(duì)多的依賴關(guān)系的，當(dāng)一個(gè)對(duì)象發(fā)生變化，其它依賴他的對(duì)象都要得到通知并更新。

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

那針對(duì)這個(gè)缺點(diǎn)，一般的情況下，你沒(méi)有需求誰(shuí)訂閱一個(gè)跟自己無(wú)關(guān)的消息推送呢？這也正好說(shuō)明推送的消息需要整理而不能一窩蜂的什么消息都往一個(gè)通道里面拋，要分而治之，合理的設(shè)計(jì)發(fā)布通道的用途，也合理的訂閱通道。

那么如此一來(lái)，升級(jí)到系統(tǒng)項(xiàng)目級(jí)別，他別給我們又帶來(lái)啦，莫大的好處，便是：剝離系統(tǒng)耦合，減少單線功能的依賴關(guān)系，又正迎合啦高內(nèi)聚，松耦合的系統(tǒng)架構(gòu)設(shè)計(jì)。

Redis中的發(fā)布/訂閱功能

這一節(jié)參考官方文檔：https://redis.io/topics/pubsub

首先我準(zhǔn)備啦1個(gè)redis服務(wù)，3個(gè)客戶端，如下圖所示：

然后打開(kāi)官方文檔，首先可以看到以下6個(gè)命令，對(duì)，就只有這6個(gè)命令，只要你能掌握理解，發(fā)散思維靈活運(yùn)用。吐納，吐納，那么道于此，生一，生二、生三，生萬(wàn)物，根本不在話下??！C，C，C，WC, 小伙，以后拯救世界就看你啦。

下面我們使用這幾個(gè)命令，做一個(gè)演示，便于你理解。

1、2個(gè)客戶端訂閱order.create通道消息，如下：

2、最后一個(gè)客戶端發(fā)布往order.create通道發(fā)布消息。如下：

3、你會(huì)立馬發(fā)現(xiàn)訂閱此通道的另外2個(gè)客戶端有信息輸出出來(lái)，如下：

簡(jiǎn)單不，一個(gè)發(fā)布訂閱的基礎(chǔ)功能以及完事啦。

那如果你對(duì)其他一些發(fā)布訂閱管理系統(tǒng)比較了解的話，你立馬會(huì)想到一個(gè)功能，類似rabbitmq中的topic類型的匹配功能。那redis中有嗎，就這6個(gè)命令，答案是有的。使用的命令為psubscribe。

127.0.0.1:6379> psubscribe * ---訂閱所有通道
127.0.0.1:6379> psubscribe order.* ---訂閱通道名稱以order.開(kāi)頭的所有通道消息

那又如何取消訂閱過(guò)的通道呢？

127.0.0.1:6379> unsubscribe order.create ---取消訂閱
127.0.0.1:6379> punsubscribe order.* ---取消訂閱通道名稱以order.開(kāi)頭的所有通道消息

如何查看訂閱信息呢？

127.0.0.1:6379> pubsub channels ---查看當(dāng)前服務(wù)器訂閱的所有通道
127.0.0.1:6379> pubsub channels order.* ---查看訂閱通道名稱以order.開(kāi)頭的所有通道
127.0.0.1:6379> pubsub numsub order.create user ---查看訂閱order.create 和user 通道的訂閱者數(shù)量，支持查詢多個(gè)通道

呀，到此為止，6個(gè)命令已經(jīng)用完啦。就是這么任性，對(duì)，你潛心修煉10多分鐘已經(jīng)學(xué)會(huì)啦redis中最上層的發(fā)布訂閱技能。你可以出關(guān)，打敗天下無(wú)敵手啦。

StackExchange.Redis實(shí)現(xiàn)redis中的發(fā)布訂閱功能

那這一節(jié)呢，我也實(shí)在說(shuō)不出怎么講更合理點(diǎn)，我就上一個(gè)示例，你自己把代碼拷貝去，玩玩吧。上代碼。

static void Main(string[] args)
  {
   Console.WriteLine("請(qǐng)輸入發(fā)布訂閱類型?");
   var type = Console.ReadLine();
   if (type == "publish")
   {
    while (true)
    {
     Console.WriteLine("請(qǐng)輸入要發(fā)布向哪個(gè)通道？");
     var channel = Console.ReadLine();
     Console.WriteLine("請(qǐng)輸入要發(fā)布的消息內(nèi)容.");
     var message = Console.ReadLine();
     sub.Publish(channel, message);
    }
   }
   else
   {
    Console.WriteLine("請(qǐng)輸入您要訂閱哪個(gè)通道的信息？");
    var channelKey = Console.ReadLine();
    sub.Subscribe(channelKey, (channel, message) =>
    {
     Console.WriteLine("接受到發(fā)布的內(nèi)容為：" + message);
    });
    Console.WriteLine("您訂閱的通道為：<< "+ channelKey + " >> ! 一切就緒，等待發(fā)布消息！勿動(dòng)，一動(dòng)就沒(méi)啦??！");
    Console.ReadKey();
   }
  }

運(yùn)行起來(lái)幾個(gè)實(shí)例，來(lái)玩一玩。如下，5個(gè)，1個(gè)發(fā)布信息，4個(gè)訂閱信息，其中2個(gè)訂閱zhanglonghao通道，2個(gè)訂閱bokeyuan通道。

第一次我發(fā)布消息到zhanglonghao通道，發(fā)布的消息為：hello shuaige ??！如下：

可以看出只有訂閱zhanglonghao通道的才接受到啦消息。

那再往bokeyuan通道里面發(fā)送，hello bokeyuan ！

到此為止，自己玩去吧。

總結(jié)

以上就是這篇文章的全部?jī)?nèi)容了，希望本文的內(nèi)容對(duì)大家的學(xué)習(xí)或者工作能帶來(lái)一定的幫助，如果有疑問(wèn)大家可以留言交流，謝謝大家對(duì)腳本之家的支持。

最新評(píng)論