MySQL源代码解析：二进制日志崩溃恢复机制深入探讨

前言

本文主要介绍binlog crash recovery 的过程

假设用户使用 InnoDB 引擎&＃xff0c;sync_binlog&＃61;1

使用 MySQL 5.7.20 版本进行分析

crash recovery 过程中&＃xff0c;binlog 需要保证&＃xff1a;

所有已提交事务的binlog已存在
所有未提交事务的binlog不存在

两阶段提交

MySQL 使用两阶段提交解决 binlog 和 InnoDB redo log 的一致性的问题

也就是将普通事务当做内部XA事务处理&＃xff0c;为每个事务分配一个XID&＃xff0c;binlog作为事务的协调者

阶段1&＃xff1a;InnoDB redo log 写盘&＃xff0c;InnoDB 事务进入 prepare 状态
阶段2&＃xff1a;binlog 写盘&＃xff0c;InooDB 事务进入 commit 状态

每个事务binlog的末尾&＃xff0c;会记录一个 XID event&＃xff0c;标志着事务是否提交成功&＃xff0c;也就是说&＃xff0c;recovery 过程中&＃xff0c;binlog 最后一个 XID event 之后的内容都应该被 purge。

InnoDB 日志可能也需要回滚或者提交&＃xff0c;这里就不再展开。

binlog 文件的 crash recovery

mysqld_maininit_server_componentsMYSQL_BIN_LOG::openMYSQL_BIN_LOG::open_binlog

binlog recover 的主要过程在 MYSQL_BIN_LOG::open_binlog 中

int MYSQL_BIN_LOG::open_binlog(const char *opt_name) {/* 确保 index 文件初始化成功 */if (!my_b_inited(&index_file)) {/* There was a failure to open the index file, can&＃39;t open the binlog */cleanup();return 1;}/* 找到 index 中第一个 binlog */if ((error&＃61; find_log_pos(&log_info, NullS, true/*need_lock_index&＃61;true*/))){/* 找到 index 中最后一个 binlog */do{strmake(log_name, log_info.log_file_name, sizeof(log_name)-1); } while (!(error&＃61; find_next_log(&log_info, true/*need_lock_index&＃61;true*/)));/*打开最后一个binlog&＃xff0c;会校验文件头的 magic number "\xfe\x62\x69\x6e"如果 magic number 校验失败&＃xff0c;会直接报错退出&＃xff0c;无法完成recovery如果确定最后一个binlog没有内容&＃xff0c;可以删除binlog 文件再重试*/if ((file&＃61; open_binlog_file(&log, log_name, &errmsg)) <0)/*如果 binlog 没有正常关闭&＃xff0c;mysql server 可能crash过&＃xff0c;我们需要调用 MYSQL_BIN_LOG::recover&＃xff1a;a) 找到最后一个 XIDb) 完成最后一个事务的两阶段提交&＃xff08;InnoDB commit&＃xff09;c) 找到最后一个合法位点因此&＃xff0c;我们需要遍历 binlog 文件&＃xff0c;找到最后一个合法event集合&＃xff0c;并 purge 无效binlog*/if ((ev&＃61; Log_event::read_log_event(&log, 0, &fdle,opt_master_verify_checksum)) &&ev->get_type_code() &＃61;&＃61; binary_log::FORMAT_DESCRIPTION_EVENT &&(ev->common_header->flags & LOG_EVENT_BINLOG_IN_USE_F ||DBUG_EVALUATE_IF("eval_force_bin_log_recovery", true, false))){sql_print_information("Recovering after a crash using %s", opt_name); /* 初始化合法位点 */ valid_pos&＃61; my_b_tell(&log);/* 执行recover 过程 &＃xff0c;并计算出合法位点 */error&＃61; recover(&log, (Format_description_log_event *)ev, &valid_pos);}elseerror&＃61;0;if (valid_pos > 0){if (valid_pos }

recover 函数的逻辑很简单&＃xff1a;遍历最后一个binlog的所有 event&＃xff0c;每次事务结尾&＃xff0c;或者非事务event结尾更新 valid_pos(gtid event不更新)。并在一个 hash 中记录所有xid&＃xff0c;用于引擎层 recover

int MYSQL_BIN_LOG::recover(IO_CACHE *log, Format_description_log_event *fdle,my_off_t *valid_pos) {/* 初始化 XID hash&＃xff0c;用于记录 binlog 中的 xid */if (! fdle->is_valid() || my_hash_init(&xids, &my_charset_bin, TC_LOG_PAGE_SIZE/3, 0,sizeof(my_xid), 0, 0, MYF(0),key_memory_binlog_recover_exec))goto err1;/* 依次读取 binlog event */while ((ev&＃61; Log_event::read_log_event(log, 0, fdle, TRUE))&& ev->is_valid()){if (ev->get_type_code() &＃61;&＃61; binary_log::QUERY_EVENT &&!strcmp(((Query_log_event*)ev)->query, "BEGIN"))/* begin 代表事务开始 */in_transaction&＃61; TRUE;if (ev->get_type_code() &＃61;&＃61; binary_log::QUERY_EVENT &&!strcmp(((Query_log_event*)ev)->query, "COMMIT")){DBUG_ASSERT(in_transaction &＃61;&＃61; TRUE);/* commit 代表事务结束 */in_transaction&＃61; FALSE;}else if (ev->get_type_code() &＃61;&＃61; binary_log::XID_EVENT){DBUG_ASSERT(in_transaction &＃61;&＃61; TRUE);/* xid event 代表事务结束 */in_transaction&＃61; FALSE;Xid_log_event *xev&＃61;(Xid_log_event *)ev;uchar *x&＃61; (uchar *) memdup_root(&mem_root, (uchar*) &xev->xid,sizeof(xev->xid));/* 记录 xid */if (!x || my_hash_insert(&xids, x))goto err2;}/*如果不在事务中&＃xff0c;且不是gtid event&＃xff0c;则更新 valid_pos显然&＃xff0c;如果在事务中&＃xff0c;最后一段 event 不是一个完整事务&＃xff0c;pos并不合法*/if (!log->error && !in_transaction &&!is_gtid_event(ev))*valid_pos&＃61; my_b_tell(log);}/*存储引擎recover所有已经记录 XID 的事务必须在存储引擎中提交未记录 XID 的事务必须回滚*/if (total_ha_2pc > 1 && ha_recover(&xids))goto err2;

binlog index 的 crash recovery

为了保证 binlog index 的 crash safe&＃xff0c;MySQL 引入了一个临时文件 crash_safe_index_file

新的 binlog_file_name 写入 binlog_index_file 流程如下&＃xff1a;

创建临时文件 crash_safe_index_file
拷贝 binlog_index_file 中的内容到 crash_safe_index_file
新的 binlog_file_name 写入 crash_safe_index_file
删除 binlog_index_file
重命名 crash_safe_index_file 到 binlog_index_file

这个流程保证了在任何时候crash&＃xff0c;binlog_index_file 和 crash_safe_index_file 至少有一个可用

这样再recover 时只要判断这两个文件是否可用&＃xff0c;如果 binlog_index_file 可用则无需特殊处理&＃xff0c;如果binlog_index_file 不可用则重命名 crash_safe_index_file 到 binlog_index_file

binlog index 的 recover 过程主要在 bool MYSQL_BIN_LOG::open_index_file 中

显然&＃xff0c;open_indix_file 在 open_binlog 之前

mysqld_maininit_server_componentsMYSQL_BIN_LOG::open_index_file

bool MYSQL_BIN_LOG::open_index_file(const char *index_file_name_arg,const char *log_name, bool need_lock_index) {/* 拼接 index_file_name */fn_format(index_file_name, index_file_name_arg, mysql_data_home,".index", opt); /* 拼接 crash_safe_index_file_name */if (set_crash_safe_index_file_name(index_file_name_arg))/*recover 主要体现在这里检查 index_file_name 和 crash_safe_index_file_name 是否存在如果 index_file_name 不存在 crash_safe_index_file_name 存在&＃xff0c;那么将 crash_safe_index_file_name 重命名为 index_file_name*/if (my_access(index_file_name, F_OK) &&!my_access(crash_safe_index_file_name, F_OK) &&my_rename(crash_safe_index_file_name, index_file_name, MYF(MY_WME))){sql_print_error("MYSQL_BIN_LOG::open_index_file failed to ""move crash_safe_index_file to index file.");error&＃61; true;goto end;}}

新的 binlog_file_name 写入 binlog_index_file 的过程在 MYSQL_BIN_LOG::add_log_to_index

int MYSQL_BIN_LOG::add_log_to_index(uchar* log_name,size_t log_name_len, bool need_lock_index) {/* 创建 crash_safe_index_file */if (open_crash_safe_index_file())/* 拷贝 index_file 内容到 crash_safe_index_file */if (copy_file(&index_file, &crash_safe_index_file, 0))/* 写入 binlog_file_name */if (my_b_write(&crash_safe_index_file, log_name, log_name_len) ||my_b_write(&crash_safe_index_file, (uchar*) "\n", 1) ||flush_io_cache(&crash_safe_index_file) ||mysql_file_sync(crash_safe_index_file.file, MYF(MY_WME)))/*函数内部先 delete binlog_index_file 再 rename crash_safe_index_file如果 delete 到 rename 之间发生 crash&＃xff0c; crash_safe_index_file 会在 recover过程中 rename 成 binlog_index_file*/if (move_crash_safe_index_file_to_index_file(need_lock_index))}