mongodb中怎么搭建shard_replica集群

本篇文章為大家展示了mongodb中怎么搭建shard_replica集群，內容簡明扼要并且容易理解，絕對能使你眼前一亮，通過這篇文章的詳細介紹希望你能有所收獲。

參考官方文檔，大致步驟

第一步：創建Config Server實例,配置Config Server實例成Replica Set

第二步：創建Shard Server實例，配置Shard Server實例成Replica Set

第三步：創建Route Server實例，把Config Server實例和Shard Server實例配置進來

第四步：創建數據庫并執行db.printShardingStatus()命令驗證

涉及replSet、shardsvr、configsvr幾個參數

replSet：配置replica set，replica set中的所有主機必須具有相同的replica set名稱。

shardsvr：將此mongod實例配置為分片集群中的分片。默認端口是27018。

configsvr：聲明此mongod實例作為分片集群的配置服務器。默認端口是27019，默認的dbpath目錄是/data/configdb，配置服務器存儲集群的元數據和配置設置。從MongoDB 3.4開始，配置服務器必須部署為一個replicate set副本集，為了防止這個配置服務是單點服務。如果你的集群只有一個配置服務器，一旦這個配置服務器出現故障則集群將不可用

涉及Config Server、Shard Server、Route Server幾個實例

1. Config Server: mongod實例，存儲了整個Cluster Metadata，其中包括Chunk信息。

2. Shard Server: mongod實例，用于存儲實際的數據塊，實際生產環境中一個Shard Server角色可由幾臺機器組個一個Replica Set承擔，防止主機單點故障。

3. Route Server: mongos實例，前端路由，客戶端由此接入，且讓整個集群看上去像單一數據庫，前端應用可以透明使用。

部署規劃

2臺物理設備服務器，ip分別為172.22.138.157、172.22.138.158

兩臺服務器上分別創建端口是29001的Config Server實例，這兩臺服務器上的Config Server實例組成Replica Set模式

兩臺服務器上分別創建端口分別是28001、28002、28003的shard server實例，兩臺服務器上相同端口的shard server實例組成Replica Set模式

兩臺服務器上分別創建端口是27001的Route Server實例

部署架構

外部程序-->Route Server實例-->Config Server實例-->shard server實例

Route Server實例不是單點，兩臺服務器上都有，配置都是一樣，都是指向一樣的Config Server實例

Config Server實例不是單點，是Replica Set模式

shard server實例不是單點，是Replica Set模式

第一步:

創建Config Server實例,配置Config Server實例成Replica Set

1.1、在兩臺服務器上分別編輯如下文件(兩個重點參數configsvr、replSet)

cat /mongodb/configsvr29001.conf

port=29001

dbpath=/mongodb/mongoconfig29001

logpath=/mongodb/log/mongoconfig29001.log

configsvr=true

replSet=config29001

fork=true

logappend=true

directoryperdb=true

bind_ip=0.0.0.0

pidfilepath=/mongodb/mongoconfig29001.pid

1.2、兩臺服務器上分別啟動Config Server實例

mongod -f /mongodb/configsvr29001.conf

1.3、配置兩臺服務器的Config Server實例成Replica Set

     登錄任意一臺服務器執行如下操作即可

mongo --host 172.22.138.157 --port 29001

rs.initiate(

  {

    _id: "config29001",

    configsvr: true,

    members: [

      { _id : 0, host : "172.22.138.157:29001" },

      { _id : 1, host : "172.22.138.158:29001" }

    ]

  }

)

第二步

創建Shard Server實例，配置Shard Server實例成Replica Set

2.1、在兩臺服務器上分別編輯如下三個文件(兩個重點參數shardsvr、replSet)

cat /mongodb/shardsvr28001.conf

port=28001

dbpath=/mongodb/mongoshard28001

logpath=/mongodb/log/mongoshard28001.log

shardsvr=true

replSet=shard28001

fork=true

logappend=true

directoryperdb=true

verbose=true

bind_ip=0.0.0.0

pidfilepath=/mongodb/mongoshard28001.pid

cat /mongodb/shardsvr28002.conf

port=28002

dbpath=/mongodb/mongoshard28002

logpath=/mongodb/log/mongoshard28002.log

shardsvr=true

replSet=shard28002

fork=true

logappend=true

directoryperdb=true

verbose=true

bind_ip=0.0.0.0

pidfilepath=/mongodb/mongoshard28002.pid

cat /mongodb/shardsvr28003.conf

port=28003

dbpath=/mongodb/mongoshard28003

logpath=/mongodb/log/mongoshard28003.log

shardsvr=true

replSet=shard28003

fork=true

logappend=true

directoryperdb=true

verbose=true

bind_ip=0.0.0.0

pidfilepath=/mongodb/mongoshard28003.pid

2.2、兩臺服務器上分別啟動Shard Server實例

mongod -f /mongodb/shardsvr28001.conf

mongod -f /mongodb/shardsvr28002.conf

mongod -f /mongodb/shardsvr28003.conf

2.3、配置兩臺服務器的3個Shard Server實例成Replica Set

     登錄任意一臺服務器執行如下操作即可

mongo --host 172.22.138.157 --port 28001

rs.initiate(

  {

    _id: "shard28001",

    members: [

      { _id : 0, host : "172.22.138.157:28001" },

      { _id : 1, host : "172.22.138.158:28001" }

    ]

  }

)

mongo --host 172.22.138.157 --port 28002

rs.initiate(

  {

    _id: "shard28002",

    members: [

      { _id : 0, host : "172.22.138.157:28002" },

      { _id : 1, host : "172.22.138.158:28002" }

    ]

  }

)

mongo --host 172.22.138.157 --port 28003

rs.initiate(

  {

    _id: "shard28003",

    members: [

      { _id : 0, host : "172.22.138.157:28003" },

      { _id : 1, host : "172.22.138.158:28003" }

    ]

  }

)

第三步

創建Route Server實例

3.1、在兩臺服務器上分別編輯如下文件(重點參數configdb,把上面第一步的Config Server實例配置進來)

cat /mongodb/Routesvr27001.conf

port=27001

logpath=/mongodb/log/mongoRoute27001.log

configdb=config29001/172.22.138.157:29001,172.22.138.158:29001

fork=true

bind_ip=0.0.0.0

pidfilepath=/mongodb/mongoRoute27001.pid

3.2、兩臺服務器上分別啟動Config Server實例

mongos -f /mongodb/Routesvr27001.conf

3.3、添加shard分片到集群，把上面第二步的Shard Server實例配置進來

     登錄任意一臺服務器執行如下操作即可

mongo --host 172.22.138.157 --port 27001

sh.addShard( "shard28001/172.22.138.157:28001,172.22.138.158:28001")

sh.addShard( "shard28002/172.22.138.157:28002,172.22.138.158:28002")

sh.addShard( "shard28003/172.22.138.157:28003,172.22.138.158:28003")

第四步

驗證

登錄任意一臺mongos實例，創建四個數據庫

mongo --host 172.22.138.157 --port 27001

mongos> use TDB1

mongos> db.createCollection("test01")

mongos> db.test01.insert({hid:1,hname:"w001"})

mongos> use TDB2

mongos> db.createCollection("test02")

mongos> db.test02.insert({hid:11,hname:"x001"})

mongos> use TDB3

mongos> db.createCollection("test03")

mongos> db.test03.insert({hid:111,hname:"y001"})

mongos> use TDB4

mongos> db.createCollection("test04")

mongos> db.test04.insert({hid:1111,hname:"z001"})

連接任意一臺mongos實例，都可以看到這四個數據庫，執行db.printShardingStatus()看到四個數據庫被分到了不同的shard上了，TDB1分到了shard28001上，TDB2\TDB3分到了shard28002上,TDB4分到了shard28003上，登錄mongod實例shard集群分片28001端口只看到TDB1數據庫，登錄mongod實例集群分片28002端口只看到TDB2、TDB3數據庫，登錄mongod實例集群分片28003端口只看到TDB4數據庫，通過mongos，用戶看到所有數據庫，底下的shard server對用戶而言是可以不用了解的

mongo --host 172.22.138.158 --port 27001

mongos> show dbs

TDB1    0.000GB

TDB2    0.000GB

TDB3    0.000GB

TDB4    0.000GB

admin   0.000GB

config  0.001GB

mongos> db.printShardingStatus()

--- Sharding Status ---

  sharding version: {

        "_id" : 1,

        "minCompatibleVersion" : 5,

        "currentVersion" : 6,

        "clusterId" : ObjectId("5d09cd1c38fe676e9fb94a92")

  }

  shards:

        {  "_id" : "shard28001",  "host" : "shard28001/172.22.138.157:28001,172.22.138.158:28001",  "state" : 1 }

        {  "_id" : "shard28002",  "host" : "shard28002/172.22.138.157:28002,172.22.138.158:28002",  "state" : 1 }

        {  "_id" : "shard28003",  "host" : "shard28003/172.22.138.157:28003,172.22.138.158:28003",  "state" : 1 }

  active mongoses:

        "3.6.12" : 2

  autosplit:

        Currently enabled: yes

  balancer:

        Currently enabled:  yes

        Currently running:  no

        Failed balancer rounds in last 5 attempts:  0

        Migration Results for the last 24 hours:

                No recent migrations

  databases:

        {  "_id" : "TDB1",  "primary" : "shard28001",  "partitioned" : false }

        {  "_id" : "TDB2",  "primary" : "shard28002",  "partitioned" : false }

        {  "_id" : "TDB3",  "primary" : "shard28002",  "partitioned" : false }

        {  "_id" : "TDB4",  "primary" : "shard28003",  "partitioned" : false }

        {  "_id" : "config",  "primary" : "config",  "partitioned" : true }

                config.system.sessions

                        shard key: { "_id" : 1 }

                        unique: false

                        balancing: true

                        chunks:

                                shard28001      1

                        { "_id" : { "$minKey" : 1 } } -->> { "_id" : { "$maxKey" : 1 } } on : shard28001 Timestamp(1, 0)

mongo --host 172.22.138.157 --port 28001

shard28001:PRIMARY> show dbs

TDB1    0.000GB

admin   0.000GB

config  0.000GB

local   0.000GB

mongo --host 172.22.138.157 --port 28002

shard28002:PRIMARY> show dbs

TDB2    0.000GB

TDB3    0.000GB

admin   0.000GB

config  0.000GB

local   0.000GB

mongo --host 172.22.138.157 --port 28003

shard28003:PRIMARY> show dbs

TDB4    0.000GB

admin   0.000GB

config  0.000GB

local   0.000GB

第五步

如果想對某個數據庫里面的表分片存儲，即A表一部分放入shared1，一部分放入shard2，就需要先使用sh.enableSharding("db_name")對這個數據庫啟用分片，數據庫啟用分片后，上面第四步驗證結果"partitioned" : false就變成了"partitioned" : true。如果該表已包含數據，則必須在使用shardCollection()對表分片之前使用db.collection.createIndex()方法在分片鍵上創建索引。如果表為空，MongoDB將創建索引作為shardCollection()的一部分。

mongo --host 172.22.138.158 --port 27001

mongos> use testdb

mongos> db.createCollection("table1")

mongos> db.printShardingStatus() --此時testdb對應的數據庫"partitioned" : false

mongos> sh.enableSharding("testdb")

mongos> db.printShardingStatus() --此時testdb對應的數據庫"partitioned" : true

對表testdb.table1按age字段范圍分片(代號為1)，指定散列分片鍵對空集合進行分片時最初要創建的塊數為5

mongos> sh.shardCollection("testdb.table1",{age:1},{numInitialChunks:5})

mongos> for (var i=0;i<150000;i++) db.table1.save({name:"u_"+i,age:0+i,sex:i%2,class:"number2",grade:"number3",birthd:"shanghai",motk:"shanghai",controyload:"chian",birthn:3030303030303030303,horbity:"footboll"})

對表testdb.table2按age字段范圍分片(代號為1)，指定散列分片鍵對空集合進行分片時最初要創建的塊數為1

mongos> db.createCollection("table2")

mongos> sh.shardCollection("testdb.table2",{age:1},{numInitialChunks:1})

mongos> for (var i=0;i<100000;i++) db.table2.save({name:"u_"+i,age:0+i,sex:i%2,class:"number2",grade:"number3",birthd:"shanghai",motk:"shanghai",controyload:"chian",birthn:3030303030303030303,horbity:"footboll"})

對表testdb.table3按age字段范圍分片(代號為hashed)，指定散列分片鍵對空集合進行分片時最初要創建的塊數為1

mongos> db.createCollection("table3")

mongos> sh.shardCollection("testdb.table2",{age:"hashed"},{numInitialChunks:1})

mongos> for (var i=0;i<100000;i++) db.table3.save({name:"u_"+i,age:0+i,sex:i%2,class:"number2",grade:"number3",birthd:"shanghai",motk:"shanghai",controyload:"chian",birthn:3030303030303030303,horbity:"footboll"})

上述內容就是mongodb中怎么搭建shard_replica集群，你們學到知識或技能了嗎？如果還想學到更多技能或者豐富自己的知識儲備，歡迎關注億速云行業資訊頻道。