快捷導(dǎo)航

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

更新時間：2015年03月18日 09:52:58 投稿：junjie

這篇文章主要介紹了MySQL服務(wù)器連接過程淺析,本文從源碼分析了MySQL服務(wù)器的連接過程,需要的朋友可以參考下

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

一切都是從熟悉的main()函數(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ù)：

復(fù)制代碼代碼如下:

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()實現(xiàn)這個功能。

以下是刪減后的代碼

復(fù)制代碼代碼如下:

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ù)線程中實現(xiàn)的，《深入理解MySQL》中有很詳細(xì)的代碼跟蹤，感興趣的同學(xué)可以看看。我把函數(shù)調(diào)用順序附上，供參考。

復(fù)制代碼代碼如下:

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

您可能感興趣的文章: