mysql源码分析-启动过程

mysql源码分析-启动过程

概要

# sql/mysqld.cc, 不包含psi的初始化过程
mysqld_main:
    // 加载my.cnf和my.cnf.d，还有命令行参数
    if (load_defaults(MYSQL_CONFIG_NAME, load_default_groups, &argc, &argv))
        return 1;
    init_sql_statement_names();
    sys_var_init();
    init_error_log_mutext();
    mysql_audit_initialize();

    logger.init_base();

    // 读取和设置配置文件和命令行参数，并根据相关参数进行相应的初始化操作，这个函数相当庞大
    if (init_common_variables())
        unireg_abort(1);
    
    init_signals();
    
    if (init_server_components())
        unireg_abort(1);

    init_ssl();
    // 网络初始化，获取监听地址，监听unix_socket，开始监听
    network_init();
    
    if (mysql_rm_tmp_tables() || 
        acl_init(opt_noacl) ||
        my_tz_init((THD *)0, default_tz_name, opt_bootstrap))
    { ... }

    if (!opt_noacl)
        grant_init();
    if (!opt_bootstrap)    
        servers_init(0);
    
    init_status_vars();

    start_handle_manager();

    sql_print_information(...);

    handle_connections_sockets();

    mysql_mutex_lock(&LOCK_thread_count);
    while (!ready_to_exit) 
        mysql_cond_wait(&COND_thread_count, &LOCK_thread_count)
    mysql_mutex_unlock(&LOCK_thread_count)

init_common_variables:
    // 设置数据库默认的存储引擎
#if defined(WITH_INNOBASE_STORAGE_ENGINE) || defined(WITH_XTRADB_STORAGE_ENGINE)
      default_storage_engine= const_cast<char *>("InnoDB");
#else
      default_storage_engine= const_cast<char *>("MyISAM");
#endif
    // 添加show status里的一些变量
    if (add_status_vars(status_vars))
    return 1; 
    
    // 解析命令行参数
    // 根据thread_handling设置thread_scheduler（也就是thd->scheduler)， scheduler实现在sql/scheduler.cc和sql/mysqld.cc，目前有两种模型，one-thread-per-connection和no-threads
    if (get_options(&remaining_argc, &remaining_argv))
        return 1;
    //其他，超级庞大

network_init:
    // 

handle_connections_sockets:
    // poll mysqld监听的socket(tcp,unix), 代码省略
    // 新建vio实例，其实就是绑定不同的通信实例（有windows的namedpipe, 平台独立的shmem, 还有支持openssl，其他类型的连接统一处理）
    // 配置一些socket 选项
    if (!(vio_tmp = vio_new(new_sock,
                            sock == unix_sock ? VIO_TYPE_SOCKET : VIO_TYPE_TCPIP,
                            sock == unix_sock ? VIO_LOCALHOST : 0)) ||
        // 绑定THD和vio实例
        my_net_init(&thd->net, vio_tmp))
    {
        // 失败处理，省略
    }
    // 设置一些THD实例的统计信息，如连接数，检查连接数是否超出上线，触发thd->scheduler->add_connection方法 
    // 新建pthread执行handle_one_connection处理请求， 在sql/sql_connect.cc中定义
    create_new_thread(thd)

// sql/sql_connect.cc
handle_one_connetion:
    do_handle_one_connection(thd)

do_handle_one_connection:
    // 统计slow_launch_threads， 代码省略
    for (;;) { // 此处死循环是为了复用thd，下次直接初始化新的connection信息，处理下一个connection
        // 用户认证，初始化请求信息，
        if (thd_prepare_connection(thd)) { // 错误处理，省略}
    
        while (thd_is_connection_alive(thd)) {
            // 通知plugin->release_thd，然后unlock thd->audit_class_plugins中的plugins
            mysql_audit_release(thd);
            if (do_command(thd))
                break;    
        }
    }

// sql/sql_parse.cc, 省略对WITH_WSREP的处理，wsrep thd有很多特别的处理步骤
do_command:
    if (packet_length = mysql_net_read(net)) == packet_error) { // 错误处理，省略}
    
    // 获取请求消息的起始位置
    packet = (char*) net->read_pos;
    // 从请求消息中获取mysql命令， include/mysql_com.h中有定义所有的mysql 支持的命令
    command = (enum enum_server_command) (uchar) packet[0];
    return_value = dispatch_command(command, thd, packet+1, (uint) (packet_length-1));

// sql/sql_parse.cc， 超级庞大
dispatch_command:
    // 根据command来switch不同的分支，执行不同的mysql命令，执行sql语句为COM_QUERY，或者COM_STMT_EXCUTE(预处理sql语句)
    // case COM_QUERY:
    mysql_parse(thd, thd->query(), thd->query_length(), &parser_state);

// sql/sql/parse.cc
mysql_parse:
    # 解析sql语句
    parse_sql(thd, parser_state, NULL);
    # 如果发现分号，就开始执行sql语句
    mysql_execute_command(thd)

mysql_execute_command:
    # 根据解析出来的sql command执行不同的命令，基本上在mysql命令行敲的每个命令都对应一个分支，比如begin(SQLCOM_BEGIN)，select(SQL_SELECT)等

参看

1. https://dev.mysql.com/doc/internals/en/