IT数码 购物 网址 头条 软件 日历 阅读 图书馆
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
图片批量下载器
↓批量下载图片,美女图库↓
图片自动播放器
↓图片自动播放器↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁
 
   -> 大数据 -> MySQL 事务日志 -> 正文阅读

[大数据]MySQL 事务日志

一、二进制日志(Binlog)

1. Binlog概念

Binlog 是逻辑日记,用于记录数据库执行的写入操作(查询不记录)信息,Server层记录和引擎层无关,并且是以追加方式进行写入,可以通过参数 max_binlog_size设置每个 Binlog 文件的大小,文件大小达到设定值时会生成新的文件来保存日记。

概念解释
逻辑日志 “逻辑日志”可以简单理解为记录的就是sql语句。Binkog和Undo log记录的是逻辑日志
Server“Server”是MySQL基本架构的一层,MySQL基本架构分为Server层和引擎层详细介绍可以参考简单记一条查询SQL语句的执行全过程

2. Binlog作用

在实际应用中,主要用在两个场景:主从复制和数据恢复

  • 主从复制场景:在 Master 主端开启 Binlog,将 Binlog 发生到各个 Slave 从端,Slave 从端重放 Binlog 从而达到主从数据一致
  • 数据恢复场景:通过使用 mysqlbinlog 工具来恢复数据

3. Binlog 记录过程及刷盘时机

Binlog 大致记录过程是先写 Binlog Buffer,然后通过刷盘时机,控制刷入 OS Buffer,控制 fsync() 进行写入 Binlog File 日记磁盘的过程。

概念解释
刷盘时机“刷盘时机”是指啥时候、通过什么策略将内存中的日志写到磁盘中。因为日志每次都是先写入内存的buffer中,然后通过刷盘时机设置的参数控制刷盘时机,最后才刷入磁盘。这个参数设置对于Undo、Redo和Binlog都有一套参数

对于 Binlog,MySQL 是通过参数 sync_binlog 参数来控制刷盘时机,取值是 0、1 和 N 三种值。0 表示由系统自行判断何时调用 sync() 写入磁盘;1 表示每次事务 commit 都要调用 fsync() 写入磁盘;N 表示每 N 个事务,才会调用 fsync() 写入磁盘。
在这里插入图片描述
图2:内存和磁盘日记结构图

4. Binlog 记录格式

MySQL 5.7.7 版本之前默认格式是 STATEMENT,版本之后默认是 ROW,可以通过参数 binlog-format 指定。

二、事务日志(Undo log)

1. Undo log 概念

Undo log是逻辑日记、回滚日记。比如一条修改 +3 的逻辑语句,Undo log 会记录对应一条 -3 的逻辑日记,一条插入语句则会记录一条删除语句,这样发生错误时,根据执行 Undo log 就可以回滚到事务之前的数据状态。

2. Undo log 作用

  • 回滚数据:当程序发生异常错误时等,根据执行 Undo log 就可以回滚到事务之前的数据状态,保证原子性,要么成功要么失败。
  • MVCC 一致性视图:通过 Undo log 找到对应的数据版本号,是保证 MVCC 视图的一致性的必要条件。

3. Undo log 记录过程及刷盘时机

刷盘过程及时机类似于 Binlog 和 Redo,可以参考 Redo log 刷盘时机章节给出的图片,已经体现出来了。

4. Undo log 总结

Undo log 日记内容不是很多,重点是回滚多版本控制 MVCC那块。此外,我记得印象笔记深刻的是长事务会导致日记过多,这个日记就是 Undo log。因为长事务存在,导致需要保存很多视图快照,其实这里就是涉及到Undo log 何时删除和生成的问题,当时纠结好久,其实很简单。生成是事务开始后写 Redo log 之前生成,当没有事务需要用到 Undo log 时就会被删除。举个例子,如果事务 A 一直存活,那么事务 A 之后产生的事务 B、C…等等就算提交了,也不会被删除,因为事务 A 需要用到 B、C… 事务去找 A 的版本。所以避免长事务可以减少Undo log 日记量,当然还可以提高性能。

三、事务日记 (Redo log)

1. Redo log 概念

Redo log 是重做日记,属于InnoDB引擎的日记。是物理日记,日记记录的内容的是数据页的更改,这个页 “做了什么改动”。如:add xx记录 to Page1,向数据页Page1增加一个记录。

概念解释
数据页MySQL是按照数据页为最小单位进行存储的,b+树的特性,一页默认16k,数据属于页,页包含数据当操作一条数据的时候,实际上就是在操作一个数据页,多条数据可能是在一个数据页也可能是在多个数据页,看数据具体分布。

2. Redo log 作用

  • 前滚操作:具备 crash-safe能力,提供断电重启时解决事务丢失数据问题。
  • 提高性能:先写Redo log记录更新。当等到有空闲线程、内存不足、Redo log满了时刷脏。写 Redo log 是顺序写入,刷脏是随机写,节省的是随机写磁盘的 IO 消耗(转成顺序写),所以性能得到提升。此技术称为WAL技术:Write-Ahead Logging,它的关键点就是先写日记磁盘,再写数据磁盘。

3. Redo log 容灾恢复过程

MySQL的处理过程如下

  • 判断 redo log 是否完整,如果判断是完整(commit)的,直接用 Redo log 恢复
  • 如果 redo log 只是预提交 prepare 但不是 commit 状态,这个时候就会去判断 binlog 是否完整,如果完整就提交 Redo log,用 Redo log 恢复,不完整就回滚事务,丢弃数据。

只有在 redo log 状态为 prepare 时,才会去检查 binlog 是否存在,否则只校验 redo log 是否是 commit 就可以啦。怎么检查 binlog:一个完整事务 binlog 结尾有固定的格式。

4. Redo log 刷盘时机

Undo log 的刷盘时机和 Redo log 差不多,但是对于 Undo log 我没找到对应的刷盘参数设计,所以不在提。Redo log 每次先写入 Redo Log Buffer 中,然后通过刷盘时机控制刷入 OS Buffer 时间和刷入日记磁盘的时间。
在这里插入图片描述
图3:内存和磁盘日记结构图

在 Undo Log 中,MySQL 是通过参数innodb_flush_log_at_trx_commit来控制刷盘时机,取值是 0、1 和 2三种值。0 表示事务提交后,每秒写入 OS Buffer 并调用 fsync() 写入日记磁盘中;1 表示每次事务提交会写入OS Buffer 并调用 fsync() 将日记写入日记磁盘中。2 表示事务每次提交写入到 OS Buffer,每秒调用 fsync() 写入日记磁盘。可见参数为 1 是最安全的,同时也是默认值。
在这里插入图片描述
图4:Redo log刷盘时机参数对应操作图

5. Redo log 存储方式

在这里插入图片描述
图5:Redo log File 环形存储结构图

上图是日记磁盘的 Redo log 环形设计图(从头写,写到结束又从头开始写~循环)。write pos 和 check point 是两个指针,write pos指针指向当前日记文件写入的位置,check point 指针指向当前要擦除的开始位置。图中绿色部分是可以写入 Redo log 地方,每次写入,write pos 指针会顺时针推进,当然基本不会与 check point 指针重合,因为 MySQL 有这种机制去实现,每次触发检查点checkpoint,check point 会指针向前推进,这个过程就是需要进行刷日记和数据磁盘,记录相应的 LSN,引出难点 LSN。

6. Redo Log 检查点

啥时候会触发检查点 checkpoint

  1. 数据库正常关闭时,即innodb_fast_shutdown=0时需要执行sharp checkpoint
  2. redo log发生切换时或者redo log快满时进行fuzzy checkpoint
  3. master thread每隔1s或者10s定期进行fuzzy checkpoint
  4. innodb保证有足够多的空闲page,如果发现不足,需要移出lru list末尾的page,如果这些page是脏页,那么也需要fuzzy checkpoint
  5. innodb buffer pool中脏页比超过innodb_max_dirty_pages_pct时也会触发fuzzy checkpoint

「Checkpoint 发生的时间、条件及脏页的选择等都非常复杂。而 Checkpoint 所做的事情无外乎是将缓冲池中的脏页刷回到磁盘,不同之处在于每次刷新多少页到磁盘,每次从哪里取脏页,以及什么时间触发 Checkpoint。这些本文不会去研究」

7. Redo Log LSN

LSN 这个概念,比较复杂。LSN 称为日志的逻辑序列号(log sequence number),在 innodb 存储引擎中,lsn占用 8 个字节。LSN 的值会随着日志的写入而逐渐增大。「可以简单理解SLN就是记录从开始到现在已经产生了多少字节的Redo log值」

存储方式两个指针又是通过 LSN 计算得到指向位置,因为 LSN 记录的是文件的大小字节,当超过文件大小时,需要用取模计算出这两个指针位置,取模使得写入就会从头开始写,这样使得两个指针在一个文件中,一直落在循环位置,你追我赶的过程。这就是 Redo log 环形逻辑思想设计实现。

上面提到LSN比较复杂,是因为它有很多个值,输入命令 show engine innodb status; ,可以看到四个的 lsn 记录

概念解释
Log sequence number当前的redo log(in buffer)中的LSN,系统最大最新的LSN值我们叫他
Log flushed up tp已经刷到日志磁盘中的LSN我们叫他redo log file lsn
Pages flushed up已经刷到数据磁盘数据页上的LSN,每个数据页头部都会记录一个LSN,我们叫他:data disk lsn。内存中的LSN我们叫他data buffer lsn
Last checkpoint at日志磁盘上一次检查点记录的LSN,只有数据刷完才会记录。即小于此值的LSN的数据页一定已经刷入数据磁盘,大于的可能已经刷入,可能未刷入。我们叫他:checkpoint lsn

为了方便识别,我都为它们重新命名,如下所示。名词记不住,后面无法继续深入

  • 内存日记:redo log buffer lsn;磁盘日记:redo log file lsn;

一般关系为:redo log buffer lsn >= redo log file lsn,如果刷盘时机为1,则redo log buffer lsn = redo log file lsn。

  • 内存数据页:data buffer lsn;数据磁盘数据页:data disk lsn;

一般关系为data buffer lsn > data disk lsn,如果已经刷入数据磁盘,则data buffer lsn = data disk lsn。

  • 检查点:chckpoint lsn;

后面提到检查点刷盘,数据刷盘和日记刷盘(如果有日记刷盘:则说明我假设的日记刷盘的时机设置值不为1,为1 是同步的,即始终 redo log buffer lsn = redo log file lsn,不会由检查点触发刷日记磁盘)。

都说 Redo log 是环形记录,那么怎么记录的?下面结合 LSN 给出记录过程虚构图,可以对比 Redo log 存储方式图

1-8 按时间顺序发生。1 点是假设最初的状态;2、3 点写日记磁盘;4 点是触发了检查点 checkpoint,进行刷盘,「checkpoint lsn=1开始」,刷盘结束并更新「checkpoint lsn=512」。在 5 点、6 点已经刷过了一循环内存、二循环内存,「从头开始写入 log,两个指针指向回到了头部」。第 7 点也是一个触发 checkpoint 的过程。9 点是假设没有更新,最后达到平衡的结果,即内存中数据页和日记都完成了刷盘。
在这里插入图片描述
图8:Redo Log File存储过程

整个流程:

在某些情况下,触发 checkpoint,触发数据页和日志页刷盘,此时将内存中的脏数据— 数据脏页日志脏数据分别刷到数据磁盘和日记磁盘中,而且两者刷盘速度不一样。checkpoint 会保护机制,当数据刷盘速度超过日志刷盘时,将会暂时停止数据刷盘,等待日志刷盘进度超过数据刷盘。

刷盘时,对于数据磁盘,全部都是在内存中,此时每次刷一个数据页到内存更新数据页也更新了「data disk lsn」「data buffer lsn」(在更新内存数据页时,会更新data buffer lsn)。

对于日记磁盘,除了要记录 checkpoint lsn 的值为检查点 checkpoint的值(必须在结束时直接记录一个值,速度很快),这里是针对日记刷盘时机不是1(1是同步缓存刷日记刷盘)时,并且日记还没刷到日记磁盘需要触发将缓存中日记提前刷到日记磁盘中,此时会将redo buffer log 刷到 redo log file 中也更新了redo log file lsnredo log buffer lsn

模拟检查点触发前后,整个流程变化,一个数据页和日记,「数据变化及lsn从179-180的变化图(刷盘时机不为1)」
在这里插入图片描述

8. Redo log 容灾恢复过程与 LSN

Redo log 容灾恢复过程和 LSN 的知识,再次细化 Redo log 恢复过程

重启 innodb 时,Redo log 完不完整,采用 Redo log 相关知识。用 Redo log 恢复,启动数据库时,InnoDB 会扫描数据磁盘的数据页 data disk lsn 和日志磁盘中的 checkpoint lsn。两者相等则从 checkpoint lsn 点开始恢复,恢复过程是利用 redo log 到 buffer pool,直到 checkpoint lsn 等于 redo log file lsn,则恢复完成。

如果 checkpoint lsn 小于 data disk lsn,说明在检查点触发后还没结束刷盘时数据库宕机了。因为 checkpoint lsn 最新值是在数据刷盘结束后才记录的,检查点之后有一部分数据已经刷入数据磁盘,这个时候数据磁盘已经写入部分的部分恢复将不会重做,直接跳到没有恢复的 lsn 值开始恢复。

四、ChangeBuffer

1. 为啥提到 ChangeBuffer

为啥本文我会提到 ChangeBuffer 呢,其实很多时候会将 ChangeBuffer 和 Redo log 搞混,两者都是巧用内存,减少磁盘 IO,为了不弄混我觉得有必要专门对这个进行一个讲解。

2. ChangeBuffer 概念及作用

下面是我对 ChangeBuffer 的简单介绍

概念解释
ChangeBuffer"ChangeBuffer"是Buffer Pool分割出去的一块内存,记录更新操作,当更新没有用到唯一索引并且内存没有对应数据页,就不用从数据磁盘读入到内存,而是直接记录在ChangeBuffer中。

也就是说对于更新的操作,如果用到了 ChangeBuffer,更新的数据所在的数据页如果不在内存中,将不用去数据磁盘将数据页读到内存,而是将这一次操作记录在 ChangeBuffer 中,「ChangeBuffer 主要节省的则是随机读磁盘的 IO 消耗」,下次读取查询等读取数据页时用上 ChangeBuffer 中的记录即可。其实也是一种巧用内存的思想。

3. ChangeBuffer 与 Redo log 区别

Redo log 主要节省的是随机写磁盘的 IO 消耗(转成顺序写),而 ChangeBuffer 主要节省的则是随机读磁盘的 IO 消耗

这句话怎么理解,看下面:

Redo log 与 ChangeBuffer (含磁盘持久化) 这 2 个机制,不同之处在于优化了整个变更流程的不同阶段。

先不考虑 Redo log、ChangeBuffer 机制,简化抽象一个更新 (insert、update、delete) 流程:

  • 从磁盘读取待变更的行所在的数据页,读入内存页中

  • 对内存页中的行,执行变更操作

  • 将变更后的数据页,写入至数据磁盘中

其中,流程中的步骤 1 涉及随机读磁盘 IO;步骤 3 涉及随机写磁盘 IO;刚好对应 ChangeBuffer 和 Redo log。

对那句话的理解答案:

  • ChangeBuffer 机制,优化了步骤 1——避免了随机读磁盘 IO ,将不在内存中的数据页的操作写入ChangeBuffer 中,而不是将数据页从磁盘读入内存页中
  • Redo log 机制, 优化了步骤 3——避免了随机写磁盘 IO,将随机写磁盘,优化为了顺序写磁盘(写 Redo log,确保 crash-safe)

4. 有没有用到 ChangeBuffer 对于 Redo log 的区别

Redo log 机制,为了保证 crash-safe,一直都会用到。有无用到 ChangeBuffer 机制,对于 redo log 这步的区别在于—— 用到了 ChangeBuffer 机制时,在 Redo log 中记录的本次变更,是记录 new change buffer item 相关的信息,而不是直接的记录物理页的变更。在我们 mysql innodb 中, ChangeBuffer 机制不是一直会被应用到,仅当待操作的数据页当前不在内存中,需要先读磁盘加载数据页时,ChangeBuffer 才有用武之地。

5. ChangeBuffer的 merge 过程

概念解释
merge"merge"是指将ChangeBuffer应用到内存中的,得到最新的内存页,并将数据页的改动记录到Redo中的一个过程

除了访问这个数据页会触发 merge 外,系统有后台线程会定期 merge。在数据库正常关闭(shutdown)的过程中,也会执行 merge 操作。

merge 过程做三步

  • 从磁盘读入数据页到内存(老版本的数据页);

  • 从 change buffer 里找出这个数据页的 change buffer 记录 (可能有多个),依次应用,得到新版数据页;

  • 写 redo log。这个 redo log 包含了数据的变更和 change buffer 的变更。

五、日记大连贯U-R-B,一举攻破拿下

前面分别讲的是 Binlog、Undo log 和 Redo log,下面将他们都串联起来,在一些流程体现全部日记。

同样,以一些最经典的更新语句例子展开说明。

1. 制造演示数据

测试语句:插入语句+查询语句,a字段是普通索引

insert into ta(a,b) values(2,5),(7, 5)
select * from t where a in (2, 7)

假设原来的数据如下图,数据页 page1 在内存中,page2 不在。插入的数据 (2,5) 落在 page1,数据 (7,5) 落在page2 中。
在这里插入图片描述

2. 假设没有日记和 ChangeBuffer 示范

先不考虑所有日记及 ChangeBuffer 机制,简化抽象一个更新 insert 流程

  • 从磁盘读取待变更的行所在的数据页,读入内存页中

  • 对内存页中的行,执行变更操作

  • 将变更后的数据页,写入至数据磁盘中
    在这里插入图片描述

3. 考虑所有日记和 ChangeBuffer 示范–现有 Innodb 流程

过程是 两阶段提交-----日记刷盘------数据刷盘(涉及 Redo log lsn 和 ChangeBuffer 的内容)

3.1 两阶段提交过程

  • 数据 (2,5) 所在页 page 1 在内存中直接更新内存;数据 (7,5) 所在页 page 2 不在内存中,记录 change buffer(具有唯一性的索引或者没有使用 change buffer 的操作是将磁盘中的数据页读入内存中并做更新)。

  • 写 undo 日记。「先写缓存,后面根据刷盘参数决定何时刷入磁盘,后面的 redo/Binlog 都一样」。日记刷盘 在每一个日记中基本已经提到,它和设置的参数有关,下文不会再展开介绍。

  • 写 redo 日记(先记在内存中的更新,然后记不在内存中的 change buffer 的改变)

  • 日记状态改成 prepare 阶段。

  • 写 Binlog日记。

  • 提交事务,日记状态改成 commit 阶段。
    在这里插入图片描述

3.2 merge 过程

紧接着上文,图片可上下参考,假设现在执行查询语句 select * from t where a in (2, 7) ,此次查询索引 a=7 所在的数据页不在内存中,并且上一步更新已经在 change buffer 中有记录,将会触发 merge 过程

  • 将 page 2 读入内存

  • 依次应用 change buffer 中的记录,得到最新版数据页

  • 写入 redo,之前记录的 changebuffer 改动,现在改成数据页的改动

至于 changebuffer 被应用后是删除还是标记,还有 redo 中原有的记录 changebuffer 的改动怎么调整是删除还是修改成数据页的改动这里下面的图是按照自己的想法描述出来,如有误望留言指正。
在这里插入图片描述

3.3 数据刷盘过程

数据刷盘 flush 的有四种情况

  • InnoDB 的 redo log 写满了。这时候系统会停止所有更新操作,把 checkpoint 往前推进,redo log 留出空间可以继续写

  • 系统内存不足。当需要新的内存页,而内存不够用的时候,就要淘汰一些数据页,空出内存给别的数据页使用。如果淘汰的是脏页,就要先将脏页写到磁盘

  • MySQL 认为系统空闲的时候

  • MySQL 正常关闭的情况

数据刷盘也代表着 Redo log 检查点 checkpoint 触发,较为复杂。

假设数据刷盘 flush 的四种情况发生了一种,那么联系上文的过程将如下

  • 将脏页从内存中刷回到数据磁盘

  • 刷完后更新检查点 checkpoint 的值

在这里插入图片描述
流程中间某个环节数据库宕机后,恢复具体过程,这些留在心里了,没往上去写,读者可以自行思考,不难。

参考链接

  • https://mp.weixin.qq.com/s?__biz=MzkwMDE1MzkwNQ==&mid=2247495785&idx=1&sn=99903f50be4ca647ccb1bb6262e66619&source=41#wechat_redirect
  大数据 最新文章
实现Kafka至少消费一次
亚马逊云科技:还在苦于ETL?Zero ETL的时代
初探MapReduce
【SpringBoot框架篇】32.基于注解+redis实现
Elasticsearch:如何减少 Elasticsearch 集
Go redis操作
Redis面试题
专题五 Redis高并发场景
基于GBase8s和Calcite的多数据源查询
Redis——底层数据结构原理
上一篇文章      下一篇文章      查看所有文章
加:2022-04-27 11:23:07  更:2022-04-27 11:26:30 
 
开发: C++知识库 Java知识库 JavaScript Python PHP知识库 人工智能 区块链 大数据 移动开发 嵌入式 开发工具 数据结构与算法 开发测试 游戏开发 网络协议 系统运维
教程: HTML教程 CSS教程 JavaScript教程 Go语言教程 JQuery教程 VUE教程 VUE3教程 Bootstrap教程 SQL数据库教程 C语言教程 C++教程 Java教程 Python教程 Python3教程 C#教程
数码: 电脑 笔记本 显卡 显示器 固态硬盘 硬盘 耳机 手机 iphone vivo oppo 小米 华为 单反 装机 图拉丁

360图书馆 购物 三丰科技 阅读网 日历 万年历 2024年11日历 -2024/11/24 3:17:40-

图片自动播放器
↓图片自动播放器↓
TxT小说阅读器
↓语音阅读,小说下载,古典文学↓
一键清除垃圾
↓轻轻一点,清除系统垃圾↓
图片批量下载器
↓批量下载图片,美女图库↓
  网站联系: qq:121756557 email:121756557@qq.com  IT数码