Mongodb分片配置实例

数据分片即是从一个集合中选择一个片键(shard key)作为数据拆分的依据,原理与索引类似,然后将集合的数据拆分并保存到不同的服务器上。
以下通过一个例子来介绍一下Mongodb的分片配置。

有四台主机:

  • 172.17.0.6 (配置服务器)
  • 172.17.0.7 (mongos)
  • 172.17.0.8 (片服务器)
  • 172.17.0.9 (片服务器)

1.在 172.17.0.6 上启动 mongod 服务作为配置服务器;
修改配置,使其作为一个配置服务器,默认监听 27019 端口。

1
configsvr = true

启动服务 $ service mongodb start

2.在 172.17.0.7 上启动 mongos 服务作为路由服务;
建立mongos进程。(可以有多台配置服务器),用法如下:

1
$ mongos --configdb <config server hostnames>[,<config server hostnames>]

例如: $ mongos --configdb 172.17.0.6:27019

注意:在同一个分片集群中的每个 mongos 必须使用相同的 configDB 配置。

3.添加分片
一个片服务既可以是单个 mongod 实例,也可以是一个副本集。
1).先分别在 172.17.0.8 和 172.17.0.9 上启动片服务器,即就是一个普通的 mongod 服务。

1
$ service mongodb start

2).使用 mongo 客户端连接到 mongos 服务

1
$ mongo --host <hostname of machine running mongos> --port <port mongos listens on>

如: $ mongo --host 172.17.0.7 --port 27017

3).在 mongo 客户端上执行命令添加分片:

1
2
3
4
> use admin
> db.auth(<user>, <pswd>)
> sh.addShard("172.17.0.8:27017")
> sh.addShard("172.17.0.9:27017")

4.切片数据
1).首先对数据库进行切片
使用 mongo 客户端连接到 mongos ,执行命令打开数据库的分片功能,用法如下:

1
> sh.enableSharding("<database>")

例如要打开 mydb 数据库的分片功能: > sh.enableSharding("mydb")

2).然后对数据集合进行切片
命令用法如下:

1
> sh.shardCollection("<database>.<collection>", shard-key-pattern)

shard-key-pattern 与索引的用法一样,例如,要对 mydb 数据库的 test 集合按照 _id 字段进行分片: > sh.shardCollection("mydb.test", {"_id": "hashed"})

接下来通过一个程序来测试一下,向数据库中添加10000条数据:

1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
#!/usr/bin/env ruby
#-*- coding:utf-8 -*-
require "mongo"
begin
conn = Mongo::Connection.new '172.17.0.7'
db = conn['mydb']
rescue Exception=>e
p e
exit 1
end
i = 0
while i < 10000
d = {'no' => i}
d = db['test'].insert(d)
i += 1
puts d
end

然后分别查看 172.17.0.8 和 172.17.0.9 的状态:

1
2
3
4
5
6
7
172.17.0.8:
> db.test.count()
4952
172.17.0.9:
> db.test.count()
5048

数据基本上是平均的分布在两台服务器上。

参考: http://docs.mongodb.org/manual/tutorial/deploy-shard-cluster/