雙十一來了，別讓你的mongodb宕機了

 

        好久沒過來吹牛了，前段時間一直趕項目，沒有時間來更新博客，項目也終於趕完了，接下來就要面臨雙十一這場驚心動魄的處女秀考驗，

我們項目中會有一個wcf集群，而集群地址則放在mongodb中，所以mongodb的核心地位可想而知，如果mongodb掛掉，整個項目也就陷入

癱瘓，想讓mongodb不宕機，最簡單的方法就是要做雙機熱備，跟傳統的關系型數據庫的雙機熱備模式一樣，一個主服務器，一個備份服務器，

一個仲裁服務器。如果熱備集群中的主服務器宕掉，會有仲裁服務器參與投票來選出一台作為主服務器，我想這個大家都比較清楚，下面我們來

實戰一下，最后會奉獻源代碼。

 

一：搭建mongodb熱備集群

1. 准備工作

　　為了做到最簡化搭建，我就做一個主，一個備，一個仲裁就好了，然后最簡化配置信息都放在mongodb.conf文件中，如下圖：

 

從上圖中可以看到，三個mongodb，我建立了對應的三個文件夾來存放對應的三個db，其中“主服務器”的端口為27000,“備服務器“的端口為

27001，”仲裁服務器“端口為27002。 具體mongodb.conf內容如下：

 

2. 開啟 “主服務器” 【27000】

  

 

3.  開啟 “備服務器” 【27001】

 

4.  開啟 “仲裁服務器” 【27002】

 

現在三台服務器都開啟起來了，細心的你會發現，三個控制台都有這么一段英文單詞” replSet info you may need to run replSetInitiate“。。。

既然都這么說了，我現在就去run這個func。

 

db.runCommand({
    "replSetInitiate":{
        "_id":"datamip",
        "members":[
            {
                "_id":1,
                "host":"127.0.0.1:27000"
            },
            {
                "_id":2,
                "host":"127.0.0.1:27001"
            }
        ]
    }
}) 

 

配置完了之后，然后我們把“仲裁服務器【27002】”加入到“datamip”這個雙機熱備分集群中。

 

rs.addArb( { host: "127.0.0.1:27002"} )

 

這個命令可以參考下官網的介紹：https://docs.mongodb.com/manual/reference/command/replSetInitiate/   好了，現在大致配置好了，接下

來我們用rs.Status()來查看下當前“主，備，仲裁”的分布情況。

 

從圖中你應該看到了【27000】成為了主服務器，【27001】成為了備服務器，【27002】成為了仲裁服務器，到目前為止，搭建完成，是不是有

一個很爽的感覺呢？？？

 

三：使用驅動

　　既然mongodb的雙機熱備已經做好了，我們驅動也必須支持，這樣我們才能夠嗨，對伐？？？其實在配置中使用也很簡單，里面有一個

MongoClientSettings，你需要配置一下”ReplicaSetName“和”Servers“列表即可，核心代碼如下：

        static MongoDBHelper()
        {
            var ips = connectionString.Split(';');

            var servicesList = new List<MongoServerAddress>();

            foreach (var ip in ips)
            {
                var host = ip.Split(':')[0];
                var port = Convert.ToInt32(ip.Split(':')[1]);

                servicesList.Add(new MongoServerAddress(host, port));
            }

            setting = new MongoClientSettings();
            setting.ReplicaSetName = "datamip";

            //集群中的服務器列表
            setting.Servers = servicesList;
        }

 

其中ips的信息是配置在app.config中。

 <appSettings>
    <add key="mongodbServerList" value="127.0.0.1:27000;127.0.0.1:27001;127.0.0.1:27002"/>
  </appSettings>

 

然后我簡單的封裝了下mongodb。

namespace DataMipCRM.Common
{
    public class MongoDBHelper<T>
    {
        private static readonly string connectionString = ConfigurationManager.AppSettings["mongodbServerList"];

        static MongoClientSettings setting = null;
        MongoServer server = null;

        public string tableName = "person";

        public string databaseName = "test";

        static MongoDBHelper()
        {
            var ips = connectionString.Split(';');

            var servicesList = new List<MongoServerAddress>();

            foreach (var ip in ips)
            {
                var host = ip.Split(':')[0];
                var port = Convert.ToInt32(ip.Split(':')[1]);

                servicesList.Add(new MongoServerAddress(host, port));
            }

            setting = new MongoClientSettings();
            setting.ReplicaSetName = "datamip";

            //集群中的服務器列表
            setting.Servers = servicesList;
        }

        public MongoDBHelper(string databaseName, string tableName)
        {
            this.databaseName = databaseName;
            this.tableName = tableName;

            server = new MongoClient(setting).GetServer();
        }

        public bool Remove(Expression<Func<T, bool>> func)
        {
            try
            {
                var database = server.GetDatabase(databaseName);

                var collection = database.GetCollection<T>(tableName);

                var query = Query<T>.Where(func);

                var result = collection.Remove(query);

                return result.Response["ok"].AsInt32 > 0 ? true : false;
            }
            catch (Exception ex)
            {
                return false;
            }
        }

        public bool RemoveAll()
        {
            try
            {
                var database = server.GetDatabase(databaseName);   //mongodb中的數據庫

                var collection = database.GetCollection<T>(tableName);

                var result = collection.RemoveAll();

                return result.Response["ok"].AsInt32 > 0 ? true : false;
            }
            catch (Exception ex)
            {
                return false;
            }
        }

        #region 單條插入
        /// <summary>
        /// 單條插入
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="t"></param>
        public bool Insert(T t)
        {
            try
            {
                var database = server.GetDatabase(databaseName);   //mongodb中的數據庫

                var collection = database.GetCollection<T>(tableName);

                var result = collection.Insert(t);
                return result.DocumentsAffected > 0;
            }
            catch (Exception ex)
            {
                return false;
            }
        }
        #endregion

        #region 單條覆蓋，如果不存在插入，如果存在覆蓋
        /// <summary>
        /// 單條覆蓋，如果不存在插入，如果存在覆蓋
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="t"></param>
        public bool Save(T t)
        {
            try
            {
                var database = server.GetDatabase(databaseName);   //mongodb中的數據庫

                var collection = database.GetCollection<T>(tableName);
                var result = collection.Save(t);
                return result.DocumentsAffected > 0;
            }
            catch (Exception ex)
            {
                return false;
            }
        }
        #endregion

        #region 批量插入
        /// <summary>
        /// 批量插入
        /// </summary>
        /// <typeparam name="T"></typeparam>
        /// <param name="t"></param>
        public bool Insert(IEnumerable<T> t)
        {
            try
            {
                var database = server.GetDatabase(databaseName);   //mongodb中的數據庫

                var collection = database.GetCollection<T>(tableName);

                collection.InsertBatch(t);

                return true;
            }
            catch (Exception ex)
            {
                return false;
            }
        }
        #endregion

        #region 批量查詢

        public List<T> Search(Expression<Func<T, bool>> func, bool forcemaster = false)
        {
            var list = new List<T>();

            try
            {
                //是否強制使用 “主服務器”
                if (forcemaster)
                {
                    var database = server.GetDatabase(databaseName);   //mongodb中的數據庫

                    var collection = database.GetCollection<T>(tableName);
                    list = collection.Find(Query<T>.Where(func)).ToList();
                }
                else
                {
                    var database = server.GetDatabase(databaseName);    //mongodb中的數據庫

                    var collection = database.GetCollection<T>(tableName);

                    list = collection.Find(Query<T>.Where(func)).ToList();
                }
            }
            catch (Exception ex)
            {
                throw;
            }

            return list;
        }

        #endregion

        #region 單條查詢
        /// <summary>
        /// 單條查詢
        /// </summary>
        public T SearchOne(Expression<Func<T, bool>> func, bool forcemaster = false)
        {
            T t = default(T);

            try
            {
                if (forcemaster)
                {
                    var database = server.GetDatabase(databaseName);   //mongodb中的數據庫

                    var collection = database.GetCollection<T>(tableName);

                    t = collection.FindOne(Query<T>.Where(func));
                }
                else
                {
                    var database = server.GetDatabase(databaseName);   //mongodb中的數據庫

                    var collection = database.GetCollection<T>(tableName);

                    t = collection.FindOne(Query<T>.Where(func));
                }

                return t;
            }
            catch (Exception ex)
            {
                return t;
            }
        }
        #endregion

        /// <summary>
        /// 查詢所有數據
        /// </summary>
        /// <returns></returns>
        public List<T> SearchAll()
        {
            var list = new List<T>();

            try
            {
                var database = server.GetDatabase(databaseName);    //mongodb中的數據庫

                var collection = database.GetCollection<T>(tableName);

                list = collection.FindAll().ToList();

                return list;
            }
            catch (Exception ex)
            {
                return list;
            }
        }
    }
}

 

四：測試一下

1. 首先向mongodb中插入一條記錄，dbname=mydb, tablename=test，插入后我們用mongodUVE看一下數據：

namespace ConsoleApplication2
{
    class Program
    {
        static void Main(string[] args)
        {
            MongoDBHelper<MongodbCustomerModel> helper = new MongoDBHelper<MongodbCustomerModel>("mydb", "test");

            helper.Save(new MongodbCustomerModel()
            {
                SendLastTime = DateTime.Now,
                ShopID = 1
            });
        }
    }

    public class MongodbCustomerModel
    {
        public ObjectId _id { get; set; }

        public int ShopID { get; set; }

        public DateTime SendLastTime { get; set; }
    }
}

 

2. 然后我把【27000】 這個primary關閉掉，通過rs.Status看看“主備情況”。

 

3. 接下來，我們繼續用mongodbHelper執行一下search，看是否能撈取到數據，如果可以，說明一台機器掛了沒關系，這個“主備集群”還是活的。

 

是不是很牛逼的感覺，雖然掛了一台，我的客戶端程序還是可以繼續從mognodb中獲取到剛才插入的數據，好了，大概就說這么多，洗洗睡了，

 

最后祝頂着雙十一壓力的兄弟們，一路平安。

 

--文件下載--