实验环境

操作系统 主机地址 主机名
CentOS 7.4 192.168.153.220 mysql-master1
CentOS 7.4 192.168.153.215 mysql-master2
CentOS 7.4 192.168.153.148 mysql-slave1
CentOS 7.4 192.168.153.219 mysql-slave2

MySQL在5.7.2上面添加了多源复制（Multi-Source）功能，意味着一个从库可以连多个主库，从而同时进行同步，但是如果是同一个表的话，会存在主键和唯一索引冲突的风险，需要提前做好规划
个人认为MySQL能实现多源复制的关键有两点
1. MySQL5.7中的从库进行同步的SQL_THREAD，IO_THREAD可以并发执行，这使得使多数据源的binlog同时同步变为可能。我们只需要对每一个Master执行Change Master 语句，只需要在每个语句最后使用For Channel来进行区分。
master1:
change master to master2 channel ‘master’;

master2:
change master to master1 channel ‘master1’;

slave1:
change master to master1 channel ‘master1’;
change master to master2 channel ‘master’;
2. MySQL5.7中添加了channel（通道）来判别不同的数据源，这样slave可以非常简单的进行多数据源的配置与区分。
3. 由于复制的原理没有改变，在没有开启GTID的时候Master的版本可以是MySQL5.5、5.6、5.7。并且从库需要master-info-repository、relay-log-info-repository设置为table，否则会报错：

  1. ERROR 3077 (HY000): To have multiple channels, repository cannot be of type FILE; Please check the repository configuration and convert them to TABLE.

实战操作

前提：本次使用的binlog日志方式。手动指定binlog日志名称以及位置的方式；

配置host解析

  1. # cat /etc/hosts
  2. 192.168.153.220 mysql-master1
  3. 192.168.153.215 mysql-master2
  4. 192.168.153.148 mysql-slave1
  5. 192.168.153.219 mysql-slave2

安装Mysql 5.7

4台机器均安装，这里采用yum安装
Mysql官网地址：https://www.mysql.com/
image.png

  1. # wget https://dev.mysql.com/get/mysql80-community-release-el7-4.noarch.rpm
  2. # rpm -ivh mysql80-community-release-el7-4.noarch.rpm
  3. # vi /etc/yum.repos.d/mysql-community.repo   //配置yum源，下载mysql5.7

image.png

  1. # yum -y install mysql-community-server
  2. [root@mysq-master1 ~]# mysql --version   #一定要确定4台机器下载的Mysql版本一致
  3. mysql  Ver 14.14 Distrib 5.7.36, for Linux (x86_64) using  EditLine wrapper

修改4台mysql的配置文件
打开/etc/my.cnf，在[mysqld]标签下添加内容：
image.pngimage.pngimage.pngimage.png

启动配置Mysql

mysql-master1节点操作

  1. [root@mysq-master1 ~]# systemctl start mysqld
  2. [root@mysq-master1 ~]# grep password /var/log/mysqld.log

image.png

  1. [root@mysq-master1 ~]# mysqladmin -uroot -p'WdJ_H?xVk8-k' password 'Youngfit@123456'
  2. [root@mysq-master1 ~]# mysql -uroot -p'Youngfit@123456'
  3. mysql> grant replication slave,replication client on *.* to 'rep'@'192.168.153.%' identified by 'Rep@123456';  --创建同步使用的用户，注意网段
  4. Query OK, 0 rows affected, 1 warning (0.00 sec)
  6. mysql> flush privileges;
  7. Query OK, 0 rows affected (0.00 sec)

mysql-master2操作如同mysql-master1一样步骤

双主配置

查看mysql-master2的binlog日志名称和位置：
image.png
在mysql-master1上指定操作：

  1. mysql> change master to                        --设置mysql-mastre2为自己的主节点
  2. master_host='mysql-master2',
  3. master_user='rep',
  4. master_password='Rep@123456',
  5. master_log_file='mylog.000002',
  6. master_log_pos=856916 for channel 'mysql-master2';
  7. Query OK, 0 rows affected, 2 warnings (0.00 sec)
  9. mysql> start slave;
  10. mysql> show slave status\G

查看mysql-master1的binlog日志名称和位置：
image.png
在mysql-master2上指定操作：

  1. mysql> change master to                        --设置mysql-mastre1为自己的主节点
  2. master_host='mysql-master1',
  3. master_user='rep',
  4. master_password='Rep@123456',
  5. master_log_file='mylog.000003',   --我这里不一样，根据你自己的名称和位置去写
  6. master_log_pos=659 for channel 'mysql-master1';
  7. Query OK, 0 rows affected, 2 warnings (0.00 sec)
  9. mysql> start slave;
  10. mysql> show slave status\G

2台分别查看同步的io线程和sql线程是否为YES

  1. mysql> show slave status\G

image.png

  1. mysql> show slave status\G

image.png
经常操作：

  1. # 查看单个channel的状态
  2. mysql> show slave status for channel 'mysql-master2'\G
  3. # 停止单个channel同步
  4. mysql>  stop slave for channel 'mysql-master2';
  5. # 开启单个channel同步
  6. mysql>  start slave for channel 'mysql-master2';
  7. # 重置单个channel
  8. mysql>  reset slave for channel 'mysql-master2';
  9. # 查看所有channel
  10. mysql> show slave status\G
  11. # 开启所有channel
  12. mysql> start slave;

监控：系统库performance_schema增加了一些replication的监控表

  1. mysql> use performance_schema
  2. mysql> show tables like 'replicat%';
  3. +-------------------------------------------+
  4. | Tables_in_performance_schema (replicat%)  |
  5. +-------------------------------------------+
  6. | replication_applier_configuration         |###查看各个channel是否配置了复制延迟
  7. | replication_applier_status                |###查看各个channel是否复制正常（service_state）以及事务重连的次数
  8. | replication_applier_status_by_coordinator |###查看各个channel是否复制正常，以及复制错误的code、message和时间
  9. | replication_applier_status_by_worker      |###查看各个channel是否复制正常，以及并行复制work号，复制错误的code、SQL和时间
  10. | replication_connection_configuration      |###查看各个channel的连接配置信息：host、port、user、auto_position等
  11. | replication_connection_status             |###查看各个channel的连接信息
  12. | replication_group_member_stats            |###
  13. | replication_group_members                 |###
  14. +-------------------------------------------+

双从配置

mysql-slave1

  1. [root@mysql-slave1 ~]# systemctl start mysqld
  2. [root@mysql-slave1 ~]# grep password /var/log/mysqld.log 
  3. [root@mysql-slave1 ~]# mysqladmin -uroot -p'oUm?lgeoA8yY' password 'Youngfit@123456'
  4. [root@mysql-slave1 ~]# mysql -uroot -p'Youngfit@123456'
  5. mysql> change master to                        --设置mysql-mastre1为自己的主节点
  6. master_host='mysql-master1',
  7. master_user='rep',
  8. master_password='Rep@123456',
  9. master_log_file='mylog.000003',   --我这里不一样，根据你自己的名称和位置去写
  10. master_log_pos=659 for channel 'mysql-master1';
  11. Query OK, 0 rows affected, 2 warnings (0.00 sec)
  13. mysql> change master to                        --设置mysql-mastre2为自己的主节点
  14. master_host='mysql-master2',
  15. master_user='rep',
  16. master_password='Rep@123456',
  17. master_log_file='mylog.000002',   --我这里不一样，根据你自己的名称和位置去写
  18. master_log_pos=856916 for channel 'mysql-master2';
  19. Query OK, 0 rows affected, 2 warnings (0.00 sec)
  21. mysql> start slave for channel 'mysql-master1';
  22. Query OK, 0 rows affected (0.00 sec)
  24. mysql> start slave for channel 'mysql-master2';
  25. Query OK, 0 rows affected (0.00 sec)
  27. mysql> show slave status\G

image.png
image.png
mysql-slave2同样操作

  1. [root@mysql-slave2 ~]# systemctl start mysqld
  2. [root@mysql-slave2 ~]# grep password /var/log/mysqld.log 
  3. [root@mysql-slave2 ~]# mysqladmin -uroot -p'oUm?lgeoA8yY' password 'Youngfit@123456'
  4. [root@mysql-slave2 ~]# mysql-uroot -p'Youngfit@123456'
  5. mysql> change master to                        --设置mysql-mastre1为自己的主节点
  6. master_host='mysql-master1',
  7. master_user='rep',
  8. master_password='Rep@123456',
  9. master_log_file='mylog.000003',   --我这里不一样，根据你自己的名称和位置去写
  10. master_log_pos=659 for channel 'mysql-master1';
  11. Query OK, 0 rows affected, 2 warnings (0.00 sec)
  13. mysql> change master to                        --设置mysql-mastre2为自己的主节点
  14. master_host='mysql-master2',
  15. master_user='rep',
  16. master_password='Rep@123456',
  17. master_log_file='mylog.000002',   --我这里不一样，根据你自己的名称和位置去写
  18. master_log_pos=856916 for channel 'mysql-master2';
  19. Query OK, 0 rows affected, 2 warnings (0.00 sec)
  21. mysql> start slave for channel 'mysql-master1';
  22. Query OK, 0 rows affected (0.00 sec)
  24. mysql> start slave for channel 'mysql-master2';
  25. Query OK, 0 rows affected (0.00 sec)
  27. mysql> show slave status\G

image.png
image.png

验证集群

在mysql-master1上创建1个库，查看其他节点是否同步

  1. mysql> create database testbase1;
  2. Query OK, 1 row affected (0.00 sec)

image.png
image.png
image.png
以上看出没有问题，再来试试mysql-master2插入数据，在mysql-master2节点操作

  1. mysql> create table testbase1.table1(id int,age int);
  2. Query OK, 0 rows affected (0.00 sec)

image.png
image.png
image.png

高可用性验证

停止mysql-master2节点

  1. [root@mysq-master2 ~]# systemctl stop mysqld

能看到所有从节点，连接mysql-master2的io线程异常
image.png
image.png
但是连接mysql-master1的仍为正常
image.png
image.png
那么下面测试一下在mysql-master1上继续创建数据，看2个从节点是否还正常同步

  1. mysql> create table  testbase1.table2(name char(3),home varchar(20));
  2. Query OK, 0 rows affected (0.01 sec)

image.pngimage.png

修复问题

修复流程：
1.停止mysql-master2节点的数据库，清空数据，
2.mysql-master1将数据全部导出，发送给mysql-master2
3.mysql-master2导入数据，重新change master to
这种修复操作，一般在Mysql没有访问的时候，像我们公司，是晚上11点以后，基本不会有请求。如果不放心，可以直接先让防火墙屏蔽掉数据库端口3306，这样所有请求都无法进入，但是要对mysql-master1,mysql-slave1,mysql-slave2放行。
在mysql-master2操作

  1. [root@mysq-master2 ~]# systemctl stop mysqld  #停止数据库
  2. [root@mysq-master2 ~]# rm -rf /var/lib/mysql/*  #删除所有原来的数据，当然要确保其他节点正常，最好是再对所有数据进行一次备份，以防万一
  3. [root@mysq-master2 ~]# rm -rf /var/log/mysqld.log
  4. [root@mysq-master2 ~]# systemctl start mysqld
  5. [root@mysq-master2 ~]# grep password /var/log/mysqld.log 
  6. 2021-12-12T12:17:13.471634Z 1 [Note] A temporary password is generated for root@localhost: #pHeA4KFauP?
  7. [root@mysq-master2 ~]# mysqladmin -uroot -p'#pHeA4KFauP?' password 'Youngfit@123456'

在mysql-master1备份数据，并发送给mysql-master2

  1. [root@mysq-master1 ~]# mysqldump -uroot -p'Youngfit@123456' -A --set-gtid-purged=OFF > alldata.sql
  2. [root@mysq-master1 ~]# scp alldata.sql mysql-master2:/root/

在mysql-master2导入数据，保证跟集群数据一致

  1. [root@mysq-master2 ~]# mysql -uroot -p'Youngfit@123456' < alldata.sql
  2. [root@mysq-master2 ~]# mysql -uroot -p'Youngfit@123456'
  3. mysql> grant replication slave,replication client on *.* to 'rep'@'192.168.153.%' identified by 'Rep@123456';  --创建同步使用的用户，注意网段
  4. Query OK, 0 rows affected, 1 warning (0.00 sec)
  6. mysql> flush privileges;
  7. Query OK, 0 rows affected (0.00 sec)

下面进行恢复：
查看mysql-master1的binlog日志名称和位置：
image.png
在Mysql-master2操作：

  1. mysql> change master to                                                
  2. master_host='mysql-master1',
  3. master_user='rep',
  4. master_password='Rep@123456',
  5. master_log_file='mylog.000003',   #注意对应名称和日志位置
  6. master_log_pos=498 for channel 'mysql-master1';
  8. mysql> start slave for channel 'mysql-master1';
  9. Query OK, 0 rows affected (0.00 sec)
  11. mysql> show slave status for channel 'mysql-master1'\G

image.png
mysql-master1未恢复正常：
image.png
所以，mysql-master1需要重新指定：
先查看mysql-master2的binlog日志名称和位置：
image.png
在mysql-master1上重新指定操作：

  1. mysql> stop slave for channel 'mysql-master2';
  2. Query OK, 0 rows affected (0.00 sec)
  4. mysql> reset slave for channel 'mysql-master2';
  5. Query OK, 0 rows affected (0.00 sec)
  7. mysql> change master to                                                
  8. master_host='mysql-master2',
  9. master_user='rep',
  10. master_password='Rep@123456',
  11. master_log_file='mylog.000002',
  12. master_log_pos=880 for channel 'mysql-master2';
  14. mysql> start slave for channel 'mysql-master2';
  15. Query OK, 0 rows affected (0.00 sec)
  17. mysql> show slave status for channel 'mysql-master2';

image.png
但是mysql-slave1还未恢复正常：
image.png
在mysql-slave1上操作：

  1. mysql> stop slave for channel 'mysql-master2';
  2. Query OK, 0 rows affected (0.01 sec)
  4. mysql> reset slave for channel 'mysql-master2';
  5. Query OK, 0 rows affected (0.00 sec)

看下mysql-master2的日志名称和位置：
image.png
在mysql-slave1上操作：

  1. mysql> change master to                                                
  2. master_host='mysql-master2',
  3. master_user='rep',
  4. master_password='Rep@123456',
  5. master_log_file='mylog.000002',  -- 注意对应binlog日志名称和位置
  6. master_log_pos=856916 for channel 'mysql-master2';
  8. mysql> start slave for channel 'mysql-master2';
  9. Query OK, 0 rows affected (0.00 sec)

image.png
在mysql-slave2上查看，也未恢复正常
image.png
在mysql-slave2上操作：

  1. mysql> stop slave for channel 'mysql-master2';
  2. Query OK, 0 rows affected (0.01 sec)
  4. mysql> reset slave for channel 'mysql-master2';
  5. Query OK, 0 rows affected (0.00 sec)

查看mysql-master2的binlog日志名称和位置：
image.png
在mysql-slave2上操作：

  1. mysql> change master to
  2. master_host='mysql-master2',
  3. master_user='rep',
  4. master_password='Rep@123456',
  5. master_log_file='mylog.000002', -- 注意对应binlog日志名称和位置
  6. master_log_pos=856916 for channel 'mysql-master2';
  8. mysql> start slave for channel 'mysql-master2';
  9. Query OK, 0 rows affected (0.01 sec)
  11. mysql> show slave status for channel 'mysql-master2'\G

image.png

再次验证

在mysql-master1上新建数据，查看其他节点是否同步

  1. mysql> create table testbase1.table2(id int,age int);
  2. Query OK, 0 rows affected (0.01 sec)

其他3个节点查看验证：
image.png
image.pngimage.png
666！