本文對于初學網路編程的極為友好，文中所有代碼全部基于C語言實作，文中見解僅限于作者對于完成埠的初步認識，由于作者才疏學淺，出現的錯誤和紕漏，麻煩您一定要指出來，咱們共同進步，謝謝！！！
完成埠(completion Port)
前言：
網路通信分為兩種：同步和異步，
在同步通信中，每一次接受資料都會導致主執行緒的掛起，從而阻塞住了其他操作，為了解決這一問題，我們通常會采取同步通信+多執行緒的策略，即為每一個連入的Socket分配一個執行緒，然而隨著連入的Socket的數量的增加，執行緒的數量也在增加，這樣CPU則需要不停地進行執行緒的切換，因此難以成為高性能的服務器程式，
異步通信則可以把接收資料這一操作交給內核，即在內核接收資料的時候，主執行緒可以不用被阻塞并且繼續執行其他操作，而一旦接收資料完成以后，再由內核通知主執行緒，而如何通知主執行緒是一個關鍵，不同的異步通信策略有著不同的通知方式，
在這樣的情況下，完成埠這一I/O模型被提出，成為目前Windows下性能最好的I/O模型之一，
(注：文中所有函式引數均已MSDN上的為標準，文中觀點僅代表個人理解，如有錯誤，還請多多包涵并及時留言，我會第一時間改正，謝謝！！！)
完成埠模型簡介：
上面所說的“初學”指你已經熟悉Socket進行TCP/IP編程的基本原理，前期基本的概念我這里就略過不提了，直入主題，
嗯~~!怎么說呢，完成埠是Windows的一種機制，這種機制是在重疊IO上的優化，所以說完成埠也是基于重疊結構的，換句話說如果對于重疊IO結構特別熟悉的話，那么完成埠對于你來說就特別簡單，為什么說完成埠是在重疊IO上的一種優化呢？對比一下下面第一張和第二轉張結構圖，一定會有人好奇，為什么兩張圖差不多一樣呢？仔細看會發現完成埠結構圖里面作業系統有一步操作是將通知放進佇列(第三張結構圖，模仿訊息佇列原理系統會創建一個通知佇列)，到這就可以說明完成埠在重疊IO具體優化的是什么了，熟悉重疊IO的都知道，重疊IO最嚴重的問題就是執行緒數量，有多少的客戶端，那就得有多少根執行緒，肯定會有人說執行緒多了不是更好嗎？速度跟快嗎？程式執行時間更短碼？那就錯了，恰恰是相反的，上面我也大致提到了執行緒太多的問題，了解作業系統的都知道，執行緒在一個周期內分得的時間越多，那么執行就越快，換而言之如果執行緒數量增加，那么每根執行緒上所分得的時間就會變短，再加上切換執行緒的時間，這樣一來反而時間更久，而理論上最優的執行緒數就是和CPU核數一樣(還有其他的幾種：CPU核數*2、CPU核數*2+2，為什么會有這幾種情況，這里就不多多介紹了，)這樣以來就可以充分的利用CPU資源，不過這也要求執行緒函式中沒有呼叫諸如Sleep(),WSAWaitForMultipleEvents()...這類函式，這類函式會使執行緒掛起（但不占cpu時間片），從而使得CPU某個核空閑了，這就不好了，所以一般我們多建個兩三根，以解決此類情況，讓CPU不停歇，從而在整體上保證程式執行效率，本文采取的是和CPU核數一樣多，而對于重疊IO中的無序性問題，完成埠采用了上述所說的創建一個通知佇列(第三張結構圖)來進行管理，從而達到有序，所以說完成埠是對重疊IO的改進也不為過，
完成埠原理以及部分函式用法：
1.用CreateIoCompletionPort()函式創建一個完成埠，
對于 CreateIoCompletionPort()函式它有兩個功能一個功能是創建完成埠，另一個功能就是將SOCKET與完成埠進行系結,在這里就是創建完成埠，至于說功能不一樣，也就是引數不同而已，
HANDLE WINAPI CreateIoCompletionPort(
__in HANDLE FileHandle,
__in_opt HANDLE ExistingCompletionPort,
__in ULONG_PTR CompletionKey,
__in DWORD NumberOfConcurrentThreads
);
引數（Parameters）:
此函式若要是在不關聯I/O完成埠的情況下創建I/O完成埠，如果指定了引數FileHandle為INVALID_HANDLE_VALUE，在這種情況下，ExistingCompletionPort引數必須為NULL，而CompletionKey引數則被忽略可填0；那么引數NumberOfConcurrentThreads是允許此埠上最多同時運行的執行緒數量，一般設定為零(這里的零并不是引數3中忽略的意思，而是自動獲取CPU核數，當然你也可以不用自動獲取自己去指定通過函式GetSystemInfo())，
(注：這里簡單介紹一下GetSystemInfo()函式的用法，這個函式也特別簡單，引數也就一個SYSTEM_INFO型別的結構體，在這里我們只需要專注這個結構體里面的DWORD dwNumberOfProcessors成員即可; )
回傳值（Return value）：
函式執行成功會回傳一個可用的埠變數，否則回傳0；這里可以用GetLastError()獲取錯誤碼，
(注意:這里為什么不用WSAGetLastError()獲取錯誤碼？創建完成埠是Windows的一種機制,不是專門用于網路的,和網路是無關的，完成埠的模型只是利用了這種機制，)
2.用 CreateIoCompletionPort()函式將重疊套接字(客戶端SOCKET+服務器SOCKET)與完成埠進行系結，
毋庸置疑這就是CreateIoCompletionPort()函式的第二個功能：系結重疊套接字與完成埠
HANDLE WINAPI CreateIoCompletionPort(
__in HANDLE FileHandle,
__in_opt HANDLE ExistingCompletionPort,
__in ULONG_PTR CompletionKey,
__in DWORD NumberOfConcurrentThreads
);
引數（Parameters）:
FileHandle:要系結的SOCKET，
ExistingCompletionPort：創建完成埠時回傳的變數，
CompletionKey:這個引數就要和下面即將講到的一個函式GetQueuedCompletionStatus()的引數3關聯在一起比較著看，會很清楚，
先大概說一下GetQueuedCompletionStatus()這個函式，上面我也提到過系統會把所有SOCKET上的通知放進通知佇列里面，而GetQueuedCompletionStatus()
函式就是從這個佇列里面依次往外拿出通知然后進行分類處理，而CreateIoCompletionPort()函式的引數3就是告知函式GetQueuedCompletionStatus()從
佇列里面拿出的事件通知具體是哪一個SOCKET上的發生的，
所以這里的引數就是要傳入具體發生事件通知的SOCKET(如果是把所有的SOCKET裝進陣列里面的話，這里也可以傳具體SOCKET的下標)，
NumberOfConcurrentThreads:如果引數ExistingCompletionPort不是NULL，則忽略此引數，可填0，
回傳值（Return value）：
函式執行成功回傳自己,也就是再回傳引數2；如果執行不成功那肯定就不等于引數2了啊！
3.使用AcceptEx(),WSARecv(),WSASend()函式投遞請求，(這三個異步函式就偷個懶這里不過多的介紹了，因為是直接拿的重疊IO里面的函式，哈哈哈)
4.使用CreateThread()函式創建執行緒，使用GetSystemInfo()獲得作業系統相關資訊，比如獲取CPU核數，
(GetSystemInfo()函數上文已經大致介紹了一下，和網路也沒有太大的關系這里就不詳細介紹了，想了解的可以看一下MSDN)
創建執行緒函式CreateThread()的功能就是一次創建一根執行緒,如果要創建多根執行緒，可以用回圈
HANDLE CreateThread(
LPSECURITY_ATTRIBUTES lpThreadAttributes,
SIZE_T dwStackSize,
LPTHREAD_START_ROUTINE lpStartAddress,
__drv_aliasesMem LPVOID lpParameter,
DWORD dwCreationFlags,
LPDWORD lpThreadId
);
引數（Parameters）:
lpThreadAttributes:執行緒句柄是否被繼承，不繼承就填NULL，如果不繼承就是子執行緒與父執行緒共享一份執行緒句柄，相當于全域變數；
如果繼承的話子類復制一份父類的此時就會有兩份，相當于區域變數自己用自己的；
還有一個功能就是指定執行緒的權限，默認權限就填NULL，
所以此引數填NULL就好，
dwStackSize：執行緒大小(堆疊區大小)，填0，默認大小為1M，可以指定大小以位元組為單位，
lpStartAddress：執行緒函式地址；
執行緒函式函式頭:DWORD WINAPI ThreadProc(LPVOID lpParameter)； 這個函式的引數由函式CreateThread()的引數4傳入
lpParameter：外部給執行緒傳遞資料，把傳遞進來的資料傳遞給引數3中的執行緒函式中；
dwCreationFlags：執行緒創建出來的一種執行狀態；
立即執行填0，也就是立即獲得時間片分得的時間；
掛起狀態填CREATE_SUSPENDED(不占用時間周期)，呼叫ResumeThread()函式,激活掛起狀態的執行緒，
如果填STACK_SIZE_PARAM_IS_A_RESERVATION，這個宏是和引數2關聯在一起的，如果想修改堆疊區大小，
設定了這個宏，引數2就是修改的堆疊保留大小，即虛擬記憶體上堆疊得大小；如果沒有設定修改的就是堆疊提交大小，即物理記憶體上的大小，
lpThreadId：執行緒ID,每根執行緒的ID都不一樣，不用就填NULL，
回傳值（Return value）：
函式執行成功回傳執行緒句柄，失敗回傳NULL，可以用GetLastError()獲得錯誤碼，
執行緒句柄是內核物件，用完要釋放用CloseHandle()函式，
5.當系統異步處理完成后，會生成一個通知，這個通知就會放進通知佇列里面，而完成埠就可以理解為通知佇列的頭，該佇列由作業系統系統創建，維護，
6.通過GetQueuedCompletionStatus()函式從佇列頭一個一個往外拿，進行處理，
如果通知佇列里沒有通知，那么會使執行緒處于掛起狀態，這樣就不會占用CPU時間，
BOOL GetQueuedCompletionStatus( HANDLE CompletionPort, LPDWORD lpNumberOfBytesTransferred, PULONG_PTR lpCompletionKey, LPOVERLAPPED *lpOverlapped, DWORD dwMilliseconds );
引數（Parameters）:
CompletionPort：創建完成埠時回傳的變數，
lpNumberOfBytesTransferred：收到或發送的位元組數，如果是客戶端SOKCET發生事件通知并且此引數回傳的是0，那就說明是客戶端退出，
lpCompletionKey：在上面寫系結重疊套接字與完成埠的時候已經介紹到了此引數，這里就不過多說了，它就是接收系結完成埠的時候傳進來的SOCKET，
lpOverlapped：回傳一個發生事件通知的SOCKET上所系結的那個重疊結構的地址，
dwMilliseconds：等待時間，可以是具體的等待時間以毫秒為單位；也可以一直等到有事件通知為止，一直等填INFINITE，
回傳值（Return value）：
函式執行成功回傳TRUE，失敗回傳FALSE，可以用GetLastError()獲取錯誤碼，
完成埠代碼邏輯：
1.打開網路庫(WSAStartup())
2.校驗版本(副版本:HIBYTE()、主版本:LOBYTE())
3.創建SOCKET(WSASocket())
4.系結地址與埠號(bind())
5.創建完成埠(CreateIoCompletionPort())
6.將重疊套接字(客戶端SOCKET+服務器SOCKET)與完成埠進行系結(CreateIoCompletionPort())
7.開始監聽(listen())
8.創建執行緒(CreteThread())
9.獲取事件通知(GetQueuedCompletionPort())進行分類處理
10.釋放
轉載請註明出處，本文鏈接：https://www.uj5u.com/houduan/285520.html
標籤：C
上一篇：基于SSL(TLS)的HTTPS網頁下載——如何撰寫健壯的可靠的網頁下載
下一篇：左值與右值