溫馨提示×

溫馨提示×

您好，登錄后才能下訂單哦！

密碼登錄×
登錄注冊×
其他方式登錄
點擊 登錄注冊 即表示同意《億速云用戶服務(wù)條款》

MongoDB 分片（Cluster）

發(fā)布時間：2020-04-09 05:11:56 來源：網(wǎng)絡(luò) 閱讀：619 作者：raygtr 欄目：MongoDB數(shù)據(jù)庫

基本環(huán)境：

由于資源緊張，只有3臺虛擬機的關(guān)系，只做兩個replicaSet，每臺機器配置分別如下：

10.10.1.55這臺機器安裝 Primary1，configServer1， Arbiter1

10.10.1.56 安裝 Primary2，configServer2, Arbiter2

10.10.1.57 安裝 Secondary1,Secondary2,configServer3,mongos


1.55機器的配置文件如下：

Primary1的conf文件：

dbpath=/data/mongodb/rs0_0
logpath=/data/mongodb/log/rs0_0.log
logappend=true
port=40000
bind_ip=192.168.11.55,10.10.1.55
oplogSize=10000
fork=true
journal = true
#noprealloc = true
replSet=rs0
directoryperdb=true

Arbiter1的配置文件：

dbpath=/data/mongodb/rs0_arbiter
logpath=/data/mongodb/log/rs0_arbiter.log
logappend=true
port=40002
bind_ip=192.168.11.55,10.10.1.55
oplogSize=10000
fork=true
journal = true
#noprealloc = true
replSet=rs0
directoryperdb=true

ConfigServer1的配置文件：

dbpath=/data/mongodb/rs0_conf
logpath=/data/mongodb/log/rs0_conf.log
logappend=true
port=40006
bind_ip=192.168.11.55,10.10.1.55
fork=true
journal = true
#noprealloc = true
configsvr=true
directoryperdb=true

分別通過mongod --config  filename 來啟動不同的mongo 進程，成功啟動后可以通過netstat 查看在1.55 機器上分別分配了Primary1端口：40000，Arbiter1端口：40002，configureServer1端口：40006

1.56機器的配置：

Primary2的配置文件：

dbpath=/data/mongodb/rs1_primary
logpath=/data/mongodb/log/rs1_p.log
logappend=true
bind_ip=192.168.11.56,10.10.1.56
directoryperdb=true  
port=40003
oplogSize=10000
fork=true
journal = true
noprealloc = true
replSet=rs1

Arbiter2配置文件：

dbpath=/data/mongodb/rs1_arbiter
logpath=/data/mongodb/log/rs1_a.log
logappend=true
bind_ip=192.168.11.56,10.10.1.56
directoryperdb=true  
port=40005
oplogSize=10000
fork=true
journal = true
noprealloc = true
replSet=rs1

ConfigureServer2配置文件：

dbpath=/data/mongodb/rs1_conf
logpath=/data/mongodb/log/rs1_conf.log
logappend=true
bind_ip=192.168.11.56,10.10.1.56
directoryperdb=true  
port=40007
oplogSize=10000
fork=true
journal = true
noprealloc = true
configsvr=true

分別通過mongod --config  filename 來啟動不同的mongo 進程，成功啟動后可以通過netstat 查看在1.55 機器上分別分配了Primary2端口：40003，Arbiter2端口：40005，configureServer2端口：40007



1.56機器的配置：

rs0_Secondary1配置：

dbpath=/data/mongodb/rs0_secondary1
logpath=/data/mongodb/log/rs0_secondary1.log
logappend=true
port=40001
bind_ip=192.168.11.57,10.10.1.57
oplogSize=10000
fork=true
journal = true
#noprealloc = true
replSet=rs0
directoryperdb=true

rs1_Secondary1配置：

dbpath=/data/mongodb/rs1_secondary1
logpath=/data/mongodb/log/rs1_secondary1.log
logappend=true
bind_ip=192.168.11.57,10.10.1.57
directoryperdb=true  
port=40004
oplogSize=10000
fork=true
journal = true
noprealloc = true
replSet=rs1

configureServer3配置：

dbpath=/data/mongodb/confSvr3
logpath=/data/mongodb/log/conf3.log
logappend=true
bind_ip=192.168.11.57,10.10.1.57
directoryperdb=true  
port=40008
oplogSize=10000
fork=true
journal = true
configsvr=true

mongos 配置：(啟動mongos路由器要注意多臺服務(wù)器時間必須要同步，否則出現(xiàn)錯誤)

logpath=/data/mongodb/log/mongos.log
port = 40009
configdb=10.10.1.55:40006,10.10.1.56:40007,10.10.1.57:40008
fork = true

分別通過mongod --config  filename 來啟動不同的mongo 進程，成功啟動后可以通過netstat 查看在1.55 機器上分別分配了rs0_secondary1端口：40001，rs1_secondary1端口：40004，configureServer3端口：40008，mongos路由端口：40009



現(xiàn)在用mongo shell登錄primary1 配置replicaSet0,步驟如下：

cfg={ "_id" : "rs0", "members" : [ { "_id" : 0, "host" : "10.10.1.55:40000" }, { "_id" : 1, "host" : "10.10.1.57:40001" } ] }

rs.initiate(cfg)
rs.status()

rs.addArb("10.10.1.55:40002")

現(xiàn)在用mongo shell登錄primary2 配置replicaSet1,步驟如下：

cfg={ "_id" : "rs1", "members" : [ { "_id" : 0, "host" : "10.10.1.56:40003" }, { "_id" : 1, "host" : "10.10.1.57:40004" } ] }

rs.initiate(cfg)
rs.status()

rs.addArb("10.10.1.56:40005")


使用mongo shell登錄mongos路由添加分片信息：

mongo --host 10.10.1.57 --port 40009
mongos> sh.addShard("rs0/10.10.1.55:40000,10.10.1.57:40001")
{ "shardAdded" : "rs0", "ok" : 1 }
mongos> sh.addShard("rs1/10.10.1.56:40003,10.10.1.57:40004")
{ "shardAdded" : "rs1", "ok" : 1 }
mongos> sh.status()
--- Sharding Status --- 
  sharding version: {
    "_id" : 1,
    "version" : 4,
    "minCompatibleVersion" : 4,
    "currentVersion" : 5,
    "clusterId" : ObjectId("561c7bdd4315b18f9862adb4")
}
  shards:
    {  "_id" : "rs0",  "host" : "rs0/10.10.1.55:40000,10.10.1.57:40001" }
    {  "_id" : "rs1",  "host" : "rs1/10.10.1.56:40003,10.10.1.57:40004" }
  databases:
    {  "_id" : "admin",  "partitioned" : false,  "primary" : "config" }

現(xiàn)在創(chuàng)建一個新的數(shù)據(jù)庫來測試一下分片：

mongos> use people
switched to db people
mongos> for(var i=1;i<10;i++) db.customers.insert({name:"jordan"+i,country:"American"})
WriteResult({ "nInserted" : 1 })
mongos> for(var i=1;i<10;i++) db.customers.insert({name:"gaga"+i,country:"American"})
WriteResult({ "nInserted" : 1 })
mongos> for(var i=1;i<10;i++) db.customers.insert({name:"ham"+i,country:"UK"})
WriteResult({ "nInserted" : 1 })
mongos> for(var i=1;i<10;i++) db.customers.insert({name:"brown"+i,country:"UK"})
WriteResult({ "nInserted" : 1 })
mongos> for(var i=1;i<10;i++) db.customers.insert({name:"ramda"+i,country:"Malaysia"})
WriteResult({ "nInserted" : 1 })


開始建立分片：

mongos> db.customers.ensureIndex({country:1,_id:1})
{
    "raw" : {
        "rs0/10.10.1.55:40000,10.10.1.57:40001" : {
            "createdCollectionAutomatically" : false,
            "numIndexesBefore" : 1,
            "numIndexesAfter" : 2,
            "ok" : 1
        }
    },
    "ok" : 1
}
mongos> sh.shardCollection("people.customers",{country:1,_id:1})
{ "collectionsharded" : "people.customers", "ok" : 1 }
mongos> sh.status()
--- Sharding Status --- 
  sharding version: {
    "_id" : 1,
    "version" : 4,
    "minCompatibleVersion" : 4,
    "currentVersion" : 5,
    "clusterId" : ObjectId("561c7bdd4315b18f9862adb4")
}
  shards:
    {  "_id" : "rs0",  "host" : "rs0/10.10.1.55:40000,10.10.1.57:40001" }
    {  "_id" : "rs1",  "host" : "rs1/10.10.1.56:40003,10.10.1.57:40004" }
  databases:
    {  "_id" : "admin",  "partitioned" : false,  "primary" : "config" }
    {  "_id" : "test",  "partitioned" : false,  "primary" : "rs0" }
    {  "_id" : "people",  "partitioned" : true,  "primary" : "rs0" }
        people.customers
            shard key: { "country" : 1, "_id" : 1 }
            chunks:
                rs0    1
            { "country" : { "$minKey" : 1 }, "_id" : { "$minKey" : 1 } } -->> { "country" : { "$maxKey" : 1 }, "_id" : { "$maxKey" : 1 } } on : rs0 Timestamp(1, 0)

現(xiàn)在由于數(shù)據(jù)量不多只有一個分片在rs0上，可以通過增加數(shù)據(jù)量來提高分片：

for(var i=10;i<10000;i++) db.customers.insert({name:"ham"+i,country:"UK"})
for(var i=10;i<10000;i++) db.customers.insert({name:"ramda"+i,country:"Malaysia"})

mongos> sh.status()
--- Sharding Status ---
  sharding version: {
    "_id" : 1,
    "version" : 4,
    "minCompatibleVersion" : 4,
    "currentVersion" : 5,
    "clusterId" : ObjectId("561c7bdd4315b18f9862adb4")
}
  shards:
    {  "_id" : "rs0",  "host" : "rs0/10.10.1.55:40000,10.10.1.57:40001" }
    {  "_id" : "rs1",  "host" : "rs1/10.10.1.56:40003,10.10.1.57:40004" }
  databases:
    {  "_id" : "admin",  "partitioned" : false,  "primary" : "config" }
    {  "_id" : "test",  "partitioned" : false,  "primary" : "rs0" }
    {  "_id" : "people",  "partitioned" : true,  "primary" : "rs0" }
        people.customers
            shard key: { "country" : 1, "_id" : 1 }
            chunks:
                rs1    2
                rs0    1
            { "country" : { "$minKey" : 1 }, "_id" : { "$minKey" : 1 } } -->> { "country" : "American", "_id" : ObjectId("561c7da73af7c7865defefb1") } on : rs1 Timestamp(2, 0)
            { "country" : "American", "_id" : ObjectId("561c7da73af7c7865defefb1") } -->> { "country" : "UK", "_id" : ObjectId("561c7db63af7c7865defefd4") } on : rs0 Timestamp(3, 1)
            { "country" : "UK", "_id" : ObjectId("561c7db63af7c7865defefd4") } -->> { "country" : { "$maxKey" : 1 }, "_id" : { "$maxKey" : 1 } } on : rs1 Timestamp(3, 0)

現(xiàn)在rs0上有一個分片，rs1上有兩個分片

向AI問一下細節(jié)

免責(zé)聲明：本站發(fā)布的內(nèi)容（圖片、視頻和文字）以原創(chuàng)、轉(zhuǎn)載和分享為主，文章觀點不代表本網(wǎng)站立場，如果涉及侵權(quán)請聯(lián)系站長郵箱：is@yisu.com進行舉報，并提供相關(guān)證據(jù)，一經(jīng)查實，將立刻刪除涉嫌侵權(quán)內(nèi)容。

AI
助
手