六種SOCKET模型（好文章必須要收藏）
阿新 • • 發佈：2019-02-06
一：select模型
二：WSAAsyncSelect模型
三：WSAEventSelect模型
四：Overlapped I/O 事件通知模型
五：Overlapped I/O 完成例程模型
六：IOCP模型
老陳有一個在外地工作的女兒，不能經常回來，老陳和她通過信件聯絡。他們的信會被郵遞員投遞到他們的信箱裡。
這和Socket模型非常類似。下面我就以老陳接收信件為例講解Socket I/O模型~~~
一：select模型
老陳非常想看到女兒的信。以至於他每隔10分鐘就下樓檢查信箱，看是否有女兒的信~~~~~
在這種情況下，"下樓檢查信箱"然後回到樓上耽誤了老陳太多的時間，以至於老陳無法做其他工作。
select模型和老陳的這種情況非常相似：周而復始地去檢查......如果有資料......接收/傳送.......
使用執行緒來select應該是通用的做法：
procedure TListenThread.Execute;
var
addr : TSockAddrIn;
fd_read : TFDSet;
timeout : TTimeVal;
ASock,
MainSock : TSocket;
len, i : Integer;
begin
MainSock := socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
addr.sin_family := AF_INET;
addr.sin_port := htons(5678);
addr.sin_addr.S_addr := htonl(INADDR_ANY);
bind( MainSock, @addr, sizeof(addr) );
listen( MainSock, 5 );
while (not Terminated) do
begin
FD_ZERO( fd_read );
FD_SET( MainSock, fd_read );
timeout.tv_sec := 0;
timeout.tv_usec := 500;
if select( 0, @fd_read, nil, nil, @timeout ) > 0 then //至少有1個等待Accept的connection
begin
if FD_ISSET( MainSock, fd_read ) then
begin
for i:=0 to fd_read.fd_count-1 do //注意，fd_count <= 64，也就是說select只能同時管理最多64個連線
begin
len := sizeof(addr);
ASock := accept( MainSock, addr, len );
if ASock <> INVALID_SOCKET then
....//為ASock建立一個新的執行緒，在新的執行緒中再不停地select
end;
end;
end;
end; //while (not self.Terminated)
shutdown( MainSock, SD_BOTH );
closesocket( MainSock );
end;
二：WSAAsyncSelect模型
後來，老陳使用了微軟公司的新式信箱。這種信箱非常先進，一旦信箱裡有新的信件，蓋茨就會給老陳打電話：喂，大爺，你有新的信件了！從此，老陳再也不必頻繁上下樓檢查信箱了，牙也不疼了，你瞅準了，藍天......不是，微軟~~~~~~~~
微軟提供的WSAAsyncSelect模型就是這個意思。
WSAAsyncSelect模型是Windows下最簡單易用的一種Socket I/O模型。使用這種模型時，Windows會把網路事件以訊息的形勢通知應用程式。
首先定義一個訊息標示常量：
const WM_SOCKET = WM_USER + 55;
再在主Form的private域新增一個處理此訊息的函式宣告：
private
procedure WMSocket(var Msg: TMessage); message WM_SOCKET;
然後就可以使用WSAAsyncSelect了：
var
addr : TSockAddr;
sock : TSocket;
sock := socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
addr.sin_family := AF_INET;
addr.sin_port := htons(5678);
addr.sin_addr.S_addr := htonl(INADDR_ANY);
bind( m_sock, @addr, sizeof(SOCKADDR) );
WSAAsyncSelect( m_sock, Handle, WM_SOCKET, FD_ACCEPT or FD_CLOSE );
listen( m_sock, 5 );
....
應用程式可以對收到WM_SOCKET訊息進行分析，判斷是哪一個socket產生了網路事件以及事件型別：
procedure TfmMain.WMSocket(var Msg: TMessage);
var
sock : TSocket;
addr : TSockAddrIn;
addrlen : Integer;
buf : Array [0..4095] of Char;
begin
//Msg的WParam是產生了網路事件的socket控制代碼，LParam則包含了事件型別
case WSAGetSelectEvent( Msg.LParam ) of
FD_ACCEPT :
begin
addrlen := sizeof(addr);
sock := accept( Msg.WParam, addr, addrlen );
if sock <> INVALID_SOCKET then
WSAAsyncSelect( sock, Handle, WM_SOCKET, FD_READ or FD_WRITE or FD_CLOSE );
end;
FD_CLOSE : closesocket( Msg.WParam );
FD_READ : recv( Msg.WParam, buf[0], 4096, 0 );
FD_WRITE : ;
end;
end;
三：WSAEventSelect模型
後來，微軟的信箱非常暢銷，購買微軟信箱的人以百萬計數......以至於蓋茨每天24小時給客戶打電話，累得腰痠背痛，喝蟻力神都不好使~~~~~~
微軟改進了他們的信箱：在客戶的家中新增一個附加裝置，這個裝置會監視客戶的信箱，每當新的信件來臨，此裝置會發出"新信件到達"聲，提醒老陳去收信。蓋茨終於可以睡覺了。
同樣要使用執行緒：
procedure TListenThread.Execute;
var
hEvent : WSAEvent;
ret : Integer;
ne : TWSANetworkEvents;
sock : TSocket;
adr : TSockAddrIn;
sMsg : String;
Index,
EventTotal : DWORD;
EventArray : Array [0..WSA_MAXIMUM_WAIT_EVENTS-1] of WSAEVENT;
begin
...socket...bind...
hEvent := WSACreateEvent();
WSAEventSelect( ListenSock, hEvent, FD_ACCEPT or FD_CLOSE );
...listen...
while ( not Terminated ) do
begin
Index := WSAWaitForMultipleEvents( EventTotal, @EventArray[0], FALSE, WSA_INFINITE, FALSE );
FillChar( ne, sizeof(ne), 0 );
WSAEnumNetworkEvents( SockArray[Index-WSA_WAIT_EVENT_0], EventArray[Index-WSA_WAIT_EVENT_0], @ne );
if ( ne.lNetworkEvents and FD_ACCEPT ) > 0 then
begin
if ne.iErrorCode[FD_ACCEPT_BIT] <> 0 then
continue;
ret := sizeof(adr);
sock := accept( SockArray[Index-WSA_WAIT_EVENT_0], adr, ret );
if EventTotal > WSA_MAXIMUM_WAIT_EVENTS-1 then//這裡WSA_MAXIMUM_WAIT_EVENTS同樣是64
begin
closesocket( sock );
continue;
end;
hEvent := WSACreateEvent();
WSAEventSelect( sock, hEvent, FD_READ or FD_WRITE or FD_CLOSE );
SockArray[EventTotal] := sock;
EventArray[EventTotal] := hEvent;
Inc( EventTotal );
end;
if ( ne.lNetworkEvents and FD_READ ) > 0 then
begin
if ne.iErrorCode[FD_READ_BIT] <> 0 then
continue;
FillChar( RecvBuf[0], PACK_SIZE_RECEIVE, 0 );
ret := recv( SockArray[Index-WSA_WAIT_EVENT_0], RecvBuf[0], PACK_SIZE_RECEIVE, 0 );
......
end;
end;
end;
四：Overlapped I/O 事件通知模型
後來，微軟通過調查發現，老陳不喜歡上下樓收發信件，因為上下樓其實很浪費時間。於是微軟再次改進他們的信箱。新式的信箱採用了更為先進的技術，只要使用者告訴微軟自己的家在幾樓幾號，新式信箱會把信件直接傳送到使用者的家中，然後告訴使用者，你的信件已經放到你的家中了！老陳很高興，因為他不必再親自收發信件了！
Overlapped I/O 事件通知模型和WSAEventSelect模型在實現上非常相似，主要區別在"Overlapped"，Overlapped模型是讓應用程式使用重疊資料結構(WSAOVERLAPPED)，一次投遞一個或多個Winsock I/O請求。這些提交的請求完成後，應用程式會收到通知。什麼意思呢？就是說，如果你想從socket上接收資料，只需要告訴系統，由系統為你接收資料，而你需要做的只是為系統提供一個緩衝區~~~~~
Listen執行緒和WSAEventSelect模型一模一樣，Recv/Send執行緒則完全不同：
procedure TOverlapThread.Execute;
var
dwTemp : DWORD;
ret : Integer;
Index : DWORD;
begin
......
while ( not Terminated ) do
begin
Index := WSAWaitForMultipleEvents( FLinks.Count, @FLinks.Events[0], FALSE, RECV_TIME_OUT, FALSE );
Dec( Index, WSA_WAIT_EVENT_0 );
if Index > WSA_MAXIMUM_WAIT_EVENTS-1 then //超時或者其他錯誤
continue;
WSAResetEvent( FLinks.Events[Index] );
WSAGetOverlappedResult( FLinks.Sockets[Index], FLinks.pOverlaps[Index], @dwTemp, FALSE, FLinks.pdwFlags[Index]^ );
if dwTemp = 0 then //連線已經關閉
begin
......
continue;
end else
begin
fmMain.ListBox1.Items.Add( FLinks.pBufs[Index]^.buf );
end;
//初始化緩衝區
FLinks.pdwFlags[Index]^ := 0;
FillChar( FLinks.pOverlaps[Index]^, sizeof(WSAOVERLAPPED), 0 );
FLinks.pOverlaps[Index]^.hEvent := FLinks.Events[Index];
FillChar( FLinks.pBufs[Index]^.buf^, BUFFER_SIZE, 0 );
//遞一個接收資料請求
WSARecv( FLinks.Sockets[Index], FLinks.pBufs[Index], 1, FLinks.pdwRecvd[Index]^, FLinks.pdwFlags[Index]^, FLinks.pOverlaps[Index], nil );
end;
end;
五：Overlapped I/O 完成例程模型
老陳接收到新的信件後，一般的程式是：開啟信封----掏出信紙----閱讀信件----回覆信件......為了進一步減輕使用者負擔，微軟又開發了一種新的技術：使用者只要告訴微軟對信件的操作步驟，微軟信箱將按照這些步驟去處理信件，不再需要使用者親自拆信/閱讀/回覆了！老陳終於過上了小資生活！
Overlapped I/O 完成例程要求使用者提供一個回撥函式，發生新的網路事件的時候系統將執行這個函式：
procedure WorkerRoutine( const dwError, cbTransferred : DWORD; const
lpOverlapped : LPWSAOVERLAPPED; const dwFlags : DWORD ); stdcall;
然後告訴系統用WorkerRoutine函式處理接收到的資料：
WSARecv( m_socket, @FBuf, 1, dwTemp, dwFlag, @m_overlap, WorkerRoutine );
然後......沒有什麼然後了，系統什麼都給你做了！微軟真實體貼！
while ( not Terminated ) do//這就是一個Recv/Send執行緒要做的事情......什麼都不用做啊！！！
begin
if SleepEx( RECV_TIME_OUT, True ) = WAIT_IO_COMPLETION then //
begin
;
end else
begin
continue;
end;
end;
六：IOCP模型
微軟信箱似乎很完美，老陳也很滿意。但是在一些大公司情況卻完全不同！這些大公司有數以萬計的信箱，每秒鐘都有數以百計的信件需要處理，以至於微軟信箱經常因超負荷運轉而崩潰！需要重新啟動！微軟不得不使出殺手鐗......
微軟給每個大公司派了一名名叫"Completion Port"的超級機器人，讓這個機器人去處理那些信件！
"Windows NT小組注意到這些應用程式的效能沒有預料的那麼高。特別的，處理很多同時的客戶請求意味著很多執行緒併發地執行在系統中。因為所有這些執行緒都是可執行的[沒有被掛起和等待發生什麼事]，Microsoft意識到NT核心花費了太多的時間來轉換執行執行緒的上下文[Context]，執行緒就沒有得到很多CPU時間來做它們的工作。大家可能也都感覺到並行模型的瓶頸在於它為每一個客戶請求都建立了一個新執行緒。建立執行緒比起建立程序開銷要小，但也遠不是沒有開銷的。我們不妨設想一下：如果事先開好N個執行緒，讓它們在那hold[堵塞]，然後可以將所有使用者的請求都投遞到一個訊息佇列中去。然後那N個執行緒逐一從訊息佇列中去取出訊息並加以處理。就可以避免針對每一個使用者請求都開執行緒。不僅減少了執行緒的資源，也提高了執行緒的利用率。理論上很不錯，你想我等泛泛之輩都能想出來的問題，Microsoft又怎會沒有考慮到呢?"-----摘自nonocast的《理解I/O Completion Port》
先看一下IOCP模型的實現：
//建立一個完成埠
FCompletPort := CreateIoCompletionPort( INVALID_HANDLE_VALUE, 0,0,0 );
//接受遠端連線，並把這個連線的socket控制代碼繫結到剛才建立的IOCP上
AConnect := accept( FListenSock, addr, len);
CreateIoCompletionPort( AConnect, FCompletPort, nil, 0 );
//建立CPU數*2 + 2個執行緒
for i:=1 to si.dwNumberOfProcessors*2+2 do
begin
AThread := TRecvSendThread.Create( false );
AThread.CompletPort := FCompletPort;//告訴這個執行緒，你要去這個IOCP去訪問資料
end;
OK，就這麼簡單，我們要做的就是建立一個IOCP，把遠端連線的socket控制代碼繫結到剛才建立的IOCP上，最後建立n個執行緒，並告訴這n個執行緒到這個IOCP上去訪問資料就可以了。
再看一下TRecvSendThread執行緒都幹些什麼：
procedure TRecvSendThread.Execute;
var
......
begin
while (not self.Terminated) do
begin
//查詢IOCP狀態（資料讀寫操作是否完成）
GetQueuedCompletionStatus( CompletPort, BytesTransd, CompletKey, POVERLAPPED(pPerIoDat), TIME_OUT );
if BytesTransd <> 0 then
....;//資料讀寫操作完成
//再投遞一個讀資料請求
WSARecv( CompletKey, @(pPerIoDat^.BufData), 1, BytesRecv, Flags, @(pPerIoDat^.Overlap), nil );
end;
end;
讀寫執行緒只是簡單地檢查IOCP是否完成了我們投遞的讀寫操作，如果完成了則再投遞一個新的讀寫請求。
應該注意到，我們建立的所有TRecvSendThread都在訪問同一個IOCP（因為我們只建立了一個IOCP），並且我們沒有使用臨界區！難道不會產生衝突嗎？不用考慮同步問題嗎？
呵呵，這正是IOCP的奧妙所在。IOCP不是一個普通的物件，不需要考慮執行緒安全問題。它會自動調配訪問它的執行緒：如果某個socket上有一個執行緒A正在訪問，那麼執行緒B的訪問請求會被分配到另外一個socket。這一切都是由系統自動調配的，我們無需過問。
二：WSAAsyncSelect模型
三：WSAEventSelect模型
四：Overlapped I/O 事件通知模型
五：Overlapped I/O 完成例程模型
六：IOCP模型
老陳有一個在外地工作的女兒，不能經常回來，老陳和她通過信件聯絡。他們的信會被郵遞員投遞到他們的信箱裡。
這和Socket模型非常類似。下面我就以老陳接收信件為例講解Socket I/O模型~~~
一：select模型
老陳非常想看到女兒的信。以至於他每隔10分鐘就下樓檢查信箱，看是否有女兒的信~~~~~
在這種情況下，"下樓檢查信箱"然後回到樓上耽誤了老陳太多的時間，以至於老陳無法做其他工作。
select模型和老陳的這種情況非常相似：周而復始地去檢查......如果有資料......接收/傳送.......
使用執行緒來select應該是通用的做法：
procedure TListenThread.Execute;
var
addr : TSockAddrIn;
fd_read : TFDSet;
timeout : TTimeVal;
ASock,
MainSock : TSocket;
len, i : Integer;
begin
MainSock := socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
addr.sin_family := AF_INET;
addr.sin_port := htons(5678);
addr.sin_addr.S_addr := htonl(INADDR_ANY);
bind( MainSock, @addr, sizeof(addr) );
listen( MainSock, 5 );
while (not Terminated) do
begin
FD_ZERO( fd_read );
FD_SET( MainSock, fd_read );
timeout.tv_sec := 0;
timeout.tv_usec := 500;
if select( 0, @fd_read, nil, nil, @timeout ) > 0 then //至少有1個等待Accept的connection
begin
if FD_ISSET( MainSock, fd_read ) then
begin
for i:=0 to fd_read.fd_count-1 do //注意，fd_count <= 64，也就是說select只能同時管理最多64個連線
begin
len := sizeof(addr);
ASock := accept( MainSock, addr, len );
if ASock <> INVALID_SOCKET then
....//為ASock建立一個新的執行緒，在新的執行緒中再不停地select
end;
end;
end;
end; //while (not self.Terminated)
shutdown( MainSock, SD_BOTH );
closesocket( MainSock );
end;
二：WSAAsyncSelect模型
後來，老陳使用了微軟公司的新式信箱。這種信箱非常先進，一旦信箱裡有新的信件，蓋茨就會給老陳打電話：喂，大爺，你有新的信件了！從此，老陳再也不必頻繁上下樓檢查信箱了，牙也不疼了，你瞅準了，藍天......不是，微軟~~~~~~~~
微軟提供的WSAAsyncSelect模型就是這個意思。
WSAAsyncSelect模型是Windows下最簡單易用的一種Socket I/O模型。使用這種模型時，Windows會把網路事件以訊息的形勢通知應用程式。
首先定義一個訊息標示常量：
const WM_SOCKET = WM_USER + 55;
再在主Form的private域新增一個處理此訊息的函式宣告：
private
procedure WMSocket(var Msg: TMessage); message WM_SOCKET;
然後就可以使用WSAAsyncSelect了：
var
addr : TSockAddr;
sock : TSocket;
sock := socket( AF_INET, SOCK_STREAM, IPPROTO_TCP );
addr.sin_family := AF_INET;
addr.sin_port := htons(5678);
addr.sin_addr.S_addr := htonl(INADDR_ANY);
bind( m_sock, @addr, sizeof(SOCKADDR) );
WSAAsyncSelect( m_sock, Handle, WM_SOCKET, FD_ACCEPT or FD_CLOSE );
listen( m_sock, 5 );
....
應用程式可以對收到WM_SOCKET訊息進行分析，判斷是哪一個socket產生了網路事件以及事件型別：
procedure TfmMain.WMSocket(var Msg: TMessage);
var
sock : TSocket;
addr : TSockAddrIn;
addrlen : Integer;
buf : Array [0..4095] of Char;
begin
//Msg的WParam是產生了網路事件的socket控制代碼，LParam則包含了事件型別
case WSAGetSelectEvent( Msg.LParam ) of
FD_ACCEPT :
begin
addrlen := sizeof(addr);
sock := accept( Msg.WParam, addr, addrlen );
if sock <> INVALID_SOCKET then
WSAAsyncSelect( sock, Handle, WM_SOCKET, FD_READ or FD_WRITE or FD_CLOSE );
end;
FD_CLOSE : closesocket( Msg.WParam );
FD_READ : recv( Msg.WParam, buf[0], 4096, 0 );
FD_WRITE : ;
end;
end;
三：WSAEventSelect模型
後來，微軟的信箱非常暢銷，購買微軟信箱的人以百萬計數......以至於蓋茨每天24小時給客戶打電話，累得腰痠背痛，喝蟻力神都不好使~~~~~~
微軟改進了他們的信箱：在客戶的家中新增一個附加裝置，這個裝置會監視客戶的信箱，每當新的信件來臨，此裝置會發出"新信件到達"聲，提醒老陳去收信。蓋茨終於可以睡覺了。
同樣要使用執行緒：
procedure TListenThread.Execute;
var
hEvent : WSAEvent;
ret : Integer;
ne : TWSANetworkEvents;
sock : TSocket;
adr : TSockAddrIn;
sMsg : String;
Index,
EventTotal : DWORD;
EventArray : Array [0..WSA_MAXIMUM_WAIT_EVENTS-1] of WSAEVENT;
begin
...socket...bind...
hEvent := WSACreateEvent();
WSAEventSelect( ListenSock, hEvent, FD_ACCEPT or FD_CLOSE );
...listen...
while ( not Terminated ) do
begin
Index := WSAWaitForMultipleEvents( EventTotal, @EventArray[0], FALSE, WSA_INFINITE, FALSE );
FillChar( ne, sizeof(ne), 0 );
WSAEnumNetworkEvents( SockArray[Index-WSA_WAIT_EVENT_0], EventArray[Index-WSA_WAIT_EVENT_0], @ne );
if ( ne.lNetworkEvents and FD_ACCEPT ) > 0 then
begin
if ne.iErrorCode[FD_ACCEPT_BIT] <> 0 then
continue;
ret := sizeof(adr);
sock := accept( SockArray[Index-WSA_WAIT_EVENT_0], adr, ret );
if EventTotal > WSA_MAXIMUM_WAIT_EVENTS-1 then//這裡WSA_MAXIMUM_WAIT_EVENTS同樣是64
begin
closesocket( sock );
continue;
end;
hEvent := WSACreateEvent();
WSAEventSelect( sock, hEvent, FD_READ or FD_WRITE or FD_CLOSE );
SockArray[EventTotal] := sock;
EventArray[EventTotal] := hEvent;
Inc( EventTotal );
end;
if ( ne.lNetworkEvents and FD_READ ) > 0 then
begin
if ne.iErrorCode[FD_READ_BIT] <> 0 then
continue;
FillChar( RecvBuf[0], PACK_SIZE_RECEIVE, 0 );
ret := recv( SockArray[Index-WSA_WAIT_EVENT_0], RecvBuf[0], PACK_SIZE_RECEIVE, 0 );
......
end;
end;
end;
四：Overlapped I/O 事件通知模型
後來，微軟通過調查發現，老陳不喜歡上下樓收發信件，因為上下樓其實很浪費時間。於是微軟再次改進他們的信箱。新式的信箱採用了更為先進的技術，只要使用者告訴微軟自己的家在幾樓幾號，新式信箱會把信件直接傳送到使用者的家中，然後告訴使用者，你的信件已經放到你的家中了！老陳很高興，因為他不必再親自收發信件了！
Overlapped I/O 事件通知模型和WSAEventSelect模型在實現上非常相似，主要區別在"Overlapped"，Overlapped模型是讓應用程式使用重疊資料結構(WSAOVERLAPPED)，一次投遞一個或多個Winsock I/O請求。這些提交的請求完成後，應用程式會收到通知。什麼意思呢？就是說，如果你想從socket上接收資料，只需要告訴系統，由系統為你接收資料，而你需要做的只是為系統提供一個緩衝區~~~~~
Listen執行緒和WSAEventSelect模型一模一樣，Recv/Send執行緒則完全不同：
procedure TOverlapThread.Execute;
var
dwTemp : DWORD;
ret : Integer;
Index : DWORD;
begin
......
while ( not Terminated ) do
begin
Index := WSAWaitForMultipleEvents( FLinks.Count, @FLinks.Events[0], FALSE, RECV_TIME_OUT, FALSE );
Dec( Index, WSA_WAIT_EVENT_0 );
if Index > WSA_MAXIMUM_WAIT_EVENTS-1 then //超時或者其他錯誤
continue;
WSAResetEvent( FLinks.Events[Index] );
WSAGetOverlappedResult( FLinks.Sockets[Index], FLinks.pOverlaps[Index], @dwTemp, FALSE, FLinks.pdwFlags[Index]^ );
if dwTemp = 0 then //連線已經關閉
begin
......
continue;
end else
begin
fmMain.ListBox1.Items.Add( FLinks.pBufs[Index]^.buf );
end;
//初始化緩衝區
FLinks.pdwFlags[Index]^ := 0;
FillChar( FLinks.pOverlaps[Index]^, sizeof(WSAOVERLAPPED), 0 );
FLinks.pOverlaps[Index]^.hEvent := FLinks.Events[Index];
FillChar( FLinks.pBufs[Index]^.buf^, BUFFER_SIZE, 0 );
//遞一個接收資料請求
WSARecv( FLinks.Sockets[Index], FLinks.pBufs[Index], 1, FLinks.pdwRecvd[Index]^, FLinks.pdwFlags[Index]^, FLinks.pOverlaps[Index], nil );
end;
end;
五：Overlapped I/O 完成例程模型
老陳接收到新的信件後，一般的程式是：開啟信封----掏出信紙----閱讀信件----回覆信件......為了進一步減輕使用者負擔，微軟又開發了一種新的技術：使用者只要告訴微軟對信件的操作步驟，微軟信箱將按照這些步驟去處理信件，不再需要使用者親自拆信/閱讀/回覆了！老陳終於過上了小資生活！
Overlapped I/O 完成例程要求使用者提供一個回撥函式，發生新的網路事件的時候系統將執行這個函式：
procedure WorkerRoutine( const dwError, cbTransferred : DWORD; const
lpOverlapped : LPWSAOVERLAPPED; const dwFlags : DWORD ); stdcall;
然後告訴系統用WorkerRoutine函式處理接收到的資料：
WSARecv( m_socket, @FBuf, 1, dwTemp, dwFlag, @m_overlap, WorkerRoutine );
然後......沒有什麼然後了，系統什麼都給你做了！微軟真實體貼！
while ( not Terminated ) do//這就是一個Recv/Send執行緒要做的事情......什麼都不用做啊！！！
begin
if SleepEx( RECV_TIME_OUT, True ) = WAIT_IO_COMPLETION then //
begin
;
end else
begin
continue;
end;
end;
六：IOCP模型
微軟信箱似乎很完美，老陳也很滿意。但是在一些大公司情況卻完全不同！這些大公司有數以萬計的信箱，每秒鐘都有數以百計的信件需要處理，以至於微軟信箱經常因超負荷運轉而崩潰！需要重新啟動！微軟不得不使出殺手鐗......
微軟給每個大公司派了一名名叫"Completion Port"的超級機器人，讓這個機器人去處理那些信件！
"Windows NT小組注意到這些應用程式的效能沒有預料的那麼高。特別的，處理很多同時的客戶請求意味著很多執行緒併發地執行在系統中。因為所有這些執行緒都是可執行的[沒有被掛起和等待發生什麼事]，Microsoft意識到NT核心花費了太多的時間來轉換執行執行緒的上下文[Context]，執行緒就沒有得到很多CPU時間來做它們的工作。大家可能也都感覺到並行模型的瓶頸在於它為每一個客戶請求都建立了一個新執行緒。建立執行緒比起建立程序開銷要小，但也遠不是沒有開銷的。我們不妨設想一下：如果事先開好N個執行緒，讓它們在那hold[堵塞]，然後可以將所有使用者的請求都投遞到一個訊息佇列中去。然後那N個執行緒逐一從訊息佇列中去取出訊息並加以處理。就可以避免針對每一個使用者請求都開執行緒。不僅減少了執行緒的資源，也提高了執行緒的利用率。理論上很不錯，你想我等泛泛之輩都能想出來的問題，Microsoft又怎會沒有考慮到呢?"-----摘自nonocast的《理解I/O Completion Port》
先看一下IOCP模型的實現：
//建立一個完成埠
FCompletPort := CreateIoCompletionPort( INVALID_HANDLE_VALUE, 0,0,0 );
//接受遠端連線，並把這個連線的socket控制代碼繫結到剛才建立的IOCP上
AConnect := accept( FListenSock, addr, len);
CreateIoCompletionPort( AConnect, FCompletPort, nil, 0 );
//建立CPU數*2 + 2個執行緒
for i:=1 to si.dwNumberOfProcessors*2+2 do
begin
AThread := TRecvSendThread.Create( false );
AThread.CompletPort := FCompletPort;//告訴這個執行緒，你要去這個IOCP去訪問資料
end;
OK，就這麼簡單，我們要做的就是建立一個IOCP，把遠端連線的socket控制代碼繫結到剛才建立的IOCP上，最後建立n個執行緒，並告訴這n個執行緒到這個IOCP上去訪問資料就可以了。
再看一下TRecvSendThread執行緒都幹些什麼：
procedure TRecvSendThread.Execute;
var
......
begin
while (not self.Terminated) do
begin
//查詢IOCP狀態（資料讀寫操作是否完成）
GetQueuedCompletionStatus( CompletPort, BytesTransd, CompletKey, POVERLAPPED(pPerIoDat), TIME_OUT );
if BytesTransd <> 0 then
....;//資料讀寫操作完成
//再投遞一個讀資料請求
WSARecv( CompletKey, @(pPerIoDat^.BufData), 1, BytesRecv, Flags, @(pPerIoDat^.Overlap), nil );
end;
end;
讀寫執行緒只是簡單地檢查IOCP是否完成了我們投遞的讀寫操作，如果完成了則再投遞一個新的讀寫請求。
應該注意到，我們建立的所有TRecvSendThread都在訪問同一個IOCP（因為我們只建立了一個IOCP），並且我們沒有使用臨界區！難道不會產生衝突嗎？不用考慮同步問題嗎？
呵呵，這正是IOCP的奧妙所在。IOCP不是一個普通的物件，不需要考慮執行緒安全問題。它會自動調配訪問它的執行緒：如果某個socket上有一個執行緒A正在訪問，那麼執行緒B的訪問請求會被分配到另外一個socket。這一切都是由系統自動調配的，我們無需過問。