博客
关于我
强烈建议你试试无所不能的chatGPT,快点击我
MySQL Replication--半同步复制(Semi-Sync Replication)
阅读量:4696 次
发布时间:2019-06-09

本文共 6620 字,大约阅读时间需要 22 分钟。

半同步复制

默认配置下,MYSQL主从库通过binlog来保持一致,主库事务提交后,将binlog日志写入磁盘,然后返回给用户,备库通过拉取主库的binlog来同步主库的操作,无法保证主备节点数据实时一致,只能保证最终一致,因此属于异步复制。

为保证在主备切换时,主备节点数据完全一致,MYSQL提供了半同步复制,其实现原理为:事务在主库上执行完成,生成BINLOG并推送给备库,等待备库的影响消息,备库将接受到的binlog(file,pos)信息返回给主库,主库接收到背库的确认消息后,在返回给用户,事务提交完成。

半同步复制只保证主库和备库的binlog同步,但主库无需等待备库应用这些binglog就会返回提交结果,从库异步地应用这些binlog,因此主库和从库的数据不是实时同步的,因此称为“半同步”。

半同步复制参数rpl_semi_sync_master_timeout用于控制主库等待备库响应的消息时间(单位ms),如果超过该阀值,则认为备库存在问题,将半同步复制修改为异步复制,避免主库的执行事务长时间等待。参数rpl_semi_sync_master_timeout的默认值为50ms。

rpl_semi_sync_master_enabled:表示主上是否开启半同步复制功能,可以动态修改。可选值:ON\OFF
rpl_semi_sync_slave_enabled:表示从上是否开启半同步复制功能,可以动态修改。可选值:ON\OFF

半同步复制要求执行的每一个事务,都至少有一个备库成功接收后,才返回给用户,在主库实例上,有一个专门的线程(ack_receiver)接收备库的响应消息,并以通知机制告知备库已经接收日志。在半同步复制模式下,默认Master发送事务默认至少需要一个Slave的响应才能继续下一个事务,在MySQL5.7版本中引入参数rpl_semi_sync_master_wait_for_slave_count来设置需要应答的Slave的数量,默认值为1。在一主多从的架构下,可以增大rpl_semi_sync_master_wait_for_slave_count的值来保证多个从库均包含最新事务,但增加rpl_semi_sync_master_wait_for_slave_count的值会增加主库等待接受从库响应的时间。

 

半同步复制通信模式

MySQL 5.5和MySQL5.6的半同步复制使单工通信方式,master发送事务的Binlog后,需要接收和处理Slave的应答后才会继续发送下一个事务:

而MySQL 5.7的半同步复制创建单独的应答接收线程,形成双工模式,发送和接收互不影响,因此提示发送效率,降低半同步的延迟。

PS: MySQL5.7单独的应答接收线程在开启半同步复制的时候默认创建,无需额外设置。

 

AFTER_COMMIT与AFTER_SYNC

在MySQL 5.5中引入半同步复制,默认使用AFTER_COMMIT方式,因为主库上事务在提交后才发送给从库,因此存在主库宕机导致事务丢失的情况。

AFTER_COMMIT操作顺序:

AFTER_COMMIT:1>将事务写入binlog和备库2>将binlog刷新到磁盘3>提交事务,等待备库返回确认信息4>接收到备库确认信息5>返回结果给客户端

 

 

在MySQL 5.7版本对半同步复制做了改进,增加了AFTER_SYNC方式,并默认使用AFTER_SYNC方式。

AFTER_SYNC操作顺序:

1>将事务写入binlog和备库2>将binlog刷新到磁盘3>等待备库返回确认信息4>接收到备库确认信息,提交事务5>返回结果给客户端

 

 

 

AFTER_COMMIT和AFTER_SYNC对比

 

两者区别在于:AFTER_COMMIT:在接收到备库确认信息前将事务提交AFTER_SYNC:在接收到备库确认信息后将事务提交造成影响:对于AFTER_SYNC,所有客户端可以在同一时间看到事务被提交;对于AFTER_COMMIT,由于事务提交后还需要等待备库的确认信息,在提交事务的客户端等待的这段时间内,其他客户端已经可以看到事务提交,并能访问到被提交的数据。主库发生宕机时:对于AFTER_SYNC,所有在主库上提交的事务都已复制到备库,因此备库数据是实时的,主备切换不丢失数据。对于AFTER_COMMIT,不能保证所有主库上提交的事务都已复制到备库,存在数据丢失风险。假设主库执行事务A操作新增一条数据并提交,事务A产生的BINLOG传递给从库并等待从库返回ACK,此时主库宕机并主从自动故障切换:场景1:从库未收到事务A的BINLOG,主从切换后新主库上事务A的数据丢失1、在AFTER_COMMIT模式下,主从切换前由于"事务已提交"应用其他线程读取到事务A新增记录,主从切换后对新增记录进行更新,更新失败业务异常。2、在AFTER_SYNC模式下,主从切换前由于"事务未提交"应用其他线程无法读取到事务A新增记录,主从切换前后不存在”幻读“情况。场景2:从库收到事务A的BINLOG,主从切换后新主库含有事务A的新增数据1、在AFTER_COMMIT模式下,执行事务A的操作未收到事务提交成功消息,判断插入操作失败重试,操作自动切换后的新主库,导致数据重复业务异常。2、在AFTER_SYNC模式下,执行事务A的操作未收到事务提交成功消息,判断插入操作失败重试,操作自动切换后的新主库,导致数据重复业务异常。

 

 

 

启用半同步复制

## 查看MYSQL服务器是否支持动态插件SELECT @@have_dynamic_loading;+------------------------+| @@have_dynamic_loading |+------------------------+| YES                    |+------------------------+##在主库上安装PLUGIN,执行:INSTALL PLUGIN rpl_semi_sync_master SONAME 'semisync_master.so';##在从库上安装PLUGIN,执行:INSTALL PLUGIN rpl_semi_sync_slave SONAME 'semisync_slave.so';##在主库上启用半同步复制,并设置等待时长为1000ms,执行:SET GLOBAL rpl_semi_sync_master_enabled = 1;SET GLOBAL rpl_semi_sync_master_timeout = 1000;##在从库上启用版同步复制,执行:SET GLOBAL rpl_semi_sync_slave_enabled = 1;##在从库上重启IO_THREAD,执行:STOP SLAVE IO_THREAD; START SLAVE IO_THREAD;

 

半同步复制相关参数

##============================================================##查看半同步复制的状态和参数:SHOW VARIABLES LIKE 'rpl_semi_sync%';+-------------------------------------------+------------+| Variable_name                             | Value      |+-------------------------------------------+------------+| rpl_semi_sync_master_enabled              | ON         || rpl_semi_sync_master_timeout              | 1000       || rpl_semi_sync_master_trace_level          | 32         || rpl_semi_sync_master_wait_for_slave_count | 1          || rpl_semi_sync_master_wait_no_slave        | ON         || rpl_semi_sync_master_wait_point           | AFTER_SYNC |+-------------------------------------------+------------+##============================================================##查看半同步复制的状态SHOW STATUS LIKE 'rpl_semi_sync%';+--------------------------------------------+-------+| Variable_name                              | Value |+--------------------------------------------+-------+| Rpl_semi_sync_master_clients               | 1     || Rpl_semi_sync_master_net_avg_wait_time     | 0     || Rpl_semi_sync_master_net_wait_time         | 0     || Rpl_semi_sync_master_net_waits             | 1     || Rpl_semi_sync_master_no_times              | 0     || Rpl_semi_sync_master_no_tx                 | 0     || Rpl_semi_sync_master_status                | ON    || Rpl_semi_sync_master_timefunc_failures     | 0     || Rpl_semi_sync_master_tx_avg_wait_time      | 1336  || Rpl_semi_sync_master_tx_wait_time          | 1336  || Rpl_semi_sync_master_tx_waits              | 1     || Rpl_semi_sync_master_wait_pos_backtraverse | 0     || Rpl_semi_sync_master_wait_sessions         | 0     || Rpl_semi_sync_master_yes_tx                | 1     |+--------------------------------------------+-------+Rpl_semi_sync_master_clients:当前有多少个从库被设置为半同步模式。Rpl_semi_sync_master_net_avg_wait_time:等待从库返回去确认消息的平均时间(单位:ms)Rpl_semi_sync_master_net_wait_time:等到从库返回确认消息的总时间(单位:ms)Rpl_semi_sync_master_net_waits:等待从库返回确认消息的总次数Rpl_semi_sync_master_no_tx:事务没有得到从库返回确认消息就提交的次数,The number of commits that were not acknowledged successfully by a slave.Rpl_semi_sync_master_timefunc_failures:调用函数gettimeofday()失败的次数,The number of times the master failed when calling time functions such as gettimeofday(). Rpl_semi_sync_master_tx_avg_wait_time:主库上平均每个事务等待时长,The average time in microseconds the master waited for each transaction. Rpl_semi_sync_master_tx_wait_time:主库上事务等待的总时长,The total time in microseconds the master waited for transactions. Rpl_semi_sync_master_tx_waits:主库上事务等待的次数,The total number of times the master waited for transactions. Rpl_semi_sync_master_wait_pos_backtraverse:改变当前等待最小二进制日志的次数,The total number of times the master waited for an event with binary coordinates lower than events waited for previously. This can occur when the order in which transactions start waiting for a reply is different from the order in which their binary log events are written.  Rpl_semi_sync_master_wait_sessions:当前等待从库返回确认消息的回话数,The number of sessions currently waiting for slave replies. Rpl_semi_sync_master_yes_tx:得到从库返回消息的事务数,The number of commits that were acknowledged successfully by a slave. 当半同步复制开启后,Rpl_semi_sync_master_status 变量用动态地显示半同步复制的状态。Rpl_semi_sync_master_status设置为OFF,表明当前处于异步复制下,当等待从库返回确认消息时间超过rpl_semi_sync_master_timeout值后修改为OFF.;Rpl_semi_sync_master_status设置为ON,表明当前处于半同步复制下。当从库追赶上主库后修改为ON,If a timeout occurs without any slave having acknowledged the transaction, the master reverts to asynchronous replication. When at least one semisynchronous slave catches up, the master returns to semisynchronous replication.

 

参考链接:

https://www.jianshu.com/p/3bfb0bfb8b34

http://www.cnblogs.com/zhoujinyi/p/5704567.html

 

转载于:https://www.cnblogs.com/gaogao67/p/11152935.html

你可能感兴趣的文章
php生成器使用总结
查看>>
T-SQL中的indexof函数
查看>>
javascript基础之数组(Array)对象
查看>>
mysql DML DDL DCL
查看>>
RAMPS1.4 3d打印控制板接线与测试1
查看>>
python with语句中的变量有作用域吗?
查看>>
24@Servlet_day03
查看>>
初级ant的学习
查看>>
memcached 细究(三)
查看>>
RSA System.Security.Cryptography.CryptographicException
查看>>
webservice整合spring cxf
查看>>
[解题报告] 100 - The 3n + 1 problem
查看>>
Entity Framework 学习高级篇1—改善EF代码的方法(上)
查看>>
Mybatis逆向工程配置文件详细介绍(转)
查看>>
String类的深入学习与理解
查看>>
不把DB放进容器的理由
查看>>
OnePage收集
查看>>
Java parseInt()方法
查看>>
yahoo的30条优化规则
查看>>
[CCF2015.09]题解
查看>>