MongoDB Driver:連線複製集的正確方式
MongoDB複製集(Replica
Set)通過儲存多份資料副本
來保證資料的高可靠,通過自動的主備切換機制
來保證服務的高可用。但需要注意的時,連線副本集的姿勢
如果不對,服務高可用將不復存在。
使用複製集時你需要知道的
MongoDB複製集裡Primary節點是不固定的,當遇到複製集輪轉升級、Primary宕機、網路分割槽等場景時,複製集可能會選舉出一個新的Primary,而原來的Primary則會降級為Secondary,即發生主備切換。
總而言之,MongoDB複製集裡Primary節點是不固定的,不固定的,不固定的,重要的事情說3遍。
當連線複製集時,如果直接指定Primary
所以生產環境千萬不要直連Primary,千萬不要直連Primary,千萬不要直連Primary。
說了這麼多,到底該如何連線複製集?
正確連線複製集的姿勢
要正確連線複製集,需要先了解下MongoDB的Connection String URI,所有官方的driver都支援以Connection
String的方式來連線MongoDB。
下面就是Connection String包含的主要內容
mongodb://[username: [email protected]]host1[:port1][,host2[:port2],...[,hostN[:portN]]][/[database][?options]]
- mongodb:// 字首,代表這是一個Connection String
- username:[email protected] 如果啟用了鑑權,需要指定使用者密碼
- 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