mongodb之分片复制集的搭建

系统管理员 2022-10-05 00:52 166阅读 0赞

mongodb 分片是通过路由节点访问分片的节点。路由节点的配置数据存放在配置节点

1.配置并启动config节点集群（高可用配置多个，配置信息一样）

#数据库文件位置
    dbpath=config/config1
    #日志文件位置
    logpath=config/logs/config1.log
    #以追加方式写入日志
    logappend=true
    #以守护进程运行
    fork=true
    bind_ip=0.0.0.0
    port=17017
    #表示是一个配置服务器
    configsvr=true
    #配置服务器副本集名称
    replSet=configsvri

2.启动所有配置集群节点

./bin/mongod -f 配置文件

3.进入任意节点的mongo shell并添加配置节点集群 注意use admin

./bin/mongo --port 17017
    
    use admin
    var cfg={ 
    	"_id":"configsvri",
    	"members":[
    	{ "_id":1,"host":"192.168.1.9:17017"},
    	{ "_id":2,"host":"192.168.1.9:17018"},
    	{ "_id":3,"host":"192.168.1.9:17019"},
    	]
    };
    
    rs.initiate(cfg)

4.配置shard 1集群（高可用配置多个，配置信息一样）

dbpath=shard/shard1/shard1-37017
    bind_ip=0.0.0.0
    port=37017
    fork=true
    logpath=shard/shard1/shard1-37017.log
    replSet=shard1
    shardsvr=true

启动每个mongo 然后进入其中一个进行集群配置

var cfg={ 
    	"_id":"shard1",
    	"protocolVersion":1,
    	"members":[
    		{ "_id":1,"host":"192.168.1.9:37017"},
    		{ "_id":2,"host":"192.168.1.9:37018"},
    		{ "_id":3,"host":"192.168.1.9:37019"}
    	]
    }
    rs.initiate(cfg)
    rs.status()

5.配置shard 2集群（高可用配置多个，配置信息一样）

dbpath=shard2/shard2-47017
    bind_ip=0.0.0.0
    port=47017
    fork=true
    logpath=shard2/shard2-47017.log
    replSet=shard2
    shardsvr=true

启动每一个mongod 然后进入其中一个进行集群配置

./bin/mongo  --port 47017
    var cfg={ 
    	"_id":"shard2",
    	"protocolVersion":1,
    	"members":[
    		{ "_id":1,"host":"192.168.1.9:47017"},
    		{ "_id":2,"host":"192.168.1.9:47018"},
    		{ "_id":3,"host":"192.168.1.9:47019"}
    	]
    }
    rs.initiate(cfg)
    rs.status()

6.配置和启动 路由节点

route-27017.conf
    
    port=27017
    bind_ip=0.0.0.0
    fork=true
    logpath=route/logs/route.log
    configdb=configsvr/192.168.1.9:17017,192.168.1.9:17018,192.168.1.9:17019

启动路由节点使用mongos

./bin/mongos -f 配置文件

7.mongos(路由) 中添加分片节点  
进入路由mongos

./bin/mongo --port 27017
    sh.status()
    sh.addShard("shard1/192.168.1.9:37017,192.168.1.9:37018,192.168.1.9:37019")
    sh.addShard("shard2/192.168.1.9:47017,192.168.1.9:47018,192.168.1.9:47019")
    sh.status()

8.开启数据库和集合分片（指定分片键）  
继续使用mongos完成分片开启和分片大小设置

为数据库开启分片功能

sh.enableSharding("yyj_resume")

为指定集合开启分片功能

sh.shardCollection("yyj_resume.yyj_resume_datas",{ "片键字段名如 name":索引类型如 hashed})

9.向集合中插入数据测试  
通过路由循环向集合中添加数据  
use yyj\_resume;  
for(var i=1;i<=1000;i++)\{  
db.yyj\_resume\_datas.insert(\{“name”:“test”+i,  
salary:(Math.random()\*20000).toFixed(2)\});  
\}

10.验证分片效果  
分别进入shard1和shard2中的数据库 进行验证