数据库MySQL集群MGR

news2025/6/5 12:37:47

一、MGR原理

一、基本定义

MGR（MySQL Group Replication） 是 MySQL 官方推出的一种高可用、高可靠的数据库集群解决方案，基于分布式系统理论（如 Paxos 协议变种）实现，主要用于构建强一致性的主从复制集群，支持多主或单主模式，确保数据在多个节点之间的可靠复制和故障转移。

二、核心特性

  1. 强一致性（Consistency）

    • 通过分布式事务协调机制（基于 Paxos 的优化协议），确保所有节点的数据变更按相同顺序提交，避免传统主从复制可能出现的异步延迟导致的数据不一致问题。
    • 所有写操作需多数节点（Quorum）确认后才会提交，保证集群内数据的强一致性。

  2. 高可用性（High Availability）

    • 自动检测节点故障，当主节点失效时，集群可自动选举新主节点（需满足多数节点存活），无需人工干预，减少服务中断时间。
    • 支持在线添加 / 删除节点，不影响集群正常运行。

  3. 多主或单主模式

    • 单主模式（Single-Master）：仅允许一个主节点写入，其他节点作为从节点只读，适合传统主从架构场景，避免多主写入冲突。
    • 多主模式（Multi-Master）：允许多个节点同时写入，通过冲突检测机制（如行级锁、全局事务 ID）避免写入冲突，适合读写分离或分布式写入场景。

  4. 成员管理与故障检测

    • 基于组通信协议（如 NetXCOM）实现节点间的状态同步和心跳检测，实时监控集群成员状态。
    • 节点加入 / 退出集群时，通过自动数据同步（State Transfer）快速完成数据初始化，无需手动备份恢复。
三、架构原理

  1. 节点角色

    • 主节点（Primary）：处理写操作并将变更同步到其他节点（单主模式下唯一可写节点；多主模式下所有节点均可写）。
    • 从节点（Replica）：接收主节点的变更并应用，提供读服务。

  2. 关键组件

    • Group Replication Plugin：实现节点加入集群、事务协调、故障检测等核心逻辑。
    • MySQL Binlog：记录数据变更，通过组复制协议在节点间同步。
    • InnoDB 存储引擎：支持事务和行级锁，确保冲突检测和一致性。

  3. 工作流程

    • 写事务提交时，主节点将事务包装为 “写集合”（Write Set），通过组播协议发送给所有从节点。
    • 从节点验证事务是否冲突（如更新同一行记录），无冲突则应用事务，有冲突则回滚。
    • 多数节点确认事务提交后，主节点才最终提交事务，确保数据一致性。

二、部署MGR集群

部署mgr集群需要三个MySQL单实例，MySQL安装单机版本安装就好了，这里不再说MySQL单机部署了跳过，介绍MGR集群如果构建。

介绍基础环境 三个节点10.10.65.101,10.10.65.102,10.10.65.103，已安装了MySQL单实例（注意这里要把MySQL的密码策略调整一致，如果不一致后期会因为这个组复制失败）

一、基础环境 把三台机器的信息写入到/etc/hosts文件里。

cat >> /etc/hosts <<  EOF
10.10.65.101 mgr1-010010065101
10.10.65.102 mgr2-010010065102
10.10.65.103 mgr3-010010065103
EOF

二、部署多主模式

有两种模式 一种是 single-primary 一种是 multi-primary 即单主或多主，这里部署的是多主模式

配置注意

每个节点配置需要不同

server-id=1

每个节点配置文件这个参数是自己节点的IP地址

group_replication_local_address=10.10.65.101:33061

每个节点配置文件uuid需要都相同

group_replication_group_name=70e4c56a-63b9-4666-bcd1-165266666eb9f

配置文件每个节点不一样

10.10.65.101 的配置文件

[client] 　
default-character-set=utf8mb4
[mysql]
default-character-set=utf8mb4
[mysqld]
NGINE_SUBSTITUTION
character-set-server=utf8mb4
# 注意这里我改了MySQL的存储目录
datadir=/data/mysql
socket=/var/lib/mysql/mysql.sock
symbolic-links=0
log-error=/data/mysql/mysqld.log
pid-file=/data/mysqld/mysqld.pid

# MGR集群
# 插件目录
plugin_dir=/usr/lib64/mysql/plugin

server-id=1
gtid_mode=ON
enforce_gtid_consistency=ON
log_bin=binlog
binlog_format=ROW
log_slave_updates=ON
transaction_write_set_extraction=XXHASH64

# MGR配置
master_info_repository=TABLE
relay_log_info_repository=TABLE
binlog_checksum=NONE
early_plugin_load="group_replication.so"
group_replication_group_name=70e4c56a-63b9-4666-bcd1-165266666eb9f
group_replication_start_on_boot=OFF
group_replication_local_address=10.10.65.101:33061
group_replication_group_seeds=10.10.65.101:33061,10.10.65.102:33061,10.10.65.103:33061
group_replication_bootstrap_group=OFF
group_replication_single_primary_mode=OFF
group_replication_enforce_update_everywhere_checks=ON

# 其他优化参数
innodb_buffer_pool_size=1G
innodb_flush_log_at_trx_commit=2
sync_binlog=0

10.10.65.102 的配置文件

[client] 　
default-character-set=utf8mb4
[mysql]
default-character-set=utf8mb4
[mysqld]
character-set-server=utf8mb4
datadir=/data/mysql
socket=/var/lib/mysql/mysql.sock
symbolic-links=0
log-error=/data/mysql/mysqld.log
pid-file=/data/mysqld/mysqld.pid

# MGR集群
# 插件目录
plugin_dir=/usr/lib64/mysql/plugin

server-id=2
gtid_mode=ON
enforce_gtid_consistency=ON
log_bin=binlog
binlog_format=ROW
log_slave_updates=ON
transaction_write_set_extraction=XXHASH64


# MGR配置
master_info_repository=TABLE
relay_log_info_repository=TABLE
binlog_checksum=NONE
early_plugin_load="group_replication.so"
group_replication_group_name=70e4c56a-63b9-4666-bcd1-165266666eb9f
group_replication_start_on_boot=OFF
group_replication_local_address=10.10.65.102:33061
group_replication_group_seeds=10.10.65.101:33061,10.10.65.102:33061,10.10.65.103:33061
group_replication_bootstrap_group=OFF
group_replication_single_primary_mode=OFF
group_replication_enforce_update_everywhere_checks=ON

# 其他优化参数
innodb_buffer_pool_size=1G
innodb_flush_log_at_trx_commit=2
sync_binlog=0

10.10.65.103 的配置文件

[client] 　
default-character-set=utf8mb4
[mysql]
default-character-set=utf8mb4
[mysqld]
character-set-server=utf8mb4
datadir=/data/mysql
socket=/var/lib/mysql/mysql.sock
symbolic-links=0
log-error=/data/mysql/mysqld.log
pid-file=/data/mysqld/mysqld.pid


# MGR集群
# 插件目录
plugin_dir=/usr/lib64/mysql/plugin

server-id=3
gtid_mode=ON
enforce_gtid_consistency=ON
log_bin=binlog
binlog_format=ROW
log_slave_updates=ON
transaction_write_set_extraction=XXHASH64


# MGR配置
master_info_repository=TABLE
relay_log_info_repository=TABLE
binlog_checksum=NONE
early_plugin_load="group_replication.so"
group_replication_group_name=70e4c56a-63b9-4666-bcd1-165266666eb9f
group_replication_start_on_boot=OFF
group_replication_local_address=10.10.65.103:33061
group_replication_group_seeds=10.10.65.101:33061,10.10.65.102:33061,10.10.65.103:33061
group_replication_bootstrap_group=OFF
group_replication_single_primary_mode=OFF
group_replication_enforce_update_everywhere_checks=ON

# 其他优化参数
innodb_buffer_pool_size=1G
innodb_flush_log_at_trx_commit=2
sync_binlog=0

准备好上述配置文件后，重启MySQL数据库 。

三、创建用于MGR集群组复制的账号

以下sql在所有节点上操作

mysql> use mysql;
Reading table information for completion of table and column names
You can turn off this feature to get a quicker startup with -A

Database changed
mysql> SELECT User, Host FROM user;
+---------------+-----------+
| User          | Host      |
+---------------+-----------+
| admin         | %         |
| root          | %         |
| mysql.session | localhost |
| mysql.sys     | localhost |
| root          | localhost |
+---------------+-----------+
5 rows in set (0.00 sec)

mysql> CREATE USER 'repl_user'@'%' IDENTIFIED BY 'ReplicationPassword1!';
Query OK, 0 rows affected (0.00 sec)

mysql> GRANT REPLICATION SLAVE ON *.* TO 'repl_user'@'%';
Query OK, 0 rows affected (0.00 sec)

mysql> FLUSH PRIVILEGES;
Query OK, 0 rows affected (0.00 sec)

四、创建mgr集群

在第一节点操作 引导创建集群

SET GLOBAL group_replication_bootstrap_group=ON;
START GROUP_REPLICATION;
SET GLOBAL group_replication_bootstrap_group=OFF;
SELECT * FROM performance_schema.replication_group_members;

查询第一个节点创建出来的集群信息，目前只有一个节点。

SELECT * FROM performance_schema.replication_group_members;
+---------------------------+--------------------------------------+-----------------------+-------------+--------------+
| CHANNEL_NAME              | MEMBER_ID                            | MEMBER_HOST           | MEMBER_PORT | MEMBER_STATE |
+---------------------------+--------------------------------------+-----------------------+-------------+--------------+
| group_replication_applier | 2e1544a9-3203-11f0-b40b-005056914eca | mgr1-010010065101 |        3306 | ONLINE       |
+---------------------------+--------------------------------------+-----------------------+-------------+--------------+
1 row in set (0.00 sec)

在第二和三节点上运行

STOP GROUP_REPLICATION;
 RESET SLAVE ALL;
CHANGE MASTER TO 
      MASTER_USER='repl_user', 
       MASTER_PASSWORD='ReplicationPassword1!' 
   FOR CHANNEL 'group_replication_recovery';
 START GROUP_REPLICATION;

验证集群有几个节点，在任意一个节点都可以执行。这里需要查看每个节点的状态是ONLINE，说明节点是正常的，如果这里是RECOVERING状态需要注意，如果有节点长时间是RECOVERING状态，可能是这个节点没有完成数据同步，也有可能节点出现了异常，需要查看。

SELECT * FROM performance_schema.replication_group_members;
+---------------------------+--------------------------------------+-----------------------+-------------+--------------+
| CHANNEL_NAME              | MEMBER_ID                            | MEMBER_HOST           | MEMBER_PORT | MEMBER_STATE |
+---------------------------+--------------------------------------+-----------------------+-------------+--------------+
| group_replication_applier | 2e1544a9-3203-11f0-b40b-005056914eca | mgr1-010010065101 |        3306 | ONLINE       |
| group_replication_applier | 31cc45ea-3203-11f0-8d5f-005056916f84 | mgr2-010010065102 |        3306 | ONLINE       |
| group_replication_applier | 337c4d3d-3203-11f0-a4a4-005056916d63 | mgr3-010010065103 |        3306 | ONLINE       |
+---------------------------+--------------------------------------+-----------------------+-------------+--------------+
3 rows in set (0.00 sec)

查看这里说明MGR已经部署完成了，你可以在任意节点上创建数据库和sql，每个节点都可以读写，

问题：节点RECOVERING状态

如果节点异常RECOVERING状态，需要重新加入集群，运行以下代码，先停止复制，重置清空复制数据，最后开起组复制。

STOP GROUP_REPLICATION;
RESET SLAVE ALL;
CHANGE MASTER TO 
  MASTER_USER='repl_user', 
  MASTER_PASSWORD='ReplicationPassword1!' 
FOR CHANNEL 'group_replication_recovery';
START GROUP_REPLICATION;

问题：ERROR 3092 (HY000): The server is not configured properly to be an active member of the group. Please see more details on error log.

mgr集群出现 这个报错的时候查看报错日志，这里是因为binlog读取异常，这里要把binlog重置数据，停止复制后，重置binlog数据，再开启复制。

 mysql]# tail -fn 300 mysqld.log | grep ERROR
2025-05-23T08:33:58.077528Z 0 [ERROR] Plugin group_replication reported: 'This member has more executed transactions than those present in the group. Local transactions: 11b3c0dd-37a9-11f0-b76b-0050569f8e51:1-8 > Group transactions: 70e4c56a-63b9-40a2-bcd1-1652eb52eb88:1-4'
2025-05-23T08:33:58.077610Z 0 [ERROR] Plugin group_replication reported: 'The member contains transactions not present in the group. The member will now exit the group.'

节点恢复操作

-- 停止组复制
STOP GROUP_REPLICATION;

-- 清除所有复制信息
RESET MASTER;
RESET SLAVE ALL;

-- 配置复制用户
CHANGE MASTER TO 
  MASTER_USER='repl_user', 
  MASTER_PASSWORD='ReplicationPassword1!' 
FOR CHANNEL 'group_replication_recovery';

-- 启动组复制
START GROUP_REPLICATION;

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

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

相关文章

AXI 协议补充（二）

AXI 协议补充（二）

axi协议存在slave 和master 之间的数据交互，在ahb ，axi-stream 高速接口 ，叠加大位宽代码逻辑中，往往有时序问题，valid 和ready 的组合电路中的问题引发的时序问题较多。 本文根据axi 协议和现有解决反压造成的时序问题的方法做一个详细的科普。 1. 解决时序问题的方法：…
阅读更多...
Linux 基础指令入门指南：解锁命令行的实用密码

Linux 基础指令入门指南：解锁命令行的实用密码

文章目录 引言&#xff1a;Linux 下基本指令常用选项ls 指令pwd 命令cd 指令touch 指令mkdir 指令rmdir 指令 && rm 指令man 指令cp 指令mv 指令cat 指令more 指令less 指令head 指令tail 指令date 指令cal 指令find 指令按文件名搜索按文件大小搜索按修改时间搜索按文…
阅读更多...
标准精读：2025 《可信数据空间 技术架构》【附全文阅读】

标准精读：2025 《可信数据空间 技术架构》【附全文阅读】

《可信数据空间 技术架构》规范了可信数据空间的技术架构，明确其作为国家数据基础设施的定位，以数字合约和使用控制技术为核心，涵盖功能架构（含服务平台与接入连接器的身份管理、目录管理、数字合约管理等功能）、业务流程（登记、发现、创建空间及数据流通利用）及安全要求…
阅读更多...
山东大学软件学院项目实训-基于大模型的模拟面试系统-面试官和面试记录的分享功能（2）

山东大学软件学院项目实训-基于大模型的模拟面试系统-面试官和面试记录的分享功能（2）

本文记录在发布文章时&#xff0c;可以添加自己创建的面试官和面试记录到文章中这一功能的实现。 前端 首先是在原本的界面的底部添加了两个多选框&#xff08;后期需要美化调整&#xff09; 实现的代码&#xff1a; <el-col style"margin-top: 1rem;"><e…
阅读更多...
Webug4.0靶场通关笔记05- 第5关SQL注入之过滤关键字

Webug4.0靶场通关笔记05- 第5关SQL注入之过滤关键字

目录 一、代码审计 1、源码分析 2、SQL注入分析 &#xff08;1&#xff09;大小写绕过 &#xff08;2&#xff09;双写绕过 二、第05关 过滤型注入 1、进入靶场 2、sqlmap渗透 &#xff08;1&#xff09;bp抓包保存报文 &#xff08;2&#xff09;sqlmap渗透 &…
阅读更多...
ONLYOFFICE文档API：更强的安全功能

ONLYOFFICE文档API：更强的安全功能

在数字化办公时代&#xff0c;文档的安全性与隐私保护已成为企业和个人用户的核心关切。如何确保信息在存储、传输及协作过程中的安全&#xff0c;是开发者与IT管理者亟需解决的问题。ONLYOFFICE作为一款功能强大的开源办公套件&#xff0c;不仅提供了高效的文档编辑与协作体验…
阅读更多...
解析楼宇自控系统：分布式结构的核心特点与优势展现

解析楼宇自控系统：分布式结构的核心特点与优势展现

在建筑智能化发展的进程中&#xff0c;楼宇自控系统作为实现建筑高效运行与管理的关键&#xff0c;其系统结构的选择至关重要。传统的集中式楼宇自控系统在面对日益复杂的建筑环境和多样化的管理需求时&#xff0c;逐渐暴露出诸多弊端&#xff0c;如可靠性低、扩展性差、响应速…
阅读更多...
C#数字图像处理(三)

C#数字图像处理(三)

文章目录 前言1.图像平移1.1 图像平移定义1.2 图像平移编程实例 2.图像镜像2.1 图像镜像定义2.2 图像镜像编程实例 3.图像缩放3.1 图像缩放定义3.2 灰度插值法3.3 图像缩放编程实例 4.图像旋转4.1 图像旋转定义4.2 图像旋转编程实例 前言 在某种意义上来说&#xff0c;图像的几…
阅读更多...
SQL Transactions（事务）、隔离机制

SQL Transactions（事务）、隔离机制

目录 Why Transactions? Example: Bad Interaction Transactions ACID Transactions COMMIT ROLLBACK How the Transaction Log Works How Data Is Stored Example: Interacting Processes Interleaving of Statements Example: Strange Interleaving Fixing the…
阅读更多...
【机器学习基础】机器学习入门核心：Jaccard相似度 (Jaccard Index) 和 Pearson相似度 (Pearson Correlation)

【机器学习基础】机器学习入门核心：Jaccard相似度 (Jaccard Index) 和 Pearson相似度 (Pearson Correlation)

机器学习入门核心&#xff1a;Jaccard相似度 &#xff08;Jaccard Index&#xff09; 和 Pearson相似度 &#xff08;Pearson Correlation&#xff09; 一、算法逻辑Jaccard相似度 (Jaccard Index)**Pearson相似度 (Pearson Correlation)** 二、算法原理与数学推导1. Jaccard相…
阅读更多...
QT之头像剪裁效果实现

QT之头像剪裁效果实现

文章目录 源码地址&#xff0c;环境&#xff1a;QT5.15&#xff0c;MinGW32位效果演示导入图片设置剪裁区域创建剪裁小窗口重写剪裁小窗口的鼠标事件mousePressEventmouseMoveEventmouseReleaseEvent 小窗口移动触发父窗口的重绘事件剪裁效果实现 源码地址&#xff0c;环境&…
阅读更多...
【GPT入门】第40课 vllm与ollama特性对比，与模型部署

【GPT入门】第40课 vllm与ollama特性对比，与模型部署

【GPT入门】第40课 vllm与ollama特性对比&#xff0c;与模型部署 1.两种部署1.1 vllm与ollama特性对比2. vllm部署2.1 服务器准备2.1 下载模型2.2 提供模型服务 1.两种部署 1.1 vllm与ollama特性对比 2. vllm部署 2.1 服务器准备 在autodl 等大模型服务器提供商&#xff0c;…
阅读更多...
unity开发棋牌游戏

unity开发棋牌游戏

使用unity开发的棋牌游戏&#xff0c;目前包含麻将、斗地主、比鸡、牛牛四种玩法游戏。 相关技术 客户端&#xff1a;unity 热更新&#xff1a;xlua 服务器&#xff1a;c Web服务器&#xff1a;ruoyi 游戏视频 unity开发棋牌游戏 游戏截图
阅读更多...
Nat Commun项目文章 ▏小麦CUTTag助力解析转录因子TaTCP6调控小麦氮磷高效利用机制

Nat Commun项目文章 ▏小麦CUTTag助力解析转录因子TaTCP6调控小麦氮磷高效利用机制

今年2月份发表在《Nature Communications》&#xff08;IF14.4&#xff09;的“TaTCP6 is required for efficientand balanced utilization of nitrate and phosphorus in wheat”揭示了TaTCP6在小麦氮磷利用中的关键调控作用&#xff0c;为优化肥料利用和提高作物产量提供了理…
阅读更多...
C 语言开发中常见的开发环境

C 语言开发中常见的开发环境

目录 1.Dev-C 2.Visual Studio Code 3.虚拟机 Linux 环境 4.嵌入式 MCU 专用开发环境 1.Dev-C 使用集成的 C/C 开发环境&#xff08;适合基础学习&#xff09;,下载链接Dev-C下载 - 官方正版 - 极客应用 2.Visual Studio Code 结合 C/C 扩展 GCC/MinGW 编译器&#xff0c…
阅读更多...
vscode命令行debug

vscode命令行debug

vscode命令行debug 一般命令行debug会在远程连服务器的时候用上&#xff0c;命令行debug的本质是在执行时暴露一个监听端口&#xff0c;通过进入这个端口&#xff0c;像本地调试一样进行。 这里提供两种方式&#xff1a; 直接在命令行中添加debugpy&#xff0c;适用于python…
阅读更多...
Matlab作图之 subplot

Matlab作图之 subplot

1. subplot(m, n, p) 将当前图形划分为m*n的网格&#xff0c;在 p 指定的位置创建坐标轴 matlab 按照行号对子图的位置进行编号 第一个子图是第一行第一列&#xff0c;第二个子图是第二行第二列......... 如果指定 p 位置存在坐标轴&#xff0c; 此命令会将已存在的坐标轴设…
阅读更多...
【机器学习基础】机器学习入门核心算法：层次聚类算法（AGNES算法和 DIANA算法）

【机器学习基础】机器学习入门核心算法：层次聚类算法（AGNES算法和 DIANA算法）

机器学习入门核心算法&#xff1a;层次聚类算法&#xff08;AGNES算法和 DIANA算法&#xff09; 一、算法逻辑二、算法原理与数学推导1. 距离度量2. 簇间距离计算&#xff08;连接标准&#xff09;3. 算法伪代码&#xff08;凝聚式&#xff09; 三、模型评估1. 内部评估指标2. …
阅读更多...
Google Play的最新安全变更可能会让一些高级用户无法使用App

Google Play的最新安全变更可能会让一些高级用户无法使用App

喜欢Root或刷机的Android用户要注意了&#xff0c;Google最近全面启用了新版Play Integrity API&#xff0c;可能会导致部分用户面临无法使用某些App的窘境。Play Integrity API是Google提供给开发者的工具&#xff0c;用于验证App是否在“未修改”的设备上运行。 许多重要应用…
阅读更多...
React---day5

React---day5

4、React的组件化 组件的分类&#xff1a; 根据组件的定义方式&#xff0c;可以分为&#xff1a;函数组件(Functional Component )和类组件(Class Component)&#xff1b;根据组件内部是否有状态需要维护&#xff0c;可以分成&#xff1a;无状态组件(Stateless Component )和…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023