MongoDB学习整理之Replica Sets安装

准备：



1、创建数据文件、日志路径目录及复制集key文件

mkdir -p /app/mongo/mongodb/data/sets/r0

mkdir -p /app/mongo/mongodb/data/sets/r1

mkdir -p /app/mongo/mongodb/data/sets/r2

mkdir -p /app/mongo/mongodb/data/sets/key/

mkdir -p /app/mongo/mongodb/data/sets/log/

echo "test sets" > /app/mongo/mongodb/data/sets/key/r0

echo "test sets" > /app/mongo/mongodb/data/sets/key/r1

echo "test sets" > /app/mongo/mongodb/data/sets/key/r2

chmod 600 /app/mongo/mongodb/data/sets/key/r*

2、启动3个mongodb实例模拟3个节点服务器：

/app/mongo/mongodb/bin/mongod --replSet rs1 --keyFile /app/mongo/mongodb/data/sets/key/r0 --port 28010 --dbpath=/app/mongo/mongodb/data/sets/r0 --logpath=/app/mongo/mongodb/data/sets/log/r0.log --logappend --fork

/app/mongo/mongodb/bin/mongod --replSet rs1 --keyFile /app/mongo/mongodb/data/sets/key/r1 --port 28011 --dbpath=/app/mongo/mongodb/data/sets/r1 --logpath=/app/mongo/mongodb/data/sets/log/r2.log --logappend --fork

/app/mongo/mongodb/bin/mongod --replSet rs1 --keyFile /app/mongo/mongodb/data/sets/key/r2 --port 28012 --dbpath=/app/mongo/mongodb/data/sets/r2 --logpath=/app/mongo/mongodb/data/sets/log/r3.log --logappend --fork

3、初始化Replica Sets环境

[mongodb@ST03SN01 mongo]$ /app/mongo/mongodb/bin/mongo -port 28010 //连接

>config_rs={_id:'rs1',members:[{_id:0,host:'localhost:28010'},{_id:1,host:'localhost:28011'},{_id:2,host:'localhost:28012'}]}

>rs.initiate(config_rs);

4、查看复制集状态，分析复制集的各项运行指标,如图所示：





ok，安装Replica Sets就成功了！下面我们在了解一下有关Replica Sets管理信息：

主从操作日志：

通过一个primary数据库的日志表来存储写操作，日志表oplog.rs,固定Capped Collection，位于local数据库，可以通过启动参数oplogSize改变

PRIMARY> db.oplog.rs.find()

{ "ts" : { "t" : 1339511556000, "i" : 1 }, "h" : NumberLong(0), "op" : "n", "ns" : "", "o" : { "msg" : "initiating set" } }

PRIMARY> db.printReplicationInfo()



configured oplog size:配置的oplog文件大小

log length start to end：oplog日志的启用时间段

oplog first event time：第一个事务日志产生时间

oplog last event time:最后一个事务日志产生时间

now：现在的时间

查看复制集的同步状态：



source:从库的IP及端口

syncedTo:目前同步情况及最后一次同步时间

主从配置信息：

在local库system.replset集合保存了所有Replica Sets的配置信息，如下：

PRIMARY> db.system.replset.find()

{ "_id" : "rs1", "version" : 1, "members" : [

{ "_id" : 0, "host" : "localhost:28010" },

{ "_id" : 1, "host" : "localhost:28011" },

{ "_id" : 2, "host" : "localhost:28012" } ]

}

管理Replica Sets

1、主从切换测试：

环境：

端口 当前成员角色 目标成员角色

28010 主 从

28011 从 从

28012 从 主

1）除了现在的主实例（端口28010）和目标主实例（端口28012）以外，其他实例全部为“冰冻”状态（即非主状态），代码如下：

[mongodb@ST03SN01 mongo]$ /app/mongo/mongodb/bin/mongo -port 28011

SECONDARY> rs.fressze(30) --代表30秒内不参加内部选举工作

2）将当前主库的实例“降级”（stepDown），代码如下：

[mongodb@ST03SN01 mongo]$ /app/mongo/mongodb/bin/mongo -port 28010

rs.stepDown(30) ---30秒内这个实例不会把自己选为primary角色

3）查看复制集状态，状态就切换了，如下显示：



2、读写分离测试：根据性能进行分配到不同的机器，然后进行快速的数据同步

1）先向主库插入一条测试数据，代码如下：



2）在从库里是不让查看的，如图所示：



3）让从库可以读，以分担主库的压力



3、故障转移测试

1）杀掉28010端口的Mongodb进程，如下图所示：



2）查看复制集的状态



3）继续服务：



4、增加节点，Mongodb提供了两种方法添加节点：一种是通过oplog增加节点，另一种通过数据库快照和oplog添加节点

1）通过oplog增加节点：数据同步完全依赖于oplog，即oplog中有多少操作日志，都需要在新节点执行一遍，以达到数据同步，优点操作简单且无需人工干预，但是oplog是Capped collection，所以会导致数据不全和不一致

a、启动一个新节点

mkdir -p /app/mongo/mongodb/data/sets/r3

echo "test sets" > /app/mongo/mongodb/data/sets/key/r3

chmod 600 /app/mongo/mongodb/data/sets/key/r3

/app/mongo/mongodb/bin/mongod --replSet rs1 --keyFile /app/mongo/mongodb/data/sets/key/r3 --port 28013 --dbpath=/app/mongo/mongodb/data/sets/r3 --logpath=/app/mongo/mongodb/data/sets/log/r3.log --logappend --fork

b、添加新节点到现有Replica Set是中，如：

rs.add("localhost:28013")

c、查看复制状态，可以看到新节点，但状态为不可用，因为还为数据同步

d、执行数据同步（自动）

e、使用新节点查询数据，如图：



2）通过数据库快照和oplog增加节点：取某一个复制集成员的物理文件作为初始化数据，剩余的部分用oplog日志来补充，达到数据一致性，步骤如下：

a、取某一个复制集成员的物理文件作为初始化数据，操作如下：

scp -r /app/mongo/mongodb/data/sets/r3 /app/mongo/mongodb/data/sets/r4

echo "test Sets" > /app/mongo/mongodb/data/sets/key/r4

chmod 600 /app/mongo/mongodb/data/sets/key/r4

b、为了验证用oplog日志来补充数据，我们在主库c1集合插入一个新记录，如下：



c、启动28014端口给新的节点，如下所示：

/app/mongo/mongodb/bin/mongod --replSet rs1 --keyFile /app/mongo/mongodb/data/sets/key/r4 --port 28014 --dbpath=/app/mongo/mongodb/data/sets/r4 --logpath=/app/mongo/mongodb/data/sets/log/r4.log --logappend --fork

d、添加28014节点到现有的复制集中，如下所示：

PRIMARY> rs.add("localhost:28014")

{ "ok" : 1 }

PRIMARY>

e、验证数据已经同步。查看是否一个记录从物理文件同步过来的，一条是从操作日志同步过来的，如下所示：



5、减少节点是减少成本，减少节点很简单，只需调用rs.remove()就行，比如：我们要移除28013和28014，操作如下：

PRIMARY> rs.remove("localhost:28013")

PRIMARY> rs.remove("localhost:28014")