ProxySQL源码分析2-Main流程

Main流程图

ProxySQL源码分析2-Main流程

  • 初始化全局变量,proxysql的main库里面的global_variables里面可查看变量
  • daemon_fork,这里fork两次(感兴趣可找资料看下),创建守护进程,proxysql宕机可自动拉起。
  • 阶段2-not_started--初始化Main模块,主要就是new来各种全局对象,包括GloQC(query cache)、GloQPro(query processor)、授权、GloMyMon(mysql monitor)、日志、GloMTH(mysql thread handler)、GloMyStmt、MyHGM(host group manager)等
  • MyHGM启动两个线程,一个用来管理连接,一个用来采集服务器的gtid(后面用来判断延迟之列的,选择从库的时候使用)
  • 阶段2-not_started--初始化Admin模块,主要用来初始化admin、stats、cluster对象,admin最重要,管理请求、配置变更等都是这里做的;Stats是核心的统计库,统计的内容在后面的库表分析中会说明;cluser对象主要就是用来管理proxysql集群的,同步配置。
  • 阶段3-start_all,这个阶段的核心工作就是将库表里面的信息加载到全局对象中,比如server信息、user信息、mysql集群信息等。其中初始化MySQL线程处理模块会启动2类线程,这2类线程是处理用户请求,最核心,后面会分析。初始化MySQL监控模块会启动monitor监控线程,这块只负责处理mysql serve相关的监控,比如:ping、delay、read_only等。
  • 接着main会使用watchdog来监控worker线程、idle线程的heartbeat,这里可能会造成proxysql的重启。
  • 如果给进程发送shutdown指令,就到阶段4了。

源码

Main函数

int main_test(int argc, const char *argv[])
{
    // 初始化全局变量GloVar
    ProxySQL_Main_process_global_variables(argc, argv);
    // 初始化SSL模块
    ProxySQL_Main_init_SSL_module();
    // daemon_fork进程
    if (GloVars.global.foreground == false)
    {
        ProxySQL_daemonize_phase1((char *)argv[0]);
        /* Do the fork */
        if ((pid = daemon_fork()) < 0)
        { /* Exit on error */
            daemon_retval_done();
            exit(EXIT_FAILURE);
        }
        else if (pid)
        { /* The parent */
            ProxySQL_daemonize_wait_daemon();
        }
        else
        { /* The daemon */
            cpu_timer t;
            GloVars.global.start_time = monotonic_time();
            GloVars.install_signal_handler();
            if (ProxySQL_daemonize_phase2() == false)
            {
                goto finish;
            }
        }
    }
__start_label:
    // 初始化-阶段2-not_started
    ProxySQL_Main_init_phase2___not_started();
    // 初始化-阶段3-start_all
    ProxySQL_Main_init_phase3___start_all();
    // 处理threads_missing_heartbeat
    {
        while (glovars.shutdown == 0)
        {
            if (GloMTH)
            {
                if (GloMTH->mysql_threads)
                {
                    for (i = 0; i < GloMTH->num_threads; i++)
                    {
                        if (GloMTH->mysql_threads[i].worker)
                        {
                            atomic_curtime = GloMTH->mysql_threads[i].worker->atomic_curtime;
                            // 判断进程heartbeat
                            if (curtime > atomic_curtime + poll_timeout)
                            {  
                                threads_missing_heartbeat++;
                            }
                        }
                    }
                }
                if (threads_missing_heartbeat)
                {
                    missed_heartbeats++;
                    if (missed_heartbeats >= (unsigned int)GloVars.restart_on_missing_heartbeats)
                    {
                        // 如果配置进程hangs重启,则重启ProxySQL
                        if (GloVars.restart_on_missing_heartbeats)
                        {
                            proxy_error("Watchdog: reached %u missed heartbeats. Aborting!\n", missed_heartbeats);
                            proxy_error("Watchdog: see details at https://github.com/sysown/proxysql/wiki/Watchdog\n");
                            assert(0);
                        }
                    }
                }
            }
        }
    }
__shutdown:
    // 初始化-阶段4-shutdown
    UnloadPlugins();
    ProxySQL_Main_init_phase4___shutdown();
    return 0;
}

初始化-阶段2-not_started

void ProxySQL_Main_init_phase2___not_started()
{
    LoadPlugins();
    ProxySQL_Main_init_main_modules();
    ProxySQL_Main_init_Admin_module();
    ProxySQL_Main_init_Auth_module();
}

初始化-阶段3-start_all

void ProxySQL_Main_init_phase3___start_all()
{
    GloMyMon = new MySQL_Monitor();
    // load all mysql servers to GloHGH
    {
        GloAdmin->init_mysql_servers();
        GloAdmin->init_proxysql_servers();
        GloAdmin->load_scheduler_to_runtime();
        GloAdmin->proxysql_restapi().load_restapi_to_runtime();
    }
    ProxySQL_Main_init_Query_module();
    ProxySQL_Main_init_MySQL_Threads_Handler_module();
    ProxySQL_Main_init_Query_Cache_module();
    GloMTH->start_listeners();
    ProxySQL_Main_init_MySQL_Monitor_module();
}

ProxySQL源码分析2-Main流程

上一篇:MySQL alter table时执行innobackupex全备再谈Seconds_Behind_Master


下一篇:sql获取多个分组中的一条记录