基於Delphi的Socket I/O模型全接觸2

 三：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;
　　 就這麼簡單，我們要做的就是建立一個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是否完成了我們投遞的讀寫操作，如果完成了則再投遞一個新的讀寫請求