RedisRepository封裝—Redis發布訂閱以及StackExchange.Redis中的使用

本文版權歸博客園和作者本人吳雙共同所有，轉載請注明本Redis系列分享地址。http://www.cnblogs.com/tdws/tag/NoSql/

Redis Pub/Sub模式 基本介紹

Redis發布訂閱—Pub/Sub模式或者說是觀察者模式。我想大家即使沒有使用過，也已經耳熟能詳了。

先簡單舉例說明下應用場景，在場景中我們可以分析到其優勢在哪。

比如你的線上應用應用，你想設置一個日志報警系統，當應用出現異常的時候，立馬發送通知給你，可能是短信的形式，也可能是郵件的形式。當然如果只將報警通知給你一個人，實現起來很簡單，在報警系統中將你的手機號和短信寫死在程序中。但是如果你的項目龐大，每個模塊有各自的負責人，並且負責人也經常會變更，那么咱們就不能總修改代碼了吧？

或者說你的個人博客可以讓讀者訂閱，讀者這么多，咱們根本控制不過來呀。

現在發布訂閱模式，就可以解決你的問題。在某一點發生改變的時候，其他客戶端立即得到通知。也可以說訂閱服務器得到應用發布消息，由服務器立即通知給你手中的客戶端。這樣的好處就是一種松耦合的模式，你不再需要修改發布端和訂閱端的任何代碼，你只要提供好發布和訂閱的操作接口，今后調用就可以了。

首先看一下Redis在控制台中的發布訂閱操作。

我開啟兩個redis命令客戶端對相同的一個redis服務進行操作。

首先我們在第一個客戶端我們對message01進行訂閱，channel名稱是我們自定義的，訂閱哪個就是哪個。

其次，我們在第二個客戶端對message01這個channel進行發布消息。返回值表示有幾個客戶端訂閱。

發布消息后，訂閱的客戶端立即受收到消息。

StackExchange.Redis操作發布訂閱

畢竟我們不可能只將其用在Redis命令控制台哈，最后來看一下在.NET中的使用。我們依然借助StackExchange.

基礎配置，本系列第一篇分享已經包含。還記得靜態構造函數中，下面這段代碼嗎？

_redis.PreserveAsyncOrder = RedisClientConfigurations.PreserveAsyncOrder;//並行

配置中，定義了使用並行的方式來執行命令，大大提高了效率（在你無所謂消息傳遞的順序時，可以這樣使用）。

在接口中定義如下方法：

 #region Redis發布訂閱
        /// <summary>
        /// Redis發布訂閱  訂閱
        /// </summary>
        /// <param name="subChannel"></param>
        void RedisSub(string subChannel);
        /// <summary>
        /// Redis發布訂閱  發布
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="channel"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        long RedisPub<T>(string channel, T msg);
        /// <summary>
        /// Redis發布訂閱  取消訂閱
        /// </summary>
        /// <param name="channel"></param>
        void Unsubscribe(string channel);
        /// <summary>
        /// Redis發布訂閱  取消全部訂閱
        /// </summary>
        void UnsubscribeAll();

        #endregion

實現如下：

 #region Redis發布訂閱
        /// <summary>
        /// Redis發布訂閱  訂閱
        /// </summary>
        /// <param name="subChannel"></param>
        public void RedisSub(string subChannel)
        {
            sub.Subscribe(subChannel, (channel, message) =>
            {
                Console.WriteLine((string)message);
            });
        }
        /// <summary>
        /// Redis發布訂閱  發布
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="channel"></param>
        /// <param name="msg"></param>
        /// <returns></returns>
        public long RedisPub<T>(string channel, T msg)
        {

            return sub.Publish(channel, SerializeContent(msg));
        }
        /// <summary>
        /// Redis發布訂閱  取消訂閱
        /// </summary>
        /// <param name="channel"></param>
        public void Unsubscribe(string channel)
        {
            sub.Unsubscribe(channel);
        }
        /// <summary>
        /// Redis發布訂閱  取消全部訂閱
        /// </summary>
        public void UnsubscribeAll()
        {
            sub.UnsubscribeAll();
        }
        #endregion

客戶端測試，我將建立一個ConsoleApp和一個Winform程序，並在其中定義兩個按鈕。代碼如下：

在ConsoleApp中我們作為訂閱

     static void Main(string[] args)
        {
            IRedisClient client = new RedisClient();

            client.RedisSub("myFirstChannel");
            client.RedisSub("mySecondChannel");
         }          

在Winform程序中進行發布

 IRedisClient client = new RedisClient();
        private void button1_Click(object sender, EventArgs e)
        {
            client.RedisPub("myFirstChannel", "first");
        }

        private void button2_Click(object sender, EventArgs e)
        {
            client.RedisPub("mySecondChannel", "second");
        }

將兩個應用運行起來，操作以及結果如下：

下面操作兩個按鈕，得到結果。

 

訂閱成功。

 

如果我的點滴分享，對您能有一點幫助，歡迎點贊支持,也歡迎大牛們持續關注和給予指導建議。