mongodb分片+副本集实验
该实验在两台虚拟机搭建一个自动故障转移集群，因为副本集只会自动切换主库，而应用是不会自动变换IP的，为了实现应用对主数据库的自动查找，可以利用mongodb的mongos，为此需要将两台虚拟机搭建成一个分片节点。环境：
两台服务器：
Ubuntu Linux：192.168.56.101
Windows:192.168.56.1
其中Linux上启动3个mongod来创建副本集，windows服务上创建路由服务器，配置服务器和一个分片。
Linux上创建副本集：
启动3个mongod进程分别为：
192.168.56.101:10101
192.168.56.101:20101
192.168.56.101:30101
其中192.168.56.101:30101为仲裁机器
./mongod--dbpath=/usr/local/mongodb2.0.1/db --logpath=/usr/local/mongodb2.0.1/log/mongod.log --logappend --fork --port=10101-replSet test
./mongod--dbpath=/usr/local/mongodb2.0.2/db --logpath=/usr/local/mongodb2.0.2/log/mongod.log --logappend --fork --port=20101-replSet test
./mongod--dbpath=/usr/local/mongodb2.0.3/db --logpath=/usr/local/mongodb2.0.3/log/mongod.log --logappend --fork --port=30101-replSet test
登陆192.168.56.101:10101配置初始化副本集：
./mongo 192.168.56.101:10101
use admin
db.runCommand({"replSetInitiate":{"_id":"test","members":[{"_id":0,"host":"192.168.56.101:10101"},{"_id":1,"host":"192.168.56.101:20101"},{"_id":2,"host":"192.168.56.101:30101",arbiterOnly:true}]}})
返回：
{
"info" : "Config now saved locally. Should come online in about a minute.",
"ok" : 1
}
说明初始化配置成功。
运行rs.status();
PRIMARY> rs.status();
{
"set" : "test",
"date" : ISODate("2013-04-01T03:15:09Z"),
"myState" : 1,
"members" : [
{
"_id" : 0,
"name" : "192.168.56.101:10101",
"health" : 1,
"state" : 1,
"stateStr" : "PRIMARY",
"optime" : {
"t" : 1364786052000,
"i" : 1
},
"optimeDate" : ISODate("2013-04-01T03:14:12Z"),
"self" : true
},
{
"_id" : 1,
"name" : "192.168.56.101:20101",
"health" : 1,
"state" : 2,
"stateStr" : "SECONDARY",
"uptime" : 51,
"optime" : {
"t" : 1364786052000,
"i" : 1
},
"optimeDate" : ISODate("2013-04-01T03:14:12Z"),
"lastHeartbeat" : ISODate("2013-04-01T03:15:08Z"),
"pingMs" : 0
},
{
"_id" : 2,
"name" : "192.168.56.101:30101",
"health" : 1,
"state" : 7,
"stateStr" : "ARBITER",
"uptime" : 51,
"optime" : {
"t" : 0,
"i" : 0
},
"optimeDate" : ISODate("1970-01-01T00:00:00Z"),
"lastHeartbeat" : ISODate("2013-04-01T03:15:08Z"),
"pingMs" : 2899947
}
],
"ok" : 1
}
PRIMARY表示192.168.56.101:10101为主节点。192.168.56.101:20101为从节点SECONDARY，仲裁节点为192.168.56.101:30101.
至此，副本集已经建立完毕【测试副本集过程省略】。
创建分片：
Winows机器上启动3个mongod.
192.168.56.1:10001【配置服务器】
192.168.56.1:20001【mongos服务器】
192.168.56.1:30001【分片节点】
1：开启config服务器192.168.56.1:10001
mongod -dbpath D:\software\mongodb2.4.1\db -logpath D:\software\mongodb2.4.1\log\mongod.log -port 10001 -logappend
2. 开启mongos服务器192.168.56.1:20001
mongos --port=20001 --configdb=192.168.56.1:10001 [指定配置服务器192.168.56.1:10001]，以后添加查询都是通过mongos服务器对外接口的
3：启动mongod分片服务器192.168.56.1:30001
mongod -dbpath D:\software\mongodb2.4.3\db -logpath D:\software\mongodb2.4.3\log\mongod.log -port 30001 -logappend
4：服务配置
登陆mongos
mongo 192.168.56.1:20001
use admin
添加分片：
A添加192.168.56.1:30001这台分片。运行：
db.runCommand({"addshard":"192.168.56.1:30001",allowLocal:true})
B 添加刚才创建的副本集，添加主节点192.168.56.101:10101为分片,运行：
db.runCommand({addshard:"test/192.168.56.101:10101"})
【test为副本集名称，192.168.56.101:10101为副本集主节点】
C 设置分片
[*]
开启数据库分片功能，命令很简单 enablesharding(),这里我就开启ShardTest数据库。运行： db.runCommand({"enablesharding":"ShardTest"})
[*]
指定集合中分片的片键，这里我就指定为person.name字段。运行： db.runCommand({"shardcollection":"ShardTest.person","key":{"name":1}})
查看效果：
至此我们的分片操作全部结束，接下来我们通过mongos向mongodb插入10w记录，然后通过printShardingStatus命令查看mongodb的数据分片情况。运行：
use ShardTest
for(var i=0;i> { "name" : "guo0" }
on : test从无穷小到guo0的片键在test分片上，记在192.168.101:10101这个副本集上。
2.{ "name" : "guo0" } -->> { "name" : "guo9999" } on : sha
rd0000即在192.168.56.1:30001机器上。
3.{ "name" : "guo9999" } -->> { "name" : { "$maxKey" : 1 }on : shard0000从9999到无穷大的片键也分片在shard0000上
分区情况为：3：1，从后面的 on shardXXXX也能看得出。
此时登陆到192.168.101:10101查询person集合的数据，发现并没有记录，根据上面的片键分片策略无穷小到guo0分配到test副本集上，这也是正常的。因为我们添加的记录都是》=0的。为了测试片键分配策略，我们添加一些负数记录，看是否存储到test副本集上。
在mongos上执行：
for(var i=-10000;i rs.status();
{
"set" : "test",
"date" : ISODate("2013-04-01T04:57:42Z"),
"myState" : 1,
"syncingTo" : "192.168.56.101:10101",
"members" : [
{
"_id" : 0,
"name" : "192.168.56.101:10101",
"health" : 0,
"state" : 8,
"stateStr" : "(not reachable/healthy)",
"uptime" : 0,
"optime" : {
"t" : 1364791344000,
"i" : 246
},
"optimeDate" : ISODate("2013-04-01T04:42:24Z"),
"lastHeartbeat" : ISODate("2013-04-01T04:54:43Z"),
"pingMs" : 0,
"errmsg" : "socket exception"
},
{
"_id" : 1,
"name" : "192.168.56.101:20101",
"health" : 1,
"state" : 1,
"stateStr" : "PRIMARY",
"optime" : {
"t" : 1364791344000,
"i" : 246
},
"optimeDate" : ISODate("2013-04-01T04:42:24Z"),
"self" : true
},
{
"_id" : 2,
"name" : "192.168.56.101:30101",
"health" : 1,
"state" : 7,
"stateStr" : "ARBITER",
"uptime" : 6193,
"optime" : {
"t" : 0,
"i" : 0
},
"optimeDate" : ISODate("1970-01-01T00:00:00Z"),
"lastHeartbeat" : ISODate("2013-04-01T04:57:41Z"),
"pingMs" : 0
}
],
"ok" : 1
}
PRIMARY>
在通过mongos添加一条记录{"name":"guo-10001"}，看副本集是否还能进行添加。
再登陆副本集节点192.168.56.101:20101查询。
发现副本集中的从节点192.168.56.1::20101已经接替节点192.168.56.1:10101成为主节点。
综上所述，可以对数据库服务器做副本集并使所有的访问都通过mongos来达到数据库服务器故障的自动转移。
页:
[1]