MongoDB 分片(Cluster)
内容导读
互联网集市收集整理的这篇技术教程文章主要介绍了MongoDB 分片(Cluster),小编现在分享给大家,供广大互联网技能从业者学习和参考。文章包含7926字,纯文字阅读大概需要12分钟。
内容图文
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上有两个分片
本文出自 “技术博客” 博客,请务必保留此出处http://raytech.blog.51cto.com/7602157/1702465
MongoDB 分片(Cluster)
标签:mongodb 分片 cluster
本文系统来源:http://raytech.blog.51cto.com/7602157/1702465
内容总结
以上是互联网集市为您收集整理的MongoDB 分片(Cluster)全部内容,希望文章能够帮你解决MongoDB 分片(Cluster)所遇到的程序开发问题。 如果觉得互联网集市技术教程内容还不错,欢迎将互联网集市网站推荐给程序员好友。
内容备注
版权声明:本文内容由互联网用户自发贡献,该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 gblab@vip.qq.com 举报,一经查实,本站将立刻删除。
内容手机端
扫描二维码推送至手机访问。