MongoDB分片（Cluster）-创新互联

基本环境：

十载的新和网站建设经验，针对设计、前端、开发、售后、文案、推广等六对一服务，响应快，48小时及时工作处理。成都全网营销推广的优势是能够根据用户设备显示端的尺寸不同，自动调整新和建站的显示方式，使网站能够适用不同显示终端，在浏览器中调整网站的宽度，无论在任何一种浏览器上浏览网站，都能展现优雅布局与设计，从而大程度地提升浏览体验。创新互联从事“新和网站设计”,“新和网站推广”以来，每个客户项目都认真落实执行。

由于资源紧张，只有3台虚拟机的关系，只做两个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路由器要注意多台服务器时间必须要同步，否则出现错误)

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

现在用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")

现在用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" }

现在创建一个新的数据库来测试一下分片：

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)

现在由于数据量不多只有一个分片在rs0上，可以通过增加数据量来提高分片：

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)

现在rs0上有一个分片，rs1上有两个分片

另外有需要云服务器可以了解下创新互联cdcxhl.cn，海内外云服务器15元起步，三天无理由+7*72小时售后在线，公司持有idc许可证，提供“云服务器、裸金属服务器、高防服务器、香港服务器、美国服务器、虚拟主机、免备案服务器”等云主机租用服务以及企业上云的综合解决方案，具有“安全稳定、简单易用、服务可用性高、性价比高”等特点与优势，专为企业上云打造定制，能够满足用户丰富、多元化的应用场景需求。

新闻名称：MongoDB分片（Cluster）-创新互联
地址分享：http://ybzwz.com/article/dsijse.html

MongoDB分片（Cluster）-创新互联

其他资讯