首页 / MONGODB / MongoDB高可用方案之副本集(Replica Set)

MongoDB高可用方案之副本集(Replica Set)

内容导读

互联网集市收集整理的这篇技术教程文章主要介绍了MongoDB高可用方案之副本集(Replica Set)，小编现在分享给大家，供广大互联网技能从业者学习和参考。文章包含6928字，纯文字阅读大概需要10分钟。

内容图文

一、介绍

Replicat Set比起传统的Master - Slave结构而言，应用场景更加多，也有了自动failover的能力

二、副本集结构图（参考：https://www.linuxidc.com/Linux/2017-03/142379.htm）

技术分享图片

类似于“MySQL中1主2从+mha_manager”的结构。

Replication通过Oplog实现语句复现

技术分享图片

三、副本集成员的属性

Replication通过Oplog实现语句复现
分别为Primary、Secondary(Secondaries)
Primary负责处理所有的write请求，并记录到oplog(operation log)中。
Secondary负责复制oplog并应用这些write请求到他们自己的数据集中。(有一些类似于MySQL Replication)

所有的副本集都可以处理读操作，但是需要设置。

最小化的副本集配置建议有三个成员：
1个Primary + 2个Secondary
或者
1个Primary + 1个Secondary + 1个Arbiter(仲裁者)

四、Arbiter和选举机制

Arbiter可以作为副本集的一部分，但它不是一个数据副本，故它不会成为Primary。
Arbiter在Primary不可用的时候，作为一个选举的角色存在。
如果Arbiter不存在，Primary挂掉的情况下，剩下的两个Secondary则也会进行选举。

在1个Primary + 2个Secondary的情况下，failover如下：

技术分享图片

五、搭建

1、实验环境

192.168.1.34（Primary）
192.168.1.35（Secondary1）
192.168.1.36（Secondary2）
192.168.1.37（Arbiter）

2、安装mongodb并启动

先在三台安装mongodb，先关闭防火墙

service iptables stop

在三台机器分别创建对应目录并启动mongodb

# mkdir -p /data/mongo_replset
#./mongod --dbpath=/data/mongo_replset --logpath=/data/mongo_replset/mongo.log --fork --replSet=first_replset

3、配置副本集

登录192.168.1.34（Primary）的mongo shell

# ./mongo
> use admin
switched to db admin
输入
> cnf = {_id:"first_replset", members:[
...         {_id:1, host:"192.168.1.34:27017"},
...         {_id:2, host:"192.168.1.35:27017"},
...         {_id:3, host:"192.168.1.36:27017"},
...         ]
...     }
输出：
{
    "_id" : "first_replset",
    "members" : [
        {
            "_id" : 1,
            "host" : "192.168.1.34:27017"
        },
        {
            "_id" : 2,
            "host" : "192.168.1.35:27017"
        },
        {
            "_id" : 3,
            "host" : "192.168.1.36:27017"
        }
    ]
}

初始化配置：

>  rs.initiate(cnf);
{ "ok" : 1 }
first_replset:OTHER> 
first_replset:PRIMARY> 
first_replset:PRIMARY>

此时可以发现该mongodb实例已经成为PRIMARY了。

可以查看下这个副本集的各个成员的状态：

first_replset:PRIMARY> rs.status();
{
    "set" : "first_replset",
    "date" : ISODate("2018-01-03T06:37:10.559Z"),
    "myState" : 1,
    "members" : [
        {
            "_id" : 1,
            "name" : "192.168.1.34:27017",
            "health" : 1,
            "state" : 1,
            "stateStr" : "PRIMARY",
            "uptime" : 599,
            "optime" : Timestamp(1514961357, 1),
            "optimeDate" : ISODate("2018-01-03T06:35:57Z"),
            "electionTime" : Timestamp(1514961361, 1),
            "electionDate" : ISODate("2018-01-03T06:36:01Z"),
            "configVersion" : 1,
            "self" : true
        },
        {
            "_id" : 2,
            "name" : "192.168.1.35:27017",
            "health" : 1,
            "state" : 2,
            "stateStr" : "SECONDARY",
            "uptime" : 73,
            "optime" : Timestamp(1514961357, 1),
            "optimeDate" : ISODate("2018-01-03T06:35:57Z"),
            "lastHeartbeat" : ISODate("2018-01-03T06:37:09.308Z"),
            "lastHeartbeatRecv" : ISODate("2018-01-03T06:37:09.316Z"),
            "pingMs" : 1,
            "lastHeartbeatMessage" : "could not find member to sync from",
            "configVersion" : 1
        },
        {
            "_id" : 3,
            "name" : "192.168.1.36:27017",
            "health" : 1,
            "state" : 2,
            "stateStr" : "SECONDARY",
            "uptime" : 73,
            "optime" : Timestamp(1514961357, 1),
            "optimeDate" : ISODate("2018-01-03T06:35:57Z"),
            "lastHeartbeat" : ISODate("2018-01-03T06:37:09.306Z"),
            "lastHeartbeatRecv" : ISODate("2018-01-03T06:37:09.313Z"),
            "pingMs" : 1,
            "lastHeartbeatMessage" : "could not find member to sync from",
            "configVersion" : 1
        }
    ],
    "ok" : 1
}

4、副本集复制状态测试

在PRIMARY上insert:

# ./mongo 127.0.0.1/test
first_replset:PRIMARY> db.test_table.insert({"id": 1})
WriteResult({ "nInserted" : 1 })
first_replset:PRIMARY> db.test_table.find()
{ "_id" : ObjectId("5a4c7b44ecb269292f0de224"), "id" : 1 }

在35、36任意SECONDARY上查询：

同master - slave结构一样，默认SECONDARY是不可读的，需要执行rs.slaveOk()。

first_replset:SECONDARY> rs.slaveOk()
first_replset:SECONDARY> db.test_table.find()
{ "_id" : ObjectId("5a4c7b44ecb269292f0de224"), "id" : 1 }

5、failover测试

此时情况:
192.168.1.34（Primary）
192.168.1.35（Secondary）
192.168.1.36（Secondary）

停掉PRIAMRY:

first_replset:PRIMARY> use admin
switched to db admin
first_replset:PRIMARY> db.shutdownServer()
2018-01-03T14:46:14.048+0800 I NETWORK  DBClientCursor::init call() failed
server should be down...
2018-01-03T14:46:14.052+0800 I NETWORK  trying reconnect to 127.0.0.1:27017 (127.0.0.1) failed
2018-01-03T14:46:14.052+0800 I NETWORK  reconnect 127.0.0.1:27017 (127.0.0.1) ok
2018-01-03T14:46:14.053+0800 I NETWORK  DBClientCursor::init call() failed
2018-01-03T14:46:14.056+0800 I NETWORK  trying reconnect to 127.0.0.1:27017 (127.0.0.1) failed
2018-01-03T14:46:14.056+0800 I NETWORK  reconnect 127.0.0.1:27017 (127.0.0.1) ok
2018-01-03T14:46:14.397+0800 I NETWORK  Socket recv() errno:104 Connection reset by peer 127.0.0.1:270172018-01-03T14:46:14.397+0800 I NETWORK  SocketException: remote: 127.0.0.1:27017 error: 9001 socket exception [RECV_ERROR] server [127.0.0.1:27017] 
2018-01-03T14:46:14.397+0800 I NETWORK  DBClientCursor::init call() failed

(原SECONDARY)35上查到，此时35已经为PRIMARY了

first_replset:SECONDARY> 
first_replset:PRIMARY> rs.status()
{
    "set" : "first_replset",
    "date" : ISODate("2018-01-03T06:47:14.289Z"),
    "myState" : 1,
    "members" : [
        {
            "_id" : 1,
            "name" : "192.168.1.34:27017",
            "health" : 0,
            "state" : 8,
            "stateStr" : "(not reachable/healthy)",
            "uptime" : 0,
            "optime" : Timestamp(0, 0),
            "optimeDate" : ISODate("1970-01-01T00:00:00Z"),
            "lastHeartbeat" : ISODate("2018-01-03T06:47:14.034Z"),
            "lastHeartbeatRecv" : ISODate("2018-01-03T06:46:13.934Z"),
            "pingMs" : 0,
            "lastHeartbeatMessage" : "Failed attempt to connect to 192.168.1.34:27017; couldn‘t connect to server 192.168.1.34:27017 (192.168.1.34), connection attempt failed",
            "configVersion" : -1
        },
        {
            "_id" : 2,
            "name" : "192.168.1.35:27017",
            "health" : 1,
            "state" : 1,
            "stateStr" : "PRIMARY",
            "uptime" : 1180,
            "optime" : Timestamp(1514961732, 2),
            "optimeDate" : ISODate("2018-01-03T06:42:12Z"),
            "electionTime" : Timestamp(1514961976, 1),
            "electionDate" : ISODate("2018-01-03T06:46:16Z"),
            "configVersion" : 1,
            "self" : true
        },
        {
            "_id" : 3,
            "name" : "192.168.1.36:27017",
            "health" : 1,
            "state" : 2,
            "stateStr" : "SECONDARY",
            "uptime" : 676,
            "optime" : Timestamp(1514961732, 2),
            "optimeDate" : ISODate("2018-01-03T06:42:12Z"),
            "lastHeartbeat" : ISODate("2018-01-03T06:47:13.997Z"),
            "lastHeartbeatRecv" : ISODate("2018-01-03T06:47:13.995Z"),
            "pingMs" : 0,
            "configVersion" : 1
        }
    ],
    "ok" : 1
}

6、在副本集中添加一个属性为Arbiter的成员

当然此处只做添加实践，实际上并不建议在Secondary-Primary-Secondary的结构上再多一个Arbiter成员形成偶数个节点。
在192.168.1.37上启动一个mongod实例：

# mkdir -p /data/arb
# ./mongod --dbpath=/data/arb/ --logpath=/data/arb/mongo.log --fork --replSet=first_replset

在failover后的PRIMARY节点添加Arbiter

first_replset:PRIMARY> rs.addArb("192.168.1.37:27017")
{ "ok" : 1 }
first_replset:PRIMARY> rs.status()
{
            "_id" : 4,
            "name" : "192.168.1.37:27017",
            "health" : 1,
            "state" : 7,
            "stateStr" : "ARBITER",
            "uptime" : 82,
            "lastHeartbeat" : ISODate("2018-01-03T07:16:14.872Z"),
            "lastHeartbeatRecv" : ISODate("2018-01-03T07:16:15.497Z"),
            "pingMs" : 1,
            "configVersion" : 2
        }
    ],
    "ok" : 1

此时回到arbiter的mongo shell，发现正如文档所说，arbiter是不会存有副本集中数据的。

first_replset:ARBITER> rs.slaveOk()
first_replset:ARBITER> use test;
switched to db test
first_replset:ARBITER> show tables;
first_replset:ARBITER> db.test_table.find();
Error: error: {
    "$err" : "not master or secondary; cannot currently read from this replSet member",
    "code" : 13436
}

原文：https://www.cnblogs.com/guantou1992/p/9729616.html

内容总结

以上是互联网集市为您收集整理的MongoDB高可用方案之副本集(Replica Set)全部内容，希望文章能够帮你解决MongoDB高可用方案之副本集(Replica Set)所遇到的程序开发问题。如果觉得互联网集市技术教程内容还不错，欢迎将互联网集市网站推荐给程序员好友。

内容备注

版权声明：本文内容由互联网用户自发贡献，该文观点与技术仅代表作者本人。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容，请发送邮件至 gblab@vip.qq.com 举报，一经查实，本站将立刻删除。

内容手机端

扫描二维码推送至手机访问。

本文链接：https://qyyshop.com/info/1134882.html

来源：【匿名】

【上一篇】MongoDB入门四【下一篇】在MongoDB上如何进行数据的导入与导出

更多 ►

【MongoDB高可用方案之副本集(Replica Set)】教程文章相关的互联网学习教程文章

Mongodb3.4.7搭建高可用集群（二）【代码】

部署Mongodb高可用集群准备按照官方说明，至少需要3个config server，2个mongos，2个shard，每个shard至少2个副本，就是4个shard，共需要9个Mongodb实例。这里只虚拟出2个机器节点，将不同的Mongodb实例部署在不同的端口上模拟实现。节点端口关系表config serverleo.zhi.1:10010,leo.zhi.2:10010mongos serverleo.zhi.1:10020,leo.zhi.2:10020shard serverleo.zhi.1:10001,leo.zhi.2:10002leo.zhi.1和leo.zhi.2上分别创建文件夹[ro...

MongoDB高可用方案之副本集(Replica Set)【代码】【图】

一、介绍Replicat Set比起传统的Master - Slave结构而言，应用场景更加多，也有了自动failover的能力二、副本集结构图（参考：https://www.linuxidc.com/Linux/2017-03/142379.htm）类似于“MySQL中1主2从+mha_manager”的结构。Replication通过Oplog实现语句复现三、副本集成员的属性Replication通过Oplog实现语句复现分别为Primary、Secondary(Secondaries)Primary负责处理所有的write请求，并记录到oplog(operation log)中。Sec...

HAProxy+mongos搭建高可用负载均衡mongodb【图】

HAProxy是一款提供高可用性、负载均衡以及基于TCP和HTTP应用的代理软件，HAProxy是完全免费的、借助HAProxy可以快速并且可靠的提供基于TCP和HTTP应用的代理解决方案。HAProxy适用于那些负载较大的web站点，这些站点通常又需要会话保持或七层处理。 HAProxy可以支持数以万计的并发连接,并且HAProxy的运行模式使得它可以很简单安全的整合进架构中，同时可以保护web服务器不被暴露到网络上。现在开始动手，使用的是Ubuntu64位操作系统...

MongoDB 高可用基础之副本集【代码】【图】

一、副本集 1.1 复制功能为保证数据安全，实现高可用，MongoDB 提供了复制功能，可以将主节点上的数据复制到多个从节点上，这样即便主节点异常，由于数据是以多副本的方式存储，仍然可以保证数据安全。一个标准的三节点的副本集的架构如下： 1. 初始同步在副本集初始化时，主节点的 mongod 进程会扫描当前节点上每个数据库中的每个集合，然后将这些数据发送给从节点，进行初始化的全量复制。 2. 同步复制从节点在初始化完成后，...

搭建高可用mongodb集群（二）—— 副本集【图】

了，替代方案是采用副本集的模式，点击查看，如图：那什么是副本集呢？打魔兽世界总说打副本，其实这两个概念差不多一个意思。游戏里的副本是指玩家集中在高峰时间去一个场景打怪，会出现玩家暴多怪物少的情况，游戏开发商为了保证玩家的体验度，就为每一批玩家单独开放一个同样的空间同样的数量的怪物，这一个复制的场景就是一个副本，不管有多少个玩家各自在各自的副本里玩不会互相影响。 mongoDB的副本也是这个，主从模式其实就...

搭建高可用mongodb集群（分片）【代码】【图】

一、概述1.1 背景为解决mongodb在replica set每个从节点上面的数据库均是对数据库的全量拷贝，从节点压力在高并发大数据量的场景下存在很大挑战，同时考虑到后期mongodb集群的在数据压力巨大时的扩展性，应对海量数据引出了分片机制。1.2 分片概念分片是将数据库进行拆分，将其分散在不同的机器上的过程，无需功能强大的服务器就可以存储更多的数据，处理更大的负载，在总数据中，将集合切成小块，将这些块分散到若干片中，每个片只...

搭建高可用mongodb集群【图】

在大数据的时代，传统的关系型数据库要能更高的服务必须要解决高并发读写、海量数据高效存储、高可扩展性和高可用性这些难题。不过就是因为这些问题Nosql诞生了。 NOSQL有这些优势：大数据量，可以通过廉价服务器存储大量的数据，轻松摆脱传统mysql单表存储量级限制。高扩展性，Nosql去掉了关系数据库的关系型特性，很容易横向扩展，摆脱了以往老是纵向扩展的诟病。高性能，Nosql通过简单的key-value方式获取数据，非常快速。还...

搭建高可用MongoDB集群副本【图】

” 和上面命令参数“ –replSet application” 要保持 config ={_id:"application",members:[{_id:0,host:"192.168.216.128:10001"},{_id:1,host:"192.168.216.129:10002"},{_id:2,host:"192.168.216.130:10003"}]} 如图命令和输出初始化副本配置命令： rs.initiate(config); 输出结果： { "info" : "Config now saved locally. Should come online in about a minute.", "ok" : 1 } 如果输出如下：表示192.168.216.129：10...

mongodb高可用Replica Set【代码】

*************************************************************** 第一部分：系统配置 ***************************************************************---0.配置yum源cd /etc/yum.repos.dmv CentOS-Base.repo CentOS-Base.repo.oldwget http://mirrors.163.com/.help/CentOS6-Base-163.repoyum makecache检查可更新的rpm包 #yum check-update更新所有的rpm包 #yum update---1.安全加固1.1 SELinux /usr/sbin/sestatus -v | gr...

搭建高可用mongodb集群—— 分片【图】

搭建高可用mongodb集群（三）—— 深入副本集内部机制 Posted on 17 二月, 2014 by lanceyan | 13条评论在上一篇文章《搭建高可用mongodb集群（二）—— 副本集》介绍了副本集的配置，这篇文章深入研究一下副本集的内部机制。还是带着副本集的问题来看吧！副本集故障转移，主节点是如何选举的？能否手动干涉下架某一台主节点。官方说副本集数量最好是奇数，为什么？ mongodb副本集是如何同步的？如果同步不及时会出现什么情况？会...

搭建高可用MongoDB集群（二）：副本集【图】

：mongoDB官方已经不建议使用主从模式了，替代方案是采用副本集的模式，点击查看，如图：那什么是副本集呢？打魔兽世界总说打副本，其实这两个概念差不多一个意思。游戏里的副本是指玩家集中在高峰时间去一个场景打怪，会出现玩家暴多怪物少的情况，游戏开发商为了保证玩家的体验度，就为每一批玩家单独开放一个同样的空间同样的数量的怪物，这一个复制的场景就是一个副本，不管有多少个玩家各自在各自的副本里玩不会互相影响。 ...

搭建高可用MongoDB集群（四）：分片【图】

，数据库集群请求的入口，所有的请求都通过mongos进行协调，不需要在应用程序添加一个路由选择器，mongos自己就是一个请求分发中心，它负责把对应的数据请求请求转发到对应的shard服务器上。在生产环境通常有多mongos作为请求的入口，防止其中一个挂掉所有的mongodb请求都没有办法操作。config server，顾名思义为配置服务器，存储所有数据库元信息（路由、分片）的配置。mongos本身没有物理存储分片服务器和数据路由信息，只是缓存...

MongoDB高可用集群配置的方案【图】

高可用性即HA（High Availability）指的是通过尽量缩短因日常维护操作（计划）和突发的系统崩溃（非计划）所导致的停机时间，以提高系统和应用的可用性。计算机系统的高可用在不同的层面上有不同的表现：（1）网络高可用由于网络存储的快速发展，网络冗余技术被不断提升，提高IT系统的高可用性的关键应用就是网络高可用性，网络高可用性与网络高可靠性是有区别的，网络高可用性是通过匹配冗余的网络设备实现网络设备的冗余，达到...

搭建高可用mongodb集群（转）

搭建高可用mongodb集群（一）——配置mongodb 搭建高可用mongodb集群（二）—— 副本集搭建高可用mongodb集群（三）—— 深入副本集内部机制搭建高可用mongodb集群（四）—— 分片搭建高可用mongodb集群（转）标签：本文系统来源：http://www.cnblogs.com/ajianbeyourself/p/5966617.html

MongoDB高可用部署【代码】【图】

1、准备基础环境在网上下载mongodb-linux-x86_64-rhel62-3.4.2.gz放到各个服务器上，解压后放在对应的目录下，然后在根目录下新建data文件夹统一用于存放数据和配置信息。2、搭建配置集群243-244-245 在mongo的根目录下新建start脚本，内容如下bin/./mongod --dbpath data/ --logpath data/mongo.log --configsvr --fork --port 20243 --replSet config 其中 configsvr表示配置服务，fork表示后台启动，replSet表示集群...

MONGODB - 技术教程分类

MongoDB 教程 MongoDB 简介 MongoDB 概念解析 MongoDB 连接 MongoDB 创建数据库 MongoDB 删除数据库 MongoDB 创建集合 MongoDB 删除集合 MongoDB 插入文档 MongoDB 更新文档 MongoDB 删除文档 MongoDB 查询文档 MongoDB 条件操作符 MongoDB $type 操作符 MongoDB Limit与Skip方法 MongoDB 排序 MongoDB 索引 MongoDB 聚合 MongoDB 复制(副本集) MongoDB 分片 MongoDB 备份与恢复 MongoDB 监控 MongoDB PHP 扩展 Node.js MongoDB MongoDB 关系 MongoDB 数据库引用 MongoDB 覆盖索引查询 MongoDB 查询分析 MongoDB 原子操作 MongoDB 高级索引 MongoDB 索引限制 MongoDB ObjectId MongoDB Map Reduce MongoDB 全文检索 MongoDB 管理工具 MongoDB GridFS MongoDB 固定集合 MongoDB 自动增长 mongodb 全部

MONGODB - 最热教程

TP5(thinkPHP5)框架mongodb扩展安装及特...MongoDB数据库设置初始化脚本【MongoDB】在windows平台下mongodb的分...MongoDB查询超时异常SocketTimeoutExce...mongodb关于启动权限的问题 mongodb chunk 大小设置 MongoDB分片集群配置 mongodb web管理工具rockmongo MongoDB中insert方法、update方法、sav...mongodb如何对子文档进行分页

首页 / MONGODB / MongoDB高可用方案之副本集(Replica Set)

MongoDB高可用方案之副本集(Replica Set)

内容导读

内容图文

内容总结

内容备注

内容手机端

【MongoDB高可用方案之副本集(Replica Set)】教程文章相关的互联网学习教程文章

MONGODB - 技术教程分类

MONGODB - 最新教程

MONGODB - 最热教程