MongoDB Driver:使用正確的姿勢連接復制集


 

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


免責聲明!

本站轉載的文章為個人學習借鑒使用,本站對版權不負任何法律責任。如果侵犯了您的隱私權益,請聯系本站郵箱yoyou2525@163.com刪除。



 
粵ICP備18138465號   © 2018-2025 CODEPRJ.COM