zoukankan      html  css  js  c++  java
  • MongoDB学习笔记(四) 集群搭建之主从复制

    常见的 MongoDB 集群有三种,分别是主从复制、副本集和分片,这篇文章将会对主从复制进行简单的介绍

    开始先说一下,这篇文章用到的所有代码都是经过本地测试的,博主用于测试的操作系统为 CentOS 7

    好,下面正式开始!

    1、介绍

    主从复制(Master/Slaver)可以算得上是最简单的一种集群搭建方式啦,严格来说可能都算不上一个集群

    实际上,它只是 使用一个或多个从节点同步主节点的数据 而已,整体结构并不复杂,搭建起来也比较简单

    主从复制集群的特点如下:

    • 使用从节点对主节点的数据进行备份,保障数据安全
    • 读写操作均发生在主节点上,导致主节点压力较大
    • 当主数据库挂掉之后,客户端无法继续读写数据

    数据同步

    主节点在写入或更新数据的同时,将操作信息写入 oplog (operation log) 日志文件

    从节点定期获取主节点的 oplog,然后根据日志内容更新自身数据,从而保持与主节点一致

    2、搭建

    下面是在本地进行的一个简单模拟,一个主节点,一个从节点

    (1)下载 MongoDB

    > su
    > cd /root
    > mkdir mongodb-master-slaver-cluster
    > cd mongodb-master-slaver-cluster
    
    > mkdir mongodb
    > cd mongodb
    > wget https://fastdl.mongodb.org/linux/mongodb-linux-x86_64-3.2.7.tgz
    > tar -zxvf mongodb-linux-x86_64-3.2.7.tgz
    > cd ..
    

    (2)创建两个文件夹,分别用于模拟 master 和 slaver 节点

    > mkdir master # 主节点
    > touch ./master/mongodb.conf
    > mkdir ./master/log
    > mkdir -p ./master/data/db
    
    > mkdir slaver # 从节点
    > touch ./slaver/mongodb.conf
    > mkdir ./slaver/log
    > mkdir -p ./slaver/data/db
    

    创建完成之后,目录结构如下:

    + mongodb-master-slaver-cluster
    	+ mongodb
    		+ mongodb-linux-x86_64-3.2.7.tgz
    		+ mongodb-linux-x86_64-3.2.7
    	+ master
    		+ log
    		+ data
    			+ db
    		+ mongodb.conf
    	+ slaver
    		+ log
    		+ data
    			+ db
    		+ mongodb.conf
    

    (3)写配置文件

    # master/mongodb.conf 文件内容
    # 数据文件的存放位置
    dbpath = /root/mongodb-master-slaver-cluster/master/data/db
    # 日志文件的存放位置
    logpath = /root/mongodb-master-slaver-cluster/master/log/mongodb.log
    # 监听的端口,默认为 27017
    port = 27001
    # 以守护进程的方式运行 MongoDB
    fork = true
    
    # 确认本节点为 master 节点
    master = true
    
    # slaver/mongodb.conf 文件内容
    # 数据文件的存放位置
    dbpath = /root/mongodb-master-slaver-cluster/slaver/data/db
    # 日志文件的存放位置
    logpath = /root/mongodb-master-slaver-cluster/slaver/log/mongodb.log
    # 监听的端口,默认为 27017
    port = 27002
    # 以守护进程的方式运行 MongoDB
    fork = true
    
    # 确认本节点为 slaver 节点
    slave = true
    # 指定数据同步来源,指向 master 节点
    source = 127.0.0.1:27001
    

    (4)分别开启两个数据库

    > cd /root/mongodb-master-slaver-cluster/mongodb/mongodb-linux-x86_64-3.2.7/bin/
    > ./mongod -f /root/mongodb-master-slaver-cluster/master/mongodb.conf
    > ./mongod -f /root/mongodb-master-slaver-cluster/slaver/mongodb.conf
    

    这样就可以啦,此时应该可以看到两个 MongoDB 进程正在运行

    > ps aux | grep mongo
    

    3、测试

    打开新的终端,连接到主数据库,插入一条数据(可写),之后对其进行查询(可读)

    > cd /root/mongodb-master-slaver-cluster/mongodb/mongodb-linux-x86_64-3.2.7/bin/
    > ./mongo mongodb://127.0.0.1:27001/admin
    
    > db.user.insert({'username': 'Alice', 'password': '123456'}) // 插入数据(可写)
    // WriteResult({ "nInserted" : 1 })
    > db.user.find() // 查询数据(可读)
    // { "username" : "Alice", "password" : "123456" }
    

    打开另外一个终端,连接到从数据库,查询是否同步(可读),然后尝试在从数据库中插入一条数据(不可写)

    > cd /root/mongodb-master-slaver-cluster/mongodb/mongodb-linux-x86_64-3.2.7/bin/
    > ./mongo mongodb://127.0.0.1:27002/admin
    
    > rs.slaveOk() // 在查询之前需要先设置从节点状态
    > db.user.find() // 查询数据(可读)
    // { "username" : "Alice", "password" : "123456" }
    > db.user.insert({'username': 'Bob', 'password': 'abc'}) // 插入数据(不可写)
    // WriteResult({ "writeError" : { "code" : 10107, "errmsg" : "not master" } })
    

    再开一个终端,手动关闭主数据库,模拟主节点挂掉的情况

    > cd /root/mongodb-master-slaver-cluster/mongodb/mongodb-linux-x86_64-3.2.7/bin/
    > ./mongod --shutdown --dbpath /root/mongodb-master-slaver-cluster/master/data/db
    

    如果这时我们再对主数据库发送查询或插入的请求,都会显示连接失败的错误

    > db.user.find()
    // network error while attempting to run command 'find' on host '127.0.0.1:27001' 
    

    【 阅读更多 MongoDB 系列文章,请看 MongoDB学习笔记

    版权声明:本博客属于个人维护博客,未经博主允许不得转载其中文章。
  • 相关阅读:
    Flink 源码(十一):阅读 Flink 源码前必会的知识(六)高性能异步编程 和 实时流模型关联
    Flink 源码(十):阅读 Flink 源码前必会的知识(五)SPI 和 ClassLoader(二) SPI 技术
    Flink 源码(九):阅读 Flink 源码前必会的知识(四)SPI 和 ClassLoader(一)ClassLoader
    Flink 源码(八):阅读 Flink 源码前必会的知识(三)Java 8 异步编程 CompletableFuture 全解析(三)
    Flink 源码(七):阅读 Flink 源码前必会的知识(二)Java 8 异步编程 CompletableFuture 全解析(二)
    Flink 源码(六):阅读 Flink 源码前必会的知识(一)Java 8 异步编程 CompletableFuture 全解析(一)
    GIT基础(二十四):Git 基本操作(十五)git push 命令
    GIT基础(二十三):Git 基本操作(十四)git pull 命令
    吴恩达机器学习CS229课程笔记学习
    KVM 虚机的创建过程
  • 原文地址:https://www.cnblogs.com/wsmrzx/p/11599027.html
Copyright © 2011-2022 走看看