回到目錄

Redis這個Nosql的儲存系統一般會被部署到linux系統中，我們可以把它當成是一個數據伺服器，對於併發理大時，我們會使用多臺伺服器充當Redis伺服器，這時，各個Redis之間也是分散式的，而Redis與WWW之間也是一種分散式，對於各個redis之間的分散式不需要我們去幹預，它是由我們的redis客戶端去負責連結的，你當時鏈到哪臺伺服器，完全由客戶端去控制，redis這種模式我們通常稱為“主從模式”，即一個主伺服器，主要負責寫入資料，多臺從伺服器，負責資料的讀取，而它們之前的資料同步，也是redis自已為我們實現的，我們不需要去幹預它，這種模式通常會稱為“多級伺服器叢集架構”，它大大改善了程式的效能！

下面我們分別開啟主redis和從redis，如圖

對於配置從伺服器，我們主要設定port,bind和slaveof這三個引數就可以了，port是埠，bind是從伺服器的ip地址，slaveof是主伺服器的地址和埠，程式碼如下

port 6380
bind 127.0.0.1
slaveof  127.0.0.1 6379 

例項：在主伺服器寫入一個字串，在從伺服器讀取字串

首先對redisConfig進行相關配置，我加了一些說明

    /// <summary>
    /// redis主要資訊的配置引數
    /// </summary>
    public
 
 sealed class RedisConfigInfo : ConfigurationSection
    {
        public static RedisConfigInfo GetConfig()
        {
            RedisConfigInfo section = (RedisConfigInfo)ConfigurationManager.GetSection("RedisConfig");
            return section;
        }

        public static RedisConfigInfo GetConfig(string
 
 sectionName)
        {
            RedisConfigInfo section = (RedisConfigInfo)ConfigurationManager.GetSection("RedisConfig");
            if (section == null)
                throw new ConfigurationErrorsException("Section " + sectionName + " is not found.");
            return section;
        }
        /// <summary>
        /// 負責寫入的Redis連結地址，一般為一個伺服器，我們稱為主伺服器
        /// </summary>
        [ConfigurationProperty("WriteServerList", IsRequired = false)]
        public string WriteServerList
        {
            get
            {
                return (string)base["WriteServerList"]; 
            }
            set
            {
                base["WriteServerList"] = value;
            }
        }

        
        /// <summary>
        /// 負責讀的Redis連結地址，它一般由多個伺服器元件，一般稱為從伺服器(slave)，各個伺服器之間用逗號分開
        /// </summary>
        [ConfigurationProperty("ReadServerList", IsRequired = false)]
        public string ReadServerList
        {
            get
            {
                return (string)base["ReadServerList"]; 
            }
            set
            {
                base["ReadServerList"] = value;
            }
        }

        
        /// <summary>
        /// 最大寫連結數
        /// </summary>
        [ConfigurationProperty("MaxWritePoolSize", IsRequired = false, DefaultValue = 5)]
        public int MaxWritePoolSize
        {
            get
            {
                int _maxWritePoolSize = (int)base["MaxWritePoolSize"];
                return _maxWritePoolSize > 0 ? _maxWritePoolSize : 5;
            }
            set
            {
                base["MaxWritePoolSize"] = value;
            }
        }

       
        /// <summary>
        /// 最大讀連結數
        /// </summary>
        [ConfigurationProperty("MaxReadPoolSize", IsRequired = false, DefaultValue = 5)]
        public int MaxReadPoolSize
        {
            get
            {
                int _maxReadPoolSize = (int)base["MaxReadPoolSize"];
                return _maxReadPoolSize > 0 ? _maxReadPoolSize : 5;
            }
            set
            {
                base["MaxReadPoolSize"] = value;
            }
        }

         
        /// <summary>
        /// 自動重啟
        /// </summary>
        [ConfigurationProperty("AutoStart", IsRequired = false, DefaultValue = true)]
        public bool AutoStart
        {
            get
            {
                return (bool)base["AutoStart"];
            }
            set
            {
                base["AutoStart"] = value;
            }
        }


        
        /// <summary>
        /// 本地快取到期時間(超時時間)，單位:秒
        /// </summary>
        [ConfigurationProperty("LocalCacheTime", IsRequired = false, DefaultValue = 36000)]
        public int LocalCacheTime
        {
            get
            {
                return (int)base["LocalCacheTime"];
            }
            set
            {
                base["LocalCacheTime"] = value;
            }
        }

       
        /// <summary>
        /// 是否記錄日誌,該設定僅用於排查redis執行時出現的問題,如redis工作正常,請關閉該項
        /// </summary>
        [ConfigurationProperty("RecordeLog", IsRequired = false, DefaultValue = false)]
        public bool RecordeLog
        {
            get
            {
                return (bool)base["RecordeLog"];
            }
            set
            {
                base["RecordeLog"] = value;
            }
        }        

    }

而配置檔案中，我們可以把redis讀伺服器和寫伺服器進行配置，多個伺服器使用逗號分開（redis本身就是支援讀寫分離的）

  <RedisConfig WriteServerList="192.168.2.71:6379" ReadServerList="192.168.2.71:6379,192.168.2.71:6380" MaxWritePoolSize="60" MaxReadPoolSize="60" AutoStart="true" LocalCacheTime="180" RecordeLog="false">
  </RedisConfig>

下面我們向主伺服器加個物件

using (var test = redisClient.GetTypedClient<string>())
                        {
                            test.Lists["Test"].Add("資訊被新增");

                        }
              　

當沒有呼叫save方法時，物件只儲存在記憶體中，資料不會被同步到從伺服器，而呼叫了save方法後，資料才會被同步到各個從伺服器中。

下面我們添加了這個save方法之後，在從伺服器上就會有資訊同步了

　　　　　　using (var redisClient = RedisManager.GetClient())
            {
                using (var test = redisClient.GetTypedClient<string>())
                {

                    test.Lists["bobo"].Add("info");
                    test.Save();
                }
            }

如圖所示

　

對於裝有防火牆的伺服器來說，當然要把對應的埠開放一下，否則客戶端也是不能連結上的，呵呵

設定好之事，我們可以在命令列上測試一下從伺服器的資料，如圖

相關推薦