阿里云-云小站（无限量代金券发放中）
【腾讯云】云服务器、云数据库、COS、CDN、短信等热卖云产品特惠抢购

MongoDB的集群模式 – Replica Set

219次阅读
没有评论

共计 9567 个字符，预计需要花费 24 分钟才能阅读完成。

一、Replica Set 集群分为两种架构：

  • 奇数个节点构成 Replica Set，所有节点拥有数据集。最小架构: 1 个 Primary 节点，2 个 Secondary 节点

MongoDB 的集群模式 - Replica Set

  • 偶数个节点 + 一个仲裁节点 构成的 Replica Set，节点拥有数据集，仲裁节点仅参与仲裁选举出 Primary 节点。最小架构：1 个 Primary 节点，1 个 Secondary 节点，1 个 Arbiter 节点
  •  MongoDB 的集群模式 - Replica Set

接下来就以 3 台服务器为例，部署具有仲裁的框架。

IP 地址 操作系统版本 MongoDB 版本 端口 功能
10.10.18.10 CentOS7.5  4.0  27017  Primary
10.10.18.11 Centos7.5  4.0  27017  Secondary
10.10.18.12 Centos7.5  4.0  27017  Arbiter

二、安装部署（请访问 “MongoDB 安装“）https://www.linuxidc.com/Linux/2019-07/159249.htm

Primary 的配置文件：

systemLog:
   destination: file
   path: "/data/mongodb/log/mongod.log"
   logAppend: true
storage:
   dbPath: "/data/mongodb/data"
   journal:
      enabled: true
   wiredTiger:
      engineConfig:
        cacheSizeGB: 2
processManagement:
   fork: true
   pidFilePath: "/data/mongodb/pid/m.pid"
net:
   bindIp: 10.10.18.10
   port: 27017
replication:
   replSetName: "rs0"

Secondary 的配置文件

systemLog:
   destination: file
   path: "/data/mongodb/log/mongod.log"
   logAppend: true
storage:
   dbPath: "/data/mongodb/data"
   journal:
      enabled: true
   wiredTiger:
      engineConfig:
        cacheSizeGB: 2
processManagement:
   fork: true
   pidFilePath: "/data/mongodb/pid/m.pid"
net:
   bindIp: 10.10.18.11
   port: 27017
replication:
   replSetName: "rs0"

Arbiter 的配置文件

systemLog:
   destination: file
   path: "/data/mongodb/log/mongod.log"
   logAppend: true
storage:
   dbPath: "/data/mongodb/data"
   journal:
      enabled: true
   wiredTiger:
      engineConfig:
        cacheSizeGB: 2
processManagement:
   fork: true
   pidFilePath: "/data/mongodb/pid/m.pid"
net:
   bindIp: 10.10.18.12
   port: 27017
replication:
   replSetName: "rs0"

启动三台服务器上的 mongdb

mongod -f /data/mongodb/mongod.conf

关闭进程

 mongod -f /data/mongodb/mongod.conf --shutdown

三、配置 Replica Set

登录三台服务器中任意一台，登录 mongo（如果报错就将配置文件中：security 内容暂时先去掉）

mongo --host 10.10.18.10
>cfg={_id:"rs0",members:[{_id:0,host:'10.10.18.10:27017',priority:1},{_id:1,host:'10.10.18.11:27017',priority:1},{_id:2,host:'10.10.18.12:27017',arbiterOnly:true}] };

>rs.initiate(cfg)

查看 Replica Set 配置

> rs.conf()

{
“_id” : “rs0”,
“version” : 1,
“protocolVersion” : NumberLong(1),
“writeConcernMajorityJournalDefault” : true,
“members” : [
{
“_id” : 0,
“host” : “10.10.18.10:27017”,
“arbiterOnly” : false,
“buildIndexes” : true,
“hidden” : false,
“priority” : 1,
“tags” : {

},
“slaveDelay” : NumberLong(0),
“votes” : 1
},
{
“_id” : 1,
“host” : “10.10.18.11:27017”,
“arbiterOnly” : false,
“buildIndexes” : true,
“hidden” : false,
“priority” : 1,
“tags” : {

},
“slaveDelay” : NumberLong(0),
“votes” : 1
},
{
“_id” : 2,
“host” : “10.10.18.12:27017”,
“arbiterOnly” : true,
“buildIndexes” : true,
“hidden” : false,
“priority” : 0,
“tags” : {

},
“slaveDelay” : NumberLong(0),
“votes” : 1
}
],
“settings” : {
“chainingAllowed” : true,
“heartbeatIntervalMillis” : 2000,
“heartbeatTimeoutSecs” : 10,
“electionTimeoutMillis” : 10000,
“catchUpTimeoutMillis” : -1,
“catchUpTakeoverDelayMillis” : 30000,
“getLastErrorModes” : {

},
“getLastErrorDefaults” : {
“w” : 1,
“wtimeout” : 0
},
“replicaSetId” : ObjectId(“5cff76e5e57e23a5bc7054e2”)
}
}

四、验证 Replica Set

在 Primary 中插入数据

rs0:PRIMARY>  show dbs
admin   0.000GB
config  0.000GB
local   0.000GB
rs0:PRIMARY> db.users.insertOne(
... {... name:"sue",
... age: 26,
... status:"pending"
... })
{"acknowledged" : true,
        "insertedId" : ObjectId("5cff79e8993e70290a081d04")
}

rs0:PRIMARY> db.users.find()
{“_id” : ObjectId(“5cff79e8993e70290a081d04”), “name” : “sue”, “age” : 26, “status” : “pending” }

在 Secondary 中，默认是不允许读

rs0:SECONDARY> db.users.find()
Error: error: {"operationTime" : Timestamp(1560247181, 1),
        "ok" : 0,
        "errmsg" : "not master and slaveOk=false",
        "code" : 13435,
        "codeName" : "NotMasterNoSlaveOk",
        "$clusterTime" : {"clusterTime" : Timestamp(1560247181, 1),
                "signature" : {"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
                        "keyId" : NumberLong(0)
                }
        }
}

五、创建用户 https://www.linuxidc.com/Linux/2019-07/159238.htm

六、故障模拟

停止 Primary 上的 mongo 进程，在 Secondary 上登录 mongo 查看

mongo --host 10.10.18.11


rs0:PRIMARY> db.users.find()
{"_id" : ObjectId("5cff79e8993e70290a081d04"), "name" : "sue", "age" : 26, "status" : "pending" }

发现原 Secondary 变成 Primary，并且可以进行查询。

开启原 Primary 服务器上的 mongo 进程，该服务器变成了 Secondary。

七、数据备份和恢复

mongodump 从 MongoDB 中读取数据，保存为 BSON 文件，mongorestore 读取 BSON 文件恢复到 MongoDB 中。适用于小型 MongoDB 的备份和恢复。

mongodump 备份的时候只备份 MongoDB 中的文档，使用 mongorestore 恢复之后需要 重建索引

mongodump --host 10.10.18.11 --port 27017 --username myUserAdmin --password abc123 --gzip --out /data/mongobak/$(date +%F)

注：--oplog  表示备份的时候 oplog.bson 文件，存放在 dump 开始 到 dump 结束之间 所有的 oplog。

根据前面的备份恢复到一个 新的 Replica Set 集群 中其中一台服务器上。

恢复

恢复的过程中，不要启用认证。否则在将其他机器加入到 Replica Set 集群中来的时候，会出现无法认证的问题。

1、首先在一台服务器上开启一个干净 mongo 服务（无任何数据），做为 Primary

mongd.conf 配置文件内容

systemLog:
   destination: file
   path: "/data/mongodb/log/mongod.log"
   logAppend: true
storage:
   dbPath: "/data/mongodb/data"
   journal:
      enabled: true
   wiredTiger:
      engineConfig:
        cacheSizeGB: 2
processManagement:
   fork: true
   pidFilePath: "/data/mongodb/pid/mongod.pid"
net:
   bindIp: 10.10.18.10
   port: 27017
replication:
   replSetName: "rs0"

2、开启 mongod 服务

/data/mongodb/bin/mongod -f /data/mongodb/mongod.conf

3、创建单个 Replica Set

登录 mongo，然后创建单个 Replica Set

mongo --host 10.10.18.10
> cfg={_id:"rs0",members:[{_id:0,host:'10.10.18.10:27017',priority:1}]}
> rs.initiate(cfg)

创建结果：

{
        “ok” : 1,
        “operationTime” : Timestamp(1560394449, 1),
        “$clusterTime” : {
                “clusterTime” : Timestamp(1560394449, 1),
                “signature” : {
                        “hash” : BinData(0,”AAAAAAAAAAAAAAAAAAAAAAAAAAA=”),
                        “keyId” : NumberLong(0)
                }
        }
}

创建好了之后，就可以查看当前的数据库

rs0:SECONDARY> show dbs
admin   0.000GB
config  0.000GB
local   0.000GB

可以发现，目前就三个基本的数据库。

4、恢复数据

mongorestore --host 10.10.18.10 --port 27017 --gzip /data/mongobak/2019-06-12

结果

2019-06-13T10:55:33.817+0800    preparing collections to restore from
2019-06-13T10:55:33.829+0800    reading metadata for admin.test from /data/mongobak/2019-06-12/admin/test.metadata.json.gz
2019-06-13T10:55:33.832+0800    reading metadata for test.users from /data/mongobak/2019-06-12/test/users.metadata.json.gz
2019-06-13T10:55:33.834+0800    reading metadata for reporting.reporting from /data/mongobak/2019-06-12/reporting/reporting.metadata.json.gz
2019-06-13T10:55:33.841+0800    reading metadata for admin.reporting from /data/mongobak/2019-06-12/admin/reporting.metadata.json.gz
2019-06-13T10:55:33.861+0800    restoring test.users from /data/mongobak/2019-06-12/test/users.bson.gz
2019-06-13T10:55:34.085+0800    restoring admin.test from /data/mongobak/2019-06-12/admin/test.bson.gz
2019-06-13T10:55:34.123+0800    no indexes to restore
2019-06-13T10:55:34.123+0800    finished restoring test.users (1 document)
2019-06-13T10:55:34.123+0800    restoring admin.reporting from /data/mongobak/2019-06-12/admin/reporting.bson.gz
2019-06-13T10:55:34.175+0800    restoring reporting.reporting from /data/mongobak/2019-06-12/reporting/reporting.bson.gz
2019-06-13T10:55:34.230+0800    no indexes to restore
2019-06-13T10:55:34.230+0800    finished restoring admin.test (2 documents)
2019-06-13T10:55:34.233+0800    no indexes to restore
2019-06-13T10:55:34.233+0800    finished restoring reporting.reporting (1 document)
2019-06-13T10:55:34.234+0800    no indexes to restore
2019-06-13T10:55:34.234+0800    finished restoring admin.reporting (1 document)
2019-06-13T10:55:34.234+0800    restoring users from /data/mongobak/2019-06-12/admin/system.users.bson.gz
2019-06-13T10:55:34.312+0800    done

恢复完成，在登录 mongo 查看，恢复数据库的情况。

rs0:PRIMARY> show dbs
admin      0.000GB
config    0.000GB
local      0.000GB
reporting  0.000GB
test      0.000GB
rs0:PRIMARY> use test
switched to db test
rs0:PRIMARY> show collections
users
rs0:PRIMARY> db.users.find()
{“_id” : ObjectId(“5cff79e8993e70290a081d04”), “name” : “sue”, “age” : 26, “status” : “pending” }

可以看出之前的记录已经恢复了。

注意：如果备份时，MongoDB 是拥有用户名和密码才能进行登录的，在恢复之后，用户名和密码也是可以使用的。如果需要在使用认证登录，需要将下面信息添加的配置文件 mongod.conf：

security:
   keyFile: "/data/mongodb/keyfile"
   authorization: "enabled"

然后重启 mongo 服务。

5、关闭刚恢复的 MongoDB，将数据目录同步到另一台服务器上，作为 Secondary

通过之前，确认该台服务器上的 mongo 是无任何数据。将 Primary 服务上的 /data/mongodb/data 同步到 Secondary 服务器上  /data/mongodb/data

6、依次开启 Primary、Secondary、Arbiter 的 mongo 服务

7、在 Primary 服务器上，将 Secondary、Arbiter 加入到 Replica Set 集群中来

查看当前 Replica Set 集群的配置

rs0:PRIMARY> rs.conf()
{"_id" : "rs0",
        "version" : 1,
        "protocolVersion" : NumberLong(1),
        "writeConcernMajorityJournalDefault" : true,
        "members" : [
                {"_id" : 0,
                        "host" : "10.10.18.10:27017",
                        "arbiterOnly" : false,
                        "buildIndexes" : true,
                        "hidden" : false,
                        "priority" : 1,
                        "tags" : { },
                        "slaveDelay" : NumberLong(0),
                        "votes" : 1
                }
        ],
        "settings" : {"chainingAllowed" : true,
                "heartbeatIntervalMillis" : 2000,
                "heartbeatTimeoutSecs" : 10,
                "electionTimeoutMillis" : 10000,
                "catchUpTimeoutMillis" : -1,
                "catchUpTakeoverDelayMillis" : 30000,
                "getLastErrorModes" : { },
                "getLastErrorDefaults" : {"w" : 1,
                        "wtimeout" : 0
                },
                "replicaSetId" : ObjectId("5d01bad15dfd3f294d147b36")
        }
}

可以看到当前 Replica Set 集群中就一台服务器

将 Secondary、Arbiter 加入到 Replica Set 集群中

rs0:PRIMARY> rs.add(
... {... _id: 1,
... host:'10.10.18.11:27017',
... priority:1
... }
... )
{"ok" : 1,
        "operationTime" : Timestamp(1560397822, 1),
        "$clusterTime" : {"clusterTime" : Timestamp(1560397822, 1),
                "signature" : {"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
                        "keyId" : NumberLong(0)
                }
        }
}
rs0:PRIMARY> rs.add(
... {... _id: 2,
... host:'10.10.18.12:27017',
... arbiterOnly:true
... }
... )
{"ok" : 1,
        "operationTime" : Timestamp(1560397830, 1),
        "$clusterTime" : {"clusterTime" : Timestamp(1560397830, 1),
                "signature" : {"hash" : BinData(0,"AAAAAAAAAAAAAAAAAAAAAAAAAAA="),
                        "keyId" : NumberLong(0)
                }

再次查看状态：

rs0:PRIMARY> rs.conf()
{"_id" : "rs0",
        "version" : 3,
        "protocolVersion" : NumberLong(1),
        "writeConcernMajorityJournalDefault" : true,
        "members" : [
                {"_id" : 0,
                        "host" : "10.10.18.10:27017",
                        "arbiterOnly" : false,
                        "buildIndexes" : true,
                        "hidden" : false,
                        "priority" : 1,
                        "tags" : { },
                        "slaveDelay" : NumberLong(0),
                        "votes" : 1
                },
                {"_id" : 1,
                        "host" : "10.10.18.11:27017",
                        "arbiterOnly" : false,
                        "buildIndexes" : true,
                        "hidden" : false,
                        "priority" : 1,
                        "tags" : { },
                        "slaveDelay" : NumberLong(0),
                        "votes" : 1
                },
                {"_id" : 2,
                        "host" : "10.10.18.12:27017",
                        "arbiterOnly" : true,
                        "buildIndexes" : true,
                        "hidden" : false,
                        "priority" : 0,
                        "tags" : { },
                        "slaveDelay" : NumberLong(0),
                        "votes" : 1
                }
        ],
        "settings" : {"chainingAllowed" : true,
                "heartbeatIntervalMillis" : 2000,
                "heartbeatTimeoutSecs" : 10,
                "electionTimeoutMillis" : 10000,
                "catchUpTimeoutMillis" : -1,
                "catchUpTakeoverDelayMillis" : 30000,
                "getLastErrorModes" : { },
                "getLastErrorDefaults" : {"w" : 1,
                        "wtimeout" : 0
                },
                "replicaSetId" : ObjectId("5d01bad15dfd3f294d147b36")
        }
}

加入成功。

开启认证访问

在三台服务器的配置文件中添加：

security:
   keyFile: "/data/mongodb/keyfile"
   authorization: "enabled"

然后依次关闭：Arbiter Secondary Primary

依次开启：Primary Secondary Arbiter

security:
   keyFile: "/data/mongodb/keyfile"
   authorization: "enabled"

：

正文完
星哥玩云-微信公众号
post-qrcode
MongoDB MongoDB的群模式 MongoDB的集群模式 - Replica Set MySQL NoSQL Oracle Oracle教程 Oracle数据库 PostgreSQL Replica Set 数据库
发表至： 数据库技术
2022-01-22
 0
星锅
版权声明：本站原创文章，由 星锅 于2022-01-22发表，共计9567字。
转载说明：除特殊说明外本站文章皆由CC-4.0协议发布，转载请注明出处。
【腾讯云】推广者专属福利，新客户无门槛领取总价值高达2860元代金券，每种代金券限量500张，先到先得。
Linux CentOS 6.5 yum安装MongoDB
MongoDB更改oplog大小
Oracle视图编译错误解决办法
Oracle 12C & 18C 新特性 PDB Lockdown Profile
在 CentOS7 上安装 MySQL5.7
RHEL 7.3 安装 MySQL 5.6 教程
Oracle SQL 硬解析和子游标
通过systemctl管理mysqld服务
阿里云-最新活动爆款每日限量供应
评论（没有评论）
验证码
星哥说事
星哥说事
分享互联网知识
阅读量
3616140
评论数
4
文章搜索
热门文章
选择PHP与Python，可以考虑这三个问题

选择PHP与Python，可以考虑这三个问题

导读 尽管 RESTful API 和跨平台库已经使网页开发容易起来，但依然没有解决阻碍并隔分开发者、管理者和...
Centos 7平滑无缝升级PHP7.1.0到PHP 7.1.5

Centos 7平滑无缝升级PHP7.1.0到PHP 7.1.5

实验环境：CentOS Linux release 7.3.1611 (Core) 内核版本：Linux ve...
介绍ansible的Ad-hoc与commands模块

介绍ansible的Ad-hoc与commands模块

Ad-Hoc 是指 ansible 下临时执行的一条命令，并且不需要保存的命令，对于复杂的命令后面会说 pla...
Linux安装使用pidstat命令以对进程数据进行监控

Linux安装使用pidstat命令以对进程数据进行监控

导读 Linux 系统监控的命令其实有很多，pidstat 命令就是其中的一种，使用 pidstat 命令可以...
免费获取Linux，无需购买服务器既可使用Linux系统的开源工具

免费获取Linux，无需购买服务器既可使用Linux系统的开源工具

免费获取 Linux，无需购买服务器既可使用 Linux 系统的开源工具 前言 你还在为搭建 Linux 环境...
CDN
阿里云CDN-提高用户访问的响应速度和成功率
随机文章
细述：Fail2ban 阻止暴力破解案例

细述：Fail2ban 阻止暴力破解案例

导读 Fail2ban 能够监控系统日志，匹配日志中的错误信息（使用正则表达式），执行相应的屏蔽动作（支持多种...
细述使用 Python 获取 Linux 系统信息

细述使用 Python 获取 Linux 系统信息

在本文中，我们将会探索使用 Python 编程语言工具来检索 Linux 系统各种信息。 哪个 Python ...
如何解决Oracle临时表空间过大

如何解决Oracle临时表空间过大

导读 解决 Oracle 临时表空间过大有两种方法，方法一增加临时表空间的大小，方法二重建临时表空间，解决临时...
阿里云配置自动横向扩展的同城双中心服务集群

阿里云配置自动横向扩展的同城双中心服务集群

导读 如果我们是一个电商网站突然运营想搞一个秒杀活动，一个游戏公司要组织一场在线 PK 大赛。这种情况下呢，都...
Linux 上设置自己的公共时间服务器

Linux 上设置自己的公共时间服务器

导读 最重要的公共服务之一就是报时 timekeeping，但是很多人并没有意识到这一点。大多数公共时间服务器...
一言一句话
-「」
【腾讯云】云服务器、云数据库、COS、CDN、短信等云产品特惠热卖中