1. 程式人生 > >MongoDB Driver:連線複製集的正確方式

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:
[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