MongoDb分片集群搭建

基于mongodb3.6

分片集群的权限控制

Brief:

内部通过keyfile控制, 外部通过mongos控制角色用户访问。

Procedure

step1 创建密钥文件并修改其访问权限, 各个实例须用同一keyfile!!

openssl rand -base64 756 > <path-to-keyfile>
chmod 400 <path-to-keyfile>

step2 启动时增加参数 --keyFile <path-to-keyfile>
step3 创建相应角色用户(管理员, 集群管理员, 用户), admin(superman), clusterAdmin(clusterMan)及访问用户(testMan)

superman:  
db.getSiblingDB("admin").createUser( { user: "superman", pwd: "123456", roles: [ { role: "userAdminAnyDatabase", db: "admin" } ] })
clusterMan:  
db.getSiblingDB("admin").createUser( { "user" : "clusterMan", "pwd" : "123456", roles: [ { "role" : "clusterAdmin", "db" : "admin" } ] })
testMan:  
db.createUser( { "user" : "testMan", "pwd" : "123456", roles: [ { "role" : "read", "db" : "product" } ] })

搭建分片集群

以三台Server为例。

Procedure

step1 准备三台server(server1, server2, server3), 先在各server上安装mongodb并创建各实例要用到的dbpath, logpath;
step2 在各个server上以副本集形式(加"--replSet <name>" 参数)运行各个分片实例。

config: 
mongod --configsvr --replSet mongoConfig --dbpath /data/mongodata/config --port 27011 --fork --logpath  /data/logs/mongolog/config.log --keyFile /data/mongodata/mongo-keyfile/keyfile
shard1: 
mongod --shardsvr --replSet shard1 --dbpath /data/mongodata/shard1 --port 27031 --nojournal --fork --logpath /data/logs/mongolog/shard1.log --keyFile /data/mongodata/mongo-keyfile/keyfile
shard2: 
mongod --shardsvr --replSet shard2 --dbpath /data/mongodata/shard2 --port 27032 --nojournal --fork --logpath /data/logs/mongolog/shard2.log  --keyFile /data/mongodata/mongo-keyfile/keyfile
shard3: 
mongod --shardsvr --replSet shard3 --dbpath /data/mongodata/shard3 --port 27033 --nojournal --fork --logpath /data/logs/mongolog/shard3.log --keyFile /data/mongodata/mongo-keyfile/keyfile
rout: 
mongos --configdb mongoConfig/<server1-ip>:27011,<server2-ip>:27011,<server3-ip>:27011 --port 27021 --fork --logpath /data/logs/mongolog/rout.log  --keyFile /data/mongodata/mongo-keyfile/keyfile

step3 启动副本集(replica set)
首先:
分别连接到各个副本集中的任一实例 mongo --host <hostname> --port <port>

config: 
rs.initiate( { _id : "mongoConfig", configsvr: true, members: [ { _id : 0, host : "<server1-ip>:27011" }, { _id : 1, host : "<server2-ip>:27011" }, { _id : 2, host : "<server3-ip>:27011" } ] })
shard1: 
rs.initiate( { _id : "shard1", members: [ { _id : 0, host : "<server1-ip>:27031" }, { _id : 1, host : "<server2-ip>:27031" }, { _id : 2, host : "<server3-ip>:27031" } ] })
shard2: 
rs.initiate( { _id : "shard2", members: [ { _id : 0, host : "<server1-ip>:27032" }, { _id : 1, host : "<server2-ip>:27032" }, { _id : 2, host : "<server3-ip>:27032" } ] })
shard3: 
rs.initiate( { _id : "shard3", members: [ { _id : 0, host : "<server1-ip>:27033" }, { _id : 1, host : "<server2-ip>:27033" }, { _id : 2, host : "<server3-ip>:27033" } ] })

step4 往集群添加各个分片集(各个分片集指定一个代表即可)
sh.addShard( "<replSetName>/s1-mongo1.example.net:port")
example:
sh.addShard( "shard1/<server1-ip>:27031")
step5 为database开启分片能力, collection
sh.enableSharding("<dbName>")
example:
sh.enableSharding("product")
step6 将collection分片
sh.shardCollection("<database>.<collection>", { <shardKey> : <direction> } )

注意:
shardKey(分片键/分片索引):
(1)分片键决定集合(表)在集群分片中的分布, 所以分片键的选择很重要。
(2)分片集合必须有一个分片索引来支持分片, 如果集合为空, sh.shardCollection()命令将创建一个默认索引(应该是"_id"字段, 官方文档未明说), 否则, 请自己创建索引。