mongodb之分片复制集的搭建

本文主要是介绍mongodb之分片复制集的搭建，对大家解决编程问题具有一定的参考价值，需要的程序猿们随着小编来一起学习吧！

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中的数据库 进行验证

这篇关于mongodb之分片复制集的搭建的文章就介绍到这儿，希望我们推荐的文章对大家有所帮助，也希望大家多多支持为之网！