8.2.2 WSAAsyncSelect
Wi n s o c k提供了一個有用的異步I / O模型。利用這個模型,應(yīng)用程序可在一個套接字上,接收以Wi n d o w s消息為基礎(chǔ)的網(wǎng)絡(luò)事件通知。具體的做法是在建好一個套接字后,調(diào)用W S A A s y n c S e l e c t函數(shù)。該模型最早出現(xiàn)于Wi n s o c k的1 . 1版本中,用于幫助應(yīng)用程序開發(fā)者面向一些早期的1 6位Wi n d o w s平臺(如Windows for Wo r k g r o u p s),適應(yīng)其“落后”的多任務(wù)消息環(huán)境。應(yīng)用程序仍可從這種模型中得到好處,特別是它們用一個標(biāo)準(zhǔn)的Wi n d o w s例程(常
稱為“ w i n p r o c”),對窗口消息進(jìn)行管理的時候。該模型亦得到了Microsoft Foundation Class
(微軟基本類,M F C)對象C S o c k e t的采納。
消息通知
要想使用W S A A s y n c S e l e c t模型,在應(yīng)用程序中,首先必須用C r e a t e Wi n d o w函數(shù)創(chuàng)建一個窗口,再為該窗口提供一個窗口例程支持函數(shù)( Wi n p r o c)。亦可使用一個對話框,為其提供一個對話例程,而非窗口例程,因?yàn)閷υ捒虮举|(zhì)也是“窗口”。考慮到我們的目的,我們打算用一個簡單的窗口來演示這種模型,采用的是一個支持窗口例程。設(shè)置好窗口的框架后,便可開始創(chuàng)建套接字,并調(diào)用W S A A s y n c S e l e c t函數(shù),打開窗口消息通知。該函數(shù)的定義如下:
int WSAAsyncSelect(
??????????SOCKET s,
??????????HWND?hWnd,
??????????unsigned ?int wMsg,
??????????long lEvent
?????????);
其中, s參數(shù)指定的是我們感興趣的那個套接字。h W n d參數(shù)指定的是一個窗口句柄,它對應(yīng)于網(wǎng)絡(luò)事件發(fā)生之后,想要收到通知消息的那個窗口或?qū)υ捒颉 M s g參數(shù)指定在發(fā)生網(wǎng)絡(luò)事件時,打算接收的消息。該消息會投遞到由h W n d窗口句柄指定的那個窗口。通常,應(yīng)用程序需要將這個消息設(shè)為比Wi n d o w s的W M _ U S E R大的一個值,避免網(wǎng)絡(luò)窗口消息與預(yù)定義的標(biāo)準(zhǔn)窗口消息發(fā)生混淆與沖突。最后一個參數(shù)是l E v e n t,它指定的是一個位掩碼,對應(yīng)于一
系列網(wǎng)絡(luò)事件的組合(請參考表8 - 3),應(yīng)用程序感興趣的便是這一系列事件。大多數(shù)應(yīng)用程序通常感興趣的網(wǎng)絡(luò)事件類型包括: F D _ R E A D、F D _ W R I T E、F D _ A C C E P T、F D _ C O N N E C T和
F D _ C L O S E。當(dāng)然,到底使用F D _ A C C E P T,還是使用F D _ C O N N E C T類型,要取決于應(yīng)用程序的身份到底是一個客戶機(jī)呢,還是一個服務(wù)器。如應(yīng)用程序同時對多個網(wǎng)絡(luò)事件有興趣,只需對各種類型執(zhí)行一次簡單的按位O R(或)運(yùn)算,然后將它們分配給l E v e n t就可以了。舉個例子來說:
WSAAsyncSelect(s,hWnd,WM_SOCKET,FD_CONNECT|FD_READ|FD_WRITE|FD_CLOSE);
這樣一來,我們的應(yīng)用程序以后便可在套接字s上,接收到有關(guān)連接、發(fā)送、接收以及套
接字關(guān)閉這一系列網(wǎng)絡(luò)事件的通知。特別要注意的是,多個事件務(wù)必在套接字上一次注冊!
另外還要注意的是,一旦在某個套接字上允許了事件通知,那么以后除非明確調(diào)用c l o s e s o c k e t命令,或者由應(yīng)用程序針對那個套接字調(diào)用了W S A A s y n c S e l e c t,從而更改了注冊的網(wǎng)絡(luò)事件類型,否則的話,事件通知會永遠(yuǎn)有效!若將l E v e n t參數(shù)設(shè)為0,效果相當(dāng)于停止在套接字上進(jìn)行的所有網(wǎng)絡(luò)事件通知。
若應(yīng)用程序針對一個套接字調(diào)用了W S A A s y n c S e l e c t,那么套接字的模式會從“鎖定”自動變成“非鎖定”,我們在前面已提到過這一點(diǎn)。這樣一來,假如調(diào)用了像W S A R e c v這樣的Wi n s o c k? I / O函數(shù),但當(dāng)時卻并沒有數(shù)據(jù)可用,那么必然會造成調(diào)用的失敗,并返回W S A E W O U L D B L O C K
錯誤。為防止這一點(diǎn),應(yīng)用程序應(yīng)依賴于由W S A A s y n c S e l e c t的u M s g參數(shù)指定的用戶自定義窗口消息,來判斷網(wǎng)絡(luò)事件類型何時在套接字上發(fā)生;而不應(yīng)盲目地進(jìn)行調(diào)用。
表8-3 用于W S A A s y n c S e l e c t函數(shù)的網(wǎng)絡(luò)事件類型
F D _ R E A D?????????????應(yīng)用程序想要接收有關(guān)是否可讀的通知,以便讀入數(shù)據(jù)
F D _ W R I T E??????????應(yīng)用程序想要接收有關(guān)是否可寫的通知,以便寫入數(shù)據(jù)
F D _ O O B????????????????應(yīng)用程序想接收是否有帶外( O O B)數(shù)據(jù)抵達(dá)的通知
F D _ A C C E P T???????應(yīng)用程序想接收與進(jìn)入連接有關(guān)的通知
F D _ C O N N E C T????應(yīng)用程序想接收與一次連接或者多點(diǎn)j o i n操作完成的通知
F D _ C L O S E?????????????應(yīng)用程序想接收與套接字關(guān)閉有關(guān)的通知
F D _ Q O S????????????應(yīng)用程序想接收套接字“服務(wù)質(zhì)量”(Q o S)發(fā)生更改的通知
F D _ G R O U P _ Q O S?????????????應(yīng)用程序想接收套接字組“服務(wù)質(zhì)量”發(fā)生更改的通知(現(xiàn)在沒什么用處,為未來套接字組的使用保留)
F D _ R O U T I N G _ I N T E R FA C E _ C H A N G E???????應(yīng)用程序想接收在指定的方向上,與路由接口發(fā)生變化的通知
F D _ A D D R E S S _ L I S T _ C H A N G E???????應(yīng)用程序想接收針對套接字的協(xié)議家族,本地地址列表發(fā)生變化的通知
應(yīng)用程序在一個套接字上成功調(diào)用了W S A A s y n c S e l e c t之后,應(yīng)用程序會在與h W n d窗口句柄參數(shù)對應(yīng)的窗口例程中,以Windows消息的形式,接收網(wǎng)絡(luò)事件通知。窗口例程通常定義如下:
LRESULT CALLBACK WindProc(
?????????????HWND hWnd,
?????????????UINT uMsg,
?????????????WPARAM wParam,
?????????????LPARAM lParam
?????????????);
其中,h W n d參數(shù)指定一個窗口的句柄,對窗口例程的調(diào)用正是由那個窗口發(fā)出的。u M s g參數(shù)指定需要對哪些消息進(jìn)行處理。就我們的情況來說,感興趣的是W S A A s y n c S e l e c t調(diào)用中定義的消息。w P a r a m參數(shù)指定在其上面發(fā)生了一個網(wǎng)絡(luò)事件的套接字。假若同時為這個窗口例程分配了多個套接字,這個參數(shù)的重要性便顯示出來了。在l P a r a m參數(shù)中,包含了兩方面重要的信息。其中, l P a r a m的低字(低位字)指定了已經(jīng)發(fā)生的網(wǎng)絡(luò)事件,而l P a r a m的高字
(高位字)包含了可能出現(xiàn)的任何錯誤代碼。
網(wǎng)絡(luò)事件消息抵達(dá)一個窗口例程后,應(yīng)用程序首先應(yīng)檢查l P a r a m的高字位,以判斷是否在套接字上發(fā)生了一個網(wǎng)絡(luò)錯誤。這里有一個特殊的宏: W S A G E T S E L E C T E R R O R,可用它返回高字位包含的錯誤信息。若應(yīng)用程序發(fā)現(xiàn)套接字上沒有產(chǎn)生任何錯誤,接著便應(yīng)調(diào)查到底是哪個網(wǎng)絡(luò)事件類型,造成了這條Wi n d o w s消息的觸發(fā)—具體的做法便是讀取l P a r a m之低字位的內(nèi)容。此時可使用另一個特殊的宏:W S A G E T S E L E C T E V E N T,用它返回l P a r a m的低字部分。
在程序清單8 - 5中,我們向大家演示了如何使用W S A A s y n c S e l e c t這種I / O模型,來實(shí)現(xiàn)窗口消息的管理。在源程序中,我們著重強(qiáng)調(diào)的是開發(fā)一個基本服務(wù)器應(yīng)用要涉及到的基本步驟,忽略了開發(fā)一個完整的Wi n d o w s應(yīng)用需要涉及到的大量編程細(xì)節(jié)。
程序清單8-5 WSAAsyncSelect服務(wù)器示范代碼
#define WM_SOCKET? WM_USER+1
#inlude <windows.h>
int WINAPI WinMain(HINSTANCE hInstance,HINSTANCE hPrevInstance,LPSTR ?lpCmdline,int nCmdShow)
{
?SOCKET listen;
?HWND window;
?//create a window? and assign the serverWinProc blew to it
?window = CreateWindow();
?//start winsock and create a socket
?
?WSAStarup(...);
?listen = Socket();
?//Bind the socket to port 5150
?// and begin listening for connection
?
?InternetAddr.sin_family = AF_INET;
?InternetAddr.sin_addr.s_addr=htonl(INADDR_ANY);
?InternetAddr.sin_port = htons(5150);
?bind(listen,(PSOCKETADDR)&InternetAddr,sizeof(InternetAddr));
?
?//set up window message notification on the new socket using the WM_SOCKET define above
?WSAAsyncSelect(listen,window,WM_SOCKET,FD_ACCEPT|FD_CLOSE);
?
?listen(listen,5);
?
?//translate and dispatch window messages
?//until the appliation terminates
}?????????????
BOOL CALLBACK ServerWinProc(HWND hDlg,WORD wMsg,WORD wParam,WORD lParam)
{
?SOCKET accept;
?switch(wMsg)
?{
??case?WM_PAINT:
?????break;
??case?WM_SOCKET:
?????//determine whether an error occured on the socket
?????//by using the WSAGETSELECTERROR() macro
?????
?????if(WSAGETSELECTERROR(lWparam))
?????{
??????//display the error and close the socket
??????closesocket(wParam);
??????break;
?????}
?????//determine what event occured on the socket
?????
?????switch(WSAGETSELECTEVENT(lParam)
?????{
??????case?FD_ACCEPT:
?????????//ACCEPT an incoming connection
?????????Accept = accept(wParam,NULL,NULL);
?????????
?????????//prepare accepted socket for read
?????????//write,and close notifation
?????????
?????????WSAAsyncSelect(Accept,hWnd,WM_SOCKET,FD_READ|FD_WRITE|FD_CLOSE);
??????case?FD_READ:
?????????//RECEIVE data from the socket in wParam
?????????break;
??????case?FD_WRITE:
?????????//THE socket in wParam is ready for sending data
?????????
?????????break;
??????case?FD_CLOSE:
?????????//THE connection is now closed
?????????closesocket(wParam);
?????????break;
?????????
?????}
?????break;
?}
?return TRUE;
}
最后一個特別有價值的問題是應(yīng)用程序如何對F D _ W R I T E事件通知進(jìn)行處理。只有在三
種條件下,才會發(fā)出F D _ W R I T E通知:
■ 使用c o n n e c t或W S A C o n n e c t,一個套接字首次建立了連接。
■ 使用a c c e p t或W S A A c c e p t,套接字被接受以后。
■ 若s e n d、W S A S e n d、s e n d t o或W S A S e n d To操作失敗,返回了W S A E W O U L D B L O C K錯
誤,而且緩沖區(qū)的空間變得可用因此,作為一個應(yīng)用程序,自收到首條F D _ W R I T E消息開始,便應(yīng)認(rèn)為自己必然能在一個套接字上發(fā)出數(shù)據(jù),直至一個s e n d、W S A S e n d、s e n d t o或W S A S e n d To返回套接字錯誤W S A E W O U L D B L O C K。經(jīng)過了這樣的失敗以后,要再用另一條F D _ W R I T E通知應(yīng)用程序再次發(fā)送數(shù)據(jù)。
????????????