九.MySQL是怎么保证主备一致和高可用的

2024-04-30 08:38

本文主要是介绍九.MySQL是怎么保证主备一致和高可用的,希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

binlog可以用来归档,也可以用来做主备同步,但它的内容是什么样的呢,为什么备库执行了binlog就可以跟主库保持一致了呢?我们今天来探究下这个问题。

主备的基本原理

在这里插入图片描述

搭建两个节点A和B。开始时节点B是节点A的备库,备库节点B只读。A上的更新通过binlog同步到B,这样就可以保持节点A和节点B的数据是相同的。当需要切换的时候,就切成状态二,此时客户端读写访问的都是节点B,而节点A是B的备库。

主备同步的具体流程是这样的:备库B跟主库A之间维持了一个长连接,主库执行一个事务后,会写binlog,主库写完后会把binlog发到备库,备库B拿到binlog后,写到本地文件,称为中转日志(relay log)。接下来sql_thread读取中转日志,解析出日志里的命令,并执行。

binlog的三种格式

binlog有三种格式,statement,row和mixed。

STATEMENT

binlog_format=statement时,binlog里面记录的就是原文。你可以用show binlog events in 'binlog.xxxx查看binlog的内容。

由于statement格式下,记录到binlog里的是语句原文,可能会出现主库和备库执行同一条语句但结果不一样的情况,造成数据不一致。

mysql> show master status;
+---------------+----------+--------------+------------------+-------------------+
| File          | Position | Binlog_Do_DB | Binlog_Ignore_DB | Executed_Gtid_Set |
+---------------+----------+--------------+------------------+-------------------+
| binlog.000020 |      826 |              |                  |                   |
+---------------+----------+--------------+------------------+-------------------+
1 row in set (0.00 sec)mysql> show binlog events in 'binlog.000020';
+---------------+-----+----------------+-----------+-------------+----------------------------------------------------------------------------+
| Log_name      | Pos | Event_type     | Server_id | End_log_pos | Info                                                                       |
+---------------+-----+----------------+-----------+-------------+----------------------------------------------------------------------------+
| binlog.000020 |   4 | Format_desc    |         1 |         125 | Server ver: 8.0.21, Binlog ver: 4                                          |
| binlog.000020 | 125 | Previous_gtids |         1 |         156 |                                                                            |
| binlog.000020 | 156 | Anonymous_Gtid |         1 |         235 | SET @@SESSION.GTID_NEXT= 'ANONYMOUS'                                       |
| binlog.000020 | 235 | Query          |         1 |         325 | BEGIN                                                                      |
| binlog.000020 | 325 | Query          |         1 |         448 | use `test`; insert into t values(4,4,'2018-11-10')                         |
| binlog.000020 | 448 | Xid            |         1 |         479 | COMMIT /* xid=55 */                                                        |                                                      |
+---------------+-----+----------------+-----------+-------------+----------------------------------------------------------------------------+
10 rows in set (0.00 sec)

ROW

binlog_format=row时,binlog里面记录的是对每行的具体操作以及操作的内容。

mysql> show binlog events in 'binlog.000008';
+---------------+-----+----------------+-----------+-------------+--------------------------------------+
| Log_name      | Pos | Event_type     | Server_id | End_log_pos | Info                                 |
+---------------+-----+----------------+-----------+-------------+--------------------------------------+
| binlog.000008 |   4 | Format_desc    |         1 |         125 | Server ver: 8.0.21, Binlog ver: 4    |
| binlog.000008 | 125 | Previous_gtids |         1 |         156 |                                      |
| binlog.000008 | 156 | Anonymous_Gtid |         1 |         235 | SET @@SESSION.GTID_NEXT= 'ANONYMOUS' |
| binlog.000008 | 235 | Query          |         1 |         318 | BEGIN                                |
| binlog.000008 | 318 | Table_map      |         1 |         368 | table_id: 73 (test.t)                |
| binlog.000008 | 368 | Delete_rows    |         1 |         416 | table_id: 73 flags: STMT_END_F       |
| binlog.000008 | 416 | Xid            |         1 |         447 | COMMIT /* xid=9 */                   |
| binlog.000008 | 447 | Rotate         |         1 |         491 | binlog.000009;pos=4                  |
+---------------+-----+----------------+-----------+-------------+--------------------------------------+
8 rows in set (0.14 sec)

mixed

binlog_format=mixed时,binlog里面的内容既有statement格式,也有row格式。

为什么会有mixed格式的binlog:

  • 因为有些statement格式的binlog会导致主备不一致,所以要使用row格式。
  • 但row格式的缺点时占用空间。比如你用delete删掉10w行记录,用statement格式的话就是一个语句记录到binlog中,占用几十字节的空间;但如果使用row格式的binlog,就要把这10w条记录都写到binlog中。这样不仅会占用更大空间,同时写binlog也要耗费IO资源,影响执行速度。
  • 因此,MySQL就采取了折中的方案,采用mixed格式的binlog。MySQL判断某条语句是否会引起主备不一致,如果可能引起主备不一致,就用row格式,否则就用statement格式。

mixed格式可以利用statement格式的优点,同时避免了数据不一致的风险。

为什么建议把MySQL的binlog设置成ROW格式:

MySQL的binlog设置成ROW格式可以方便恢复数据

我们分别从insert,delete,update这三种角度看看ROW格式的数据恢复问题。

1.如果执行错了insert语句。row格式下insert记录了所有字段信息,把insert换成delete重新执行一遍就可以了。

2.如果执行错了delete语句。row格式下会把delete的行整行信息保存起来,执行错了把delete变成insert重新执行一遍就可以了。

3.如果执行错了update语句。row格式下update会记录修改前的整行数据和修改后的整行数据,也是可以进行恢复。

MySQL如何保证高可用

在主备关系中,只要主库执行更新生成的所有binlog,都可用传到备库并被正确的执行,备库就能达到和主库一致的状态,这就是最终一致性。MySQL要提供高可用,只有最终一致性是不够的,还需要主备延迟足够小。

所谓主备延迟,就是同一个事务,在备库执行完成的时间T3和主库执行完成的时间T1之间的差值,也就是T3-T1。你可以在备库上执行show slave status命令,它的返回结果seconds_behind_master,用于表示当前备库延迟了多少秒。

主备延迟的来源

1. 有些部署条件下,备库所在机器的性能要比主库所在的机器性能差。

一般情况下,人们这么部署的想法是,反正备库没有请求,可用用差一点儿的机器。其实我们都知道,更新请求对IOPS的压力,在主库和备库上是无差别的。因为备库机器的性能差,跟不上主库的执行速度,导致主备延迟。部署是应该选择对称部署。

2. 备库的压力大

一般情况下,主库提供了写能力,备库可以提供一些读能力。或者一些分析的脚本,在主库上跑影响业务,这些脚本只能在备库上跑。结果就是,备库上的查询耗费了大量的CPU资源,影响了同步速度,造成主备延迟。

3. 大事务。

因为主库必须等事务全部执行完才能写入binlog,再传给备库。假如一个主库上的语句执行10min,那这个事务很可能导致从库延迟10min。一次性的用delete语句删除太多数据,这就是一个典型的大事务场景。

4. 备库的并行复制能力。

备库用单线程执行relay log,而主库的TPS一直比较高的话,备库的执行binlog的速度一直赶不上主库生成binlog的速度,就会造成主备延迟。

可靠性优先策略

在双M结构下,主备切换的流程是这样的。

1.判断备库现在的seconds_behind_master,如果小于某个值(比如5s)继续进行下一步,否则持续重试这一步。

2.把主库A改成只读状态,即把readonly设置为true。

3.判断备库的seconds_behind_master,直到这个值变为0为止,此时把备库B改成可读写状态,也就是把readonly改成false。

4.最后把业务请求切换到备库B。
在这里插入图片描述

可用性优先策略

如果强行把上面的第4,5步调整到最开始执行,不等主备数据同步,直接把业务请求切换到备库B,并且让备库开始读写,那么系统几乎就没有不可用时间了。可用性切换流程,可能出现数据不一致的情况。在实际应用中,建议使用可靠性优先的策略。毕竟保证数据准确,是数据库服务的底线。在这个基础上,通过减少主备延迟,提升系统的可用性。

在满足数据可靠性的前提下,MySQL高可用系统的可用性,是依赖于主备延迟的。延迟的时间越小,在主库故障的时候,服务恢复需要的时间就越短,可用性就越高。

这篇关于九.MySQL是怎么保证主备一致和高可用的的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/948396

相关文章

[职场] 护理专业简历怎么写 #经验分享#微信

护理专业简历怎么写   很多想成为一名护理方面的从业者,但是又不知道应该怎么制作一份简历,现在这里分享了一份护理方面的简历模板供大家参考。   蓝山山   年龄:24   号码:12345678910   地址:上海市 邮箱:jianli@jianli.com   教育背景   时间:2011-09到2015-06   学校:蓝山大学   专业:护理学   学历:本科

Java面试八股之怎么通过Java程序判断JVM是32位还是64位

怎么通过Java程序判断JVM是32位还是64位 可以通过Java程序内部检查系统属性来判断当前运行的JVM是32位还是64位。以下是一个简单的方法: public class JvmBitCheck {public static void main(String[] args) {String arch = System.getProperty("os.arch");String dataM

电脑不小心删除的文件怎么恢复?4个必备恢复方法!

“刚刚在对电脑里的某些垃圾文件进行清理时,我一不小心误删了比较重要的数据。这些误删的数据还有机会恢复吗?希望大家帮帮我,非常感谢!” 在这个数字化飞速发展的时代,电脑早已成为我们日常生活和工作中不可或缺的一部分。然而,就像生活中的小插曲一样,有时我们可能会在不经意间犯下一些小错误,比如不小心删除了重要的文件。 当那份文件消失在眼前,仿佛被时间吞噬,我们不禁会心生焦虑。但别担心,就像每个问题

mysql索引四(组合索引)

单列索引,即一个索引只包含单个列,一个表可以有多个单列索引,但这不是组合索引;组合索引,即一个索引包含多个列。 因为有事,下面内容全部转自:https://www.cnblogs.com/farmer-cabbage/p/5793589.html 为了形象地对比单列索引和组合索引,为表添加多个字段:    CREATE TABLE mytable( ID INT NOT NULL, use

mysql索引三(全文索引)

前面分别介绍了mysql索引一(普通索引)、mysql索引二(唯一索引)。 本文学习mysql全文索引。 全文索引(也称全文检索)是目前搜索引擎使用的一种关键技术。它能够利用【分词技术】等多种算法智能分析出文本文字中关键词的频率和重要性,然后按照一定的算法规则智能地筛选出我们想要的搜索结果。 在MySql中,创建全文索引相对比较简单。例如:我们有一个文章表(article),其中有主键ID(

mysql索引二(唯一索引)

前文中介绍了MySQL中普通索引用法,和没有索引的区别。mysql索引一(普通索引) 下面学习一下唯一索引。 创建唯一索引的目的不是为了提高访问速度,而只是为了避免数据出现重复。唯一索引可以有多个但索引列的值必须唯一,索引列的值允许有空值。如果能确定某个数据列将只包含彼此各不相同的值,在为这个数据列创建索引的时候就应该使用关键字UNIQUE,把它定义为一个唯一索引。 添加数据库唯一索引的几种

mysql索引一(普通索引)

mysql的索引分为两大类,聚簇索引、非聚簇索引。聚簇索引是按照数据存放的物理位置为顺序的,而非聚簇索引则不同。聚簇索引能够提高多行检索的速度、非聚簇索引则对单行检索的速度很快。         在这两大类的索引类型下,还可以降索引分为4个小类型:         1,普通索引:最基本的索引,没有任何限制,是我们经常使用到的索引。         2,唯一索引:与普通索引

【服务器运维】MySQL数据存储至数据盘

查看磁盘及分区 [root@MySQL tmp]# fdisk -lDisk /dev/sda: 21.5 GB, 21474836480 bytes255 heads, 63 sectors/track, 2610 cylindersUnits = cylinders of 16065 * 512 = 8225280 bytesSector size (logical/physical)

Eureka高可用注册中心registered-replicas没有分布式注册中心

自己在学习过程中发现,如果Eureka挂掉了,其他的Client就跑不起来了,那既然是商业项目,还是要处理好这个问题,所以决定用《Spring Cloud微服务实战》(PDF版在全栈技术交流群中自行获取)中说的“高可用注册中心”。 一开始我yml的配置是这样的 server:port: 8761eureka:instance:hostname: 127.0.0.1client:fetch-r

ABAP怎么把传入的参数刷新到内表里面呢?

1.在执行相关的功能操作之前,优先执行这一段代码,把输入的数据更新入内表里面 DATA: lo_guid TYPE REF TO cl_gui_alv_grid.CALL FUNCTION 'GET_GLOBALS_FROM_SLVC_FULLSCR'IMPORTINGe_grid = lo_guid.CALL METHOD lo_guid->check_changed_data.CALL M