單機模擬分片爲複製集的集羣部署

概述

• 可以使用單個數據服務器做爲分片，也可以使用複製集做爲分片。
• 複製集爲具備自動故障恢復功能的主從集羣，而且其主從角色可自動變動。
• 每一個複製集包括3種角色：主節點（Master）、從節點(Secondary)、仲裁節點（arbiter）

 從節點默認不對外提供讀服務（由於主從延遲會致使從從節點上讀到髒數據）。

複製集不能容忍一半以上發生故障（爲了確保不會發生一個複製集中出現多個主節點的狀況）。

 

部署圖

 

 

部署過程

• Shard1（爲1個複製集）

 Shard1_ReplicaMember1 

mongod --port 30001 --logpath cluster/log/Shard1_ReplicaMember1.log --logappend --shardsvr --replSet Shard1 -dbpath cluster/data/Shard1_ReplicaMember1 --directoryperdb --rest

 

 Shard1_ReplicaMember2 

mongod --port 30002 --logpath cluster/log/Shard1_ReplicaMember2.log --logappend --shardsvr --replSet Shard1 -dbpath cluster/data/Shard1_ReplicaMember2 --directoryperdb --rest

 

 Shard1_ReplicaMember3 

mongod --port 30003 --logpath cluster/log/Shard1_ReplicaMember3.log --logappend --shardsvr --replSet Shard1 -dbpath cluster/data/Shard1_ReplicaMember3 --directoryperdb --rest

 

• Shard2（爲1個複製集）

 

 Shard2_ReplicaMember1 

mongod --port 40001 --logpath cluster/log/Shard2_ReplicaMember1.log --logappend --shardsvr --replSet Shard2 -dbpath cluster/data/Shard2_ReplicaMember1 --directoryperdb --rest

 

 Shard2_ReplicaMember2 

mongod --port 40002 --logpath cluster/log/Shard2_ReplicaMember2.log --logappend --shardsvr --replSet Shard2 -dbpath cluster/data/Shard2_ReplicaMember2 --directoryperdb --rest

 

 Shard2_ReplicaMember3 

mongod --port 40003 --logpath cluster/log/Shard2_ReplicaMember3.log --logappend --shardsvr --replSet Shard2 -dbpath cluster/data/Shard2_ReplicaMember3 --directoryperdb --rest

 

• ConfigServer

 

ConfigA 

mongod --port 20001 --logpath cluster/log/ConfigA.log --logappend --configsvr -dbpath cluster/config_data/ConfigA

 

ConfigB 

mongod --port 20002 --logpath cluster/log/ConfigB.log --logappend --configsvr -dbpath cluster/config_data/ConfigB

 

• RouteServer

先啓動  

mongos --port 10001 --logpath cluster/log/mongos.log --logappend --configdb 127.0.0.1:20001,127.0.0.1:20002

 

再配置 

mongo 127.0.0.1:27017/admindb.runCommand({ addshard : "Shard1/127.0.0.1:30001",name:"Shard1"})db.runCommand({ addshard : "Shard2/127.0.0.1:40001",name:"Shard2"})db.runCommand({ listshards : 1})db.runCommand({ enablesharding : "test"})db.runCommand({ shardcollection : "test.c1",key : {_id: 1} })