MongoDB Replica Sets

用途

1、数据冗余
2、自动故障转移
3、分发读取负载
4、简化维护（比“正常”的主从）
5、从用户错误的灾难恢复

配置

MongoDB的Replica Set是一个异步的主从复制集，增加了自动故障转移和节点自动恢复功能，它是主/从结构的超级，包含了主/从结构的所有功能。

Replica Set需要最少两个Server,配置最简单的Replica Set可以是两台服务器加一台仲裁服务器或者是三台服务器，仲裁服务器不保存任何数据，只作打破选举用，普通的服务器即可，甚至可以部署在应用服务器上。

以下以三台服务器为例，书写Replica Set的详细配置过程，配置成功之后若PRIMARY宕机或者出现异常，Replica Set会马上切换其中的一台SECORDARY为PRIMARY，这个过程大概在30秒之内，由Replica Set自动完成。

启动三个实例

./
mongod --
replSet foo --
rest --
host 192.168.61.110 --
port 27017
 --
dbpath /
data/
r0
./
mongod --
replSet foo --
rest --
host 192.168.61.111 --
port 27017
 --
dbpath /
data/
r0
./
mongod --
replSet foo --
rest --
host 192.168.61.112 --
port 27017
 --
dbpath /
data/
r0

访问http://192.168.61.110:28017/_replSet ，可以查看replica set情况

注：其他两个地址同样可以访问，以查看Replica Set的状态。

初始化replica set

在192.168.61.110上使用mongo工具连接到MongoDB。

# ./
mongo
>
 rs.initiate
(
)
;

 

增加节点到replica set

>
 rs.add
(
“192.168.61.111:
27017
”)

{
 “ok” :
 1
 }

>
 rs.addArb
(
“192.168.61.112:
27017
”)

{
 “ok” :
 1
 }

这样一个基本的Replica Set就算是搭建好了，通过http://192.168.61.110:28017/_replSet ,查看到现在110是PRIMARY（主），111和112都是SECORDARY(从)

测试

在192.168.61.110上使用mongo工具连接到MongoDB

--
连接到MongoDB,使用Shell
# ./
mongo 
>
 db.message
.save
(
{
name:
"Replica Set"
}
)

由于同一时刻只有PRIMARY是可以通过./mongo命令连接，然后进行读写，SECORDARY不允许进行读写的

mongo工具查看Replica Set配置情况的命令

rs.status()//查看ReplSet的状态
rs.conf() //查看ReplSet的配置

读写负载

一般情况下所有的读写都是在primary node上进行的，但是现在大多数的驱动都提供了slaveOk方法，由此可以使用secondary node进行读的负载，从而降低primary node的负载。

List
 addrs =
 new
 ArrayList
(
)
;

addrs.add
(
new
 ServerAddress(
"127.0.0.1"
, 27017)
)
;

addrs.add
(
new
 ServerAddress(
"127.0.0.1"
, 27018)
)
;

addrs.add
(
new
 ServerAddress(
"127.0.0.1"
, 27019)
)
;

Mongo mongo =
 new
 Mongo(
addrs)
;
 
DB db =
 mongo.getDB
(
"test"
)
;

 
collection.slaveOk
(
)
;
  //开启slaveOk，

DBCursor cursor =
 collection.findOne
(
)
;

增加新节点

不能直接将一个新节点使用rs.add()命令增加进去，首先必须拷贝一份数据文件到新节点，使他们之间的时间差不至于太大，因为Replica Set的Oplog是Capped Collection,日志大小有限。
然后再将节点使用rs.add()加入到Replica Set中。

由Master/Slave升级到Replica Set

确定主服务器

>
 db.isMaster
(
)

{

        "ismaster"
 :
 0
,
        "remote"
 :
 "localhost:27018"
,
        "info"
 :
 "direct negotiation"
,
        "maxBsonObjectSize"
 :
 16777216
,
        "ok"
 :
 1

}

 

 

关闭主从的服务

m$ killall mongod
s$ killall mongod

 

备份数据库文件

m$ cp /
data/
db/* /to_somewhere_backup/
s$ cp /data/db/* /to_slave_backup/

 

以Replica Set模式启动主服务器

m$ mongod --
rest --
replSet mysetname
m$ mongo
m>
 rs.initiate
(
)

 

增加节点

方式一：同步Slaves
一、删除数据文件

s$ rm -
r /
data/
db/* # if you're using a non-default dbpath, this may be somewhere else
s$ # /data/db is now empty

二、启动Slave

s$ mongod --
rest --
replSet mysetname

三、增加节点

m>
 // still in the mongo shell on the master

m>
 rs.add
(
"s"
)
 // "s" is your slave host name



m>
 rs.status
(
)
;
 // see also http://localhost:28017/_replSet

方式二、使用现有文件
一、启动Slave

s$ mongod --
rest --
replSet mysetname --
fastsync

二、增加节点

m>
 // still in the mongo shell on the master

m>
 rs.add
(
"s"
)
 // "s" is your slave host name



m>
 rs.status
(
)
;
 // see also http://localhost:28017/_replSet

 

增加arbiter(仲裁)

一、启动节点

arb$ mkdir /
data/
arb
arb$ mongod --
rest --
replSet mysetname --
dbpath /
data/
arb --
port 30000

二、增加仲裁

m>
 rs.addArb
(
"arb:30000"
)
;
 // replace 'arb' with your arb host name

m>
 rs.status
(
)

 

更换相应的驱动

Replica Set开启slaveOk

则查询可能发生在不同的服务器上，为了保证写完之后读能有数据（因为从PRIMARY同步到SECORDARY需要一定的时间），

使用以下代码即可

DB db...;

db.requestStart
(
)
;

code....
db
.requestDone
(
)
;

 

写确定（WriteConcern）

DBCollection coll...;

coll.insert
(
..., WriteConcern.SAFE
)
;

// is equivalent to

DB db...;

DBCollection coll...;

db.requestStart
(
)
;

coll.insert
(
...)
;

DBObject err =
 db.getLastError
(
)
;

db.requestDone
(
)
;