MongoDB如何實現讀寫分離

MongoDB如何實現讀寫分離

MongoDB復制集（Replica Set）通過存儲多份數據副本來保證數據的高可靠，通過自動的主備切換機制來保證服務的高可用。但需要注意的時，連接副本集的姿勢如果不對，服務高可用將不復存在。

使用前須知
MongoDB復制集里Primary節點是不固定的。當遇到復制集輪轉升級、Primary宕機、網絡分區等場景時，復制集可能會選舉出一個新的Primary，而原來的Primary則會降級為Secondary，即發生主備切換。總而言之，MongoDB復制集里Primary節點是不固定的。

當連接復制集時，如果直接指定Primary的地址來連接，當時可能可以正確讀寫數據，但一旦復制集發生主備切換，您連接的Primary會降級為Secondary，您將無法繼續執行寫操作，這將嚴重影響到您的線上服務。所以生產環境千萬不要直連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：指定額外的連接選項。

實現讀寫分離：在options里添加readPreference=secondaryPreferred讀請求優先到Secondary節點，從而實現讀寫分離的功能。更多讀選項請參考Read preferences。

限制連接數：在options里添加maxPoolSize=xx即可將客戶端連接池限制在xx以內。

設置數據寫入到大多數節點后返回客戶端確認：在options里添加w= majority即可保證寫請求成功寫入大多數節點才向客戶端確認，更多寫選項參考Write Concern。

以連接AliCloudDB for MongoDB為例，當您購買阿里雲MongoDB復制集時，會得到復制集的名稱以及復制集成員的地址信息。如下圖所示：

連接信息

為了方便用戶使用，MongoDB管理控制台上也生成了連接復制集的Connection String及通過Mongo Shell連接到命令。如下圖所示：

連接信息

例如通過Java來連接AliCloudDB for MongoDB：

MongoClientURI connectionString = new MongoClientURI("mongodb://root:@dds-*****.mongodb.rds.aliyuncs.com:3717,.aliyuncs.com:3717/admin?replicaSet=mgset-677201"); // ****替換為root密碼
MongoClient client = new MongoClient(connectionString);
MongoDatabase database = client.getDatabase("mydb");
MongoCollection collection = database.getCollection("mycoll");
通過正確的Connection String來連接MongoDB復制集，客戶端會自動檢測復制集的主備關系，當主備關系發生變化時，自動將寫切換到新的主上，以保證服務的高可用。
參考地址： https://help.aliyun.com/document_detail/55918.html