热门标签 | HotTags
当前位置:  开发笔记 > 编程语言 > 正文

MongoDB配置主从复制和集群复制的方法

一、主从复制一般数据库都会用到这种最通用的模式——主从模式。这种方式简单灵活,可用于备份、故障恢复,读扩展。为了平衡负载,一般通过读写分离模式,即主库写、从库读。假设我们有两台MongoDB服务器,10.11.20.140和10.11.20.139。如果要配置主从复制

一、主从复制

一般数据库都会用到这种最通用的模式——主从模式。这种方式简单灵活,可用于备份、故障恢复,读扩展。为了平衡负载,一般通过读写分离模式,即主库写、从库读。

假设我们有两台MongoDB服务器,10.11.20.140和10.11.20.139。如果要配置主从复制,可参考如下实现:

Master(10.11.20.140):

Java代码  

port = 27017  

dbpath = /data/db  

logpath = /var/log/mongodb.log  

logappend = true   

journal = true  

pidfile = /var/run/mongodb.pid  

fork = true  

master = true  

注意:

master=true

Slave(10.11.20.139):

Java代码  

port=27017  

dbpath = /data/db  

logpath = /var/log/mongodb.log  

logappend = true   

journal = true  

fork = true  

slave = true  

source = 10.11.20.140:27017  

注意:

slave=true

source=10.11.20.140:27017

上述配置,即可完成Master-Slave

简单测试下,在Master(10.11.20.140)上写数据,在Slave(10.11.20.139)上读出。

Master写入:

mongo 10.11.20.140:27017
MongoDB shell version: 2.0.7
connecting to: 10.11.20.140:27017/test
> db.test.save( { a: 1 } )

Slave 读出:

mongo 10.11.20.139:27017
MongoDB shell version: 2.0.7
connecting to: 10.11.20.139:27017/test
> db.test.find()
{ "_id" : ObjectId("502cccaf2d44738c3b181391"), "a" : 1 }
>

完成主从同步!

注意:如果这是配置了“auth = false”,主从同步可能失败。

二、集群复制

主从复制虽然可以承受一定的负载压力,但这种方式仍然是一个单点,如果主库挂了,数据写入就成了风险。如果,当主库挂掉的时候,可以在访问ip不变的前提下,自动将从库作为主库使用,是不是就能避免这种风险?貌似这又涉及到Linux上的服务KeepAlive等等。

在Mongodb中,提供了一种优于主从模式的集群复制(ReplicateSet)。最理想的模式是,节点之间不分特定的主从。任何一个节点都可以是主节点primary,而其他节点都是secondary,甚至可以通过投票方式选出主节点。

假设我们拥有3台Mongodb,192.168.158.130、192.168.158.131和192.168.158.132。我们希望这3台Mongodb能够构建ReplicateSet模式,可以依照如下操作实现:

1. 配置副本集

假设我们这里的副本集定为snowolf,需要在mongodb配置文件中进行如下配置:

   然后,我们启动这两台Mongodb,查看状态

$ mongo 192.168.158.130  

MongoDB shell version: 2.0.4  

connecting to: 192.168.158.130/test  

> rs.status()  

{  

        "startupStatus" : 3,  

        "info" : "run rs.initiate(...) if not yet done for the set",  

        "errmsg" : "can't get local.system.replset config from self or any seed (EMPTYCONFIG)",  

        "ok" : 0  

}  

>   

    这时候,复制集群还没有达到可用,需要进一步配置。

2. 配置成员

   这里可以在任一节点进行,通过rs.initiate(cfg)完成配置。

   先配置一个中间变量:

> cfg={_id:'snowolf',members:[   

... {_id:0,host:'192.168.158.130:27017'},  

... {_id:1,host:'192.168.158.131:27017'}]  

... }  

{  

        "_id" : "snowolf",  

        "members" : [  

                {  

                        "_id" : 0,  

                        "host" : "192.168.158.130:27017"  

                },  

                {  

                        "_id" : 1,  

                        "host" : "192.168.158.131:27017"  

                }  

        ]  

}  

 接下来,需要让配置生效:

> rs.initiate(cfg)  

{  

        "info" : "Config now saved locally.  Should come online in about a minute.",  

        "ok" : 1  

}  

如果如上所示,说明配置成功。

这时候,再看看当前的状态:

> rs.status()  

{  

        "set" : "snowolf",  

        "date" : ISODate("2013-11-14T08:33:58Z"),  

        "myState" : 1,  

        "members" : [  

                {  

                        "_id" : 0,  

                        "name" : "192.168.158.130:27017",  

                        "health" : 1,  

                        "state" : 1,  

                        "stateStr" : "PRIMARY",  

                        "optime" : {  

                                "t" : 1384417894000,  

                                "i" : 1  

                        },  

                        "optimeDate" : ISODate("2013-11-14T08:31:34Z"),  

                        "self" : true  

                },  

                {  

                        "_id" : 1,  

                        "name" : "192.168.158.131:27017",  

                        "health" : 1,  

                        "state" : 2,  

                        "stateStr" : "SECONDARY",  

                        "uptime" : 137,  

                        "optime" : {  

                                "t" : 1384417894000,  

                                "i" : 1  

                        },  

                        "optimeDate" : ISODate("2013-11-14T08:31:34Z"),  

                        "lastHeartbeat" : ISODate("2013-11-14T08:33:57Z"),  

                        "pingMs" : 348  

                }  

        ],  

        "ok" : 1  

}  

 我们在一开始,并没有强制设定哪个IP是primary节点,哪个是secondary节点。这完全由Mongodb集群来决定。

这时在命令行下,提示符也发生了变化。

Primary节点:

Secondary节点:

别急,这时候还没有大功告成,如果直接在secondary上操作,会发生如下错误:

SECONDARY> db.t.find()  

error: { "$err" : "not master and slaveok=false", "code" : 13435 }  

需要告知Mongodb集群,从哪台机器上进行读操作:

SECONDARY> rs.slaveOk()  

not master and slaveok=false  

 这时就不会有刚才的错误了。

测试:

在primary节点写入操作:

PRIMARY> db.t.insert({uid:12345})  

PRIMARY> db.t.find()  

{ "_id" : ObjectId("52848f782c6dd18b00fdf65d"), "uid" : 12345 }  

 在secondary节点读操作:

SECONDARY> db.t.find()  

{ "_id" : ObjectId("52848f782c6dd18b00fdf65d"), "uid" : 12345 }  

 似乎大功告成,如果这时候我们把primary节点停掉,在secondary节点执行写操作,就会发生如下错误提示:

SECONDARY> db.t.insert({uid:12345})  

not master  

如果只有2台Mongodb,配置复制集群还不够安全,需要1个外在角色调整各个节点的角色。

这些节点包括:

statndard 常规节点,存储一份完整的数据副本,参与投票,可以成为活跃节点,即primary节点

passive 只做存储,参与投票

arbiter 仲裁者只投票,不复制数据,也不能成为活跃节点

现在,我们可以增加一个仲裁节点,只负责仲裁,不做数据存储。

PRIMARY> rs.addArb("192.168.158.132:27017")  

{ "ok" : 1 }  

 这时候,再看各个节点的状态,也发生了变化:

PRIMARY> rs.status()  

{  

        "set" : "snowolf",  

        "date" : ISODate("2013-11-14T09:07:39Z"),  

        "myState" : 1,  

        "members" : [  

                {  

                        "_id" : 0,  

                        "name" : "192.168.158.130:27017",  

                        "health" : 1,  

                        "state" : 2,  

                        "stateStr" : "SECONDARY",  

                        "uptime" : 390,  

                        "optime" : {  

                                "t" : 1384420036000,  

                                "i" : 1  

                        },  

                        "optimeDate" : ISODate("2013-11-14T09:07:16Z"),  

                        "lastHeartbeat" : ISODate("2013-11-14T09:07:39Z"),  

                        "pingMs" : 1  

                },  

                {  

                        "_id" : 1,  

                        "name" : "192.168.158.131:27017",  

                        "health" : 1,  

                        "state" : 1,  

                        "stateStr" : "PRIMARY",  

                        "optime" : {  

                                "t" : 1384420036000,  

                                "i" : 1  

                        },  

                        "optimeDate" : ISODate("2013-11-14T09:07:16Z"),  

                        "self" : true  

                },  

                {  

                        "_id" : 2,  

                        "name" : "192.168.158.132:27017",  

                        "health" : 1,  

                        "state" : 7,  

                        "stateStr" : "ARBITER",  

                        "uptime" : 23,  

                        "optime" : {  

                                "t" : 1384419192000,  

                                "i" : 1  

                        },  

                        "optimeDate" : ISODate("2013-11-14T08:53:12Z"),  

                        "lastHeartbeat" : ISODate("2013-11-14T09:07:38Z"),  

                        "pingMs" : 295147904  

                }  

        ],  

        "ok" : 1  

}  

 如果这时候,我们把primary节点停掉,是否还会影响集群的稳定性?

由于存在arbiter节点,如果primary节点宕掉,剩余的secondary会被选为primary节点,继续提供服务。


推荐阅读
  • 在现代网络环境中,两台计算机之间的文件传输需求日益增长。传统的FTP和SSH方式虽然有效,但其配置复杂、步骤繁琐,难以满足快速且安全的传输需求。本文将介绍一种基于Go语言开发的新一代文件传输工具——Croc,它不仅简化了操作流程,还提供了强大的加密和跨平台支持。 ... [详细]
  • 优化联通光猫DNS服务器设置
    本文详细介绍了如何为联通光猫配置DNS服务器地址,以提高网络解析效率和访问体验。通过智能线路解析功能,域名解析可以根据访问者的IP来源和类型进行差异化处理,从而实现更优的网络性能。 ... [详细]
  • 1:有如下一段程序:packagea.b.c;publicclassTest{privatestaticinti0;publicintgetNext(){return ... [详细]
  • 本文详细介绍了如何在Linux系统上安装和配置Smokeping,以实现对网络链路质量的实时监控。通过详细的步骤和必要的依赖包安装,确保用户能够顺利完成部署并优化其网络性能监控。 ... [详细]
  • 如何配置Unturned服务器及其消息设置
    本文详细介绍了Unturned服务器的配置方法和消息设置技巧,帮助用户了解并优化服务器管理。同时,提供了关于云服务资源操作记录、远程登录设置以及文件传输的相关补充信息。 ... [详细]
  • 360SRC安全应急响应:从漏洞提交到修复的全过程
    本文详细介绍了360SRC平台处理一起关键安全事件的过程,涵盖从漏洞提交、验证、排查到最终修复的各个环节。通过这一案例,展示了360在安全应急响应方面的专业能力和严谨态度。 ... [详细]
  • 本文深入探讨了Linux系统中网卡绑定(bonding)的七种工作模式。网卡绑定技术通过将多个物理网卡组合成一个逻辑网卡,实现网络冗余、带宽聚合和负载均衡,在生产环境中广泛应用。文章详细介绍了每种模式的特点、适用场景及配置方法。 ... [详细]
  • 本文详细分析了Hive在启动过程中遇到的权限拒绝错误,并提供了多种解决方案,包括调整文件权限、用户组设置以及环境变量配置等。 ... [详细]
  • 解决MongoDB Compass远程连接问题
    本文记录了在使用阿里云服务器部署MongoDB后,通过MongoDB Compass进行远程连接时遇到的问题及解决方案。详细介绍了从防火墙配置到安全组设置的各个步骤,帮助读者顺利解决问题。 ... [详细]
  • MySQL缓存机制深度解析
    本文详细探讨了MySQL的缓存机制,包括主从复制、读写分离以及缓存同步策略等内容。通过理解这些概念和技术,读者可以更好地优化数据库性能。 ... [详细]
  • 优化ListView性能
    本文深入探讨了如何通过多种技术手段优化ListView的性能,包括视图复用、ViewHolder模式、分批加载数据、图片优化及内存管理等。这些方法能够显著提升应用的响应速度和用户体验。 ... [详细]
  • Valve 发布 Steam Deck 的新版 Windows 驱动程序
    Valve 最新发布了针对 Steam Deck 掌机的 Windows 驱动程序,旨在提升其在 Windows 环境下的兼容性、安全性和性能表现。 ... [详细]
  • 本文详细介绍了Java编程语言中的核心概念和常见面试问题,包括集合类、数据结构、线程处理、Java虚拟机(JVM)、HTTP协议以及Git操作等方面的内容。通过深入分析每个主题,帮助读者更好地理解Java的关键特性和最佳实践。 ... [详细]
  • 网络攻防实战:从HTTP到HTTPS的演变
    本文通过一系列日记记录了从发现漏洞到逐步加强安全措施的过程,探讨了如何应对网络攻击并最终实现全面的安全防护。 ... [详细]
  • MongoDB集群配置:副本集与分片详解
    本文详细介绍了如何在MongoDB中配置副本集(Replica Sets)和分片(Sharding),并提供了具体的步骤和命令,帮助读者理解并实现高可用性和水平扩展的MongoDB集群。 ... [详细]
author-avatar
江苏蓝凯-我家在装修_708
这个家伙很懒,什么也没留下!
PHP1.CN | 中国最专业的PHP中文社区 | DevBox开发工具箱 | json解析格式化 |PHP资讯 | PHP教程 | 数据库技术 | 服务器技术 | 前端开发技术 | PHP框架 | 开发工具 | 在线工具
Copyright © 1998 - 2020 PHP1.CN. All Rights Reserved | 京公网安备 11010802041100号 | 京ICP备19059560号-4 | PHP1.CN 第一PHP社区 版权所有