歡迎光臨
每天分享高質量文章

MySQL服務器連接過程分析

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


一切都是從熟悉的main()函式開始的,其實是從mysqld_main()函式開始的。這些代碼都在mysqld.cc。mysqld_main()隨後呼叫了win_main)()。win_main()函式主要是做了一些初始化的工作。


初始化工作完成之後,MySQL已經做好準備接受連接了。然後我們的主角Handle_connections_methods()函式登場了。這個函式的主要工作是新建3個子行程,他們分別接受TCP/IP、命名管道以及共享記憶體這三種方式的連接。一般情況下客戶都是用TCP/IP(socket)來連接MySQL服務器的,這是最有彈性的通信方式。但是在嵌入式軟體的應用環境中,需要採用後兩種通信方式。

  • 簡化後的handle_connections_methods()函式:

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()函式進入一個長時間迴圈,直到3個連接執行緒全部退出後才退出。這裡我主要看看socket的連接執行緒,我們的研究物件就是這個handle_connections_sockets_thread。這個執行緒把自己初始化之後,就直接呼叫了handle_connections_sockets();


handle_connections_sockets()函式使用select()呼叫監聽mysqld的端口,然後等待客戶端的連接。等到一個客戶端連接後,這個函式中會新建一個THD型別的變數,這個變數是一個“交際花”,從連接建立開始,到SQL語法分析、查詢執行、結果傳回等等。這個變數一直都在,總之這是一個非常重要的變數。


還有struct st_vio這個結構體,這個結構體是一個命令的中轉站。在“交際花”THD中也定義了一個vio型別的結構體。這個結構體的功能就是從儲存從套接字中讀取通信內容,然後又把自己的值賦給THD的vio變數。VIO型別中詳細的描述了一次請求,包括請求的內容、時間、請求的套接字地址等等。之後發生的事情就是把這個“交際花”傳遞到服務執行緒,create_thread_to_handle_connection()實現這個功能。

  • 以下是刪減後的代碼

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)));
}
}


這個函式會查看有沒有閑置的快取執行緒(MySQL不會把斷開連接後的服務執行緒立即銷毀掉,而是快取了起來),如果有就是用快取執行緒,如果沒有就新建一個執行緒來服務連接。至此,一個連接就進入了服務執行緒,連接執行緒傳回繼續等待連接。


後邊的內容就都是在服務執行緒中實現的,《深入理解MySQL》中有很詳細的代碼跟蹤,感興趣的同學可以看看。我把函式呼叫順序附上,供參考。


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


作者:cqu20093154

鏈接:http://blog.csdn.net/cqu20093154/article/details/44277791

赞(0)

分享創造快樂