mongodb10---分片

1:在3台独立服务器上,分别运行 27017,27018,27019实例, 互为副本集,形成3套repl set
2: 在3台服务器上,各配置config server, 运行27020端口上

3: 配置mongos
./bin/mongos --port 30000 \
 --dbconfig 192.168.1.201:27020,192.168.1.202:27020,192.168.1.203:27020

4:连接路由器
./bin/mongo --port 30000

5: 添加repl set为片
>sh.addShard(‘192.168.1.201:27017’);
>sh.addShard(‘192.168.1.203:27017’);
>sh.addShard(‘192.168.1.203:27017’);


6: 添加待分片的库
>sh.enableSharding(databaseName);

7: 添加待分片的表
>sh.shardCollection(‘dbName.collectionName’,{field:1});

Field是collection的一个字段,系统将会利用filed的值,来计算应该分到哪一个片上.
这个filed叫”片键”, shard key

mongodb不是从单篇文档的级别,绝对平均的散落在各个片上, 

而是N篇文档,形成一个块"chunk",
优先放在某个片上，片上又分为一个一个的块, 
当这片上的chunk,比另一个片的chunk,区别比较大时, (>=3) ,会把本片上的chunk,移到另一个片上, 以chunk为单位,
维护片之间的数据均衡

问: 为什么插入了10万条数据,才2个chunk?
答: 说明chunk比较大(默认是64M)
在config数据库中,修改chunksize的值.
Use config
Show tables
Db.settings.find();    //{id:’chunksize’,’value’:64}

问: 既然优先往某个片上插入,当chunk失衡时,再移动chunk,
自然,随着数据的增多,shard的实例之间,有chunk来回移动的现象,这将带来什么问题?
答: 服务器之间IO的增加, 

接上问: 能否我定义一个规则, 某N条数据形成1个块,预告分配M个chunk,
M个chunk预告分配在不同片上. 
以后的数据直接入各自预分配好的chunk,不再来回移动?

答: 能, 手动预先分片!

mkdir -p /data/r17 /data/r18 /data/r20 /data/mlog    //17,18是shard的端口，20是configsvr的端口

//启动2个mongo片的实例
/usr/local/mongodb/bin/mongod --dbpath /data/r17/ --logpath /data/mlog/r17.log --port 27017 --fork --smallfile
/usr/local/mongodb/bin/mongod --dbpath /data/r18/ --logpath /data/mlog/r18.log --port 27018 --fork --smallfile

//准备configsvc(不是一台存储数据的服务器，而是存储配置信息的服务器)
/usr/local/mongodb/bin/mongod --dbpath /data/r20/ --logpath /data/mlog/r20.log --port 27020 --fork --configsvr

//mongos路由器
/usr/local/mongodb/bin/mongos --logpath /data/mlog/r30.log --port 30000 --configdb 192.168.202:27020   --fork//哪台configsvr为他服务，现在mongos和configsvr连在了一起但是还没有和shard连在一起。

ps aux | grep mongo    //可以看到刚才的4个进程

//连接mongos
./bin/mongo --port 30000

//添加repl set为片,现在3者都连接到一起了，
>sh.addShard(‘192.168.1.201:27017’);
>sh.addShard(‘192.168.1.203:27018’);   

sh.status()   //可以查看分片信息

use test
db.stu.insert({ss:"ss"})
db.stu.insert({ss:"ss"})
db.stu.insert({ss:"ss"})
db.stu.insert({ss:"ss"})
db.stu.insert({ss:"ss"})


//连接到27017
./bin/mongo --port 27017
db.find()    //有数据

//连接到27018
./bin/mongo --port 27018
db.find()    //没有数据，因为没有指定分片规则

//添加待分片的库(谁可以分片)
>sh.enableSharding(‘shop‘);      //shop库可以分片

sh.status()    //可以看到shop库可以分片

//添加待分片的表
>sh.shardCollection(‘shop.goods‘,{goods_id:1});

sh.status()    //可以看到shop库goods表的状态


//添加2000数据
use shop
for(var i=1;i<600000;i++){
    db.goods.insert({ss:"ss"+1})
}
db.goods.find()


//查看分片数据
./bin/mongo --port 27017
db.find()
./bin/mongo --port 27018
db.find()