扩展MySQL高可用性：实现从库连接日志记录

# 扩展 MySQL 高可用性：实现从库连接日志记录 ## 1. 引言 在 MySQL 复制拓扑中，监控和记录从库与主库的连接时间对于故障诊断和性能优化至关重要。本文将详细介绍如何创建一个新的日志事件，用于记录从库连接到主库的时间，并将其写入二进制日志。 ## 2. 复制命令示例 首先，我们来看一个简单的示例，展示如何创建一个唯一的复制命令，用于停止复制事件的流动。以下是一个查询从库状态的示例： ```sql mysql> SHOW SLAVE STATUS \G *************************** 1. row *************************** Slave_IO_State: Master_Host: localhost Master_User: rpl Master_Port: 3310 Connect_Retry: 60 Master_Log_File: mysql-bin.000001 Read_Master_Log_Pos: 408 Relay_Log_File: clone-relay-bin.000002 Relay_Log_Pos: 366 Relay_Master_Log_File: mysql-bin.000001 Slave_IO_Running: No Slave_SQL_Running: Yes ... 1 row in set (0.00 sec) ``` 这个示例展示了如何创建一个可在主库上执行并发送到所有从库的复制命令，以停止复制事件的流动。这种扩展很容易添加，也体现了二进制日志事件的强大功能。 ## 3. 从库连接日志记录的重要性 在大型复制拓扑中，从库可能会频繁上线和下线，管理员很难手动记录每个从库的连接和断开时间。记录从库连接事件可以帮助管理员更好地诊断和修复复制问题，因为知道从库连接的时间可以将该事件的时间与其他同时发生的事件进行映射，从而判断这些事件是否相关。 ## 4. 新日志事件的设计思路 我们将创建一个新的日志事件 `SLAVE_CONNECT_LOG_EVENT`，用于记录从库连接到主库的时间。这个事件将被写入二进制日志，但会被从库忽略，不会写入从库的中继日志和二进制日志。 ## 5. 需要修改的源文件 为了实现这个新的日志事件，我们需要修改多个复制源文件，这些文件都位于 `/sql` 文件夹中。具体文件及修改内容如下表所示： | 文件 | 修改内容概述 | | --- | --- | | log_event.h | 新的 `Slave_connect_log_event` 类声明 | | log_event.cc | 新的 `Slave_connect_log_event` 类定义 | | binlog.h | 新的 `MYSQL_BIN_LOG::write_slave_connect()` 方法声明 | | binlog.cc | 新的 `MYSQL_BIN_LOG::write_slave_connect()` 定义 | | rpl_master.cc | 修改 `register_slave()` 以调用 `write_slave_connect()` | | rpl_rli.h | 添加对 `Slave_connect_log_event` 类的引用 | | rpl_rli.cc | 添加代码删除 `Slave_connect_log_event` 类实例 | | rpl_rli_pdb.cc | 添加代码删除 `Slave_connect_log_event` 类实例 | | rpl_slave.cc | 添加代码删除 `Slave_connect_log_event` 类实例 | | sql_binlog.cc | 添加代码删除 `Slave_connect_log_event` 类实例 | ## 6. 代码修改步骤 ### 6.1 修改 log_event.h 文件 首先，在 `log_event.h` 文件中，我们需要添加一个新的枚举值 `SLAVE_CONNECT_LOG_EVENT` 到 `enum Log_event_type` 列表的末尾，在 `ENUM_END_EVENT` 标记之前。以下是修改后的代码： ```cpp enum Log_event_type { /* Every time you update this enum (when you add a type), you have to fix Format_description_log_event::Format_description_log_event(). */ UNKNOWN_EVENT= 0, START_EVENT_V3= 1, QUERY_EVENT= 2, STOP_EVENT= 3, ROTATE_EVENT= 4, INTVAR_EVENT= 5, LOAD_EVENT= 6, ... /* BEGIN CAB MODIFICATION */ /* Reason for Modification: */ /* Add new log event enumeration */ SLAVE_CONNECT_LOG_EVENT= 36, /* END CAB MODIFICATION */ ENUM_END_EVENT /* end marker */ }; ``` 此外，我们还需要在 `log_event.h` 文件中添加一个新的类声明 `Slave_connect_log_event`，该类继承自 `Log_event` 基类。以下是完整的类声明： ```cpp /* BEGIN CAB MODIFICATION */ /* Reason for Modification: */ /* Add new log event class declaration */ class Slave_connect_log_event : public Log_event { public: #ifndef MYSQL_CLIENT Slave_connect_log_event(THD *thd_arg, const char * query, ulong query_len) : Log_event(thd_arg, LOG_EVENT_IGNORABLE_F, Log_event::EVENT_STMT_CACHE, Log_event::EVENT_IMMEDIATE_LOGGING) { DBUG_ENTER("Slave_connect_log_event::Slave_connect_log_event"); if (!(m_slave_connect= (char*) my_malloc(query_len + 1, MYF(MY_WME)))) return; my_snprintf(m_slave_connect, query_len + 1, "%s", query); DBUG_PRINT("enter", ("%s", m_slave_connect)); DBUG_VOID_RETURN; } #endif #ifndef MYSQL_CLIENT int pack_info(Protocol*); #endif Slave_connect_log_event(const char *buf, uint event_len, const Format_description_log_event *descr_event); virtual ~Slave_connect_log_event(); bool is_valid() const { return 1; } #ifdef MYSQL_CLIENT virtual void print(FILE *file, PRINT_EVENT_INFO *print_event_info); #endif virtual bool write_data_body(IO_CACHE *file); virtual Log_event_type get_type_code() { return SLAVE_CONNECT_LOG_EVENT; } virtual int get_data_size() { return IGNORABLE_HEADER_LEN + 1 + (uint) strlen(m_slave_connect); } #if defined(MYSQL_SERVER) && defined(HAVE_REPLICATION) virtual int do_apply_event(Relay_log_info const *rli); #endif private: char *m_slave_connect; }; /* END CAB MODIFICATION */ ``` 需要注意的是，部分代码使用了条件编译标志进行保护，这是因为该代码会被服务器源代码的其他部分共享，有些代码在某些应用场景下是不需要的。另外，`LOG_EVENT_IGNORABLE_F` 标志告诉服务器忽略该事件。 ### 6.2 修改 log_event.cc 文件 在 `log_event.cc` 文件中，我们需要对几个方法进行修改和添加。 #### 6.2.1 修改 Log_event::get_type_str() 方法 添加一个新的 `case` 语句，用于返回新日志事件的名称： ```cpp case INCIDENT_EVENT: return "Incident"; case IGNORABLE_LOG_EVENT: return "Ignorable"; case ROWS_QUERY_LOG_EVENT: return "Rows_query"; /* BEGIN CAB MODIFICATION */ /* Reason for Modification: */ /* Add case to return name of new log event */ case SLAVE_CONNECT_LOG_EVENT: return "Slave_connect"; /* END CAB MODIFICATION */ case WRITE_ROWS_EVENT: return "Write_rows"; case UPDATE_ROWS_EVENT: return "Update_rows"; case DELETE_ROWS_EVENT: return "Delete_rows"; ``` #### 6.2.2 修改 Log_event::read_log_event() 方法 添加一个新的 `case` 语句，用于创建新日志事件的实例： ```cpp case ROWS_QUERY_LOG_EVENT: ev= new Rows_query_log_event(buf, event_len, description_event); break; /* BEGIN CAB MODIFICATION */ /* Reason for Modification: */ /* Add case to create new log event */ case SLAVE_CONNECT_LOG_EVENT: ev= new Slave_connect_log_event(buf, event_len, description_event); break; /* END CAB MODIFICATION */ case GTID_LOG_EVENT: case ANONYMOUS_GTID_LOG_EVENT: ``` #### 6.2.3 修改 Format_description_log_event() 方法 返回新日志事件的头长度： ```cpp post_header_len[HEARTBEAT_LOG_EVENT-1]= 0; post_header_len[IGNORABLE_LOG_EVENT-1]= IGNORABLE_HEADER_LEN; post_header_len[ROWS_QUERY_LOG_EVENT-1]= IGNORABLE_HEADER_LEN; /* BEGIN CAB MODIFICATION */ /* Reason for Modification: */ /* Return header length for the new log event */ post_header_len[SLAVE_CONNECT_LOG_EVENT-1]= IGNORABLE_H ```