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

相关文章

Python实现字典转字符串的五种方法

《Python实现字典转字符串的五种方法》本文介绍了在Python中如何将字典数据结构转换为字符串格式的多种方法,首先可以通过内置的str()函数进行简单转换;其次利用ison.dumps()函数能够... 目录1、使用json模块的dumps方法:2、使用str方法:3、使用循环和字符串拼接:4、使用字符

深入理解Mysql OnlineDDL的算法

《深入理解MysqlOnlineDDL的算法》本文主要介绍了讲解MysqlOnlineDDL的算法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随着小... 目录一、Online DDL 是什么?二、Online DDL 的三种主要算法2.1COPY(复制法)

Linux下利用select实现串口数据读取过程

《Linux下利用select实现串口数据读取过程》文章介绍Linux中使用select、poll或epoll实现串口数据读取,通过I/O多路复用机制在数据到达时触发读取,避免持续轮询,示例代码展示设... 目录示例代码(使用select实现)代码解释总结在 linux 系统里,我们可以借助 select、

Linux挂载linux/Windows共享目录实现方式

《Linux挂载linux/Windows共享目录实现方式》:本文主要介绍Linux挂载linux/Windows共享目录实现方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地... 目录文件共享协议linux环境作为服务端(NFS)在服务器端安装 NFS创建要共享的目录修改 NFS 配

mysql8.0.43使用InnoDB Cluster配置主从复制

《mysql8.0.43使用InnoDBCluster配置主从复制》本文主要介绍了mysql8.0.43使用InnoDBCluster配置主从复制,文中通过示例代码介绍的非常详细,对大家的学习或者... 目录1、配置Hosts解析(所有服务器都要执行)2、安装mysql shell(所有服务器都要执行)3、

通过React实现页面的无限滚动效果

《通过React实现页面的无限滚动效果》今天我们来聊聊无限滚动这个现代Web开发中不可或缺的技术,无论你是刷微博、逛知乎还是看脚本,无限滚动都已经渗透到我们日常的浏览体验中,那么,如何优雅地实现它呢?... 目录1. 早期的解决方案2. 交叉观察者:IntersectionObserver2.1 Inter

Spring Gateway动态路由实现方案

《SpringGateway动态路由实现方案》本文主要介绍了SpringGateway动态路由实现方案,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面随... 目录前沿何为路由RouteDefinitionRouteLocator工作流程动态路由实现尾巴前沿S

JavaScript对象转数组的三种方法实现

《JavaScript对象转数组的三种方法实现》本文介绍了在JavaScript中将对象转换为数组的三种实用方法,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友... 目录方法1:使用Object.keys()和Array.map()方法2:使用Object.entr

k8s中实现mysql主备过程详解

《k8s中实现mysql主备过程详解》文章讲解了在K8s中使用StatefulSet部署MySQL主备架构,包含NFS安装、storageClass配置、MySQL部署及同步检查步骤,确保主备数据一致... 目录一、k8s中实现mysql主备1.1 环境信息1.2 部署nfs-provisioner1.2.

Java高效实现PowerPoint转PDF的示例详解

《Java高效实现PowerPoint转PDF的示例详解》在日常开发或办公场景中,经常需要将PowerPoint演示文稿(PPT/PPTX)转换为PDF,本文将介绍从基础转换到高级设置的多种用法,大家... 目录为什么要将 PowerPoint 转换为 PDF安装 Spire.Presentation fo