mongodb shard 分片技术
admin
2023-04-12 16:42:04
0次

启动route process

配置route process并且启动,代码如下:

[root@localhost ~]# /usr/local/mongo/bin/mongos --port 40000 --configdb localhost:30000 --fork --logpath /data/shard/log/route.log --chunkSize 1
forked process: 2911
[root@localhost ~]# all output going to: /data/shard/log/route.log

配置sharding

[root@localhost ~]# /usr/local/mongo/bin/mongo --port 40000
MongoDB shell version: 2.0.4
connecting to: 127.0.0.1:40000/test
mongos>

这个地方一定要切换到admin数据库

mongos> use admin
switched to db admin
mongos> db
admin
mongos> db.runCommand({addshard:"localhost:20000"})
{ "shardAdded" : "shard0000", "ok" : 1 }
mongos> db.runCommand({addshard:"localhost:20001"})
{ "shardAdded" : "shard0001", "ok" : 1 }

mongos> db.runCommand({enablesharding:"test"})
{ "ok" : 1 }
mongos> db.runCommand({shardcollection:"test.users",key:{_id:1}})
{ "collectionsharded" : "test.users", "ok" : 1 }

 

 

 


momongos> for(var i =1;i <= 500000;i++) db.users.insert({age:i,name:"fangwei",addr:"hangzhou",country:"China"})
mongos> db.users.find()
{ "_id" : ObjectId("53d4eefd67d21d1d69f5bcd0"), "age" : 1 }
{ "_id" : ObjectId("53d4f024b1e3fc47712a0576"), "age" : 1, "name" : "fangwei", "addr" : "hangzhou", "country" : "China" }
{ "_id" : ObjectId("53d4f024b1e3fc47712a0577"), "age" : 2, "name" : "fangwei", "addr" : "hangzhou", "country" : "China" }ngos>

 

---验证我们的分片

mongos> db.users.stats()
{
 "sharded" : true,
 "flags" : 1,
 "ns" : "test.users",
 "count" : 500001,
 "numExtents" : 17,
 "size" : 46000036,
 "storageSize" : 81166336,
 "totalIndexSize" : 18845680,
 "indexSizes" : {
  "_id_" : 18845680
 },
 "avgObjSize" : 91.999888000224,
 "nindexes" : 1,
 "nchunks" : 37,
 "shards" : {
  "shard0000" : {
   "ns" : "test.users",
   "count" : 197093,
   "size" : 18132500,

   "avgObjSize" : 91.99971587017296,
   "storageSize" : 33333248,
   "numExtents" : 8,
   "nindexes" : 1,
   "lastExtentSize" : 12083200,
   "paddingFactor" : 1,
   "flags" : 1,
   "totalIndexSize" : 8969072,
   "indexSizes" : {
    "_id_" : 8969072
   },
   "ok" : 1
  },
  "shard0001" : {
   "ns" : "test.users",
   "count" : 302908,
   "size" : 27867536,

   "avgObjSize" : 92,
   "storageSize" : 47833088,
   "numExtents" : 9,
   "nindexes" : 1,
   "lastExtentSize" : 14499840,
   "paddingFactor" : 1,
   "flags" : 1,
   "totalIndexSize" : 9876608,
   "indexSizes" : {
    "_id_" : 9876608
   },
   "ok" : 1
  }
 },
 "ok" : 1
}
mongos>

 

查看磁盘上物理文件分布情况

mongos> exit
bye
[root@localhost ~]# ll /data/shard/s0/test
total 213004
-rw-------. 1 root root  67108864 Jul 27 20:28 test.0
-rw-------. 1 root root 134217728 Jul 27 20:09 test.1
-rw-------. 1 root root  16777216 Jul 27 20:28 test.ns
drwxr-xr-x. 2 root root      4096 Jul 27 20:09 _tmp
[root@localhost ~]#

[root@localhost ~]# ll /data/shard/s1/test
total 475148
-rw-------. 1 root root  67108864 Jul 27 20:38 test.0
-rw-------. 1 root root 134217728 Jul 27 20:27 test.1
-rw-------. 1 root root 268435456 Jul 27 20:27 test.2
-rw-------. 1 root root  16777216 Jul 27 20:38 test.ns
drwxr-xr-x. 2 root root      4096 Jul 27 20:27 _tmp
[root@localhost ~]#

---列出所有的shard server

mongos> use admin
switched to db admin
mongos> db.runCommand({listshards:1})
{
 "shards" : [
  {
   "_id" : "shard0000",
   "host" : "localhost:20000"
  },
  {
   "_id" : "shard0001",
   "host" : "localhost:20001"
  }
 ],
 "ok" : 1
}

-----查看sharding信息

mongos> printShardingSizes()
--- Sharding Status ---
  sharding version: { "_id" : 1, "version" : 3 }
  shards:
      { "_id" : "shard0000", "host" : "localhost:20000" }
      { "_id" : "shard0001", "host" : "localhost:20001" }
  databases:
 { "_id" : "admin", "partitioned" : false, "primary" : "config" }
 { "_id" : "test", "partitioned" : true, "primary" : "shard0000" }
  test.users chunks:
   { "_id" : { $minKey : 1 } } -->> { "_id" : ObjectId("53d4eefd67d21d1d69f5bcd0") } on : shard0000 { "estimate" : false, "size" : 0, "numObjects" : 0 }
   { "_id" : ObjectId("53d4eefd67d21d1d69f5bcd0") } -->> { "_id" : ObjectId("53d4f024b1e3fc47712a1dd6") } on : shard0000 { "estimate" : false, "size" : 574116, "numObjects" : 6241 }
 

-------判断是佛sharding

> db.runCommand({isdbgrid:1})
{ "isdbgrid" : 1, "hostname" : "localhost.mongo102", "ok" : 1 }
>

----------对现有表执行sharding

> db
test
> db.users_2.stats()
{
 "sharded" : false,                               ---------------------可看出没有分表
 "primary" : "shard0000",
 "errmsg" : "ns not found",
 "ok" : 0
}

对其进行分表

> db
admin
> db.runCommand({shardcollection:"test.users_2",key:{_ud:1}})
{ "collectionsharded" : "test.users_2", "ok" : 1 }

> use test
switched to db test
> db.users_2.stats()
{
 "sharded" : true,
 "flags" : 1,
 "ns" : "test.users_2",
 "count" : 0,
 "numExtents" : 1,
 "size" : 0,
 "storageSize" : 8192,
 "totalIndexSize" : 16352,
 "indexSizes" : {
  "_id_" : 8176,
  "_ud_1" : 8176
 },
 "avgObjSize" : 0,
 "nindexes" : 2,
 "nchunks" : 1,
 "shards" : {
  "shard0000" : {
   "ns" : "test.users_2",
   "count" : 0,
   "size" : 0,
   "storageSize" : 8192,
   "numExtents" : 1,
   "nindexes" : 2,
   "lastExtentSize" : 8192,
   "paddingFactor" : 1,
   "flags" : 1,
   "totalIndexSize" : 16352,
   "indexSizes" : {
    "_id_" : 8176,
    "_ud_1" : 8176
   },
   "ok" : 1
  }
 },
 "ok" : 1
}
>

-------新增shard server 分片

[root@localhost ~]# mkdir /data/shard/s2

[root@localhost ~]# /usr/local/mongo/bin/mongod --shardsvr --port 20002 --dbpath /data/shard/s2 --fork --logpath /data/shard/log/s2.log --directoryperdb
[root@localhost ~]# forked process: 3480
all output going to: /data/shard/log/s2.log

[root@localhost ~]# /usr/local/mongo/bin/mongo --port 40000
MongoDB shell version: 2.0.4
connecting to: 127.0.0.1:40000/test

mongos> db
test
mongos> use admin
switched to db admin
mongos> db.runCommand({addshard:"localhost:20002"})
{ "shardAdded" : "shard0002", "ok" : 1 }
mongos>

相关内容

热门资讯

空调连续工作多久需要停机休息 空调连续工作的时间取决于多个因素,包括空调的型号、功率、使用环境和维护情况等。一般来说,空调可以连续...
空调哪个符号是除湿的 空调除湿功能通常用一个水滴形状的符号表示。不同品牌和型号的空调遥控器可能会有所差异,但一般来说,除湿...
格力空调多长时间加一次氟利昂 1、一般情况下,空调对氟利昂的使用量是非常小的,所以在空调使用了四年左右的时候再考虑加也没问题。2、...
空调用多长时间需要加氟一次 一般情况下是五年。当出现以下这几种情况时,空调才需要加氟。1、空调的室内机和室外机各有两个接口,当接...
格调生活·C标思享荟:卡萨帝在... 9月12日的郑州龙湖金融岛,夜风轻拂,灯光璀璨。“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑...
品牌价值破千亿、高端份额持续领... 9月12日,“C标时刻共传奇——卡萨帝思享荟暨20周年品牌盛典郑州站”在郑州龙湖金融岛举办。2026...
空调主板坏了修800还是换新的 空调主板坏了是修还是换新,需要考虑多个因素,以下是一些建议:1. 维修成本:如果维修费用较低,比如 ...
空调开多久需要休息多长时间 问题:空调开多久需要休息多长时间回答:1、在使用空调的过程中,一般空调开7~8个小时左右需要休息2~...
中央空调多长时间清洗一次 1、一般空调开机前清洗一次即可,空调开机中间时段再清洗一次,空调关机时清洗一次,这样比较合理。2、空...
中央空调氟利昂多久加一次 看空调制热和制冷程度,很多人的观点认为氟利昂必须一年放一次,其实这个观点是错误的,理解上面有点偏差,...