MongoDB 的分片技术

Wesley13
• 阅读 567

    在MongoDB中分片技术 也就是集群。需要1台配置服务器配置各个节点的配置信息,1台路由服务器来知道每一台节点都在哪个地方并给用户提供各个节点数据的访问功能,还有多台节点服务器,存储节点数据。

    当前我有三台机器192.168.0.114,192.168.0.115,192.168.0.116,规划如下:

   搭建配置服务器:192.168.0.114

   搭建路由服务器:192.168.0.114

   搭建3个节点:192.168.0.114,192.168.0.115,192.168.0.116

(192.168.0.114 既做配置服务器,又做路由服务器,同时还做一个节点)

1    搭建配置服务器

      配置服务器参数

[root@dghost var]# cat /etc/mong_config1.conf 
dbpath=/var/config1--指定配置路径
logpath=/var/log/mongodbs/log1.log--指定日志路径
port=28001--指定配置端口
logappend=true--指定打开节点开关
fork=true--指定后台运行

当前这里我们搭建3个配置,其他两个如下:

[root@dghost var]# cat /etc/mong_config2.conf 
dbpath=/var/config2
logpath=/var/log/mongodbs/log2.log
port=28002
logappend=true
fork=true
configsvr=true

[root@dghost var]# cat /etc/mong_config3.conf 
dbpath=/var/config3
logpath=/var/log/mongodbs/log3.log
port=28003
logappend=true
fork=true
configsvr=true

启动这3个配置

[root@dghost var]# mongod -f /etc/mong_config1.conf 
about to fork child process, waiting until server is ready for connections.
forked process: 2360
child process started successfully, parent exiting
[root@dghost var]# mongod -f /etc/mong_config2.conf 
about to fork child process, waiting until server is ready for connections.
forked process: 2374
child process started successfully, parent exiting
[root@dghost var]# mongod -f /etc/mong_config3.conf 
about to fork child process, waiting until server is ready for connections.
forked process: 2388
child process started successfully, parent exiting
[root@dghost var]# ps -ef|grep mong
root      2360     1  0 15:19 ?        00:00:00 mongod -f /etc/mong_config1.conf
root      2374     1  1 15:19 ?        00:00:00 mongod -f /etc/mong_config2.conf
root      2388     1  2 15:19 ?        00:00:00 mongod -f /etc/mong_config3.conf
root      2401  2022  0 15:19 pts/0    00:00:00 grep mong

2    搭建路由服务器

    路由服务器要配置所有的节点都在哪

[root@dghost var]# cat /etc/mong_rount.conf 
port=28000--这个端口是路由端口
configdb=192.168.0.114:28001,192.168.0.114:28002,192.168.0.114:28003--指定所有节点的IP和配置端口
logpath=/var/log/mongodbs/mongos.log--指定路由的日志
logappend=true
fork=true

    启动路由服务器

[root@dghost var]# mongos -f /etc/mong_rount.conf 
about to fork child process, waiting until server is ready for connections.
forked process: 2406
child process started successfully, parent exiting
[root@dghost var]# ps -ef|grep mong
root      2360     1  0 15:19 ?        00:00:01 mongod -f /etc/mong_config1.conf
root      2374     1  0 15:19 ?        00:00:01 mongod -f /etc/mong_config2.conf
root      2388     1  0 15:19 ?        00:00:01 mongod -f /etc/mong_config3.conf
root      2406     1  0 15:22 ?        00:00:00 mongos -f /etc/mong_rount.conf
root      2466  2022  0 15:22 pts/0    00:00:00 grep mong

到现在我们在192.168.0.114 上搭建了3个配置,1个路由。所有供又4个进程。

3    搭建所有的分片节点

[root@dghost var]# mkdir /data/mongodb -p
# 先建立一个节点存储数据的路径
[root@dghost var]# cat /data/mongodb/mongo1.conf 
dbpath=/data/mongodb
logpath=/data/mongodb/mongo1.log
fork=true
port=27020
shardsvr=true
# 配置好节点启动参数
[root@dghost var]# mongod -f /data/mongodb/mongo1.conf 
about to fork child process, waiting until server is ready for connections.
forked process: 2499
child process started successfully, parent exiting
#节点1 启动成功,启动的节点都这样做

节点搭建好之后做分片

[root@dghost var]# mongo 192.168.0.114:28000
MongoDB shell version: 2.6.4
connecting to: 192.168.0.114:28000/test
#登陆路由服务器
mongos> show dbs
admin   (empty)
config  0.016GB
mongos> use admin
# 进入admin库
mongos> db.runCommand({addshard:"192.168.0.114:27020",allowLocal:true})
{ "shardAdded" : "shard0000", "ok" : 1 }
#添加节点成功
mongos> db.runCommand({addshard:"192.168.0.115:27020"})
{ "shardAdded" : "shard0001", "ok" : 1 }
#再加一个节点
mongos> use config
switched to db config
mongos> db.shards.find()
{ "_id" : "shard0000", "host" : "192.168.0.114:27020" }
{ "_id" : "shard0001", "host" : "192.168.0.115:27020" }
# 检查已经添加的连个节点
switched to db admin
mongos> db.runCommand({"enablesharding":"test_database"})
{ "ok" : 1 }
# 在admin 下需要指定哪个库需要分片
mongos> db.runCommand({"shardcollection":"test_database.test_table","key":{"_id":1}})
{ "collectionsharded" : "test_database.test_table", "ok" : 1 }
# 继续指定哪个表需要分片
mongos> db.databases.find()
{ "_id" : "admin", "partitioned" : false, "primary" : "config" }
{ "_id" : "test_database", "partitioned" : true, "primary" : "shard0000" }
# 库test_database 已经被设置未分片成功了
mongos> db.chunks.find()
{ "_id" : "test_database.test_table-_id_MinKey", "lastmod" : Timestamp(1, 0), "lastmodEpoch" : ObjectId("58ff0371b44f90194e6a262e"), "ns" : "test_database.test_table", "min" : { "_id" : { "$minKey" : 1 } }, "max" : { "_id" : { "$maxKey" : 1 } }, "shard" : "shard0000" }
# 这个也可以检查
mongos> sh.status()
--- Sharding Status --- 
  sharding version: {
    "_id" : 1,
    "version" : 4,
    "minCompatibleVersion" : 4,
    "currentVersion" : 5,
    "clusterId" : ObjectId("58fef935b44f90194e6a2496")
}
  shards:
    {  "_id" : "shard0000",  "host" : "192.168.0.114:27020" }
    {  "_id" : "shard0001",  "host" : "192.168.0.115:27020" }
  databases:
    {  "_id" : "admin",  "partitioned" : false,  "primary" : "config" }
    {  "_id" : "test_database",  "partitioned" : true,  "primary" : "shard0000" }
        test_database.test_table
            shard key: { "_id" : 1 }
            chunks:
                shard0000    1
            { "_id" : { "$minKey" : 1 } } -->> { "_id" : { "$maxKey" : 1 } } on : shard0000 Timestamp(1, 0) 
# 这个也可以检查

后面可以插入大量数据并检查,看是不是数据已经分片了

点赞
收藏
评论区
推荐文章
blmius blmius
3年前
MySQL:[Err] 1292 - Incorrect datetime value: ‘0000-00-00 00:00:00‘ for column ‘CREATE_TIME‘ at row 1
文章目录问题用navicat导入数据时,报错:原因这是因为当前的MySQL不支持datetime为0的情况。解决修改sql\mode:sql\mode:SQLMode定义了MySQL应支持的SQL语法、数据校验等,这样可以更容易地在不同的环境中使用MySQL。全局s
皕杰报表之UUID
​在我们用皕杰报表工具设计填报报表时,如何在新增行里自动增加id呢?能新增整数排序id吗?目前可以在新增行里自动增加id,但只能用uuid函数增加UUID编码,不能新增整数排序id。uuid函数说明:获取一个UUID,可以在填报表中用来创建数据ID语法:uuid()或uuid(sep)参数说明:sep布尔值,生成的uuid中是否包含分隔符'',缺省为
待兔 待兔
4个月前
手写Java HashMap源码
HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程HashMap的使用教程22
Jacquelyn38 Jacquelyn38
3年前
2020年前端实用代码段,为你的工作保驾护航
有空的时候,自己总结了几个代码段,在开发中也经常使用,谢谢。1、使用解构获取json数据let jsonData  id: 1,status: "OK",data: 'a', 'b';let  id, status, data: number   jsonData;console.log(id, status, number )
Wesley13 Wesley13
3年前
RAC环境单实例启动数据库收到ORA
     在RAC环境中,如果你在没有启动节点的集群服务的情况下单实例启动数据库,将收到类似如下的报错:\oracle@rhel1u01\$sqlSQL\Plus:Release10.2.0.5.0ProductiononTueApr215:00:272013Copyright(
Wesley13 Wesley13
3年前
GoJS API学习
varnode{};node"key""节点Key";node"loc""00";//节点坐标node"text""节点名称";//添加节点通过按钮点击,添加新的节点到画布myDiagram.model.addNodeData(nod
Stella981 Stella981
3年前
KVM调整cpu和内存
一.修改kvm虚拟机的配置1、virsheditcentos7找到“memory”和“vcpu”标签,将<namecentos7</name<uuid2220a6d1a36a4fbb8523e078b3dfe795</uuid
Stella981 Stella981
3年前
Django中Admin中的一些参数配置
设置在列表中显示的字段,id为django模型默认的主键list_display('id','name','sex','profession','email','qq','phone','status','create_time')设置在列表可编辑字段list_editable
Wesley13 Wesley13
3年前
MySQL部分从库上面因为大量的临时表tmp_table造成慢查询
背景描述Time:20190124T00:08:14.70572408:00User@Host:@Id:Schema:sentrymetaLast_errno:0Killed:0Query_time:0.315758Lock_
Python进阶者 Python进阶者
10个月前
Excel中这日期老是出来00:00:00,怎么用Pandas把这个去除
大家好,我是皮皮。一、前言前几天在Python白银交流群【上海新年人】问了一个Pandas数据筛选的问题。问题如下:这日期老是出来00:00:00,怎么把这个去除。二、实现过程后来【论草莓如何成为冻干莓】给了一个思路和代码如下:pd.toexcel之前把这