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

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

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

簡(jiǎ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個(gè)線程之后，handle_connectins_methods()函數(shù)進(jìn)入一個(gè)長(zhǎng)時(shí)間循環(huán)，直到3個(gè)連接線程全部退出后才退出。這里我主要看看socket的連接線程，我們的研究對(duì)象就是這個(gè)handle_connections_sockets_thread。這個(gè)線程把自己初始化之后，就直接調(diào)用了handle_connections_sockets();

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

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

以下是刪減后的代碼

代碼如下:

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)))；

}

}

這個(gè)函數(shù)會(huì)查看有沒(méi)有閑置的緩存線程(MySQL不會(huì)把斷開(kāi)連接后的服務(wù)線程立即銷毀掉，而是緩存了起來(lái)),如果有就是用緩存線程，如果沒(méi)有就新建一個(gè)線程來(lái)服務(wù)連接。至此，一個(gè)連接就進(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()

更多信息請(qǐng)查看IT技術(shù)專欄