MySQL 複制源碼解析：Slave IO 線程登錄流程與 mysql_real_connect 協議深度剖析

Slave IO 線程建立主庫連接的完整協議交互

基於 MySQL 5.6 源碼，剖析 handle_slave_io → safe_connect → mysql_real_connect 的完整調用鏈與網絡協議細節。

核心調用鏈

handle_slave_io()  // Slave IO 主循環
  → safe_connect()  // 封裝重試邏輯
    → mysql_real_connect()  // C API 核心連接函數
      → vio_socket_connect()  // 底層 Socket 連接
      → cli_safe_read()       // 讀取初始握手包
      → run_plugin_auth()     // 認證插件交互
      → mysql_select_db()     // 選擇默認庫

mysql_real_connect 五階段協議交互

關鍵協議包結構

初始握手包

1  byte       protocol_version (10)
N  string[NUL] server_version
4  uint32     connection_id (thread_id)
8  string     auth_plugin_data_part_1
1  byte       0x00 (filler)
2  uint16     capabilities_low
1  byte       charset
2  uint16     status_flags
2  uint16     capabilities_high
1  byte       auth_plugin_data_len
10 string     reserved (0x00...)
N  string     auth_plugin_data_part_2 ($len = MAX(13, len-8))
N  string[NUL] auth_plugin_name (if CLIENT_PLUGIN_AUTH)

認證響應包

4  uint32     client_capabilities (CLIENT_PROTOCOL_41 always set)
4  uint32     max_packet_size
1  byte       charset
23 string     reserved (0x00...)
N  string[NUL] username
N  lenenc-str auth_response (scramble 加密後的密碼)
N  string[NUL] database (if CLIENT_CONNECT_WITH_DB)
N  string[NUL] auth_plugin_name (if CLIENT_PLUGIN_AUTH)
N  lenenc-str key-value pairs (if CLIENT_CONNECT_ATTRS)

認證結果包

1  byte       0x00 (OK) / 0xFF (ERR) / 0xFE (EOF/AuthSwitch)
...          根據類型解析 affected_rows, insert_id, status_flags, warnings, info

源碼關鍵路徑

• sql-common/client.c：mysql_real_connect 主流程
• sql-common/client_plugin.c：認證插件框架 run_plugin_auth
• sql/auth/auth_common.cc：native_password_auth_client 實現
• vio/vio.c：VIO 抽象層，Socket/SSL/命名管道統一接口
• sql/slave.cc：handle_slave_io、safe_connect、register_slave_on_master

Slave IO 特有邏輯

1. 連接成功後發送 COM_REGISTER_SLAVE 註冊從庫信息（server_id、hostname、user、password、port）
2. 發送 COM_BINLOG_DUMP 請求 binlog（位置、文件名、server_id、flags）
3. 進入循環讀取 binlog 事件，寫入 relay log

掌握協議細節，可實現自定義代理、連接池、異構同步工具，或排查「連得上卻查不了」的詭異問題。