设为首页 加入收藏

TOP

MongoDB 分片(Cluster)
2015-11-10 12:15:58 来源: 作者: 【 】 浏览:4
Tags:MongoDB分片 Cluster

基本环境:


由于资源紧张,只有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文件:


Arbiter1的配置文件:


ConfigServer1的配置文件:


分别通过mongod --config? filename 来启动不同的mongo 进程,成功启动后可以通过netstat 查看在1.55 机器上分别分配了Primary1端口:40000,Arbiter1端口:40002,configureServer1端口:40006


1.56机器的配置:


Primary2的配置文件:


Arbiter2配置文件:


ConfigureServer2配置文件:


分别通过mongod --config? filename 来启动不同的mongo 进程,成功启动后可以通过netstat 查看在1.55 机器上分别分配了Primary2端口:40003,Arbiter2端口:40005,configureServer2端口:40007?


1.56机器的配置:


rs0_Secondary1配置:


rs1_Secondary1配置:


configureServer3配置:


mongos 配置:(启动mongos路由器要注意多台服务器时间必须要同步,否则出现错误)


分别通过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路由添加分片信息:


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


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 })


开始建立分片:


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


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上有两个分片


更多MongoDB相关内容可以看看以下的有用链接:?


】【打印繁体】【投稿】【收藏】 【推荐】【举报】【评论】 【关闭】 【返回顶部
分享到: 
上一篇Oracle 12C 修改spfile路径 下一篇Percona MySQL5.6 半同步复制

评论

帐  号: 密码: (新用户注册)
验 证 码:
表  情:
内  容:

·请问微信4.0版本xwec (2025-12-24 22:48:42)
·电脑NVIDIA的文件夹 (2025-12-24 22:48:40)
·如何看待微信新版本 (2025-12-24 22:48:37)
·C语言中如何将结构体 (2025-12-24 22:20:09)
·纯C语言结构体成员变 (2025-12-24 22:20:06)