【MongoDB】在windows平台下mongodb的分片集群（三）

【MongoDB】在windows平台下mongodb的分片集群（三），mongodb集群

在上两篇博客中我们分别阐述了分片集群的工作原理以及搭建过程。在本篇博客中我们主要一起分析分片集群的测试结果；

首先看分片集群的各个状态，可以看的出复制集A和B都是正常的：

一、开启分片集合

开启一个数据库上的分片，这是对任何集合进行分片的先决条件。 假设测试数据库为slidetest. 

 

分片集合定义注意：它看起来和索引定义有几分相似之处，尤其是有那个unique键。在对一个空集合进行分片时候，mongodb会在每个分片上创建一个与分片对应的索引。可以直接连上分片，运行getIndexs()进行验证。可以登陆到3000进行查看。

 

 

二、写入分片集群

一旦完成集合的分片，分片集群就准备就绪了。现在可以向集群写入数据，数据将分布到各个分片上。 

在4000上初始化数据：

for(var i = 0; i < 200; i++){db.spreadsheets.insert({"filename": "sheet-"+i,"updatedate": new Date(),"username":"albertshao","data":"abcde"*1000 })}

查看结果：

 

 接下来我们检查整个块发生了什么，可以看到有两块，并且他们的最大值不一样。

备注：作为BSON类型的边界，$minKey和$maxkey常用于比较操作之中。$minkey总是小雨所有BSON类型，而$maxKey总是大于所有BSON类型。。 MongoDB使用这两个类型来比较块的端点

继续插入数据，假设插入20万条记录，

mongos> sh.status()
--- Sharding Status ---
  sharding version: {
        "_id" : 1,
        "version" : 4,
        "minCompatibleVersion" : 4,
        "currentVersion" : 5,
        "clusterId" : ObjectId("545d9af5340aec0c2272afda")
}
  shards:
        {  "_id" : "shard-a",  "host" : "shard-a/WIN--20141018KO:3000,WIN--20141018KO:3001" }
        {  "_id" : "shard-b",  "host" : "shard-b/WIN--20141018KO:30100,WIN--20141018KO:30101" }
  databases:
        {  "_id" : "admin",  "partitioned" : false,  "primary" : "config" }
        {  "_id" : "slidetest",  "partitioned" : true,  "primary" : "shard-a" }
                slidetest.spreadsheets
                        shard key: { "username" : 1, "_id" : 1 }
                        chunks:
                                shard-b 1
                                shard-a 2
                        { "username" : { "$minKey" : 1 }, "_id" : { "$minKey" : 1 } } -->> { "username" : "albertshao", "_id" : ObjectId("545df80537216b1577de0251") } on : shard-b Timestamp(2, 0)
                        { "username" : "albertshao", "_id" : ObjectId("545df80537216b1577de0251") } -->> { "username" : "albertshao", "_id" : ObjectId("545e062437216b1577de1802") } on : shard-a Timestamp(2, 2)
                        { "username" : "albertshao", "_id" : ObjectId("545e062437216b1577de1802") } -->> { "username" : { "$maxKey" : 1 }, "_id" : { "$maxKey" : 1 } } on : shard-a Timestamp(2, 3)

mongos>

通过上面可以看的出，是利用usename作为块划分键。同时也可以看的出上面总有3块，其中shard-a有两块，shard-b有一块。

我们通过changelog可以看到数据库的迁移：

mongos> db.changelog.count({what:"split"})
2
mongos> db.changelog.count({what:"moveChunk.commit"}).count()
2014-11-08T20:12:09.618+0800 TypeError: Object 1 has no method 'count'
mongos> db.changelog.find({what:"moveChunk.commit"}).count()
1
mongos> db.changelog.find({what:"moveChunk.commit"})
{ "_id" : "WIN--20141018KO-2014-11-08T11:01:40-545df8141603dfc967d0fdcd", "server" : "WIN--20141018KO", "clientAddr" : "127.0.0.1:50644", "time" : ISODate("2014-11-08T11:01:40.826Z"), "what" : "moveChunk.commit", "ns" : "slidetest.spreadsheets", "details" : { "min" : { "username" : { "$minKey" : 1 }, "_id" : { "$minKey" : 1 } }, "max" : { "username" : "albertshao", "_id" : ObjectId("545df80537216b1577de0251") }, "from" : "shard-a", "to" : "shard-b", "cloned" : NumberLong(0), "clonedBytes" : NumberLong(0), "catchup" : NumberLong(0), "steady" : NumberLong(0) } }
mongos>

在配置分片的节点
mongod --port 27017 --fork --logpath ar/log/mongo_shard1.log --dbpath /data0/mongo/shard1 --shardsvr
mongod --port 27018 --fork --logpath ar/log/mongo_shard2.log --dbpath /data0/mongo/shard2 --shardsvr
mongod --port 27217 --fork --logpath ar/log/mongo_config.log --dbpath /data0/mongo/config --configsvr
配置路由
mongos --port 27417 --fork --logpath ar/log/mongos.log --configdb 127.0.0.1:27217 --chunkSize 1
在客户端配置shard
mongo --port 27417
MongoDB shell version: 1.6.5
connecting to: 127.0.0.1:27417/test
> use admin;
switched to db admin
> db.runCommand({addshard:"127.0.0.1:27017"})
{ "shardAdded" : "shard0000", "ok" : 1 }
> db.runCommand({addshard:"127.0.0.1:27018"})
{ "shardAdded" : "shard0001", "ok" : 1 }

下面我们为DataBase “foo”启用Sharding，并将其中的 Collection “col” 的 shard key设置为“{_id: 1}”，用来测试Sharding功能：
> db.runCommand({enablesharding:'foo'});
{ "ok" : 1 }
> db.runCommand({shardcollection:"foo.col", key:{_id:1}});
{ "collectionsharded" : "foo.col", "ok" : 1 }
 

本来就是可以的
对于副本集模式，集群参数是写在每一个节点内部的
对于分片模式，集群参数写在配置服务器里