MongoDB復制集(Replica Set)通過存儲多份數據副本
來保證數據的高可靠,通過自動的主備切換機制
來保證服務的高可用。但需要注意的時,連接副本集的姿勢
如果不對,服務高可用將不復存在。
使用復制集時你需要知道的
MongoDB復制集里Primary節點是不固定的,當遇到復制集輪轉升級、Primary宕機、網絡分區等場景時,復制集可能會選舉出一個新的Primary,而原來的Primary則會降級為Secondary,即發生主備切換。
總而言之,MongoDB復制集里Primary節點是不固定的,不固定的,不固定的,重要的事情說3遍。
當連接復制集時,如果直接指定Primary
的地址來連接,當時可能可以正確讀寫數據的,但一旦復制集發生主備切換,你連接的Primary會降級為Secondary,你將無法繼續執行寫操作,這將嚴重影響到你的線上服務。
所以生產環境千萬不要直連Primary,千萬不要直連Primary,千萬不要直連Primary。
說了這么多,到底該如何連接復制集?
正確連接復制集的姿勢
要正確連接復制集,需要先了解下MongoDB的Connection String URI,所有官方的driver都支持以Connection String的方式來連接MongoDB。
下面就是Connection String包含的主要內容
mongodb://[username:password@]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]
- mongodb:// 前綴,代表這是一個Connection String
- username:password@ 如果啟用了鑒權,需要指定用戶密碼
- hostX:portX 復制集成員的ip:port信息,多個成員以逗號分割
- /database 鑒權時,用戶帳號所屬的數據庫
- ?options 指定額外的連接選項
以連接AliCloudDB for MongoDB為例,當你購買阿里雲MongoDB復制集時,就會得到復制集的名稱、以及復制集成員的地址信息。
為了方便用戶使用,控制台上也生成了連接復制集的Connection String及通過Mongo Shell連接到命令。
例如通過java來連接,更多的DEMO
MongoClientURI connectionString = new MongoClientURI("mongodb://root:****@dds-bp114e3f1fc441342.mongodb.rds.aliyuncs.com:3717,dds-bp114e3f1fc441341.mongodb.rds.aliyuncs.com:3717/admin?replicaSet=mgset-677201"); // ****替換為root密碼 MongoClient client = new MongoClient(connectionString); MongoDatabase database = client.getDatabase("mydb"); MongoCollection<Document> collection = database.getCollection("mycoll");
通過正確的Connection String來連接MongoDB復制集時,客戶端會自動檢測復制集的主備關系,當主備關系發生變化時,自動將寫切換到新的主上,以保證服務的高可用。
常用連接參數
如何實現讀寫分離?
在options里添加readPreference=secondaryPreferred
即可實現,讀請求優先到Secondary節點,從而實現讀寫分離的功能,更多讀選項
參考Read preferences
如何限制連接數?
在options里添加maxPoolSize=xx
即可將客戶端連接池限制在xx以內。
如何保證數據寫入到大多數節點后才返回?
在options里添加w= majority
即可保證寫請求成功寫入大多數節點才向客戶端確認,更多寫選項
參考Write Concern
轉自:https://yq.aliyun.com/articles/8461?spm=0.0.0.0.ysLZ0S