MySQL服務(wù)器連接過程分析

mysqld是MySQL服務(wù)器端主進(jìn)程，可以說mysqld是MySQL的真正核心，一切工作都是圍繞mysqld進(jìn)程進(jìn)行的。所以要解剖mysql這個龐然大物，mysqld的代碼是最好的突破口。

一切都是從熟悉的main()函數(shù)開始的，其實(shí)是從mysqld_main()函數(shù)開始的。這些代碼都在mysqld.cc。mysqld_main()隨后調(diào)用了win_main)()。win_main()函數(shù)主要是做了一些初始化的工作。

初始化工作完成之后，MySQL已經(jīng)做好準(zhǔn)備接受連接了。然后我們的主角Handle_connections_methods()函數(shù)登場了。這個函數(shù)的主要工作是新建3個子進(jìn)程，他們分別接受TCP/IP、命名管道以及共享內(nèi)存這三種方式的連接。一般情況下客戶都是用TCP/IP（socket）來連接MySQL服務(wù)器的，這是最有彈性的通信方式。但是在嵌入式軟件的應(yīng)用環(huán)境中，需要采用后兩種通信方式。

• 簡化后的handle_connections_methods()函數(shù)：

static?void?handle_connections_methods()  {  ??mysql_mutex_lock(&LOCK_thread_count);  ??mysql_cond_init(key_COND_handler_count,?&COND_handler_count,?NULL);  ??handler_count=0;  ??handler_count++;  ??mysql_thread_create(key_thread_handle_con_namedpipes,?&hThread,?&connection_attrib,?handle_connections_namedpipes,?0))；  ??handler_count++;  ??mysql_thread_create(key_thread_handle_con_sockets,?&hThread,?&connection_attrib,?handle_connections_sockets_thread,?0))；  ??handler_count++;  ??mysql_thread_create(key_thread_handle_con_sharedmem,?&hThread,?&connection_attrib,?handle_connections_shared_memory,?0))  ??while?(handler_count?>?0)  ????mysql_cond_wait(&COND_handler_count,?&LOCK_thread_count);  ??mysql_mutex_unlock(&LOCK_thread_count);  }

新建了3個線程之后，handle_connectins_methods()函數(shù)進(jìn)入一個長時間循環(huán)，直到3個連接線程全部退出后才退出。這里我主要看看socket的連接線程，我們的研究對象就是這個handle_connections_sockets_thread。這個線程把自己初始化之后，就直接調(diào)用了handle_connections_sockets();

handle_connections_sockets()函數(shù)使用select()調(diào)用監(jiān)聽mysqld的端口，然后等待客戶端的連接。等到一個客戶端連接后，這個函數(shù)中會新建一個THD類型的變量，這個變量是一個“交際花”，從連接建立開始，到SQL語法分析、查詢執(zhí)行、結(jié)果返回等等。這個變量一直都在，總之這是一個非常重要的變量。

還有struct st_vio這個結(jié)構(gòu)體，這個結(jié)構(gòu)體是一個命令的中轉(zhuǎn)站。在“交際花”THD中也定義了一個vio類型的結(jié)構(gòu)體。這個結(jié)構(gòu)體的功能就是從儲存從套接字中讀取通信內(nèi)容，然后又把自己的值賦給THD的vio變量。VIO類型中詳細(xì)的描述了一次請求，包括請求的內(nèi)容、時間、請求的套接字地址等等。之后發(fā)生的事情就是把這個“交際花”傳遞到服務(wù)線程，create_thread_to_handle_connection()實(shí)現(xiàn)這個功能。

• 以下是刪減后的代碼

void?create_thread_to_handle_connection(THD?*thd)  {  ??if?(cached_thread_count?>?wake_thread)  ??{  ????mysql_cond_signal(&COND_thread_cache);  ??}  ??else  ??{  ????mysql_thread_create(key_thread_one_connection,?&thd->real_id,?&connection_attrib,?handle_one_connection,?(void*)?thd)))；????  ??}  }

這個函數(shù)會查看有沒有閑置的緩存線程(MySQL不會把斷開連接后的服務(wù)線程立即銷毀掉，而是緩存了起來),如果有就是用緩存線程，如果沒有就新建一個線程來服務(wù)連接。至此，一個連接就進(jìn)入了服務(wù)線程，連接線程返回繼續(xù)等待連接。

后邊的內(nèi)容就都是在服務(wù)線程中實(shí)現(xiàn)的，《深入理解MySQL》中有很詳細(xì)的代碼跟蹤，感興趣的同學(xué)可以看看。我把函數(shù)調(diào)用順序附上，供參考。

handle_one_connection()  mysql_thread_create()  handle_one_connection()  do_handle_one_connection()  init_new_connection_thread()  init_new_connection_handler_thread()  do_command()  dispatch_command()  mysql_parse()  mysql_execuate_command()

以上就是MySQL服務(wù)器連接過程分析的內(nèi)容，更多相關(guān)內(nèi)容請關(guān)注PHP中文網(wǎng)（www.php.cn）！