MongoDB的分片集群基本配置教程
|
为何要分片
常见的mongodb sharding 服务器架构
要构建一个 MongoDB Sharding Cluster，需要三种角色： 配置分片服务器
Shard Server 1：27017 Shard Server 2：27018 Config Server ：27027 Route Process：40000 1.步骤一: 启动Shard Server mkdir -p ./data/shard/s0 ./data/shard/s1 #创建数据目录 mkdir -p ./data/shard/log # 创建日志目录 ./bin/mongod --port 27017 --dbpath /usr/local/mongodb/data/shard/s0 --fork --logpath /usr/local/mongodb/data/shard/log/s0.log # 启动Shard Server实例1 ./bin/mongod --port 27018 --dbpath /usr/local/mongodb/data/shard/s1 --fork --logpath /usr/local/mongodb/data/shard/log/s1.log # 启动Shard Server实例2 步2.骤二: 启动Config Server mkdir -p ./data/shard/config #创建数据目录 ./bin/mongod --port 27027 --dbpath /usr/local/mongodb/data/shard/config --fork --logpath /usr/local/mongodb/data/shard/log/config.log #启动Config Server实例 注意，这里我们完全可以像启动普通mongodb服务一样启动，不需要添加―shardsvr和configsvr参数。因为这两个参数的作用就是改变启动端口的，所以我们自行指定了端口就可以
# 我们使用MongoDB Shell登录到mongos，添加Shard节点
./bin/mongo admin --port 40000 #此操作需要连接admin库
> db.runCommand({ addshard:"localhost:27017" }) #添加 Shard Server 或者用 sh.addshard()命令来添加,下同;
{ "shardAdded" : "shard0000","ok" : 1 }
> db.runCommand({ addshard:"localhost:27018" })
{ "shardAdded" : "shard0001","ok" : 1 }
> db.runCommand({ enablesharding:"test" }) #设置分片存储的数据库
{ "ok" : 1 }
> db.runCommand({ shardcollection: "test.users",key: { id:1 }}) # 设置分片的集合名称。且必须指定Shard Key，系统会自动创建索引，然后根据这个shard Key来计算
{ "collectionsharded" : "test.users","ok" : 1 }
> sh.status(); #查看片的状态
> printShardingStatus(db.getSisterDB("config"),1); # 查看片状态(完整版);
> db.stats(); # 查看所有的分片服务器状态
注意这里我们要注意片键的选择，选择片键时需要根据具体业务的数据形态来选择，切不可随意选择，实际中尤其不要轻易选择自增_id作为片键，除非你很清楚你这么做的目的，具体原因我不在此分析，根据经验推荐一种较合理的片键方式，“自增字段+查询字段”，没错，片键可以是多个字段的组合。 手动预先分片
sh.shardCollection(‘shop.user',{userid:1}); # user表用userid做shard key
for(var i=1;i<=40;i++) { sh.splitAt('shop.user',{userid:i*1000}) } # 预先在1K 2K...40K这样的界限切好chunk(虽然chunk是空的),这些chunk将会均匀移动到各片上.
通过mongos添加user数据. 数据会添加到预先分配好的chunk上,chunk就不会来回移动了.
repliction set and shard 查看分片配置的方法： 1.列举使用分片的数据库
use config
db.databases.find( { "partitioned" : true} )
例如：使用以下命令返回集群中的所有数据库 use config db.databases.find() 如果返回结果：
{ "_id" : "admin","partitioned" : false,"primary" : "config" }
{ "_id" : "mydb","partitioned" : true,"primary" : "firstset" }
{ "_id" : "test","primary" : "secondset" }
显示只有mydb使用了分片。 2.列举所有的分片
use admin
db.runCommand( { listShards : 1 })
返回结果：
{
"shards" : [
{
"_id" : "firstset","host" : "firstset/mongo01:10001,mongo01:10002,mongo01:10003"
},{
"_id" : "secondset","host" : "secondset/mongo01:30001,mongo01:30002,mongo01:30003"
}
],"ok" : 1
}
3.查看集群的详细信息 sh.status() 查看信息：
--- Sharding Status ---
sharding version: {
"_id" : 1,"version" : 4,"minCompatibleVersion" : 4,"currentVersion" : 5,"clusterId" : ObjectId("535a2dab0063b308757e1b70")
}
shards:
{ "_id" : "firstset",mongo01:10003" }
{ "_id" : "secondset",mongo01:30003" }
databases:
{ "_id" : "admin","primary" : "config" }
{ "_id" : "mydb","primary" : "firstset" }
mydb.test_collection
shard key: { "name" : 1 }
chunks:
secondset 6
firstset 6
{ "name" : { "$minKey" : 1 } } -->> { "name" : "cat" } on : secondset Timestamp(2,0)
{ "name" : "cat" } -->> { "name" : "cow" } on : secondset Timestamp(3,0)
{ "name" : "cow" } -->> { "name" : "dog" } on : secondset Timestamp(4,0)
{ "name" : "dog" } -->> { "name" : "dragon" } on : secondset Timestamp(5,0)
{ "name" : "dragon" } -->> { "name" : "elephant" } on : secondset Timestamp(6,0)
{ "name" : "elephant" } -->> { "name" : "horse" } on : secondset Timestamp(7,0)
{ "name" : "horse" } -->> { "name" : "lion" } on : firstset Timestamp(7,1)
{ "name" : "lion" } -->> { "name" : "pig" } on : firstset Timestamp(1,7)
{ "name" : "pig" } -->> { "name" : "rabbit" } on : firstset Timestamp(1,8)
{ "name" : "rabbit" } -->> { "name" : "snake" } on : firstset Timestamp(1,9)
{ "name" : "snake" } -->> { "name" : "tiger" } on : firstset Timestamp(1,10)
{ "name" : "tiger" } -->> { "name" : { "$maxKey" : 1 } } on : firstset Timestamp(1,11)
{ "_id" : "test","primary" : "secondset" }
（1）sharding version展示了分片元数据的版本号。 您可能感兴趣的文章:
（编辑：李大同） 【声明】本站内容均来自网络，其相关言论仅代表作者个人观点，不代表本站立场。若无意侵犯到您的权利，请及时与联系站长删除相关内容! |
