一次线上事故,我顿悟了MongoDB的精髓

news2024/11/23 18:51:26

目录

    • MongoDB拒绝连接?显然是MongoDB服务又挂了。
    • mongodb启动异常:about to fork child process, waiting until server is ready for connection
    • 一、什么是MongoDB分片?
    • 二、MongoDB如何分片?
    • 三、何时分片?
    • 四、搭建MongoDB分片服务器
      • 1、配置服务器 config进程
      • 2、mongos进程
      • 3、将副本集转换为分片
      • 4、数据分片
    • 五、MongoDB如何追踪集群数据?
      • 1、数据块
      • 2、块范围
      • 3、拆分块
    • 六、均衡器

大家好,我是哪吒,最近项目在使用MongoDB作为图片和文档的存储数据库,为啥不直接存MySQL里,还要搭个MongoDB集群,麻不麻烦?

让我们一起,一探究竟,继续学习MongoDB分片的理论与实践,实现快速入门,丰富个人简历,提高面试level,给自己增加一点谈资,秒变面试小达人,BAT不是梦。

MongoDB拒绝连接?显然是MongoDB服务又挂了。

在这里插入图片描述

连接MongoDB服务器,一探究竟。

通过ps -aef|grep mongo查看mongo服务是否还在?不出所料,都不在了。

在这里插入图片描述

大概率是因为磁盘满了。

df -TH查看磁盘空间。

在这里插入图片描述

磁盘100%如何解决?

cd到log目录下,通过rm -rf *删除所有日志,再重启MongoDB。

mongodb启动异常:about to fork child process, waiting until server is ready for connection

在这里插入图片描述

由于MongoDB是集群部署的,启动时,会进行数据同步,可能会比较耗时,性子急的我,怎么能忍,直接Ctrl C,强制停止,然后再重新启动。

通过ps -aef|grep mongo查看一下进程,两个一样的进程赫然在列。

通过ps -aef|grep mongo | grep -v grep | awk '{print $2}' | xargs kill -9强制停止所有mongo进程。

在这里插入图片描述

将data目录下的 mongod.lock 和 diagnostic.data文件删掉,再重启MongoDB,启动脚本mongos_start.sh(mongod --config data/mongodb.conf),完美解决。

在这里插入图片描述

MongoDB服务器的部署目录中都是什么含义呢?它们之间又有什么关系呢?下面简单介绍一下MongoDB的分片。

在这里插入图片描述

一、什么是MongoDB分片?

分片是指跨机器拆分数据的过程,也可以叫做分区。

MongoDB支持手动分区,使用这种方法,应用程序会维护到多个不同数据库服务器端的连接,每个服务器端都是完全独立的。应用程序不仅管理不同服务器上不同数据的存储,还管理在适当的服务器上查询数据。但当从集群中添加或删除节点,或者面对数据分布或负载模式的变化时,难以维护。

MongoDB支持自动分片,这种方式试图将数据库架构从应用程序中抽离出来,并简化系统管理。MongoDB自动均衡分片上的数据,使节点的添加和删除变得更容易。

MongoDB的分片机制允许你创建一个由许多分片组成的集群,并将集合中的数据分散在集群中,在每个分片上放置数据的一个子集。这允许应用程序超出单机服务器或副本集的资源限制。

分片组成的集群对应用程序来说就像一台单机服务器,分片前运行一个或多个称为mongos的路由进程,mongos维护着一个“目录”,指明了每个分片包含哪些数据。应用程序可以正常连接到此路由服务器并发出请求。路由服务器知道哪些数据在哪个分片上,可以将请求转发到适当的分片。如果有对请求的响应,理由服务器会收集它们,并将它们合并,然后再返回给应用程序,对应用程序而言,它只知道自己连接到了一个单独的mongod。

在这里插入图片描述

二、MongoDB如何分片?

在单台机器上快速建立一个集群。首先,使用--nodb--norc选项启动mongo shellmongo --nodb --norc

使用ShardingTest类创建集群。运行如下代码:

st = ShardingTest({
	name:"one-min-shards",
	chunkSize:1,
	shards:2,
	rs:{
		nodes:3,
		oplogSize:10
	},
	other:{
		enableBalancer:true
	}
});
  • name:分片集群的标签;
  • shards:制定了集群由两个分片组成;
  • rs:将每个分片定义为一组3个节点的副本集;
  • enableBalancer:在集群启动后启用均衡器;

ShardingTest是为了支持服务器端测试套件设计的,它在保持尽可能低的资源占用以及建立体系结构相对复杂的分片集群方面,提供了很多便利。当运行ShardingTest后,它会创建一个包含两个分片的集群,每个分片都是一个副本集。同时会对副本集进行配置,并使用必要的选项启动每个节点以建立复制协议。它会启动一个mongos来管理跨分片的请求,这样客户端就可以像与一个独立的mongod通信一样与集群进行交互。最后,它会为用于维护理由表信心的配置服务器启动一个额外的副本集,以确保查询被定向到正确的分片。

分片的主要使用场景是拆分数据集以解决硬件和成本的限制,或为应用程序提供更好的性能。

当ShardingTest完成集群设置后,将启动并运行10个进程,你可以连接到这些进程:两个副本集(各有3个节点)、一个配置服务器副本集(3个节点),以及一个mongos。默认情况下,这些进程会从20000端口开始。mongos会运行在20009端口上。

三、何时分片?

通常情况下,分片用于:

  • 增加可用RAM;
  • 增加可用磁盘空间;
  • 减少服务器的负载;
  • 处理单个MongoDB无法承受的吞吐量;

在这里插入图片描述

四、搭建MongoDB分片服务器

1、配置服务器 config进程

配置服务器是集群的大脑,保存着关于每个服务器包含哪些数据的所有元数据,因此必须首先创建配置服务器。配置服务器非常重要,运行时必须启动日志功能,并确保它的数据存储在非临时性驱动器上。

配置服务器必须在任何一个mongos进程之前通过mongod -f config.conf启动,因为mongos需要从配置服务器中提取配置信息。

当对配置服务器进行写入时,MongoDB会使用“majority” 的 writeConcern级别;
当对配置服务器进行读取时,MongoDB会使用“majority” 的 readConcern级别;

这确保了分片集群元数据在不发生回滚的情况下才会被提交到配置服务器副本集。它还确保了只有那些不受配置服务器故障影响的元数据才能被读取。这可以确保所有mongos路由节点对分片集群中的数据组织方式具有一致性。

在服务器资源方面,配置服务器应该具有充分的网络和CPU资源,配置服务器只保存了集群中数据的目录,因此只需要很少的硬盘存储资源。

由于配置服务器的重要性,在进行任何集群维护前,都应该先对配置服务器的数据进行备份。

2、mongos进程

mongos 是路由服务器,供应用程序连接使用。通过mongod -f config.conf启动路由服务器,mongos进程需要知道配置服务器的地址,因此需要在config.conf中配置 configdb=configReplSet/配置服务器的三个地址,通过配置logpath,保存MongoDB的日志。

应该启动一定数量的mongos进程,并尽可能将其放在靠近所有分片的位置,这样可以提高查询性能。

3、将副本集转换为分片

在依次启动配置服务器、路由服务器后,可以添加分片了,如果之前已经存在副本集,那么这个副本集就会成为第一个分片。

从MongoDB 3.4 开始,对于分片集群,分片的mongod实例必须配置 --shardsvr 选项,也就是在config.conf中添加shardsvr=true,将副本集转换为分片的过程中,需要对副本集的每个成员都重复以上动作。

将副本集作为分片添加到集群后,就可以将应用程序的连接从副本集改为mongos路由服务器了,并通过设置防火墙,切断应用程序与分片的直接连接。

4、数据分片

(1)如何数据分片

假如有一个test数据库,并在name键上对worker集合进行分片。

  1. 先对数据库进行分片,> sh.enableSharding("test")
  2. 再对集合进行分片,sh.shardCollection("test.worker",{"name":1})

如果worker集合已经存在,则必须在name字段上有索引,否则,shardCollection会返回错误。如果分片的集合不存在,mongos会自动在name片键上创建索引。

shardCollection命令会将集合拆分成多个数据块,MongoDB会在集群中的分片间均匀的分散集合中的数据。

在这里插入图片描述

五、MongoDB如何追踪集群数据?

1、数据块

因为MongoDB的数据量巨大,MongoDB一般会将文档以数据块的形式进行分组,这些数据块是片键指定范围内的文档,MongoDB一般会用一个较小的表来维护数据块与分片之间的映射关系。

需要注意:

  1. 块与块之间不能重叠;
  2. 一个块中的文档数量过大时,会自动拆分成两个文档;
  3. 一个文档总是属于且仅属于一个块;

2、块范围

  1. 新分片的集合中只有一个块,块的边界是负无穷到正无穷;
  2. 随着块的增长,MongoDB会自动将其拆分成两块,范围从负无穷到value,value到正无穷。范围较小的块包含比value小的值,范围较大的块包含value和比value大的值;

因此,mongos可以很容易的找到文档在哪个块。

3、拆分块

各个分片的主节点mongod进程会跟踪它们当前的块,一旦达到某个阈值,就会检查该块是否需要拆分,如果需要拆分,mongod就会从配置服务器请求全局块大小配置值,然后执行块拆分并更新配置服务器上的元数据。配置服务器会创建新的块文档,并修改旧块的范围。

当客户端写入一个块时,mongod会检查该块的拆分阈值。

在这里插入图片描述

如果已经达到了拆分阈值,mongod就会向均衡器发送一个请求,将最顶部的块进行迁移,否则该块会留在此分片上。

在这里插入图片描述

因为具有相同片键的两个文档一定会处于相同的块中,所以只能在片键值不同的文档之间进行拆分。

下面文档如果以readTime分片,是可以的。

但是,如果我读书读的比较快,所有书籍在一个月的时间里都读完了,readTime就会是一样的了,那就无法分片了。

因此拥有不同的片键值在分片时,显得尤其重要。

{"name":"哪吒编程","book":"Java核心技术","readTime":"October"}
{"name":"哪吒编程","book":"Java编程思想","readTime":"October"}
{"name":"哪吒编程","book":"深入理解Java虚拟机","readTime":"October"}
{"name":"哪吒编程","book":"effective java","readTime":"November"}
{"name":"哪吒编程","book":"重构 改善既有代码的设计","readTime":"November"}
{"name":"哪吒编程","book":"高性能MySQL","readTime":"December"}
{"name":"哪吒编程","book":"Spring技术内幕","readTime":"December"}
{"name":"哪吒编程","book":"重学Java设计模式","readTime":"December"}
{"name":"哪吒编程","book":"深入理解高并发编程","readTime":"January"}
{"name":"哪吒编程","book":"Redis设计与实现","readTime":"January"}

分片的前提条件是所有的配置服务器必须启动并可以访问。如果mongod不断接到对一个块的写请求,则它会持续尝试拆分该块并失败,而这些拆分尝试会拖慢mongod。mongod反复尝试分片却无法成功分片的过程被称为拆分风暴

在这里插入图片描述

六、均衡器

均衡器负责数据的迁移。均衡器会定期检查分片之间是否存在不均衡,如果存在,就会对块进行迁移。在MongoDB 3.4 以上的版本上,均衡器位于配置服务器副本集的主节点成员上。

均衡器是配置服务器副本集主节点上的后台进程,它会监视每个分片上的块数量。只有当一个分片上的块数量达到特定迁移阈值时,均衡器才会被激活。


在这里插入图片描述

Java学习路线总结,搬砖工逆袭Java架构师

10万字208道Java经典面试题总结(附答案)

Java基础教程系列

Java高并发编程系列

数据库进阶实战系列

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/165515.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

算法:链表(力扣+牛客经典题)

链表 力扣 203. 移除链表元素 思路:使用while循环每找到指定的值,就把下一个节点指向下下个节点的位置 /*** Definition for singly-linked list.* public class ListNode {* int val;* ListNode next;* ListNode() {}* ListNode(int…

【指针笔试题下】你知道大厂面试题的指针题是什么样的吗?快来通过这些面试题目检测一下自己吧!

目录 前言 笔试题1: 笔试题2: 笔试题3: 笔试题4: 笔试题5: 笔试题6: 笔试题7: 笔试题8: 总结: 博客主页:张栩睿的博客主页 欢迎关注:点赞收藏留…

JVM--Garbage First(G1) 垃圾收集器

G1 (Garbage-First)是一款面向服务器的垃圾收集器,主要针对配备多颗处理器及大容量内存的机器. 以极高概率满足GC停顿时间要求的同时,还具备高吞吐量性能特征。G1垃圾回收器是在Java7 update 4之后引入的一个新的垃圾回收器,在 JDK9 中更被指定为官方GC收集器一、G1…

【零基础】学python数据结构与算法笔记12

文章目录前言74.AVL树的概念75.AVL:旋转76.AVL:旋转实现177.AVL:旋转实现278.AVL:插入79.AVL树应用与数据结构总结总结前言 学习python数据结构与算法,学习常用的算法, b站学习链接 74.AVL树的概念 首先看一下二叉搜索树的效率 平均情况下&#xff0c…

networkx学习(三) 小世界网络

networkx学习(三) 小世界网络 1.小世界网络模型 K-近邻规则网络的生成与可视化

彻底分析Arduino库安装和开发板库安装路径和方式

参考:https://blog.csdn.net/weixin_43794311/article/details/128631564,https://blog.csdn.net/t01051/article/details/103766886 一个最简单的安装esp8266和esp32的方法 在网址:https://arduino.me/download,下载对应的开发…

dp(七)把数字转化为字符串 (力扣版+牛客版) 跳台阶问题+最小花费跳台阶

目录 l剑指 Offer 46. 把数字翻译成字符串力扣版本 把数字翻译成字符串_牛客题霸_牛客网牛客版 滚动数组优化 跳台阶【一】 (大数取模)一 八个零七 最小花费爬楼梯 l剑指 Offer 46. 把数字翻译成字符串力扣版本 给定一个数字,按照对应的格…

【微信小程序入门到精通】—小程序实战构建售货平台首页

目录前言一、步骤阐述二、新建项目并梳理结构三、配置导航栏四、tabBar 实现五、轮播图实现总结前言 对于目前形式,微信小程序是一个热门,那么我们该如何去学习并且掌握之后去做实际项目呢? 为此我特意开设此专栏,在我学习的同时也…

买车是个计算题,看上了比亚迪的宋DMI,选择困难了,选择55km的还是,110km的,理科生一起计算下。

1,背景 赶时髦,啥新鲜就购买啥,最火的车子当然是比亚迪宋dmi。 大家都买说明还不错,买车还要排队。等上一阵子了。 而且可以省下购置税。 就按照最热销的110 km 的版本 17/1.13*0.1 1.50 w 按照发票上“价税总计”金额计算的话…

计算两个字符串的相似度difflib.SequenceMatcher

【小白从小学Python、C、Java】 【计算机等级考试500强双证书】 【Python-数据分析】 计算两个字符串的相似度 difflib.SequenceMatcher 选择题 对于以下python代码表述错误的是? from difflib import SequenceMatcher myText1"我想学习Python做人工智能项目" myTex…

SpringCloud-Netflix学习笔记01——SpringCloud入门

一、SpringCloud是什么 Spring官网:https://spring.io/ SpringCloud, 基于SpringBoot提供了一套微服务解决方案,包括服务注册与发现,配置中心,全链路监控,服务网关,负载均衡,熔断器等组件&#…

mybatis plus基本使用初体验02

1.常用注解 1.1 TableName注解 MyBatis-Plus在确定操作的表时,由BaseMapper的泛型决定,即实体类型决定,且默认操作的表名和实体类型的类名一致。若实体类类型的类名和要操作的表的表名不一致,会出现什么问题? 将数据…

力扣sql基础篇(八)

力扣sql基础篇(八) 1 大满贯数量 1.1 题目内容 1.1.1 基本题目信息 1.1.2 示例输入输出 1.2 示例sql语句 # Championship的数字代表的就是赢得比赛的球员的id,可以使用行转列(UNION all) #如果涉及到分组函数,建议还是不要写除了分组字段外的其他字段,因为不太符合标准sql …

正则化:五重境界理解减少过拟合的神器

本文来自公众号“AI大道理” 正则化作为减少过拟合的手段被大量的使用,那么为什么会出现过拟合呢?正则化又是什么?是怎么样发挥作用的呢? 1、过拟合是什么? 过拟合是指模型在训练集上取得很高的识别性能&#xff0c…

Ubuntu 22.04配置静态IP地址

1、查看ip地址网卡名称:ifconfig 2、编辑网卡配置文件:sudo vim /etc/netplan/01-network-manager-all.yaml 默认样式: network: version: 2 renderer: NetworkManager 3、修改为: network: ethernets: enp7s0: dhcp4: no dhcp6: …

【Kotlin】集合操作 ① ( List 创建与元素获取 | 安全获取集合元素 | getOrElse | getOrNull )

文章目录一、List 创建与元素获取二、安全获取集合元素1、getOrElse 函数2、getOrNull函数三、List 创建与元素获取代码示例一、List 创建与元素获取 Kotlin 中的集合分为两类 , 只读集合 和 可变集合 ; 调用 listOf 函数 , 可以 直接创建 List 集合 ; 通过 [] 下标可以 直接获…

Spring系列 容器

创建容器 方式一:类路径加载配置文件: ApplicationContext ctx new ClassPathXmlApplicationContext("applicationContext.xml"); 方式二:文件路径加载配置文件(用绝对路径): ApplicationConte…

闲话统信UOS

这周统信UOS正式在官网发布了22.0镜像统信UOS家庭版官网-正版国产操作系统--统信软件 (uniontech.com) 支持双系统:不影响原有系统使用,更换系统不担心电脑资料丢失; 官方应用商店:无病毒、放心安全下载,工作学习无打…

[C/Linux练习]进度条小程序

前置知识点 \n\r \n 换行,但只是垂直向下,并不水平移动。 \r 回车,返回当前行的头部。 光标返回头部后再打印,会从头开始覆盖之前打印在该行的内容。 printf的\n默认解释成换行回车。 光标是与显示器匹配的,光标在哪…

基于PHP的宠物社会化小程序

摘要随着信息技术和网络技术的飞速发展,人类已进入全新信息化时代,传统管理技术已无法高效,便捷地管理信息。为了迎合时代需求,优化管理效率,各种各样的管理系统应运而生,各行各业相继进入信息管理时代&…