集群搭建:副本集模式
如图:
Primary主;secondary从;Arbiter仲裁节点;客户端同时连接主从节点,不连接仲裁节点。
准备:三台主机,举例10.32.0.1;10.32.0.2;10,32,0,3 均配置好mongoDB
搭建:
1、建立数据文件夹
一般情况下不会把数据目录建立在mongodb的解压目录下,不过这里方便起见。
mkdir -p /mongodb/data/master
mkdir -p /mongodb/data/slaver
mkdir -p /mongodb/data/arbiter
#三个目录分别对应主,备,仲裁节点
2.建立配置文件
采用配置文件方式启动比较方便
#master.conf
dbpath=/user/local/mongodb/data/master
logpath=/user/local/mongodb/logs/master.log
pidfilepath=/user/local/mongodb/master.pid
directoryperdb=true
logappend=true
replSet=testrs
bind_ip=10.32.0.1
port=27017
oplogSize=10000
fork=true
noprealloc=true
#slaver.conf
dbpath=/user/local/mongodb/data/slaver
logpath=/user/local/mongodb/logs/slaver.log
pidfilepath=/user/local/mongodb/slaver.pid
directoryperdb=true
logappend=true
replSet=testrs
bind_ip=10.32.0.2
port=27017
oplogSize=10000
fork=true
noprealloc=true
#arbiter.conf
dbpath=/user/local/mongodb/data/arbiter
logpath=/user/local/mongodb/logs/arbiter.log
pidfilepath=/user/local/mongodb/arbiter.pid
directoryperdb=true
logappend=true
replSet=testrs
bind_ip=10.32.0.3
port=27027
oplogSize=10000
fork=true
noprealloc=true
参数解释:
dbpath:数据存放目录
logpath:日志存放路径
pidfilepath:进程文件,方便停止mongodb
directoryperdb:为每一个数据库按照数据库名建立文件夹存放
logappend:以追加的方式记录日志
replSet:replica set的名字
bind_ip:mongodb所绑定的ip地址
port:mongodb进程所使用的端口号,默认为27017
oplogSize:mongodb操作日志文件的最大大小。单位为Mb,默认为硬盘剩余空间的5%
fork:以后台方式运行进程
noprealloc:不预先分配存储
3、启动mongodb
进入到bin目录下分别启动
./monood -f master.conf
./mongod -f slaver.conf
./mongod -f arbiter.conf
4.使集群生效
1、登录可以通过客户端连接mongodb,也可以直接在三个节点中选择一个连接mongodb。
./mongo 10.32.0.1:27017 #ip和port是某个节点的地址
2.1、初始化复制集
>use admin
>cfg={ _id:"testrs", members:[ {_id:0,host:'10.32.0.1.130:27017',priority:2}, {_id:1,host:'10.32.0.2.131:27017',priority:1},
{_id:2,host:'10.32.0.3:27017',arbiterOnly:true}] };
>rs.initiate(cfg) #使配置生效
cfg是可以任意的名字,当然最好不要是mongodb的关键字,conf,config都可以。最外层的_id表示replica set的名字,members里包含的是所有节点的地址以及优先级。优先级最高的即成为主节点,即这里的10.32.0.1:27017。特别注意的是,对于仲裁节点,需要有个特别的配置——arbiterOnly:true。这个千万不能少了,不然主备模式就不能生效。
配置的生效时间根据不同的机器配置会有长有短,配置不错的话基本上十几秒内就能生效,有的配置需要一两分钟。如果生效了,执行rs.status()命令查看集群状态。
2.2、另一种写法
>rs.initiate({_id:"testrs",members:[{ _id:0,host:'10.32.0.1:27017'}]})
>rs.add("10.32.0.2:27017")
>rs.addArb("10.32.0.3:27017")
成功后rs.status()显示(或者db.isMaster()):
{
"set" : "testrs",
"date" : ISODate("2016-07-04T15:46:30.941Z"),
"myState" : 2,
"term" : NumberLong(3),
"syncingTo" : "10.32.0.1:27017",
"heartbeatIntervalMillis" : NumberLong(2000),
"members" : [
{
"_id" : 0,
"name" : "10.32.0.1:27017",
"health" : 1,
"state" : 1,
"stateStr" : "PRIMARY",
"uptime" : 4622,
"optime" : {
"ts" : Timestamp(1467699119, 2),
"t" : NumberLong(3)
},
"optimeDate" : ISODate("2016-07-05T06:11:59Z"),
"lastHeartbeat" : ISODate("2016-07-04T15:46:30.457Z"),
"lastHeartbeatRecv" : ISODate("2016-07-04T15:46:29.780Z"),
"pingMs" : NumberLong(0),
"electionTime" : Timestamp(1467699119, 1),
"electionDate" : ISODate("2016-07-05T06:11:59Z"),
"configVersion" : 1
},
{
"_id" : 1,
"name" : "10.32.0.2:27017",
"health" : 1,
"state" : 2,
"stateStr" : "SECONDARY",
"uptime" : 6982,
"optime" : {
"ts" : Timestamp(1467699119, 2),
"t" : NumberLong(3)
},
"optimeDate" : ISODate("2016-07-05T06:11:59Z"),
"syncingTo" : "10.32.0.1:27017",
"configVersion" : 1,
"self" : true
},
{
"_id" : 2,
"name" : "10.32.0.3:27017",
"health" : 1,
"state" : 7,
"stateStr" : "ARBITER",
"uptime" : 6081,
"lastHeartbeat" : ISODate("2016-07-04T15:46:30.457Z"),
"lastHeartbeatRecv" : ISODate("2016-07-04T15:46:26.129Z"),
"pingMs" : NumberLong(0),
"configVersion" : 1
}
],
"ok" : 1
}
详细说明:
"_id" : #集群中节点编号
"name" : #成员服务器名称及端口
"health" : #表示成员中的健康状态(0:down;1:up)
"state" : #为0~10,表示成员的当前状态
"stateStr" : #描述该成员是主库(PRIMARY)还是备库(SECONDARY)
"uptime" : #该成员在线时间(秒)
"optime" : #成员最后一次应用日志(oplog)的信息
"optimeDate" : #成员最后一次应用日志(oplog)的时间
"electionTime" : #当前primary从操作日志中选举信息
"electionDate" : #当前primary被选定为primary的日期
"configVersion" : #mongodb版本
"self" : #为true 表示当前节点
2.3、设置某个节点永远不会成为主节点,设置优先级为0
cfg = rs.conf()
cfg.members[0].priority = 0.5
cfg.members[1].priority = 0.5
cfg.members[2].priority = 0
rs.reconfig(cfg)
说明:其中成员编号 0/1/2 为 rs.status()中的 "_id"值
members[2]则它将用于不会变成主节点
2.4、移除某成员
rs.remove("10.32.0.2:27017")
或者:
cfg = rs.conf()
cfg.members.splice(2,1)
rs.reconfig(cfg)
之后将移除服务器的conf中replSet项删除。
5.测试
1、主写——从读
涉及问题从服务需要开启读操作
testrs:SECONDARY> rs.slaveOk();
或者
testrs:SECONDARY> db.getMongo().setSlaveOk();
2、kill主观察从情况
3、启动主观察从情况
参考:
http://blog.csdn.net/luonanqin/article/details/8497860
http://blog.csdn.net/kk185800961/article/details/45700485
http://blog.csdn.net/kk185800961/article/details/45791903