自拍偷在线精品自拍偷,亚洲欧美中文日韩v在线观看不卡

MySQL源碼學(xué)習(xí)之Connection Manager詳解

作者：心中無碼
數(shù)據(jù)庫 MySQL
本文我們主要介紹了MySQL源碼學(xué)習(xí)之Connection Manager，它包括：連接的線程數(shù)、初始化網(wǎng)絡(luò)設(shè)置、連接的方式、Socket管理創(chuàng)新線程以及新線程處理流程的知識，希望能夠?qū)δ兴鶐椭?/div>

MySQL數(shù)據(jù)庫Connection Manager的相關(guān)知識是本文我們主要要介紹到內(nèi)容，接下來就讓我們一起來了解一下吧。

1.連接的線程數(shù)

MySQL支持單線程和多線程兩種連接線程數(shù)。如果是單線程，則在同一時刻，只能有一個connection連接到MySQL,其他的連接會被掛起。如果是多線程，則同一時刻可以支持多個connection同時連接到服務(wù)器?？梢酝ㄟ^設(shè)置服務(wù)器的啟動參數(shù)來設(shè)定連接的線程數(shù)：

  1. mysqld.exe --thread-handling=no-threads  
  2. mysqld.exe --thread-handling=one-thread-per-connection 

 

服務(wù)器如何通過參數(shù)來選擇使用哪種方式的呢？且看服務(wù)器中的分支代碼：

  1. #ifdef EMBEDDED_LIBRARY  
  2. one_thread_scheduler(&thread_scheduler);  
  3. #else  
  4. if (global_system_variables.thread_handling <=  
  5. SCHEDULER_ONE_THREAD_PER_CONNECTION)  
  6. one_thread_per_connection_scheduler(&thread_scheduler);  
  7. else if (global_system_variables.thread_handling == SCHEDULER_NO_THREADS)  
  8. one_thread_scheduler(&thread_scheduler);  
  9. else  
  10. pool_of_threads_scheduler(&thread_scheduler); /* purecov: tested */  
  11. #endif 

 

這段代碼出現(xiàn)在get_options函數(shù)中，此函數(shù)是根據(jù)傳入的服務(wù)器參數(shù)，設(shè)置相應(yīng)參數(shù)的模式。由這段代碼可以看出，如果定義了EMBEDDED_LIBRARY宏定義(估計應(yīng)該是嵌入式使用)，則調(diào)用one_thread_scheduler，即使用單線程。如果參數(shù)小于等于SCHEDULER_ONE_THREAD_PER_CONNECTION，則調(diào)用one_thread_per_connection_scheduler，即每個連接一個線程，即多線程。

至于global_system_variables.thread_handling是如何進行設(shè)置的呢？其實就是根據(jù)我們傳遞給服務(wù)器的參數(shù)--thread-handling進行設(shè)置的，參數(shù)的設(shè)置統(tǒng)一在函數(shù)get_options中，其調(diào)用mysqld_get_one_option，其中有個分支，代碼如下：

 

  1. case OPT_THREAD_HANDLING:  
  2. {  
  3. global_system_variables.thread_handling=  
  4. find_type_or_exit(argument, &thread_handling_typelib, opt->name)-1;  
  5. break;  
  6. } 

 

對參數(shù)初始化有興趣的可以具體的看下get_options這個函數(shù)，這里就不詳細講解了。 我們來看下one_thread_scheduler和one_thread_per_connection_scheduler的源代碼，看下他們都做了些什么？

 

  1. void one_thread_scheduler(scheduler_functions* func)  
  2. {  
  3. func->max_threads= 1;  
  4. #ifndef EMBEDDED_LIBRARY  
  5. func->add_connection= handle_connection_in_main_thread;  
  6. #endif  
  7. func->init_new_connection_thread= init_dummy;  
  8. func->end_thread= no_threads_end;  
  9. }  
  10.  
  11. void one_thread_per_connection_scheduler(scheduler_functions* func)  
  12. {  
  13. func->max_threads= max_connections;  
  14. func->add_connection= create_thread_to_handle_connection;  
  15. func->end_thread= one_thread_per_connection_end;  
  16. }  

 

原來就是設(shè)置了一個結(jié)構(gòu)體中scheduler_functions的參數(shù)，只不過這些參數(shù)是一些函數(shù)指針罷了，也就是說在具體的調(diào)用中，

只需要調(diào)用add_connection或end_thread即可，不需要知道到底是調(diào)用了哪個函數(shù)，這大概就是一種變形的多態(tài)性吧。

2.初始化網(wǎng)絡(luò)配置

網(wǎng)絡(luò)配置比較簡單，就是設(shè)置端口，創(chuàng)建套接字，綁定端口，監(jiān)聽端口。實現(xiàn)全部集中在network_init函數(shù)中，由于這個函數(shù)確

實沒什么好講的，如果對socket不熟悉的話，可以去網(wǎng)上搜索下相關(guān)知識。這里直接給出相應(yīng)的偽代碼：

 

  1. network_init  
  2. {  
  3. set_ports; //設(shè)置端口號，#define MYSQL_PORT 3306  
  4. socket； //創(chuàng)建套接字  
  5. bind; //綁定端口號  
  6. listen； //監(jiān)聽端口號  
  7. } 

 

3.連接的方式

進程間通信的方式不止是SOCKET，還有其他很多方式。Mysql支持三種連接方式：namepipe、socket和shared memory，即命名管道、套接字和共享內(nèi)存的方式。這三種方式是可以共存的。默認只使用套接字。

TCP/IP套接字方式是MySQL在任何平臺下都提供的連接方式，也是網(wǎng)絡(luò)中使用得最多的一種方式。這種方式在TCP/IP連接上建立一個基于網(wǎng)絡(luò)的連接請求，一般情況下客戶端在一臺服務(wù)器上，而MySQL實例在另一臺服務(wù)器上，這兩臺機器通過一個TCP/IP網(wǎng)絡(luò)連接。

例如，我可以在Windows服務(wù)器下請求一臺遠程Linux服務(wù)器下的MySQL實例。在Windows 2000、Windows XP、Windows 2003和Windows Vista以及在此之后的 Windows操作系統(tǒng)中，如果兩個需要通信的進程在同一臺服務(wù)器上，那么可以使用命名管道，SQL Server數(shù)據(jù)庫默認安裝后的本地連接也使用命名管道。在MySQL數(shù)據(jù)庫中，需在配置文件中啟用--enable-named-pipe選項。

在MySQL 4.1之后的版本中，MySQL還提供了共享內(nèi)存的連接方式，在配置文件中添加--shared-memory。如果想使用共享內(nèi)存的方式，在連接時，Mysql客戶端還必須使用-protocol=memory選項。啟動時可以通過下面的參數(shù)進行設(shè)置。

 

  1. mysqld.exe --enable-named-pipe  
  2. mysqld.exe --shared-memory 

 

除了在啟動時進行參數(shù)設(shè)置外，也可以通過修改MY.INI文件進行設(shè)置。我們來看下源碼中選擇連接方式的分支函數(shù)handle_connections_methods：

 

  1. handle_connections_methods()  
  2. {  
  3. if (hPipe != INVALID_HANDLE_VALUE)  
  4. {  
  5. handler_count++;  
  6. if (pthread_create(&hThread,&connection_attrib,  
  7. handle_connections_namedpipes, 0))  
  8. {  
  9. sql_print_warning("Can't create thread to handle named pipes");  
  10. handler_count--;  
  11. }  
  12. }  
  13. if (have_tcpip && !opt_disable_networking)  
  14. {  
  15. handler_count++;  
  16. if (pthread_create(&hThread,&connection_attrib,  
  17. handle_connections_sockets, 0))  
  18. {  
  19. sql_print_warning("Can't create thread to handle TCP/IP");  
  20. handler_count--;  
  21. }  
  22. }  
  23.  
  24. if (opt_enable_shared_memory)  
  25. {  
  26. handler_count++;  
  27. if (pthread_create(&hThread,&connection_attrib,  
  28. handle_connections_shared_memory, 0))  
  29. {  
  30. sql_print_warning("Can't create thread to handle shared memory");  
  31. handler_count--;  
  32. }  
  33. }  
  34. } 

 

由于對于namepipe和memory share的通信方式不太了解，這里只研究socket的通信方式。從代碼中可以看出，handle_connections_sockets便是socket的設(shè)置，我們就來看下它。

4.socket管理創(chuàng)建新線程

socket管理其實比較簡單，直接給出其偽代碼：

 

  1. handle_connections_sockets  
  2. {  
  3. select; //監(jiān)視socket文件描述符  
  4. new_socket = accept;//處理到來的客戶端連接  
  5. thd = new THD；創(chuàng)建THD類  
  6. vio_tmp = vio_new(new_socket,VIO_TYPE_TCPIP, 0); //初始化VIO結(jié)構(gòu)體  
  7. my_net_init(&thd->net, vio_tmp);//初始化thd的net結(jié)構(gòu)體  
  8. create_new_thread(thd);//為這個連接創(chuàng)建一個新的線程，如果是單線程模式的話，就不會創(chuàng)建一個新線程  
  9. } 

 

首先是select函數(shù)進行監(jiān)視socket端口，如果監(jiān)控到有連接，則通過accept函數(shù)接受客戶端的連接，然后新建一個THD類，將連接參數(shù)全部設(shè)置到THD類的參數(shù)上，最后調(diào)用create_new_thread函數(shù)，這個函數(shù)便是重點。 我們進入這個函數(shù)，看下做了啥。

 

  1. create_new_thread  
  2. {  
  3. ++connection_count;//全局連接數(shù)自增  
  4. thread_count++; //全局線程數(shù)自增  
  5. thread_scheduler.add_connection(thd);//真正創(chuàng)建線程  
  6. } 

 

So easy,首先將全局連接數(shù)+1，全局線程數(shù)+1，然后調(diào)用add_connection函數(shù)，這個函數(shù)就是我們在上面第一步設(shè)置連接的

線程數(shù)中，one_thread_scheduler和one_thread_per_connection_scheduler中設(shè)置的一個參數(shù)。這兩者的區(qū)別便是是否創(chuàng)建了

一個新的線程來處理到來的連接。one_thread_scheduler是單線程方式，木有新建線程。我們重點研究one_thread_per_connection_scheduler，其設(shè)置的add_connection函數(shù)為create_thread_to_handle_connection：

 

  1. create_thread_to_handle_connection(THD *thd)  
  2. {  
  3. thread_created++;  
  4. threads.append(thd); // 創(chuàng)建線程數(shù)自增，并加入到threads鏈表上  
  5. pthread_create(&thd->real_id,&connection_attrib,  
  6. handle_one_connection,  
  7. (void*) thd);//這就是真正創(chuàng)建線程的地方了，函數(shù)便是handle_one_connection  
  8. } 

 

可見，最后調(diào)用了pthread_create函數(shù)，這個函數(shù)便是創(chuàng)建一個新的線程，新線程的處理函數(shù)為handle_one_connection.

5.新線程處理流程

新線程處理函數(shù)為handle_one_connection，到此位置，一個新的connection被一個新創(chuàng)建的線程所單獨處理。我們看下其中

是如何進行處理的。

 

  1. handle_one_connection(void *arg)  
  2. {  
  3. for (;;)  
  4. {  
  5. lex_start(thd); //初始化詞法分析結(jié)構(gòu)體  
  6. login_connection(thd); //用戶認證，失敗報錯  
  7. prepare_new_connection_state(THD* thd)；//Initialize THD to handle queries  
  8. while (!net->error && net->vio != 0 && //循環(huán)處理command  
  9. !(thd->killed == THD::KILL_CONNECTION))  
  10. {  
  11. if (do_command(thd))  
  12. break; //處理失敗跳出  
  13. }  
  14. end_connection(thd); //關(guān)閉連接  
  15. close_connection(thd, 0, 1);  
  16. thread_scheduler.end_thread(thd,1);//結(jié)束線程  
  17. return 0;  
  18. }  
  19. } 

 

首先進行了詞法分析結(jié)構(gòu)體的初始化，然后進行用戶認證，認證成功后通過do_command循環(huán)執(zhí)行客戶端發(fā)過來的命令。

6.總結(jié)

整個connection manager的流程十分清晰，單線程的連接一般很少使用，大多使用多線程方式。多線程連接中其實還涉及到線程緩沖池的概念，即如果一個連接斷開后，其所創(chuàng)建的線程不會被銷毀掉，而是放到緩沖池中，等待下一個新的connection到來時，首先去線程緩沖池查找是否有空閑的線程，有的話直接使用，木有的話才去創(chuàng)建新的線程來管理這個connection。

關(guān)于MySQL數(shù)據(jù)庫Connection Manager的相關(guān)知識就介紹到這里了，希望本次的介紹能夠?qū)δ兴斋@！

【編輯推薦】

  1. MySQL數(shù)據(jù)庫my.cnf配置文件注釋詳解
  2. SQL Server數(shù)據(jù)庫復(fù)制失敗的原因及解決方案
  3. SQL Server 2005數(shù)據(jù)庫游標調(diào)用函數(shù)實例解析
  4. MySQL數(shù)據(jù)庫中EXPLAIN的使用及其注意事項詳解
  5. SQL Server數(shù)據(jù)庫用視圖來處理復(fù)雜的數(shù)據(jù)查詢關(guān)系
責(zé)任編輯：趙鵬 來源： 博客園
MySQLConnection Manager
相關(guān)推薦

2022-10-09 08:53:06

存儲容量SSD

2011-06-23 13:10:39

Python 對象機制

2011-04-22 14:14:21

MySQL偷窺線程

2009-07-08 13:22:30

JDK源碼分析Set

2023-03-15 16:16:07

鴻蒙Server端

2021-09-02 07:00:01

Glide流程Android

2023-02-08 15:32:56

新模塊操作系統(tǒng)

2017-06-07 14:58:39

Redis源碼學(xué)習(xí)Redis事務(wù)

2011-08-25 15:41:42

Lua源碼

2021-09-12 07:30:10

配置

2011-06-23 14:05:32

Qt 事件機制

2022-03-29 08:31:18

RabbitMQMQ客戶端

2021-09-07 06:40:25

AndroidLiveData原理

2017-04-07 14:30:26

2016-09-20 10:26:25

LaravelPHPMiddleware

2023-03-07 10:43:52

AndroidFramework測試

2023-07-10 08:43:53

SpringIDEA

2016-09-20 10:15:49

LaravelPHPContainer

2019-02-12 15:04:09

2021-08-10 20:41:33

AndroidApp流程
點贊
收藏

51CTO技術(shù)棧公眾號