A和A’互为主备,从库B、C、D指向的是主库A。一主多从的设置,一般用于读写分离,主库负责所有的写入和一部分读,其他的读请求则由从库分担。相比于一主一备的切换流程,一主多从结构在切换完成后,A’会成为新的主库,从库B、C、D也要改接到A’。
基于位点的主备切换
把节点B设置成节点A’的从库的时候,需要执行一条change master命令:
1 | CHANGE MASTER TO |
- master_host、master_port、master_user、master_password四个参数,分别代表了主库A’的IP、端口、用户名、密码。
- master_log_file、master_log_pos参数,表示要从主库的master_log_name文件的master_log_pos这个位置的日志继续同步。这个位置就是同步位点,是主库对应的文件名和日志偏移量。
原来节点B是A的从库,本地记录的也是A的位点。但是相同的日志,A的位点和A’的位点是不同的,从库B切换的时候,需要先经过“找同步位点”逻辑。
同步位点设置
切换过程中不能丢数据,找位点的时候,总是要找一个“稍微往前”的,然后再通过判断跳过那些在从库上已经执行过的事务:
- 等待新主库A’把中转日志relay log全部同步完成;
- 在A’上执行show master status命令,得到当前A’上最新的File和Position;
- 取援助库A故障的时刻T;
- 用mysqlbinlog工具解析A’的File,等得到T时刻的位点。
mysqlbinlog File –stop-datetime=T –start-datetime=T;
end_log_pos后面的值假设为’123’,表示的就是A’这个实例,在T时刻写入新的binlog的位置,把这个值123作为$master_log_pos,用在节点B的change master命令里。
同步位点不精确
在T时刻,主库A已经执行完成了一个insert语句插入了一行数据R,并且已经将binlog传给了A’和B,然后再传完的瞬间主库A的主机掉电了。
- 在从库B上,由于同步了binlog,R这一行已经存在;
- 在新主库A’上,R这一行也已经存在,日志是写在A的end_log_pos值123对应的位置之后;
- 在从库B上执行change master命令,指向A’的File文件的123位置,会把插入R这一行数据的binlog又同步到从库B去执行。
从库B的同步线程会报告Duplicate entry ‘id_of_R’ for key ‘PRIMARY’错误,提示出现了主键冲突,然后停止同步。
解决方案
切换任务的时候,主动跳过错误的两种方法:
- 主动跳过一个事务:
set global sql_slave_skip_counter=1;
start slave;
sql_slave_skip_counter跳过的是一个event,但MySQL不能只执行一半的事务,跳过了一个event,就会跳到这个事务的末尾。
切换过程中,可能会不止重复执行一个事务,需要在从库B刚开始接到新主库A’时,持续观察,每次碰到这些错误就停下来,执行一次跳过命令,直到不再出现停下来的情况,以此来跳过可能涉及的所有事务。
- 设置slave_skip_errors参数,直接跳过指定的错误:
在执行主备切换时,经常遇到的两类错误:1062错误是插入数据时唯一键冲突;1032错误是删除数据时找不到行。
把slave_skip_errors设置为“1032,1062”,中间碰到这两个错误时直接跳过。
只有主备切换过程中,直接跳过1032和1062错误时无损的,等主备间的同步关系建立按成,并稳定执行一段时间之后,需要把这个参数设置为空,以免之后真的主从数据不一致被跳过。
GTID
MySQL5.6版本引入了GTID,解决主备切换复杂易错的问题。
GTID全称是Global Transaction Identifier,全局事务ID,是一个事务在提交的时候生成的,是这个事务的唯一标识,由两部分组成,格式是:GTID=server_uuid:gno;
- server_uuid是一个实例第一次启动时自动生成的,是一个全局唯一的值;
- gno是一个整数,初始值是1,每次提交事务的时候分配给这个事务,并加1。
官方文档定义格式:GTID=source_id:transaction_id;
- source_id就是server_uuid;
- transaction_id容易造成误解,用gno代替。
MySQL中transaction_id是指事务id,事务id是在事务执行过程找那个分配的,即使这个事务回滚了,事务id也会递增,而gno是在事务提交的时候才会分配。
从效果上看GTID往往是连续的,用gno表示更容易理解。
启动一个MySQL实例的时候,加上参数gtid_mode=on和enforce_gtid_consistency=on;就可以启动GTID模式。
在GTID模式下,每个事务都会跟一个GTID一一对应。有两种生成方式,使用哪种方式取决于session变量gtid_next的值:
- 如果gtid_next=automatic,代表使用默认值。MySQL会把server_uuid:gno分配给这个事务。
a. 记录binlog的时候,先记录一行set @@session.gtid_next=’server_uuid:gno’;
b. 把这个gtid加入本实例的gtid集合。 - 如果gtid_next是一个指定的gtid值,如通过 set gtid_next=’current_gtid’指定为current_gtid,那么有两种可能:
a. 如果current_gtid已经存在于实例的gtid集合中,接下来执行的这个事务会直接被系统忽略;
b. 如果current_gtid没有存在于实例的gtid集合中,就将整个current_gtid分配给接下来要执行的事务,也就是说系统不需要给这个事务生成新的gtid,因此gno也不用加1。
一个current_gtid只能给一个事务使用。这个事务提交后,如果要执行下一个事务,就要执行set命令,把gtid_next设置成另外一个gtid或者automatic。
set gtid_next=’aaaaaaaa-bbbb-cccc-dddd-eeeeeeeeeeee:10’;
begin;
commit;
set gtid_next=automatic;
start slave;
每个MySQL实例都维护了一个gtid集合,用来对应“这个实例执行过的所有事务”。通过show master status命令查看,对应的Executed_Gtid_set参数值。
在binlog文件开头,有一个Previous_gtids,用于记录生成这个binlog的时候,实例的Executed_gtid_set。启动时只需要解析最后一个文件,就可以知道该实例所有的GTID集合,也可以快速的定位GTID在哪个文件。
基于GTID的主备切换
在GTID模式下,备库B要设置为新主库A’的从库的语法:
1 | CHANGE MASTER TO |
- master_auto_position=1表示这个准备关系使用的是GTID协议。
当前时刻,实例A’GTID集合记为set_a,实例B的GTID集合记为set_b。在实例B上执行start slave命令,取binlog的逻辑如下:
- 实例B指定主库A’,基于准备协议建立连接。
- 实例B把set_b发给主库A’。
- 实例A’算出set_a与set_b的差集,也就是所有存在于set_a,但是不存在于set_b的GTID的集合,判断A’本地是否包含了这个差集需要的所有binlog事务。
a. 如果不包含,表示A’已经把实例B需要的binlog给删掉的了,直接返回错误;
b. 如果确认全部包含,A’从自己的binlog文件里面,找出第一个不在set_b的事务,发给B; - 之后就从这个事务开始,往后读文件,按顺序取binlog发给B去执行。
设计思想之一:在基于GTID的主备关系里,系统认为只要建立了主备关系,就必须保证主库发给备库的日志是完成的。因此,如果实例B需要的日志已经不存在,A’就拒绝吧日志发给B。
如果一个新的从库接上主库,但需要的binlog已经没了,解决方案:
- 如果业务允许主从不一致的情况,可以在主库上先执行show global variables like ‘gtid_purged’,得到主库已经删除的GTID集合,假设是gtid_purger1;然后先在从库上执行reset master,再执行set global gtid_purged=’gtid_purged1’;最后执行start slave,就会从主库现存的binlog开始同步。binlog缺失的那一部分,数据在从库上可能会有丢失,造成主从不一致。
- 如果需要主从数据一致,通过重新搭建从库来做。
- 如果有其他的从库保留有全量的binlog的话,可以把新的从库先接到这个保留了全量的binlog的从库,追上日志以后,如果有需要,再接回从库。
- 如果binlog有备份的情况,可以先在从库上应用缺失的binlog,然后再执行start slave。
对比区别:基于位点的协议,是由备库决定的,备库指定哪个位点,主库就发哪个位点,不做日志的完整性判断。
GTID同时解决了循环复制的问题。
GTID模式下,一主多从主备切换,从库B、C、D只需要分别执行change master命令指向实例A’即可。找位点的工作在实例A’内部已经自动完成。对于HA系统的开发人员非常友好。
之后整个系统就由新主库A’写入,主库A’的自己生成的binlog中的GTID集合格式是:server_uuid_of_A’:1-M。
从库(包括备库)的GTID集合的整体格式为:server_uuid_of_A:1-N,server_uuid_of_A’:1-M。
GTID和在线DDL
索引缺失引起的性能问题,可以通过在线加索引来解决。考虑到要避免新增索引对主库性能造成影响,可以先在备库加索引,然后再切换。
在双M结构下,备库执行的DDL语句也会传给主库,为了避免传回后对主库造成影响,要通过set sql_log_bin=off关掉binlog。binlog并没有记录下这一更新,导致数据和日志不一致。
解决:假设互为主备关系的库是实例X和实例Y,当前主库是X,并且都打开了GTID模式,主备切换流程:
在实例X上执行 stop slave。
在实例Y上执行DDL语句。这里不需要关闭binlog。
执行完成后,查出这个DDL语句对应的GTID,并记为server_uuid_of_Y:gno。
到实例X中执行以下语句序列:
set GTID_NEXT=”server_uuid_of_Y:gno”;
begin;
commit;
set gtid_next=automatic;
start slave;这样模拟一个空事务既可以让实例Y的更新有binlog记录,同时也可以确保不会在实例X上执行这条更新。
接下来,执行完主备切换,照着上述流程再执行一遍即可。