mongodb搭建集群

如果想配置2个mongos,1个config，多个mongod也可以 

mongos比较耗cpu，mongod比较耗内存，但其实负载都很低。 

机器1：1个mongos和1个config 

[root@iz28s3djhumz ~]# ps -ef|grep mongo 

root     13617     1  0 17:12 ?        00:00:07 mongod --dbpath=/mongo_config --port 27030 --fork --logpath=/mongo_config/mongo_config.log 

root     13654     1  0 17:19 ?        00:00:01 mongos --port 27031 --configdb=42.96.130.106:27030 --fork --logpath=/mongos/mongos.log 

机器2:1个mongos和1个mongod 

[root@iz28b2hr3cxz /]# ps -ef|grep mongo 

root      9693     1  0 17:15 ?        00:00:05 mongod --dbpath=/mongo2 --port 27032 --fork --logpath=/mongo2/mongo2.log 

root      9704     1  0 17:16 ?        00:00:02 mongos --port 27033 --configdb=42.96.130.106:27030 --fork --logpath=/mongos2/mongos.log 

机器3-n：都是mongod 

root     29486     1  0 17:17 ?        00:00:05 mongod --dbpath=/mongo --port 27036 --fork --logpath=/mongo/mongo5.log 

使用命令： 

[root@iz28s3djhumz ~]# mongo 42.96.130.106:27031/admin 

[root@iz28b2hr3cxz /]# mongo 121.42.169.214:27033/admin 

一边操作，另一边可以同步看到结果，因此就相当于一个副本。 

以上的配置，当数据量达到1300万的时候，mongodb的插入变慢，约为100w/h   之前可以达到120-130w/h 

现在考虑要做负载均衡和修改chunk值来减少数据的迁移 

开始进行集群搭建 

--- 

1、理解概念 

　　mongos：首先我们要了解”片键“的概念，也就是说拆分集合的依据是什么?按照什么键值进行拆分集合....好了，mongos就是一个路由服务器，它会根据管理员设置的“片键”将数据分摊到自己管理的mongod集群，数据和片的对应关系以及相应的配置信息保存在"config服务器"上。 

　　mongod：一个普通的数据库实例，如果不分片的话，我们会直接连上mongod。 

首先我们准备4个mongodb程序，直接在12.104，12.107两条机器上部署，可以做多个文件夹的形式。 

2、开启config服务器 

　先前也说了，mongos要把mongod之间的配置放到config服务器里面，理所当然首先开启它，我这里就建立27018端口。 

mongod --dbpath=/mongo --port 27018 

config 

192.168.12.107 /mongo    --端口27018 

3、开启mongos服务器 

　这里要注意的是我们开启的是mongos，不是mongod，同时指定下config服务器 

mongod --dbpath=/mongos  --port=27020  --configdb=192.168.12.107:27018 

mongos 

192.168.12.107 /mongos   --端口27020 

[root@viptest2 /]# mongos --port 27020 --configdb=127.0.0.1:27018  --不能指定本地localhost或者127.0.0.1，要使用ip 

[root@viptest2 /]# mongos --port 27020 --configdb=192.168.12.107:27018 

4、启动mongod服务器 

　　对分片来说，也就是要添加片了，端口为：27017，27019。 

[root@testvip1 /]# mkdir mongo1 

[root@testvip1 /]# mkdir mongo2 

[root@testvip1 /]# mongod --dbpath=/mongo1  --port 27017 

再开一个窗口 

[root@testvip1 /]# mongod --dbpath=/mongo2  --port 27019 

5、服务配置 

　<1> 先前图中也可以看到，我们client直接跟mongos打交道，也就说明我们要连接mongos服务器，然后将27017，27019的mongod交给mongos,添加分片也就是addshard()。 

　　这里要注意的是，在addshard中，我们也可以添加副本集，这样能达到更高的稳定性。 

在12.107 mongos上配置分片信息 

[root@viptest2 ~]# mongo 192.168.12.107:27020/admin 

mongodb shell version: 2.4.6 

connecting to: 192.168.12.107:27020/admin 

welcome to the mongodb shell. 

for interactive help, type "help". 

for more comprehensive documentation, see 

http://docs.mongodb.org/ 

questions? try the support group 

http://groups.google.com/group/mongodb-user 

addshard 遇到的错误 

db.runcommand({addshard:”192.168.12.104:27017″}) 

{ 

“ok” : 0, 

“errmsg”: “can’t use localhost as a shard since all shards need to communicate. either use all shards and configdbs in localhost or all in actual ips host: 192.168.12.104:27017 islocalhost:0″ 

} 

遇到这样的错误是由于某些服务启动在localhost 地址。 

经过检查发现route 启动时，读取config 服务是读取的localhost 地址： 

将localhost 修改为ip 地址，问题解决。 

重新进入： 

mongos> 

mongos> db.runcommand({addshard:"192.168.12.104:27019",allowlocal:true }) 

当路由进程和分片在同一台机器上要指定allowlocal为true,因为mongodb尽量避免错误的配置，将集群配置在本地，所以这个配置指明当前仅仅是用于开发。 

因为路由和分片不在同一台机器上，因此不需要执行true，如下添加分片成功 

mongos> db.runcommand({"addshard":"192.168.12.104:27017"}); 

{ "shardadded" : "shard0000", "ok" : 1 } 

mongos> db.runcommand({"addshard":"192.168.12.104:27019"}); 

{ "shardadded" : "shard0001", "ok" : 1 } 

<2>mongos不知道该如何切分数据，也就是我们先前所说的片键，在mongodb中设置片键要做两步 

　　①：开启数据库分片功能，命令很简单 enablesharding(),这里我就开启test数据库。 

　　②：指定集合中分片的片键，这里我就指定为person.name字段。 

mongos> show collections;  --查看表 

mongos> db.runcommand({"drop":"t1"}) --删除表  ---db.t1.drop()一样的效果 

"nindexeswas" : 1, 

"msg" : "indexes dropped for collection", 

"ns" : "testdb.t1", 

"ok" : 1 

mongos> show dbs;  --查看数据库 

admin (empty) 

config 0.1875gb 

mongos> use testdb  --创建数据库,必须做一些操作，如果是建的空库，就会自动被删除 

switched to db testdb 

mongos> db.usr.insert({"name":"tom"}); --创建表 

mongos> show collections; 

system.indexes 

usr 

mongos> db.usr.find();   --查找表 

{ "_id" : objectid("541a4f38156a058cc29cce8e"), "name" : "tom" } 

mongos> db.usr.insert({"name":"tom","id":1,"address":"china","phone":"15926492390","sex":"m"})--再插入一条 

mongos> db.usr.find();  --结果显示两条 

{ "_id" : objectid("541a4fcd156a058cc29cce8f"), "name" : "tom", "id" : 1, "address" : "china", "phone" : "15926492390", "sex" : "m" } 

mongos> db.runcommand({"enablesharding":"testdb"}) 

{ "ok" : 0, "errmsg" : "access denied - use admin db" } --要使用admin数据库进行配置 

mongos> use admin 

switched to db admin 

mongos> db.runcommand({"enablesharding":"testdb"}) --切换到admin果然配置成功 

{ "ok" : 1 } 

表进行分片 

mongos> db.runcommand({"shardcollection":"testdb.usr","key":{"id":1}}) 

"proposedkey" : { 

"id" : 1 

}, 

"curindexes" : [ 

"v" : 1, 

"key" : { 

"_id" : 1 

"ns" : "testdb.usr", 

"name" : "_id_" 

], 

"ok" : 0, 

"errmsg" : "please create an index that starts with the shard key before sharding." --提示需要先建索引 

原来判断分支是查找是否有可用的索引存在，当无可用的索引，并且表不为空时，就会出现这个错误信息。 

好了找到根源了，现在解决问题：在分片key上个建立索引 

use testdb 

db.usr.ensureindex({"id":1}) 

然后对表进行分片 

"errmsg" : "found missing value in key { id: null } for doc: { _id: objectid('541a4f38156a058cc29cce8e'), name: \"tom\" }"--最开始插入的一条有问题，没有id这个字段 

修改这条记录： 

mongos> db.usr.update({"name":"tom"},{"name":"tina","id":2,"address":"us","phone":"18707551657","sex":"f"}) 

mongos> db.usr.find(); 

{ "_id" : objectid("541a4f38156a058cc29cce8e"), "name" : "tina", "id" : 2, "address" : "us", "phone" : "18707551657", "sex" : "f" } 

结果显示： 

mongos> db.runcommand({"shardcollection":"testdb.usr","key":{"id":1}})  

{ "collectionsharded" : "testdb.usr", "ok" : 1 }   --创建成功，以id为分片的主键 

6、 查看效果 

　　好了，至此我们的分片操作全部结束，接下来我们通过mongos向mongodb插入多条记录，然后通过printshardingstatus命令查看mongodb的数据分片情况。 

　　这里主要看三点信息： 

　　① shards： 我们清楚的看到已经别分为两个片了，shard0000和shard0001。 

　　② databases: 这里有个partitioned字段表示是否分区，这里清楚的看到已经分区。 

　　③ chunks： 集合 

mongos> use testdb 

mongos> db.printshardingstatus() 

--- sharding status --- 

  sharding version: { 

"_id" : 1, 

"version" : 3, 

"mincompatibleversion" : 3, 

"currentversion" : 4, 

"clusterid" : objectid("541a47a9124d847f09e99204") 

  shards: 

{  "_id" : "shard0000",  "host" : "192.168.12.104:27017" } 

{  "_id" : "shard0001",  "host" : "192.168.12.104:27019" } 

  databases: 

{  "_id" : "admin",  "partitioned" : false,  "primary" : "config" } 

{  "_id" : "testdb",  "partitioned" : true,  "primary" : "shard0000" } 

testdb.usr 

shard key: { "id" : 1 } 

chunks: 

shard0000 1 

{ "id" : { "$minkey" : 1 } } -->> { "id" : { "$maxkey" : 1 } } on : shard0000 timestamp(1, 0) 

--插入1000条数据 

mongos> for (var i=0;i<1000;i++){db.usr.insert({"name":"tina"+i,"id":3+i,"address":"china","phone":15926492390+i,"sex":"m"})} 

--在路由mongo上连接单个分片 

[root@testvip1 ~]# mongo 192.168.12.104:27017   

connecting to: 192.168.12.104:27017/test 

> use testdb 

> show collections 

> db.usr.find() 

{ "_id" : objectid("541a5455156a058cc29cce91"), "id" : 3, "name" : "tina0", "address" : "china", "phone" : 15926492390, "sex" : "m" } 

type "it" for more 

> db.usr.status() 

thu sep 18 14:54:19.410 typeerror: property 'status' of object testdb.usr is not a function 

> db.usr.status 

testdb.usr.status 

thu sep 18 14:54:31.494 typeerror: property 'status' of object testdb.usr is not a function 

> db.usr.count()    --以id做key，结果全部分到一个分片上了。 

35407 

-------------------