rabbitmq集群节点挂了_5个运行时异常

rabbitmq集群节点挂了_5个运行时异常本文关键字:MGR、监控、Wireshark 问题 在一个 MGR 集群里,一个节点异常退出后,MySQL 会如何进行调度?异常的节点什么时候会被踢出集群? 实验 实验开始前,给大家分享一个小经验:…

第14问:在 MGR 集群里,一个节点异常退出后,会发生什么?

本文关键字:MGR、监控、Wireshark

问题

在一个 MGR 集群里,一个节点异常退出后,MySQL 会如何进行调度?异常的节点什么时候会被踢出集群?

实验

实验开始前,给大家分享一个小经验:选择合适的观测工具,如果没有,就创造一个。

我们先使用三台虚拟机,创建一个 MGR 的集群。MySQL 的版本是 5.7.20(之所以使用低版本的 MySQL,因为恐怕没有人能说清楚这个低版本的 MGR 的行为,不能扯淡只能观测)。

这次我们忽略这一操作步骤,只看一下创建好的集群:

rabbitmq集群节点挂了_5个运行时异常

检查一下谁是 Primary:

rabbitmq集群节点挂了_5个运行时异常

现在我们得选择一个观测工具了。我们知道 MGR 需要通过网络来相互沟通,对集群内的节点状况达成一致。通过抓包对 MGR 的行为进行分析,看上去是个不错的主意。

不过 Wireshark 并不支持分析 MGR 的网络协议,我们只能自己创造一个 Wireshark 的分析插件(dissector)。

此处我们忽略创造插件的过程,直接拿来用就可以了。

我们访问:

https://github.com/actiontech/wireshark-dissector-mysql-group-replicaiton/releases

下载 Wireshark 的安装包,并安装好:

rabbitmq集群节点挂了_5个运行时异常

我们在 MGR 的 Primary 节点(test-mgr-1)上抓包:

rabbitmq集群节点挂了_5个运行时异常

然后将一个节点(test-mgr-3)干掉:

rabbitmq集群节点挂了_5个运行时异常

我们用刚安装的 Wireshark 打开抓包的文件 test-mgr-1.cap,并使用 MGR 协议解开抓包:

rabbitmq集群节点挂了_5个运行时异常

效果如图:

rabbitmq集群节点挂了_5个运行时异常

我们现在为 Wireshark 的列表增加一列,将 MGR 的信息类型显示出来:

rabbitmq集群节点挂了_5个运行时异常

rabbitmq集群节点挂了_5个运行时异常

这一列的公式为:mgr.app_data.body.cargo_type

这样我们就能看到 MGR 的信息类型:

rabbitmq集群节点挂了_5个运行时异常

现在我们通过过滤公式,找到特定类型的 MGR 信息:

rabbitmq集群节点挂了_5个运行时异常

可以看到 MGR 的 Primary(10.186.61.45,也就是 test-mgr-1)向另一个存活节点(10.186.61.71,也就是 test-mgr-2)发送了三个信息,分别是 view_msg,remove_node_type,view_msg。我们仔细看看这三个包的详细信息:

rabbitmq集群节点挂了_5个运行时异常

第一个包,是 Primary 发出的 view 信息(view 是 MGR 的各个节点的状态),可以看到这个 view 的信息是:第一个节点在线,第二个节点在线,第三个节点离线。

rabbitmq集群节点挂了_5个运行时异常

第二个包是删除节点的通知,Primary 通知其他节点,将删除离线的节点三。

rabbitmq集群节点挂了_5个运行时异常

第三个包是一秒之后发送的,Primary 通知其他节点新的 view 是什么样的:新的 view 只有两个节点了。

通过抓包,我们看到了 MGR 各个节点间的信息交换,借此理解 MGR 节点间的调度行为。

在一个节点崩溃后,Primary 节点很快就向全员更新了某节点离线的信息。然后将其踢出集群,并将决定通知全员。

希望我们创造的这个 Wireshark 插件,可以帮助大家理解 MGR 的调度行为,也欢迎大家提需求或缺陷。


关于 MySQL 的技术内容,你们还有什么想知道的吗?赶紧留言告诉小编吧!

rabbitmq集群节点挂了_5个运行时异常

版权声明:本文内容由互联网用户自发贡献,该文观点仅代表作者本人。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如发现本站有涉嫌侵权/违法违规的内容, 请发送邮件至 举报,一经查实,本站将立刻删除。
转载请注明出处: https://daima100.com/7585.html

(0)
上一篇 2023-03-18
下一篇 2023-03-18

相关推荐

  • Mysql中 instr与concat

    Mysql中 instr与concat#INSTR(字符串, 子串),#返回值:第一个子串的索引-1#类似indexOf()#例如:SELECT INSTR('人民万岁,世界万岁','万')SELECT I

    2022-12-17
    120
  • SQL 入门教程:更新(UPDATE)数据[通俗易懂]

    SQL 入门教程:更新(UPDATE)数据[通俗易懂]目录汇总:SQL 入门教程:面向萌新小白的零基础入门教程 更新(修改)表中的数据,可以使用 UPDATE 语句。有两种使用 UPDATE 的方式: 更新表中的特定行; 更新表中的所有行。 下面分别介绍

    2023-04-21
    106
  • 工具 | 常用 MySQL 内核 Debug 技巧「终于解决」

    工具 | 常用 MySQL 内核 Debug 技巧「终于解决」作者:柯煜昌 顾问软件工程师 目前从事 RadonDB MySQL 容器化研发,华中科技大学研究生毕业,有多年的数据库内核开发经验。 掌握 MySQL 内核源码的阅读和调试能力,不仅是数据库研发人员的

    2023-05-02
    98
  • 使用def函数定义Python函数

    使用def函数定义Python函数在Python中,函数是指一段可重复调用的代码块。它接受输入(如果有)并返回输出(如果有)。Python使用关键字def(define,定义)来定义函数。通过使用函数,我们可以将复杂的问题分解为更小的可处理的部分。这种分解是结构编程的一种基本思想。

    2024-04-24
    11
  • StoneDB读写分离实践方案「终于解决」

    StoneDB读写分离实践方案「终于解决」在 StoneDB 1.0 版本中,InnoDB 引擎处理 OLTP 的事务型业务,Tianmu 引擎处理 OLAP 的分析型业务。因此,需要在主从复制环境的基础上做读写分离,所有的写操作和部分读操作

    2023-06-09
    74
  • 使用SQLyog备份还原数据库

    使用SQLyog备份还原数据库1、点击“备份/导出”2、默认选中“包括CREATEDataBase语句”,这样的话,在目标服务器直接把这个sql文件导入后就可以和源数据库名一样的数据库,但是使用SQLyog不能修改数据库名导出的…

    2023-03-25
    96
  • pdo 预处理_C语言中什么是预处理

    pdo 预处理_C语言中什么是预处理什么叫预处理语法 就是,为了“重复执行”多条结构类似的sql语句,而将该sql语句的形式“进行预先处理”(编译); 该sql语句的“形式”中,含有“未给定的数据项”。 然后,到正式执行的时候,只要给…

    2023-02-10
    113
  • linux 学习 mysql安装到连接

    linux 学习 mysql安装到连接目录 下载与安装 1.方法一(本地翻墙) 2.方法二(本地不翻墙) 初始化和配置 1.初始化mysql 2.远程访问的设置 3.用户组权限的修改 ps:一般mysql安装后会在/var/log/下面生

    2023-02-06
    105

发表回复

您的电子邮箱地址不会被公开。 必填项已用*标注