国产探花免费观看_亚洲丰满少妇自慰呻吟_97日韩有码在线_资源在线日韩欧美_一区二区精品毛片,辰东完美世界有声小说,欢乐颂第一季,yy玄幻小说排行榜完本

首頁 > 數據庫 > MySQL > 正文

MySQL服務器連接過程淺析

2024-07-24 13:06:51
字體:
來源:轉載
供稿:網友
這篇文章主要介紹了MySQL服務器連接過程淺析,本文從源碼分析了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()
 

發表評論 共有條評論
用戶名: 密碼:
驗證碼: 匿名發表
主站蜘蛛池模板: 名山县| 邹平县| 莱西市| 红原县| 卢龙县| 唐海县| 河曲县| 聂拉木县| 绥滨县| 盐池县| 皋兰县| 东光县| 富蕴县| 大化| 神池县| 乐安县| 肥西县| 拜泉县| 蚌埠市| 娱乐| 陇川县| 佛山市| 襄城县| 台北市| 武清区| 大渡口区| 天峨县| 车险| 雅安市| 南郑县| 哈尔滨市| 金川县| 顺昌县| 天全县| 蓝山县| 德昌县| 广宗县| 江山市| 马山县| 柳河县| 大足县|