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实现温度单位转换器,主要是将摄氏温度(C)和华氏温度(F)相互转换,下面小编就来和大家简单介绍一下吧... 目录为什么选择温度转换器作为第一个项目项目概述所需基础知识实现步骤详解1. 温度转换公式2. 用户输入处

Java实现TXT文件导入功能的详细步骤

《Java实现TXT文件导入功能的详细步骤》在实际开发中,很多应用场景需要将用户上传的TXT文件进行解析,并将文件中的数据导入到数据库或其他存储系统中,本文将演示如何用Java实现一个基本的TXT文件... 目录前言1. 项目需求分析2. 示例文件格式3. 实现步骤3.1. 准备数据库(假设使用 mysql

C#控制台程序同步调用WebApi实现方式

《C#控制台程序同步调用WebApi实现方式》控制台程序作为Job时,需同步调用WebApi以确保获取返回结果后执行后续操作,否则会引发TaskCanceledException异常,同步处理可避免异... 目录同步调用WebApi方法Cls001类里面的写法总结控制台程序一般当作Job使用,有时候需要控制

Python中的sort()和sorted()用法示例解析

《Python中的sort()和sorted()用法示例解析》本文给大家介绍Python中list.sort()和sorted()的使用区别,详细介绍其参数功能及Timsort排序算法特性,涵盖自适应... 目录一、list.sort()参数说明常用内置函数基本用法示例自定义函数示例lambda表达式示例o

SpringBoot集成P6Spy的实现示例

《SpringBoot集成P6Spy的实现示例》本文主要介绍了SpringBoot集成P6Spy的实现示例,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录本节目标P6Spy简介抛出问题集成P6Spy1. SpringBoot三板斧之加入依赖2. 修改

Python学习笔记之getattr和hasattr用法示例详解

《Python学习笔记之getattr和hasattr用法示例详解》在Python中,hasattr()、getattr()和setattr()是一组内置函数,用于对对象的属性进行操作和查询,这篇文章... 目录1.getattr用法详解1.1 基本作用1.2 示例1.3 原理2.hasattr用法详解2.

Python开发简易网络服务器的示例详解(新手入门)

《Python开发简易网络服务器的示例详解(新手入门)》网络服务器是互联网基础设施的核心组件,它本质上是一个持续运行的程序,负责监听特定端口,本文将使用Python开发一个简单的网络服务器,感兴趣的小... 目录网络服务器基础概念python内置服务器模块1. HTTP服务器模块2. Socket服务器模块

Go语言使用net/http构建一个RESTful API的示例代码

《Go语言使用net/http构建一个RESTfulAPI的示例代码》Go的标准库net/http提供了构建Web服务所需的强大功能,虽然众多第三方框架(如Gin、Echo)已经封装了很多功能,但... 目录引言一、什么是 RESTful API?二、实战目标:用户信息管理 API三、代码实现1. 用户数据

Python实现数据可视化图表生成(适合新手入门)

《Python实现数据可视化图表生成(适合新手入门)》在数据科学和数据分析的新时代,高效、直观的数据可视化工具显得尤为重要,下面:本文主要介绍Python实现数据可视化图表生成的相关资料,文中通过... 目录前言为什么需要数据可视化准备工作基本图表绘制折线图柱状图散点图使用Seaborn创建高级图表箱线图热

Redis分布式锁中Redission底层实现方式

《Redis分布式锁中Redission底层实现方式》Redission基于Redis原子操作和Lua脚本实现分布式锁,通过SETNX命令、看门狗续期、可重入机制及异常处理,确保锁的可靠性和一致性,是... 目录Redis分布式锁中Redission底层实现一、Redission分布式锁的基本使用二、Red