mysql的主从复制（含位点复制和GTID复制）的代码实例

news2024/11/25 23:52:39

提示：

master主库ip地址：192.168.137.2

从库s1的ip地址：192.168.137.11

从库s2的ip地址：192.168.137.22

主从复制的原理：

MySQL主从复制是一个异步的复制过程，主要是通过二进制日志（binary log）文件实现。下面是主从复制的基本原理：

  1. 主服务器记录二进制日志：在主服务器上，每个更改数据的事件都会被记录到二进制日志中。

  2. 从服务器请求二进制日志：从服务器连接到主服务器，请求从指定日志位置之后的事件。

  3. 主服务器发送二进制日志：主服务器通过网络发送这些事件给从服务器。

  4. 从服务器记录二进制日志：从服务器将接收到的事件记录到自己的中继日志（relay log）中。

  5. 从服务器应用中继日志：从服务器读取中继日志中的事件并应用到自己的数据库中。

一、从零部署GTID复制

从0部署GTID复制（一）

1.开启GTID模式

GTID在my.cnf文件中最重要的配置：

log-bin=日志文件路径 #主从复制的前提

gtid_mode=ON #开启GTID模式

enforce_gtid_consistency=ON

2.查看master主库binlog是否开启

mysql> show global variables like "log_bin";

如果没有开启，就算再mysql命令行中修改为启动了，也要在my.cnf中设置log-bin，防止重启后，binlog未开启的情况

3.查看server_id

mysql> select @@global.server_id;

注意：主从的server_id不要设置成一样

没有或者与预期不符的，在my.cnf中修改server-id

4.从库做同样的操作

master主库my.cnf完整文件内容：

[client]
port        = 3306
socket      = /tmp/mysql.sock

[mysqld]
port    = 3306
socket  = /tmp/mysql.sock


##  dir set
datadir           = /usr/local/mysql/data
innodb_data_home_dir   = /usr/local/mysql/data
innodb_log_group_home_dir = /usr/local/mysql/data
log-bin           = /usr/local/mysql/binlog/mysql-bin
log_bin_index             = /usr/local/mysql/binlog/mysql-bin.index  
relay-log         = /usr/local/mysql/binlog/mysql-relay-bin
tmpdir            = /usr/local/mysql/tmpdir
slow_query_log_file   = /usr/local/mysql/log/mysql-slow.log
general_log_file   = /usr/local/mysql/log/mysql-general.log
log-error         = /usr/local/mysql/log/mysql.err

## slave and binlog
server-id = 6666            #   
skip-slave-start = 0        #
read_only = 0           #
binlog_format = row             
log-slave-updates = 1
master_info_repository = table
relay_log_info_repository = table
relay_log_purge = 1
relay_log_recovery = 1
sync_binlog = 100

binlog_cache_size = 1M
expire_logs_days = 30
log_bin_trust_function_creators = 1         
slave_net_timeout=60                
#binlog_error_action="IGNORE_ERROR"     

innodb_autoinc_lock_mode=1          

## 
back_log = 200
bulk_insert_buffer_size = 8M            
#character-set-server = utf8
lower_case_table_names = 1              #  1：不区分大小写

## 基线
local-infile = off
skip-networking = off
skip-name-resolve = on 

## connect
max_allowed_packet = 32M
max_connect_errors = 1000
max_connections = 3000
wait_timeout = 3600             # 连接之前等待活动的秒数 default:8h
interactive_timeout = 3600          # 连接之前等待活动的秒数 default:8h

table_open_cache = 4096
thread_cache_size =  64
thread_stack = 192K
transaction-isolation = REPEATABLE-READ
pid-file = mysql1.pid

## slow
slow_query_log = 1              
long_query_time = 1
log-slow-admin-statements
log_queries_not_using_indexes = 0
slow_launch_time = 1
read_buffer_size = 4M               
read_rnd_buffer_size = 8M           
sort_buffer_size = 8M
join_buffer_size = 32M
tmp_table_size = 128M
max_heap_table_size = 128M

default-storage-engine = innodb
explicit_defaults_for_timestamp = on           

## innodb
innodb_buffer_pool_size = 1G                    
innodb_max_dirty_pages_pct = 80         
innodb_thread_concurrency = 8           
innodb_buffer_pool_instances = 1        
innodb_flush_log_at_trx_commit = 2      
innodb_read_io_threads = 8          
innodb_write_io_threads = 4         
innodb_io_capacity = 1000
innodb_io_capacity_max = 2000
innodb_lru_scan_depth = 1024
innodb_use_native_aio = 1
innodb_flush_neighbors = 1
innodb_buffer_pool_load_at_startup = 1
innodb_buffer_pool_dump_at_shutdown = 1

innodb_data_file_path=ibdata:1G:autoextend
innodb_log_files_in_group = 3
innodb_log_file_size = 2G
innodb_file_per_table = 1 

innodb_flush_method = O_DIRECT
innodb_strict_mode = 1
innodb_lock_wait_timeout = 30
innodb_log_buffer_size = 16M
innodb_adaptive_flushing = 1
innodb_change_buffering = all
innodb_purge_threads = 4            
innodb_purge_batch_size = 300           

innodb_old_blocks_time = 1
innodb_fast_shutdown = 0
performance_schema = 1
innodb_print_all_deadlocks = 1
innodb_sort_buffer_size = 4M 

innodb_page_size = 16k
gtid_mode=on
enforce_gtid_consistency=on     

table_open_cache_instances=16
binlog_rows_query_log_events=1      

slave_parallel_workers = 0          # 多线程复制线程数
#slave_parallel_type=LOGICAL_CLOCK      
#binlog_group_commit_sync_delay = 500000  
#binlog_group_commit_sync_no_delay_count =12  

## pasword
default_password_lifetime=0                     # 0密码永不过期，N n天过期

[mysqldump]
quick
max_allowed_packet = 32M

[mysql]
no-auto-rehash
prompt=p@d>_

[mysqld_safe]
open-files-limit = 28192

[mysqlhotcopy]
interactive-timeout

从库的就在master主库的my.cnf文件的基础上修改server-id的值就行了

5.重启mysql

从0部署GTID复制（二）

1.主库创建用户

CREATE USER 'repl'@'%' identified WITH mysql_native_password BY 'Alice123!';
GRANT REPLICATION SLAVE ON *.* TO 'repl'@'%';

2.主库导出数据

可以考虑使用mysqldump，xtrabackup，clone plugin

mkdir -p /data/backup/
cd /data/backup/
mysqldump -uroot -p --single-transaction --all-databases --master-data=2 --set-gtid-purged=on >alldb_bak_for_gtid.sql

3.把备份文件从master主库拷贝到s1从库

从库的system控制台：

mkdir -p /data/backup

主库的system控制台：

scp alldb_bak_for_gtid.sql root@192.168.137.11:/data/backup

4.从库导入数据

(1)重置二进制日志索引文件

MySQL的RESET MASTER命令的主要作用是删除所有现有的二进制日志文件并重置二进制日志索引文件，‌将服务器重置为启动二进制日志记录之前的状态

mysql> reset master;
(2)再导入数据
cd /data/backup
mysql -uroot -p < alldb_bak_for_gtid.sql

从0部署GTID复制（三）

1.在从库中关闭slave，重置slave，配置change mater to...，start slave四件套

stop slave;
reset slave;

change master to 
master_host='192.168.137.2',
master_user='repl',
master_password='Alice123!',
MASTER_AUTO_POSITION=1;

start slave;

2.从库中查看复制状态

mysql> show slave status\G

*************************** 1. row ***************************
               Slave_IO_State: Waiting for master to send event
                  Master_Host: 192.168.137.2
                  Master_User: repl
                  Master_Port: 3306
                Connect_Retry: 60
              Master_Log_File: mysql-bin.000003
          Read_Master_Log_Pos: 1870
               Relay_Log_File: mysql-relay-bin.000002
                Relay_Log_Pos: 418
        Relay_Master_Log_File: mysql-bin.000003
             Slave_IO_Running: Yes
            Slave_SQL_Running: Yes
              Replicate_Do_DB:
          Replicate_Ignore_DB:
           Replicate_Do_Table:
       Replicate_Ignore_Table:
      Replicate_Wild_Do_Table:
  Replicate_Wild_Ignore_Table:
                   Last_Errno: 0
                   Last_Error:
                 Skip_Counter: 0
          Exec_Master_Log_Pos: 1870
              Relay_Log_Space: 627
              Until_Condition: None
               Until_Log_File:
                Until_Log_Pos: 0
           Master_SSL_Allowed: No
           Master_SSL_CA_File:
           Master_SSL_CA_Path:
              Master_SSL_Cert:
            Master_SSL_Cipher:
               Master_SSL_Key:
        Seconds_Behind_Master: 0
Master_SSL_Verify_Server_Cert: No
                Last_IO_Errno: 0
                Last_IO_Error:
               Last_SQL_Errno: 0
               Last_SQL_Error:
  Replicate_Ignore_Server_Ids:
             Master_Server_Id: 2666
                  Master_UUID: 0b796d2d-431b-11ef-a867-000c29012dba
             Master_Info_File: mysql.slave_master_info
                    SQL_Delay: 0
          SQL_Remaining_Delay: NULL
      Slave_SQL_Running_State: Slave has read all relay log; waiting for more u                                                                                                  pdates
           Master_Retry_Count: 86400
                  Master_Bind:
      Last_IO_Error_Timestamp:
     Last_SQL_Error_Timestamp:
               Master_SSL_Crl:
           Master_SSL_Crlpath:
           Retrieved_Gtid_Set:
            Executed_Gtid_Set: 0b796d2d-431b-11ef-a867-000c29012dba:1-8
                Auto_Position: 1
         Replicate_Rewrite_DB:
                 Channel_Name:
           Master_TLS_Version:
       Master_public_key_path:
        Get_master_public_key: 0
            Network_Namespace:
1 row in set, 1 warning (0.00 sec)

3.测试数据是否同步

主库执行：

create table xxx; // 建表语句，略。。。
insert into xxx; // 插入数据语句，略。。。

从库查询：

mysql> use db1
mysql> show tables;
mysql> select * from 主库新建的表;
mysql> show slave status\G
。。。略。。。
   Slave_IO_Running: Yes
   Slave_SQL_Running: Yes
。。。略。。。

注意：Slave_IO_Running和Slave_SQL_Running必须都是yes

二、一主两从和级联架构之间要怎么切换？

【一】创建一主两从架构（基于位点复制）

1.在主库创建复制用户

mysql> CREATE USER 'repl'@'%' identified WITH mysql_native_password BY 'Alice123!';
mysql> GRANT REPLICATION SLAVE ON *.* TO 'repl'@'%';

2.主库导出数据

cd /data/backup
xtrabackup --defaults-file=/etc/my.cnf -uroot -p --backup --stream=xbstream --target-dir=./ >/data/backup/xtrabackup.xbstream

3.主库完全备份文件拷贝到从库

（1）从库创建恢复目录
mkdir /data/backup/recover
（2）主库把备份sql文件拷贝到两个从库
scp xtrabackup.xbstream root@192.168.137.22:/data/backup/recover
（3）停掉从库mysql实例
service mysql stop
（4）清空新实例数据目录和binlog目录
rm /usr/local/mysql/data/* -rf
rm /usr/local/mysql/binlog/* -rf
（5）把全备恢复到新的mysql中
cd /data/backup/recover
xbstream -x < xtrabackup.xbstream
xtrabackup --prepare --target-dir=./

xtrabackup --defaults-file=/etc/my.cnf --copy-back --target-dir=./
（6）启动mysql
service mysql start
（7）查看备份时的位点信息
cat xtrabackup_binlog_info
（8）在两台从库创建复制关系（位点复制方式）

注意：如果想要改成GTID复制,change master to语句中，去掉bin_log_file和bin_log_pos参数，添加MASTER_AUTO_POSITION=1

show slave status\G

CHANGE MASTER TO
MASTER_HOST='192.168.137.2',
MASTER_USER='repl',
MASTER_PASSWORD='Alice123!',
master_log_file='xxx', // 去master_host对应ip地址的mysql实例中使用"show master status;"获取
master_log_pos=xxx; // 去master_host对应ip地址的mysql实例中使用"show master status;"获取

start slave;

在从库中查看主从状态

show slave status\G

4.测试同步

（1）主库写入

use db1

create table repl_test(id int);
insert into repl_test select 1;

（2）从库查询

use db1
select * from repl_test;

【二】一主两从改成级联（基于位点）

1.断开s2的复制

mysql> stop slave;

2.断开s1的复制

mysql> stop slave;

3.s1查看当前位点

mysql> show master status;

4.s1启动复制

mysql> start slave;
mysql> show slave status;
略...
Relay_Master_Log_File: 从库执行到的主库的日志文件
Exec_Master_Log_Pos: 从库执行到的主库的位点
略...

5.s2启动复制，同步到s1相同的位置

注意:

(1)MASTER_LOG_FILE=s1实例中使用"show slave status;"命令后显示的内容中Relay_Master_Log_File对应的值

(2)MASTER_LOG_POS=s1实例中使用"show slave status;"命令后显示的内容中Exec_Master_Log_Pos对应的数值

mysql> start slave UNTIL MASTER_LOG_FILE ="xxx",  MASTER_LOG_POS=xxx;

查看复制状态

show slave status\G

6.s2连接到s1：

眼熟的停止slave，重置slave，change master to...，start slave四件套

注意：

（1）master_host的ip地址改成s1的ip地址。

（2）如果要改为GTID复制，去掉master_log_file和master_log_pos参数，改成MASTER_AUTO_POSITION=1

stop slave;

change master to master_host='192.168.137.11',
MASTER_USER='repl',
MASTER_PASSWORD='Alice123!',
master_log_file='xxx', // 去master_host对应ip地址的mysql实例中使用"show master status;"获取
master_log_pos=xxx; // 去master_host对应ip地址的mysql实例中使用"show master status;"获取

start slave;

查看复制状态：

show slave status\G

7.测试同步

（1）主库写入测试数据

（2）从库查询数据

【三】级联改为一主两从（基于位点复制）

1.在s1获取master status的binlog文件和偏移量：

mysql> show master status\G

2.获取slave status

show slave status\G;

3.停止s1复制，再启动s1的复制

start slave;

4.重新配置s2的复制

注意:

（1）change master to中master_host改回master主库的ip地址

（2）下列语句是基于位点复制的，如果要改为GTID复制，需要去掉bin_log_file和bin_log_pos参数，添加MASTER_AUTO_POSITION=1

stop slave;

change master to master_host='192.168.137.2',
MASTER_USER='repl',
MASTER_PASSWORD='Alice123!',
master_log_file='xxx', // 去master_host对应ip地址的mysql实例中使用"show master status;"获取
master_log_pos=xxx; // 去master_host对应ip地址的mysql实例中使用"show master status;"获取

start slave;

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

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

相关文章

百度人脸识别Windows C++离线sdk C#接入

百度人脸识别Windows C++离线sdk C#接入

百度人脸识别Windows C离线sdk C#接入 目录 说明 设计背景 • 场景特点&#xff1a; • 客户特点&#xff1a; • 核心需求&#xff1a; SDK 包结构 效果 代码 说明 自己根据SDK封装了动态库&#xff0c;然后C#调用。 功能接口 设计背景 • 场景特点&#xff1a; -…
阅读更多...
PTA - 接收n个关键字参数

PTA - 接收n个关键字参数

接收n个以关键字形式传入的参数&#xff0c;按格式输出。 函数接口定义&#xff1a; def print_info (**keyargs) 提示&#xff1a;keyargs为可变参数&#xff0c;其可接受若干个关键字形式的实参值&#xff0c;并将接收到的值组装为一个字典。 裁判测试程序样例&#xff1…
阅读更多...
Linux相关命令和安装软件

Linux相关命令和安装软件

1.Linux命令 1.1 搜索文件或目录的命令 find 目录 -name "名称" 注意&#xff1a;名称可以使用通配符 *1.2 查看所有进程命令 ps -ef1.3 查看指定内容在文件中 grep "内容" 文件名1.4 管道符 | 1.5 查看端口号 netstat -tunlp | grep 端口号option说明…
阅读更多...
框架设计MVVM

框架设计MVVM

重点&#xff1a; 1.viewmodel 包含model 2.view包含viewmodel,通过驱动viewmodel去控制model的数据和业务逻辑 // Test.cpp : 此文件包含 "main" 函数。程序执行将在此处开始并结束。 //#include <iostream> #include <vector>using namespace std;#p…
阅读更多...
Java - 程序员面试笔记记录 实现 - Part5

Java - 程序员面试笔记记录 实现 - Part5

7.1 Struts 优点&#xff1a; 1. MVC模式实现了表现与逻辑的分离&#xff0c;扩展性高。 2. 提供页面导航功能&#xff0c;通过配置文件建立整个系统各部分之间的联系。 3. 集成了一些常用处理功能。 缺点&#xff1a; 1. 仅面向 Web 应用程序开发 2. Action 非线程安全…
阅读更多...
项目方案：视频图像结构化分析技术在车辆和人体检测中的应用方案（视频公共安全领域的解决方案）

项目方案：视频图像结构化分析技术在车辆和人体检测中的应用方案（视频公共安全领域的解决方案）

目录 一、视频结构化分析技术介绍 1、概述 2、定义 3、核心环节 4、应用领域 二、视频中车辆和人的结构化 1、需求 2、信息内容 3、功能说明 &#xff08;1&#xff09;信息智能识别功能 &#xff08;2&#xff09;智能检索功能 &#xff08;3&#xff09;数据统计…
阅读更多...
鸿蒙语言基础类库：【@system.configuration (应用配置)】

鸿蒙语言基础类库：【@system.configuration (应用配置)】

应用配置 说明&#xff1a; 从API Version 7 开始&#xff0c;该接口不再维护&#xff0c;推荐使用新接口[ohos.i18n]和[ohos.intl]。本模块首批接口从API version 3开始支持。后续版本的新增接口&#xff0c;采用上角标单独标记接口的起始版本。 导入模块 import configurati…
阅读更多...
LeetCode分发糖果(贪心思路分析)

LeetCode分发糖果(贪心思路分析)

题目描述 贪心思路 思路及解法 我们可以将「相邻的孩子中&#xff0c;评分高的孩子必须获得更多的糖果」这句话拆分为两个规则&#xff0c;分别处理。 左规则&#xff1a;当 ratings[i−1]<ratings[i] 时&#xff0c;i 号学生的糖果数量将比 i−1 号孩子的糖果数量多。 …
阅读更多...
新书速览|Vue.js 3.x+Express全栈开发：从0到1打造商城项目

新书速览|Vue.js 3.x+Express全栈开发：从0到1打造商城项目

《Vue.js 3.xExpress全栈开发&#xff1a;从0到1打造商城项目》 1 本书内容 《Vue.js 3.xExpress全栈开发 : 从0到1打造商城项目》是一本详尽的全栈开发教程&#xff0c;旨在通过Vue.js和Express框架引导读者从零开始构建一个完整的电商项目。内容覆盖电商项目的基本结构&…
阅读更多...
（c++）virtual关键字的作用，多态的原理（详细）

（c++）virtual关键字的作用，多态的原理（详细）

1.viirtual修饰的两种函数 virtual 修饰的函数有两种&#xff0c;一个是虚函数&#xff0c;一个是纯虚函数。 2.虚函数与纯虚函数的异同之处 1.虚函数与纯虚函数的相同之处 虚函数和纯虚函数都重写的一种&#xff0c;什么是重写呢&#xff1f;重写是指在子类中写和父类中返…
阅读更多...
2024-07-15 Unity插件 Odin Inspector3 —— Button Attributes

2024-07-15 Unity插件 Odin Inspector3 —— Button Attributes

文章目录 1 说明2 Button 特性2.1 Button2.2 ButtonGroup2.3 EnumPaging2.4 EnumToggleButtons2.5 InlineButton2.6 ResponsiveButtonGroup 1 说明 ​ 本文介绍 Odin Inspector 插件中有关 Button 特性的使用方法。 2 Button 特性 2.1 Button 依据方法&#xff0c;在 Inspec…
阅读更多...
使用DHCP动态管理主机地址

使用DHCP动态管理主机地址

前言&#xff1a;本博客仅作记录学习使用&#xff0c;部分图片出自网络&#xff0c;如有侵犯您的权益&#xff0c;请联系删除 一、动态主机地址管理协议 动态主机配置协议&#xff08;DHCP&#xff09;是一种基于UDP协议且仅限于在局域网内部使用的网络协议&#xff0c;主要用…
阅读更多...
书生大模型第一关-Linux基础知识

书生大模型第一关-Linux基础知识

1.闯关任务&#xff1a;关任务 完成SSH连接与端口映射并运行hello_world.py 首先SSH 命令连接进行转发 ssh -p 33704 rootssh.intern-ai.org.cn -CNg -L {本地机器_PORT}:127.0.0.1:{开发机_PORT} -o StrictHostKeyCheckingno在远程服务器上&#xff08;开发机&#xff09;运…
阅读更多...
操作系统杂项（二）

操作系统杂项（二）

目录 一、简述GDB常见的调试命令&#xff0c;什么是条件断点&#xff0c;多进程下如何调试 1、GDB调试 2、命令格式 3、条件断点 4、多进程下如何调试 二、简述什么是“大端小端”及如何判断 1、小端模式 2、大端模式 3、如何判断 三、简述进程调度算法有哪些 1、分…
阅读更多...
iSCSI 网络存储服务部署

iSCSI 网络存储服务部署

一、介绍 iSCSI &#xff08;Internet Small Computer System Interface&#xff09;&#xff0c;互联网小型计算机系统接口&#xff1b;iSCSI 是SCSI接口 与以太网技术相结合的新型存储技术&#xff0c;属于ip san的一种&#xff0c;可以用来在网络中传输 SCSI 接口的命令和数…
阅读更多...
用户进入网站之后看一眼就跳走，你知道原因吗？

用户进入网站之后看一眼就跳走，你知道原因吗？

用户进入网站后立即离开的原因可能有很多&#xff0c;以下是一些可能的原因和相应的规避办法&#xff1a; 页面加载速度慢&#xff1a; 如果网站加载速度过慢&#xff0c;用户可能会感到不耐烦并离开。可以通过优化网站的代码和资源&#xff0c;使用浏览器缓存、CDN加速等技术…
阅读更多...
Docker缩小镜像体积与搭建LNMP架构

Docker缩小镜像体积与搭建LNMP架构

镜像加速地址 {"registry-mirrors": ["https://docker.m.daocloud.io","https://docker.1panel.live"] } daemon.json 配置文件里面 bip 配置项中可以配置docker 的网段 {"graph": "/data/docker", #数据目录&#xff0…
阅读更多...
QTreeWidget

QTreeWidget

一、基本要点 1、QTreeWidgetItem 是 Qt 开发框架中的一个重要组件&#xff0c;它主要用于表示树形视图中的节点。在 QTreeWidget 这样的控件中&#xff0c;每个节点都是 QTreeWidgetItem 的实例&#xff0c;可以包含文本、图标以及其他数据。 2、connect 是Qt中的一个重要函…
阅读更多...
Crackmapexec一键检测网络环境（KALI工具系列四十四）

Crackmapexec一键检测网络环境（KALI工具系列四十四）

目录 1、KALI LINUX 简介 2、Crackmapexec工具介绍 3、信息收集 3.1 目标IP 3.2 kali的IP 4、操作步骤 4.1 帮助命令 4.2 扫描网段 4.3 验证访问 5、总结 1、KALI LINUX 简介 Kali Linux 是一个功能强大、多才多艺的 Linux 发行版 &#xff0c;广泛用于网络安全社区。它…
阅读更多...
蓝卓油气行业解决方案

蓝卓油气行业解决方案

我国是全球最大的能源消费国&#xff0c;保障国家能源安全是我国能源发展的首要任务&#xff0c;油气作为我国能源体系的重要组成部分&#xff0c;是支撑我国工业和经济社会发展的基础和“压舱石&#xff0c;也是必须筑牢的能源安全底线。 蓝卓根据油气田行业发展趋势&#xf…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023