青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

yehao's Blog

Winsock異步模式I/O模型WSAEventSelect的使用及FD_WRITE事件的觸發機制

http://oliver258.blog.51cto.com/750330/423813
1.Winsock同步阻塞方式的問題

在異步非阻塞模式下,像accept(WSAAccept),recv(recv,WSARecv,WSARecvFrom)等這樣的winsock函數調用后馬上返回,而不是等待可用的連接和數據。在阻塞模式下,server往往這樣等待client的連接:

while(TRUE)
{
    
//wait for a connection
     ClientSocket = accept(ListenSocket,NULL,NULL);
    if(ClientSocket == INVALID_SOCKET)
     {
         ERRORHANDLE
     }
     else
         DoSomething
}

上述代碼簡單易用,但是缺點在于如果沒有client連接的話,accept一直不會返回,而且即使accept成功創建會話套接字,在阻塞方式下,C/S間傳輸數據依然要將recv,send這類函數放到一個循環中,反復等待數據的到來,這種輪詢的方式效率很低。為此,Winsock提供了異步模式的5種I/O模型,這些模型會在有網絡事件(如socket收到連接請求,讀取收到的數據請求等等)時通過監視集合(select),事件對象(WSAEventSelect,重疊I/O),窗口消息(WSAAsyncSelect),回調函數(重疊I/O),完成端口的方式通知程序,告訴我們可以“干活了”,這樣的話大大的提高了執行效率,程序只需枕戈待旦,兵來將擋水來土掩,通知我們來什么網絡事件,就做相應的處理即可。

2.WSAEventSelect模型的使用

WSAEventSelect模型其實很簡單,就是將一個事件對象同一個socket綁定并設置要監視的網絡事件,當這個socket有我們感興趣的網絡事件到達時,ws2_32.dll就將這個事件對象置為受信狀態(signaled),在程序中等待這個事件對象受信后,根據網絡事件類型做不同的處理。如果對線程同步機制有些了解的話,這個模型很容易理解,其實就是CreateEvent系列的winsock版。

無代碼無真相,具體API的參數含義可以參考MSDN,MSDN上對這個模型解釋的非常詳盡。
// 使用WSAEventSelect的代碼片段,百度貼吧字數限制,略去錯誤處理及界面操作
    // 為了能和多個客戶端通信,使用兩個數組分別記錄所有通信的會話套接字
    // 以及和這些套接字綁定的事件對象
    // WSA_MAXIMUM_WAIT_EVENTS是系統內部定義的宏,值為64

     SOCKET g_sockArray[WSA_MAXIMUM_WAIT_EVENTS];
     WSAEVENT g_eventArray[WSA_MAXIMUM_WAIT_EVENTS];

    // 事件對象計數器
    int nEventTotal = 0;

    // 創建監聽套接字sListenSocket,并對其綁定端口和本機ip 代碼省去
     ........

    // 設置sListenSocket為監聽狀態
     listen(sListenSocket, 5);

    // 創建事件對象,同CreateEvent一樣,event創建后被置為非受信狀態
     WSAEVENT acceptEvent = WSACreateEvent();

    // 將sListenSocket和acceptEvent關聯起來
    // 并注冊程序感興趣的網絡事件FD_ACCEPT 和 FD_CLOSE
    // 這里由于是在等待客戶端connect,所以FD_ACCEPT和FD_CLOSE是我們關心的
     WSAEventSelect(sListenSocket, acceptEvent, FD_ACCEPT|FD_CLOSE);

    // 添加到數組中
     g_eventArray[nEventTotal] = acceptEvent;
     g_sockArray[nEventTotal] = sListenSocket;    
     nEventTotal++;

    // 處理網絡事件
    while(TRUE)
     {
        // 由于第三個參數是 FALSE,所以 g_eventArray 數組中有一個元素受信 WSAWaitForMultipleEvents 就返回
        // 注意 返回值 nIndex 減去 WSA_WAIT_EVENT_0 的值才是受信事件在數組中的索引。
        // 如果有多個事件同時受信,函數返回索引值最小的那個。
        // 由于第四個參數指定 WSA_INFINITE ,所以沒有對象受信時會無限等待。
        int nIndex = WSAWaitForMultipleEvents(nEventTotal, g_eventArray, FALSE, WSA_INFINITE, FALSE);

        // 取得受信事件在數組中的位置。
         nIndex = nIndex - WSA_WAIT_EVENT_0;

        // 判斷受信事件 g_eventArray[nIndex] 所關聯的套接字 g_sockArray[nIndex] 的網絡事件類型
        // MSDN中說如果事件對象不是NULL, WSAEnumNetworkEvents 會幫咱重置該事件對象為非受信,方便等待新的網絡事件
        // 也就是說這里的 g_eventArray[nIndex] 變為非受信了,所以程序中不用再調用 WSAResetEvent了
        // WSANETWORKEVENTS 這個結構中 記錄了關于g_sockArray[nIndex] 的網絡事件和錯誤碼
         WSANETWORKEVENTS event;
         WSAEnumNetworkEvents(g_sockArray[nIndex], g_eventArray[nIndex], &event);

        // 這里處理 FD_ACCEPT 這個網絡事件
        // event.lNetWorkEvents中記錄的是網絡事件類型
        if(event.lNetworkEvents & FD_ACCEPT)
         {
            // event.iErrorCode是錯誤代碼數組,event.iErrorCode[FD_ACCEPT_BIT] 為0表示正常
            if(event.iErrorCode[FD_ACCEPT_BIT] == 0)
             {
                // 連接數超過系統約定的范圍
                if(nEventTotal > WSA_MAXIMUM_WAIT_EVENTS)
                 {    
                     ErrorHandle...
                    continue;
                 }
                // 沒有問題就可以accept了
                 SOCKET sAcceptSocket = accept(g_sockArray[nIndex], NULL, NULL);

                // 新建的會話套接字用于C/S間的數據傳輸,所以這里關心FD_READ,FD_CLOSE,FD_WRITE三個事件
                 WSAEVENT event = WSACreateEvent();
                 WSAEventSelect(sAcceptSocket, event, FD_READ|FD_CLOSE|FD_WRITE);

                // 將新建的會話套接字及與該套接字關聯的事件對象添加到數組中
                 g_eventArray[nEventTotal] = event;
                 g_sockArray[nEventTotal] = sAcceptSocket;    
                 nEventTotal++;
             }

            //event.iErrorCode[FD_ACCEPT_BIT] != 0 出錯了
             else
             {
                 ErrorHandle...
                break;
             }
         }


        // 這里處理FD_READ通知消息,當會話套接字上有數據到來時,ws2_32.dll會記錄該事件
         else if(event.lNetworkEvents & FD_READ)    
         {
            if(event.iErrorCode[FD_READ_BIT] == 0)
             {
                int nRecv = recv(g_sockArray[nIndex], buffer, nbuffersize, 0);
                if(nRecv == SOCKET_ERROR)                
                 {
                    // 為了程序更魯棒,這里要特別處理一下WSAEWOULDBLOCK這個錯誤
                    // MSDN中說在異步模式下有時recv(WSARecv)讀取時winsock的緩沖區中沒有數據,導致recv立即返回
                    // 錯誤碼就是 WSAEWOULDBLOCK,但這時程序并沒有出問題,在有新的數據到來時recv還是可以讀到數據的
                    // 所以不能僅僅根據recv返回值是SOCKET_ERROR就認為出錯從而執行退出操作。
                    //如果錯誤碼不是WSAEWOULDBLOCK 則表示真的出錯了
                    if(WSAGetLastError() != WSAEWOULDBLOCK)
                     {    
                         ErrorHandle...
                        break;
                     }
                 }
                // 沒出任何錯誤
                 else
                     DoSomeThing...
             }

            // event.iErrorCode[FD_READ_BIT] != 0
             else
             {
                 ErrorHandle...
                break;
             }
         }


        // 這里處理FD_CLOSE通知消息
        // 當連接被關閉時,ws2_32.dll會記錄FD_CLOSE事件
         else if(event.lNetworkEvents & FD_CLOSE)
         {
            if(event.iErrorCode[FD_CLOSE_BIT] == 0)
             {
                 closesocket(g_sockArray[nIndex]);
                                 // 將g_sockArray[nIndex]從g_sockArray數組中刪除
                for(int j=nIndex; j<nEventTotal-1; j++)
                     g_sockArray[j] = g_sockArray[j+1];    
                 nEventTotal--;
             }

            // event.iErrorCode[FD_CLOSE_BIT] != 0
             else
             {
                 ErrorHandle...
                break;
             }
         }


        // 處理FD_WRITE通知消息
        // FD_WRITE事件其實就是ws2_32.dll告訴我們winsock的緩沖區已經ok,可以發送數據了
        // 同recv一樣,send(WSASend)的返回值也要對SOCKET_ERROR特殊判斷一下 WSAEWOULDBLOCK
         else if(event.lNetworkEvents & FD_WRITE)        
         {
            //關于FD_WRITE的討論在下面。
         }
     }

    // 如果出錯退出循環 則將套接字數組中的套接字與事件對象統統解除關聯
    // 給WSAEventSelect的最后一個參數傳0可以解除g_sockArray[nIndex]和g_eventArray[nIndex]的關聯
    // 解除關聯后,ws2_32.dll將停止記錄g_sockArray[nIndex]這個套接字的網絡事件
    // 退出時還要關閉所有創建的套接字和事件對象

    for(int i = 0; i < nEventTotal; i++)
     {
         WSAEventSelect(g_sockArray[i], g_eventArray[i], 0);    
         closesocket(g_sockArray[i]);
         WSACloseEvent(g_eventArray[i]);
     }

     nEventTotal = 0;

     DoSomethingElse....

 

3.FD_WRITE 事件的觸發

常見的網絡事件中,FD_ACCEPT和FD_READ都比較好理解。一開始我唯一困惑的就是FD_WRITE,搞不清楚到底什么時候才會觸發這個網絡事件,后來仔細查了MSDN又看了一些文章并測試了下,終于搞懂了FD_WRITE的觸發機制。

下面是MSDN中對FD_WRITE觸發機制的解釋:

The FD_WRITE network event is handled slightly differently. An FD_WRITE network event is recorded when a socket is first connected with connect/WSAConnect or accepted with accept/WSAAccept, and then after a send fails with WSAEWOULDBLOCK and buffer space becomes available. Therefore, an application can assume that sends are possible starting from the first FD_WRITE network event setting and lasting until a send returns WSAEWOULDBLOCK. After such a failure the application will find out that sends are again possible when an FD_WRITE network event is recorded and the associated event object is set

FD_WRITE事件只有在以下三種情況下才會觸發

①client 通過connect(WSAConnect)首次和server建立連接時,在client端會觸發FD_WRITE事件

②server通過accept(WSAAccept)接受client連接請求時,在server端會觸發FD_WRITE事件

③send(WSASend)/sendto(WSASendTo)發送失敗返回WSAEWOULDBLOCK,并且當緩沖區有可用空間時,則會觸發FD_WRITE事件

①②其實是同一種情況,在第一次建立連接時,C/S端都會觸發一個FD_WRITE事件。

主要是③這種情況:send出去的數據其實都先存在winsock的發送緩沖區中,然后才發送出去,如果緩沖區滿了,那么再調用send(WSASend,sendto,WSASendTo)的話,就會返回一個 WSAEWOULDBLOCK的錯誤碼,接下來隨著發送緩沖區中的數據被發送出去,緩沖區中出現可用空間時,一個 FD_WRITE 事件才會被觸發,這里比較容易混淆的是 FD_WRITE 觸發的前提是 緩沖區要先被充滿然后隨著數據的發送又出現可用空間,而不是緩沖區中有可用空間,也就是說像如下的調用方式可能出現問題

else if(event.lNetworkEvents & FD_WRITE)
{
    if(event.iErrorCode[FD_WRITE_BIT] == 0)
     {
         send(g_sockArray[nIndex], buffer, buffersize);
         ....
     }
     else
     {
     }
}

問題在于建立連接后 FD_WRITE 第一次被觸發, 如果send發送的數據不足以充滿緩沖區,雖然緩沖區中仍有空閑空間,但是 FD_WRITE 不會再被觸發,程序永遠也等不到可以發送的網絡事件。

基于以上原因,在收到FD_WRITE事件時,程序就用循環或線程不停的send數據,直至send返回WSAEWOULDBLOCK,表明緩沖區已滿,再退出循環或線程。當緩沖區中又有新的空閑空間時,FD_WRITE 事件又被觸發,程序被通知后又可發送數據了。

上面代碼片段中省略的對 FD_WRITE 事件處理

 

else if(event.lNetworkEvents & FD_WRITE)
{
    if(event.iErrorCode[FD_WRITE_BIT] == 0)
     {
        while(TRUE)
         {
            // 得到要發送的buffer,可以是用戶的輸入,從文件中讀取等
             GetBuffer....
            if(send(g_sockArray[nIndex], buffer, buffersize, 0) == SOCKET_ERROR)
             {
                // 發送緩沖區已滿
                if(WSAGetLastError() == WSAEWOULDBLOCK)
                    break;
                 else
                     ErrorHandle...
             }
         }
     }
     else
     {
         ErrorHandle..
        break;
     }
}

 

 

P.S.

1.WSAWaitForMultipleEvents內部調用的還是WaitForMulipleObjectsEx,MSDN中說使用WSAEventSelect模型等待時是不占cpu時間的,這也是效率比阻塞winsock高的原因。

2.WSAAsycSelect的用法和WSAEventSelect類似,不同的是網絡事件的通知是以windows消息的方式發送到指定的窗口。

 

posted on 2011-08-18 16:04 厚積薄發 閱讀(3431) 評論(0)  編輯 收藏 引用 所屬分類: 網絡編程

導航

<2025年11月>
2627282930311
2345678
9101112131415
16171819202122
23242526272829
30123456

統計

常用鏈接

留言簿

隨筆分類

文章分類

文章檔案

搜索

最新評論

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            欧美日韩一级视频| 久久综合免费视频影院| 亚洲欧美综合v| 欧美日韩另类视频| 亚洲精品中文字| 99国产精品国产精品久久| 欧美激情国产日韩| 99精品欧美一区| 亚洲综合精品| 激情国产一区| 日韩视频免费观看| 国产欧美日韩视频在线观看| 久久九九国产精品| 久热精品视频在线| 在线亚洲美日韩| 午夜一区在线| 亚洲欧美日韩综合| 麻豆成人在线播放| 亚洲综合视频网| 欧美母乳在线| 美女国内精品自产拍在线播放| 母乳一区在线观看| 久久精品成人欧美大片古装| 欧美美女bbbb| 欧美国内亚洲| 一区在线免费观看| 欧美一区二区视频97| 免费观看日韩| 欧美国产在线电影| 国产字幕视频一区二区| 国产视频在线观看一区二区三区| 亚洲欧洲日韩女同| 国产色视频一区| 亚洲欧美美女| 久久精品视频在线播放| 国产精品久久久久久久电影| 宅男噜噜噜66国产日韩在线观看| 亚洲国产欧美一区二区三区同亚洲 | 亚洲人精品午夜| 欧美大片免费观看| 亚洲国产精品一区在线观看不卡| 在线观看日韩专区| 蜜月aⅴ免费一区二区三区| 欧美gay视频| 99国产精品国产精品久久| 欧美不卡一区| 亚洲一二三区视频在线观看| 欧美一区二区高清在线观看| 狠狠色丁香婷综合久久| 久久久久.com| 日韩一级黄色片| 久久久久久91香蕉国产| 亚洲人成在线观看网站高清| 国产精品一区二区久久国产| 麻豆成人在线播放| 亚洲一区二区三区精品动漫| 免费试看一区| 久久不射电影网| 亚洲无限乱码一二三四麻| 激情五月综合色婷婷一区二区| 欧美日韩精品久久| 免费在线一区二区| 久久精品一区二区国产| 亚洲网站啪啪| 一本色道久久综合亚洲精品高清| 禁断一区二区三区在线| 另类春色校园亚洲| 亚洲欧美www| 中文在线资源观看网站视频免费不卡 | 久久精品欧美日韩| 欧美呦呦网站| 久久精品免费| 久久男人av资源网站| 午夜久久99| 亚洲欧美日韩精品| 一区二区三区你懂的| 欧美国产亚洲另类动漫| 欲色影视综合吧| 亚洲成人在线免费| 狠狠色狠狠色综合人人| 国产日产精品一区二区三区四区的观看方式| 久久久精品一区| 久久九九精品99国产精品| 亚洲一级在线观看| 午夜国产欧美理论在线播放| 亚洲视频在线一区| 亚洲精品久久久久久久久| 亚洲欧洲精品一区| 亚洲国产日韩美| 夜夜爽av福利精品导航| 国产精品99久久久久久宅男| 日韩一区二区福利| 亚洲一卡久久| 亚洲国产乱码最新视频| 亚洲精品国产精品国自产观看| 亚洲精品日韩久久| 在线视频欧美日韩精品| 欧美一区二区啪啪| 久久尤物视频| 国产精品日韩一区二区三区| 极品中文字幕一区| 亚洲香蕉成视频在线观看| 久久精品国产清高在天天线 | 一本色道久久88亚洲综合88| 99精品国产热久久91蜜凸| 99re热这里只有精品免费视频| 亚洲少妇最新在线视频| 欧美在线啊v一区| 亚洲精品美女在线观看| 欧美一级理论性理论a| 老司机aⅴ在线精品导航| 欧美国产先锋| 国内成人精品一区| 一区二区三区产品免费精品久久75| 亚洲欧美日韩成人| 亚洲国产高潮在线观看| 欧美在线日韩| 国产精品国产三级国产aⅴ浪潮 | 亚洲精品欧美专区| 欧美一区二区福利在线| 欧美人与禽猛交乱配视频| 精品va天堂亚洲国产| 欧美一级电影久久| 99综合电影在线视频| 欧美精品午夜视频| 原创国产精品91| 老司机67194精品线观看| 久久er精品视频| 国产在线视频欧美| 久久久www成人免费无遮挡大片| 日韩网站在线观看| 国产精品a级| 亚洲欧美网站| 久久精品国产一区二区三区免费看| 欧美视频中文字幕在线| 欧美在线看片| 久久九九免费| 最近中文字幕日韩精品| a4yy欧美一区二区三区| 在线观看三级视频欧美| 久久国产主播| 欧美大片91| 亚洲国产精品va在线观看黑人| 久久综合久久美利坚合众国| 亚洲毛片视频| 国产亚洲精品高潮| 国产精品日韩精品欧美精品| 久久久国产精品亚洲一区| 久久嫩草精品久久久久| 夜夜爽夜夜爽精品视频| 亚洲欧美中文字幕| 亚洲激情在线观看| 亚洲欧美在线高清| 亚洲激情社区| 亚洲欧美日韩国产综合精品二区| 在线日本成人| 亚洲欧美日韩在线一区| 亚洲国产精品久久久久婷婷884 | 欧美精品v国产精品v日韩精品| 亚洲欧美日韩综合aⅴ视频| 欧美韩日一区| 免费在线视频一区| 亚洲大片在线| 一区二区在线观看av| 亚洲免费视频中文字幕| 在线视频你懂得一区| 欧美精品18| 亚洲日本va在线观看| 亚洲精品在线观看视频| 久久香蕉国产线看观看av| 久久精品麻豆| 国产日韩成人精品| 亚洲欧美国产77777| 久久aⅴ国产紧身牛仔裤| 国产精品夜夜夜| 午夜久久影院| 欧美高清视频| 激情久久久久久久| 久久夜色精品国产噜噜av| 欧美国产日本高清在线| 亚洲欧洲精品一区二区三区波多野1战4 | 亚洲综合99| 国产亚洲成av人片在线观看桃| 欧美在线观看视频一区二区| 久久久一区二区| 亚洲免费久久| 国产精品国产三级国产普通话蜜臀| 亚洲午夜一级| 国产午夜精品久久久久久久| 欧美主播一区二区三区| 亚洲国产精品一区二区第一页 | 国产原创一区二区| 欧美激情一区二区三区四区| 国产日本精品| 欧美日韩国产欧美日美国产精品| 国产精品99久久99久久久二8| 免费观看不卡av| 亚洲欧美激情一区二区| 影音先锋亚洲一区| 国产亚洲精品aa午夜观看|