MySQL 主从复制

发布于:2023-02-03 ⋅ 阅读:(651) ⋅ 点赞:(0)

MySQL 主从复制


1.MySQL主从复制概述

MySQL作为世界上使用最为广泛的数据库之一,免费是其原因之一;但不可忽略的是它本身的功能的确很强大。随着技术的发展,在实际的生产环境中,由单台MySQL数据库服务器不能满足实际的需求。此时数据库集群就很好的解决了这个问题了。采用MySQL分布式集群,能够搭建一个高并发、负载均衡的集群服务器。在此之前我们必须要保证每台MySQL服务器里的数据同步。

1.1主从作用
  • 实时灾备,用于故障切换
  • 读写分离,提供查询服务
  • 备份,避免影响业务
1.2 主从形式

主从形式

  • 一主一从
  • 主主复制
  • 一主多从—扩展系统读取的性能,因为读是在从库读取的
  • 多主一从—5.7开始支持
  • 联级复制

2. 主从复制原理

主从复制原理
主从复制步骤:

  • 主库将所有的写操作记录到binlog日志中并生成一个log dump线程,将binlog日志传给从库的I/O线程
  • 从库生成两个线程,一个I/O线程,一个SQL线程
    • I/O线程去请求主库的binlog,并将得到的binlog日志写到relay log(中继日志) 文件中
    • SQL线程,会读取relay log文件中的日志,并解析成具体操作,来实现主从的操作一致,达到最终数据一致的目的

3.传统MySQL主从复制配置

主从复制需要两台虚拟机,分别为master(主服务器)和slave(从服务器)。

//主服务器和从服务器二级制安装MySQL数据库,这里已安装完成,并启动
[root@master ~]# ss -anlt
State        Recv-Q       Send-Q             Local Address:Port             Peer Address:Port      Process       
LISTEN       0            128                      0.0.0.0:22                    0.0.0.0:*                       
LISTEN       0            128                         [::]:22                       [::]:*                       
LISTEN       0            80                             *:3306                        *:*                       
[root@master ~]#

[root@slave ~]# ss -anlt
State      Recv-Q     Send-Q          Local Address:Port           Peer Address:Port     Process     
LISTEN     0          128                   0.0.0.0:22                  0.0.0.0:*                    
LISTEN     0          80                          *:3306                      *:*                    
LISTEN     0          128                      [::]:22                     [::]:*                    
[root@slave ~]# 

//主服务器关闭防火墙和selinux
[root@master ~]# systemctl stop firewalld.service 
[root@master ~]# systemctl disable firewalld.service 
Removed /etc/systemd/system/multi-user.target.wants/firewalld.service.
Removed /etc/systemd/system/dbus-org.fedoraproject.FirewallD1.service.
[root@master ~]# sed -i s/SELINUX=enforing/SELINUX=disabled/g /etc/selinux/config 
[root@master ~]# setenforce 0

[root@slave ~]# systemctl stop firewalld.service
[root@slave ~]# systemctl disable firewalld.service 
Removed /etc/systemd/system/multi-user.target.wants/firewalld.service.
Removed /etc/systemd/system/dbus-org.fedoraproject.FirewallD1.service.
[root@slave ~]# sed -i s/SELINUX=enforing/SELINUX=disabled/g /etc/selinux/config 
[root@slave ~]# setenforce 0

//在主服务器上配置主从复制,开启二进制日志,设置服务id
[root@master ~]# vim /etc/my.cnf  
[root@master ~]# cat /etc/my.cnf 
[mysqld] 
basedir = /usr/local/mysql 
datadir = /opt/mysqldata 
socket = /tmp/mysql.sock 
port = 3306 
pid-file = /opt/mysqldata/mysql.pid 
user = mysql 
skip-name-resolve 
sql-mode = STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION
log_bin=mysql_bin    //开启二进制日志
server_id=10         //服务id号,不可重复,为0则拒绝从服务器连接

//重启mysql服务
[root@master ~]# systemctl restart mysqld.service

//查看主库的状态
mysql> show master status;
+------------------+----------+--------------+------------------+-------------------+
| File             | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |
+------------------+----------+--------------+------------------+-------------------+
| mysql_bin.000001 |      836 |              |                  |                   |
+------------------+----------+--------------+------------------+-------------------+
1 row in set (0.00 sec)


//在主服务器授权一个数据库用户用于复制,创建完成后在从服务器测试登录
mysql> create user 'slave'@'%' identified by '20021020';
Query OK, 0 rows affected (0.00 sec)

mysql> grant replication slave on *.* to 'slave'@'%' identified by '20021020';
Query OK, 0 rows affected, 1 warning (0.01 sec)

mysql> flush privileges;
Query OK, 0 rows affected (0.01 sec)

在从服务器配置主从复制,设置服务id,如果主服务器有数据记得先导入
[root@slave ~]# vim /etc/my.cnf
[root@slave ~]# cat /etc/my.cnf 
[mysqld] 
basedir = /usr/local/mysql 
datadir = /opt/mysqldata 
socket = /tmp/mysql.sock 
port = 3306 
pid-file = /opt/mysqldata/mysql.pid 
user = mysql 
skip-name-resolve 
sql-mode = STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION
server-id=11                 
relay-log=mysql-relay-bin    //启用中继日志relay-log

//重启从库的mysql服务
[root@slave ~]# systemctl restart mysqld.service 
[root@slave ~]# ss -anlt
State      Recv-Q     Send-Q          Local Address:Port           Peer Address:Port     Process     
LISTEN     0          128                   0.0.0.0:22                  0.0.0.0:*                    
LISTEN     0          80                          *:3306                      *:*                    
LISTEN     0          128                      [::]:22                     [::]:* 

//配置并启动主从复制
mysql> change master to 
    -> master_host='192.168.174.164',
    -> master_user='slave',
    -> master_password='20021020',
    -> master_log_file='mysql_bin.000001',
    -> master_log_pos=836;
Query OK, 0 rows affected, 2 warnings (0.01 sec)

mysql> start slave;
Query OK, 0 rows affected (0.00 sec)

//查看从服务器状态
mysql> show slave status \G
*************************** 1. row ***************************
               Slave_IO_State: Waiting for master to send event
                  Master_Host: 192.168.174.164
                  Master_User: slave
                  Master_Port: 3306
                Connect_Retry: 60
              Master_Log_File: mysql_bin.000001
          Read_Master_Log_Pos: 836
               Relay_Log_File: mysql-relay-bin.000002
                Relay_Log_Pos: 320
        Relay_Master_Log_File: mysql_bin.000001
             Slave_IO_Running: Yes     //此处必须为yes,表明i/o进程已启动
            Slave_SQL_Running: Yes     //此处必须为yes,表明sql进程已启动

//测试验证
mysql> create database runtime;   //在主服务器创建一个runtime库
Query OK, 1 row affected (0.00 sec)

mysql> show databases;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| mysql              |
| performance_schema |
| runtime            |
| sys                |
+--------------------+
5 rows in set (0.00 sec)

mysql> show databases;    //在从数据库中查看数据是否同步
+--------------------+
| Database           |
+--------------------+
| information_schema |
| mysql              |
| performance_schema |
| runtime            |
| sys                |
+--------------------+
5 rows in set (0.00 sec)

4.GTID工作原理

从服务器连接到主服务器之后,把自己执行过的GTID (Executed_Gtid_Set: 即已经执行的事务编码) 、获取到的GTID (Retrieved_Gtid_Set: 即从库已经接收到主库的事务编号) 发给主服务器,主服务器把从服务器缺少的GTID及对应的transactions发过去补全即可。当主服务器挂掉的时候,找出同步最成功的那台从服务器,直接把它提升为主即可。如果硬要指定某一台不是最新的从服务器提升为主, 先change到同步最成功的那台从服务器, 等把GTID全部补全了,就可以把它提升为主了。

GTID是MySQL 5.6的新特性,可简化MySQL的主从切换以及Failover。GTID用于在binlog中唯一标识一个事务。当事务提交时,MySQL Server在写binlog的时候,会先写一个特殊的Binlog Event,类型为GTID_Event,指定下一个事务的GTID,然后再写事务的Binlog。主从同步时GTID_Event和事务的Binlog都会传递到从库,从库在执行的时候也是用同样的GTID写binlog,这样主从同步以后,就可通过GTID确定从库同步到的位置了。也就是说,无论是级联情况,还是一主多从情况,都可以通过GTID自动找点儿,而无需像之前那样通过File_name和File_position找点儿了。

简而言之,GTID的工作流程为:

  • master更新数据时,会在事务前产生GTID,一同记录到binlog日志中。

  • slave端的i/o 线程将变更的binlog,写入到本地的relay log中。

  • sql线程从relay log中获取GTID,然后对比slave端的binlog是否有记录。

  • 如果有记录,说明该GTID的事务已经执行,slave会忽略。

  • 如果没有记录,slave就会从relay log中执行该GTID的事务,并记录到binlog。

  • 在解析过程中会判断是否有主键,如果没有就用二级索引,如果没有就用全部扫描。

5.传统主从和gtid主从的区别

传统主从
传统主从复制主要是基于二进制日志文件位置的复制,因此主必须启动二进制日志记录并建立唯一的服务器ID,复制组中的每个服务器都必须配置唯一的服务器ID。如果您省略server-id(或者明确地将其设置为其默认值0),则主设备将拒绝来自从设备的任何连接。

gtid主从
MySQL 5.6 的新特性之一,全局事务标识符(GTID)是创建的唯一标识符,并与在源(主)服务器上提交的每个事务相关联。此标识符不但是唯一的,而且在给定复制设置中的所有服务器上都是唯一的。所有交易和所有GTID之间都有一对一的映射关系 。它由服务器ID以及事务ID组合而成。这个全局事务ID不仅仅在原始服务器上唯一,在所有存在主从关系 的mysql服务器上也是唯一的。正是因为这样一个特性使得mysql的主从复制变得更加简单,以及数据库一致性更可靠。一个GTID在一个服务器上只执行一次,避免重复执行导致数据混乱或者主从不一致

在传统的主从复制slave端,binlog是不用开启的,但是在GTID中slave端的binlog是必须开启的,目的是记录执行过的GTID(强制)。GTID用来代替classic的复制方法,不在使用binlog+pos开启复制。而是使用master_auto_postion=1的方式自动匹配GTID断点进行复制

6.GTID主从配置

主从复制需要两台虚拟机,分别为master(主服务器)和slave(从服务器)。

//主服务器和从服务器二级制安装MySQL数据库,这里已安装完成,并启动
[root@master ~]# ss -anlt
State        Recv-Q       Send-Q             Local Address:Port             Peer Address:Port      Process       
LISTEN       0            128                      0.0.0.0:22                    0.0.0.0:*                       
LISTEN       0            128                         [::]:22                       [::]:*                       
LISTEN       0            80                             *:3306                        *:*                       
[root@master ~]#

[root@slave ~]# ss -anlt
State      Recv-Q     Send-Q          Local Address:Port           Peer Address:Port     Process     
LISTEN     0          128                   0.0.0.0:22                  0.0.0.0:*                    
LISTEN     0          80                          *:3306                      *:*                    
LISTEN     0          128                      [::]:22                     [::]:*                    
[root@slave ~]# 

//主服务器关闭防火墙和selinux
[root@master ~]# systemctl stop firewalld.service 
[root@master ~]# systemctl disable firewalld.service 
Removed /etc/systemd/system/multi-user.target.wants/firewalld.service.
Removed /etc/systemd/system/dbus-org.fedoraproject.FirewallD1.service.
[root@master ~]# sed -i s/SELINUX=enforing/SELINUX=disabled/g /etc/selinux/config 
[root@master ~]# setenforce 0

[root@slave ~]# systemctl stop firewalld.service
[root@slave ~]# systemctl disable firewalld.service 
Removed /etc/systemd/system/multi-user.target.wants/firewalld.service.
Removed /etc/systemd/system/dbus-org.fedoraproject.FirewallD1.service.
[root@slave ~]# sed -i s/SELINUX=enforing/SELINUX=disabled/g /etc/selinux/config 
[root@slave ~]# setenforce 0

//主库配置
[root@master ~]# vim /etc/my.cnf 
[root@master ~]# cat /etc/my.cnf 
[mysqld] 
basedir = /usr/local/mysql 
datadir = /opt/mysqldata 
socket = /tmp/mysql.sock 
port = 3306 
pid-file = /opt/mysqldata/mysql.pid 
user = mysql 
skip-name-resolve 
sql-mode = STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION
log-bin=mysql_bin    //开启二进制日志
server-id=10
gtid_mode=on         //启动事务ID模式
enforce-gtid-consistency=true    //强制GTID一致,不允许事务违反GTID一致性
log-slave-updates=on             //告诉从库将主从复制语句也记录在binlog日志,从库需要开启binlog

//从库配置
[root@slave ~]# vim /etc/my.cnf 
[root@slave ~]# cat /etc/my.cnf 
[mysqld] 
basedir = /usr/local/mysql 
datadir = /opt/mysqldata 
socket = /tmp/mysql.sock 
port = 3306 
pid-file = /opt/mysqldata/mysql.pid 
user = mysql 
skip-name-resolve 
sql-mode = STRICT_TRANS_TABLES,NO_ZERO_IN_DATE,NO_ZERO_DATE,ERROR_FOR_DIVISION_BY_ZERO,NO_AUTO_CREATE_USER,NO_ENGINE_SUBSTITUTION
server-id=20
relay-log=myrelay
gtid_mode=on
enforce-gtid-consistency=true
log-slave-updates=on
read_only=on
master-info-repository=TABLE
relay-log-info-repository=TABLE


//重启服务生效
[root@master ~]# systemctl restart mysqld.service 
[root@master ~]# 

//在主服务器授权一个数据库用户用于复制
mysql> GRANT REPLICATION SLAVE ON *.* TO 'slave'@'%' IDENTIFIED BY '20021020';
Query OK, 0 rows affected, 1 warning (0.00 sec)

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

//登录到从服务器数据库,在数据库中配置主服务器主从复制信息
mysql> change master to
    -> master_host='192.168.174.164',
    -> master_port=3306,
    -> master_user='slave',
    -> master_password='20021020',
    ->  master_auto_position=1;
Query OK, 0 rows affected, 2 warnings (0.00 sec)

//启动主从复制
mysql> start slave;
Query OK, 0 rows affected (0.01 sec)

//查看从服务器状态
mysql> show slave status \G;
*************************** 1. row ***************************
               Slave_IO_State: Waiting for master to send event
                  Master_Host: 192.168.174.164
                  Master_User: slave
                  Master_Port: 3306
                Connect_Retry: 60
              Master_Log_File: mysql_bin.000001
          Read_Master_Log_Pos: 590
               Relay_Log_File: myrelay.000002
                Relay_Log_Pos: 803
        Relay_Master_Log_File: mysql_bin.000001
             Slave_IO_Running: Yes
            Slave_SQL_Running: Yes

//测试验证
mysql> create database runtime;    //在主服务器创建一个runtime库
Query OK, 1 row affected (0.00 sec)

mysql> show databases;
+--------------------+
| Database           |
+--------------------+
| information_schema |
| mysql              |
| performance_schema |
| runtime            |
| sys                |
+--------------------+
5 rows in set (0.00 sec)

mysql> show databases;     //在从库查看是否同步
+--------------------+
| Database           |
+--------------------+
| information_schema |
| mysql              |
| performance_schema |
| runtime            |
| sys                |
+--------------------+
5 rows in set (0.00 sec)

|
±-------------------+
5 rows in set (0.00 sec)

mysql> show databases; //在从库查看是否同步
±-------------------+
| Database |
±-------------------+
| information_schema |
| mysql |
| performance_schema |
| runtime |
| sys |
±-------------------+
5 rows in set (0.00 sec)



网站公告

今日签到

点亮在社区的每一天
去签到