MySQL实现多源复制的示例代码

2025-08-13 09:50

本文主要是介绍MySQL实现多源复制的示例代码,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

《MySQL实现多源复制的示例代码》MySQL的多源复制允许一个从服务器从多个主服务器复制数据,这在需要将多个数据源汇聚到一个数据库实例时非常有用,下面就来详细的介绍一下,感兴趣的可以了解一下...

mysql的多源复制(Multi-Source Replication)允许一个从服务器从多个主服务器复制数据。这在需要将多个数据源汇聚到一个数据库实例时非常有用,例如数据汇总和数据仓库场景。

一、多源复制原理

多源复制的原理与单源复制类似,但一个从服务器会有多个复制通道(Replication Channel),每个通道对应一个主服务器。每个通道独立工作,处理各自的二进制日志和中继日志。

二、多源复制配置步骤

2.1 主服务器配置

假设我们有两个主服务器(Master1和Master2)和一个从服务器(Slave)。我们需要配置两个主服务器,使它们能够与从服务器进行复制。

Master1配置

  1. 编辑Master1的China编程MySQL配置文件(通常为/etc/my.cnf/etc/mysql/my.cnf):
[mysqld]
server-id = 1
log_bin = /var/log/mysql/mysql-bin.log
binlog_do_db = mydatabase1  # 指定需要复制的数据库
  1. 重启MySQL服务:
sudo systemctl restart mysql
  1. 创建复制用户并授予权限:
CREATE USER 'replica_user'@'%' IDENTIFIED BY 'replica_password';
GRANT REPLICATION SLAVE ON *.* TO 'replica_user'@'%';
FLUSH PRIVILEGES;
  1. 确定二进制日志文件名和位置:
SHOW MASTER STATUS;

输出示例:

+------------------+----------+--------------+------------------+
| File             | Position | Binlog_Do_DB | Binlog_Ignore_DB |
+------------------+----------+--------------+------------------+
| mysql-bin.000001 |      154 |python mydatabase1  |                  |
+------------------+----------+--------------+------------------+

Master2配置

配置过程与Master1类似,确保server-id唯一。

  1. 编辑Master2的MySQL配置文件:
[mysqld]
server-id = 2
log_bin = /var/log/mysql/mysql-bin.log
binlog_do_db = mydatabase2  # 指定需要复制的数据库
  1. 重启MySQL服务:
sudo systemctl restart mysql
  1. 创建复制用户并授予权限:
CREATE USER 'replica_user'@'%' IDENTIFIED BY 'replica_password';
GRANT REPLICATION SLAVE ON *.* TO 'replica_user'@'%';
FLUSH PRIVILEGES;
  1. 确定二进制日志文件名和位置:
SHOW MASTER STATUS;

输出示例:

+------------------+----------+--------------+------------------+
| File             | Position | Binlog_Do_DB | Binlog_Ignore_DB |
+------------------+----------+--------------+------------------+
| mysql-bin.000001 |      200 | mydatabase2  |                  |
+------------------+----------+--------------+------------------+

2.2 从服务器配置

  1. 编辑从服务器的MySQL配置文件:
[mysqld]
server-id = 3
relay-log = /var/log/mysql/mysql-relay-bin
log_slave_updates = 1
  1. 重启MySQL服务:
sudo systemctl restart mysql
  1. 在从服务器上配置多个复制通道:
-- 配置从Master1复制的通道
CHANGE MASTER TO
MASTER_HOST='Master1_IP',
MASTER_USER='replica_user',
MASTER_PASSWORD='replica_password',
MASTER_LOG_FILEandroid='mysql-bin.000001',  -- Master1的File值
MASTER_LOG_POS=154  -- Master1的Position值
FOR CHANNEL 'channel1';

-- 配置从Master2复制的通道
CHANGE MASTER TO
MASTER_HOST='Master2_IP',
MASTER_USER='replica_user',
MASTER_PASSWORD='replica_password',
MASTER_LOG_FILE='mysql-bin.000001',  -- Master2的File值
MASTER_LOG_POS=200  -- Master2的Position值
FOR CHANNEL 'channel2';
  1. 启动多个复制通道:
START SLAVE FOR CHANNEL 'channel1';
START SLAVE FOR CHANNEL 'channel2';
  1. 检查复制状态:
SHOW SLAVE STATUS FOR CHANNEL 'channel1'\G;
SHOW SLAVE STATUS FOR CHANNEL 'channel2'\G;

确保每个通道的Slave_IO_RunningSlave_SQL_Running都显示为Yes

三、处理冲突和监控

多源复制时可能会遇到冲突问题,例如两个主服务器同时修改相同的数据。处理冲突的方法包括:

  1. 应用层解决冲突

    • 在应用层确保不会出现冲突,例如通过数据分区。
  2. 使用复制过滤器

    • 在从服务器上使用复制过滤器,确保只接收特定表或数据库的修改。
[mysqld]
replicate-do-db = mydatabase1
replicate-do-db = China编程mydatabase2
  1. 日常监控
    • 定期监控复制状态,确保没有出现延迟和错误。
SHOW SLAVE STATUS FOR CHANNEL 'channel1'\G;
SHOW SLAVE STATUS FOR CHANNEL 'channel2'\G;

四、总结

MySQL多源复制通过在从服务器上配置多个复制通道,实现从多个主服务器复制数据。配置多源复制需要确保每个主服务器和从服务器的server-id唯一,并分别配置和启动每个复制通道。处理多源复制中的冲突和定期监控复制状态,对于确保数据一致性和系统稳定性至关重要。

到此这篇关于MySQL实现多源复制的示例代码的文章就介绍到这了,更多相关MySQL 多源复制内容请搜索编程China编程(www.chinasem.cn)以前的文章或继续浏览下面的相关文章希望大家以后多多支持China编程(www.cwww.chinasem.cnppcns.com)!

这篇关于MySQL实现多源复制的示例代码的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/1155710

相关文章

C#借助Spire.XLS for .NET实现在Excel中添加文档属性

《C#借助Spire.XLSfor.NET实现在Excel中添加文档属性》在日常的数据处理和项目管理中,Excel文档扮演着举足轻重的角色,本文将深入探讨如何在C#中借助强大的第三方库Spire.... 目录为什么需要程序化添加Excel文档属性使用Spire.XLS for .NET库实现文档属性管理Sp

Python+FFmpeg实现视频自动化处理的完整指南

《Python+FFmpeg实现视频自动化处理的完整指南》本文总结了一套在Python中使用subprocess.run调用FFmpeg进行视频自动化处理的解决方案,涵盖了跨平台硬件加速、中间素材处理... 目录一、 跨平台硬件加速:统一接口设计1. 核心映射逻辑2. python 实现代码二、 中间素材处

MySQL字符串转数值的方法全解析

《MySQL字符串转数值的方法全解析》在MySQL开发中,字符串与数值的转换是高频操作,本文从隐式转换原理、显式转换方法、典型场景案例、风险防控四个维度系统梳理,助您精准掌握这一核心技能,需要的朋友可... 目录一、隐式转换:自动但需警惕的&ld编程quo;双刃剑”二、显式转换:三大核心方法详解三、典型场景

MySQL中between and的基本用法、范围查询示例详解

《MySQL中betweenand的基本用法、范围查询示例详解》BETWEENAND操作符在MySQL中用于选择在两个值之间的数据,包括边界值,它支持数值和日期类型,示例展示了如何使用BETWEEN... 目录一、between and语法二、使用示例2.1、betwphpeen and数值查询2.2、be

python中的flask_sqlalchemy的使用及示例详解

《python中的flask_sqlalchemy的使用及示例详解》文章主要介绍了在使用SQLAlchemy创建模型实例时,通过元类动态创建实例的方式,并说明了如何在实例化时执行__init__方法,... 目录@orm.reconstructorSQLAlchemy的回滚关联其他模型数据库基本操作将数据添

Java数组动态扩容的实现示例

《Java数组动态扩容的实现示例》本文主要介绍了Java数组动态扩容的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小编来一起学习学习吧... 目录1 问题2 方法3 结语1 问题实现动态的给数组添加元素效果,实现对数组扩容,原始数组使用静态分配

JAVA项目swing转javafx语法规则以及示例代码

《JAVA项目swing转javafx语法规则以及示例代码》:本文主要介绍JAVA项目swing转javafx语法规则以及示例代码的相关资料,文中详细讲解了主类继承、窗口创建、布局管理、控件替换、... 目录最常用的“一行换一行”速查表(直接全局替换)实际转换示例(JFramejs → JavaFX)迁移建

Python实现快速扫描目标主机的开放端口和服务

《Python实现快速扫描目标主机的开放端口和服务》这篇文章主要为大家详细介绍了如何使用Python编写一个功能强大的端口扫描器脚本,实现快速扫描目标主机的开放端口和服务,感兴趣的小伙伴可以了解下... 目录功能介绍场景应用1. 网络安全审计2. 系统管理维护3. 网络故障排查4. 合规性检查报错处理1.

MySQL快速复制一张表的四种核心方法(包括表结构和数据)

《MySQL快速复制一张表的四种核心方法(包括表结构和数据)》本文详细介绍了四种复制MySQL表(结构+数据)的方法,并对每种方法进行了对比分析,适用于不同场景和数据量的复制需求,特别是针对超大表(1... 目录一、mysql 复制表(结构+数据)的 4 种核心方法(面试结构化回答)方法 1:CREATE

Go异常处理、泛型和文件操作实例代码

《Go异常处理、泛型和文件操作实例代码》Go语言的异常处理机制与传统的面向对象语言(如Java、C#)所使用的try-catch结构有所不同,它采用了自己独特的设计理念和方法,:本文主要介绍Go异... 目录一:异常处理常见的异常处理向上抛中断程序恢复程序二:泛型泛型函数泛型结构体泛型切片泛型 map三:文