Redis的發佈訂閱及.NET客戶端實現

時間 2019-11-06

標籤 redis 發佈訂閱客戶端實現欄目 Redis 简体版

原文原文鏈接

序言

發佈訂閱在設計模式中也能夠說是觀察者模式，針對這個模式是處理對象間一對多的依賴關係的，當一個對象發生變化，其它依賴他的對象都要獲得通知並更新。redis

然而它也有本身的缺點，就是當主題發生一系列的變化時，觀察者都要作批量的更新，若是這樣的更新成本很高，那麼解決方法就是根據種類需求通知，而不能盲目的通知全部的觀察者。設計模式

那針對這個缺點，通常的狀況下，你沒有需求誰訂閱一個跟本身無關的消息推送呢？這也正好說明推送的消息須要整理而不能一窩蜂的什麼消息都往一個通道里面拋，要分而治之，合理的設計發佈通道的用途，也合理的訂閱通道。服務器

那麼如此一來，升級到系統項目級別，他別給咱們又帶來啦，莫大的好處，即是：剝離系統耦合，減小單線功能的依賴關係，又正迎合啦高內聚，鬆耦合的系統架構設計。架構

扯拉這麼多，只當廢話啦，由於我這一篇的序言裏面也不知道寫什麼段子啦，就這樣吧。學習

Redis中的發佈/訂閱功能

這一節參考官方文檔：https://redis.io/topics/pubsubspa

首先我準備啦1個redis服務，3個客戶端，以下圖所示：架構設計

而後打開官方文檔，首先能夠看到如下6個命令，對，就只有這6個命令，只要你能掌握理解，發散思惟靈活運用。吐納，吐納，那麼道於此，生一，生2、生三，生萬物，根本不在話下！！C，C，C，WC, 小夥，之後拯救世界就看你啦。設計

下面咱們使用這幾個命令，作一個演示，便於你理解。code

一、2個客戶端訂閱order.create通道消息，以下：對象

二、最後一個客戶端發佈往order.create通道發佈消息。以下：

三、你會立馬發現訂閱此通道的另外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();
            }
        }