• <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>
            春暖花開
            雪化了,花開了,春天來了
            posts - 149,comments - 125,trackbacks - 0
            轉(zhuǎn): 異步非阻塞套接字Winsock開發(fā)網(wǎng)絡通信程序的經(jīng)典入門
            摘自: http://hi.baidu.com/mcu%5Fspaces/blog/item/aee07a66ed816323ab184cdf.html

            對于許多初學者來說,網(wǎng)絡通信程序的開發(fā),普遍的一個現(xiàn)象就是覺得難以入手。許多概念,諸如:同步(Sync)/異步(Async),阻塞(Block)/非阻塞(Unblock)等,初學者往往迷惑不清,只知其所以而不知起所以然。


              異步方式指的是發(fā)送方不等接收方響應,便接著發(fā)下個數(shù)據(jù)包的通信方式;而同步指發(fā)送方發(fā)出數(shù)據(jù)后,等收到接收方發(fā)回的響應,才發(fā)下一個數(shù)據(jù)包的通信方式。

              阻塞套接字是指執(zhí)行此套接字的網(wǎng)絡調(diào)用時,直到成功才返回,否則一直阻塞在此網(wǎng)絡調(diào)用上,比如調(diào)用recv()函數(shù)讀取網(wǎng)絡緩沖區(qū)中的數(shù)據(jù),如果沒有數(shù)據(jù)到達,將一直掛在recv()這個函數(shù)調(diào)用上,直到讀到一些數(shù)據(jù),此函數(shù)調(diào)用才返回;而非阻塞套接字是指執(zhí)行此套接字的網(wǎng)絡調(diào)用時,不管是否執(zhí)行成功,都立即返回。比如調(diào)用recv()函數(shù)讀取網(wǎng)絡緩沖區(qū)中數(shù)據(jù),不管是否讀到數(shù)據(jù)都立即返回,而不會一直掛在此函數(shù)調(diào)用上。在實際Windows網(wǎng)絡通信軟件開發(fā)中,異步非阻塞套接字是用的最多的。平常所說的C/S(客戶端/服務器)結(jié)構(gòu)的軟件就是異步非阻塞模式的。

              對于這些概念,初學者的理解也許只能似是而非,我將用一個最簡單的例子說明異步非阻塞Socket的基本原理和工作機制。目的是讓初學者不僅對Socket異步非阻塞的概念有個非常透徹的理解,而且也給他們提供一個用Socket開發(fā)網(wǎng)絡通信應用程序的快速入門方法。操作系統(tǒng)是Windows 98(或NT4.0),開發(fā)工具是Visual C++6.0。

              MFC提供了一個異步類CAsyncSocket,它封裝了異步、非阻塞Socket的基本功能,用它做常用的網(wǎng)絡通信軟件很方便。但它屏蔽了Socket的異步、非阻塞等概念,開發(fā)人員無需了解異步、非阻塞Socket的原理和工作機制。因此,建議初學者學習編網(wǎng)絡通信程序時,暫且不要用MFC提供的類,而先用Winsock2     API,這樣有助于對異步、非阻塞Socket編程機制的理解。

              為了簡單起見,服務器端和客戶端的應用程序均是基于MFC的標準對話框,網(wǎng)絡通信部分基于Winsock2 API實現(xiàn)。
              先做服務器端應用程序。
              用MFC向?qū)ё鲆粋€基于對話框的應用程序SocketSever,注意第三步中不要選上Windwos Sockets選項。在做好工程后,創(chuàng)建一個SeverSock,將它設置為異步非阻塞模式,并為它注冊各種網(wǎng)絡異步事件,然后與自定義的網(wǎng)絡異步事件聯(lián)系上,最后還要將它設置為監(jiān)聽模式。在自定義的網(wǎng)絡異步事件的回調(diào)函數(shù)中,你可以得到各種網(wǎng)絡異步事件,根據(jù)它們的類型,做不同的處理。下面將詳細介紹如何編寫相關(guān)代碼。
              在SocketSeverDlg.h文件的類定義之前增加如下定義:

            #define     NETWORK_EVENT     WM_USER+166     file://定義網(wǎng)絡事件
               
            SOCKET ServerSock; file://服務器端Socket
            在類定義中增加如下定義:
            class CSocketSeverDlg : CDialog
            {
            public:
                   SOCKET ClientSock[CLNT_MAX_NUM]; file://存儲與客戶端通信的Socket的數(shù)組

                   /*各種網(wǎng)絡異步事件的處理函數(shù)*/
                   void OnClose(SOCKET CurSock);      file://對端Socket斷開
                   void OnSend(SOCKET CurSock);      file://發(fā)送網(wǎng)絡數(shù)據(jù)包
                   void OnReceive(SOCKET CurSock); file://網(wǎng)絡數(shù)據(jù)包到達
                   void OnAccept(SOCKET CurSock);     file://客戶端連接請求

                   BOOL InitNetwork();     file://初始化網(wǎng)絡函數(shù)
                   void OnNetEvent(WPARAM wParam, LPARAM lParam); file://異步事件回調(diào)函數(shù)
                               …
            };
                    
            在SocketSeverDlg.cpp文件中增加消息映射,其中OnNetEvent是異步事件回調(diào)函數(shù)名:
                   ON_MESSAGE(NETWORK_EVENT,OnNetEvent)
            定義初始化網(wǎng)絡函數(shù),在SocketSeverDlg.cpp文件的OnInitDialog()中調(diào)此函數(shù)即可。
            BOOL CSocketSeverDlg::InitNetwork()
            {
                   WSADATA wsaData;

                   //初始化TCP協(xié)議
                   BOOL ret = WSAStartup(MAKEWORD(2,2), &wsaData);
                   if(ret != 0)
                   {
                       MessageBox('初始化網(wǎng)絡協(xié)議失敗!');
                       return FALSE;
                   }

                   //創(chuàng)建服務器端套接字
                   ServerSock = socket(AF_INET, SOCK_STREAM, IPPROTO_TCP);
                   if(ServerSock == INVALID_SOCKET)
                   {
                       MessageBox('創(chuàng)建套接字失敗!');
                       closesocket(ServerSock);
                       WSACleanup();
                       return FALSE;
                   }

                   //綁定到本地一個端口上
                   sockaddr_in localaddr;
                   localaddr.sin_family = AF_INET;
                   localaddr.sin_port = htons(8888);     //端口號不要與其他應用程序沖突
                   localaddr.sin_addr.s_addr = 0;
                   if(bind(ServerSock ,(struct sockaddr*)&localaddr,sizeof(sockaddr))
                                                         = = SOCKET_ERROR)
                   {
                       MessageBox('綁定地址失敗!');
                       closesocket(ServerSock);
                       WSACleanup();
                       return FALSE;
                   }

                   //將SeverSock設置為異步非阻塞模式,并為它注冊各種網(wǎng)絡異步事件,其中m_hWnd      
                   //為應用程序的主對話框或主窗口的句柄
                   if(WSAAsyncSelect(ServerSock, m_hWnd, NETWORK_EVENT, FD_ACCEPT | FD_CLOSE | FD_READ | FD_WRITE) == SOCKET_ERROR)
                   {
                       MessageBox('注冊網(wǎng)絡異步事件失敗!');
                       WSACleanup();
                       return FALSE;
                   }
                   listen(ServerSock, 5); file://設置偵聽模式
                   return TRUE;
            }

            下面定義網(wǎng)絡異步事件的回調(diào)函數(shù)
            void CSocketSeverDlg::OnNetEvent(WPARAM wParam, LPARAM lParam)
            {
                   //調(diào)用Winsock API函數(shù),得到網(wǎng)絡事件類型
                   int iEvent = WSAGETSELECTEVENT(lParam);

                   //調(diào)用Winsock API函數(shù),得到發(fā)生此事件的客戶端套接字
                   SOCKET CurSock= (SOCKET)wParam;

                   switch(iEvent)
                   {
                       case FD_ACCEPT:         //客戶端連接請求事件
                           OnAccept(CurSock);
                           break;
                       case FD_CLOSE:          //客戶端斷開事件:
                           OnClose(CurSock);
                           break;
                       case FD_READ:           //網(wǎng)絡數(shù)據(jù)包到達事件
                           OnReceive(CurSock);
                           break;
                        case FD_WRITE:         //發(fā)送網(wǎng)絡數(shù)據(jù)事件
                           OnSend(CurSock);
                           break;
                        default: break;
                    }
            }
               

              以下是發(fā)生在相應Socket上的各種網(wǎng)絡異步事件的處理函數(shù),其中OnAccept傳進來的參數(shù)是服務器端創(chuàng)建的套接字,OnClose()、OnReceive()和OnSend()傳進來的參數(shù)均是服務器端在接受客戶端連接時新創(chuàng)建的用與此客戶端通信的Socket。
            void CSocketSeverDlg::OnAccept(SOCKET CurSock)
            {
                   //接受連接請求,并保存與發(fā)起連接請求的客戶端進行通信Socket
                   //為新的socket注冊異步事件,注意沒有Accept事件
            }

            void CSocketSeverDlg::OnClose(SOCET CurSock)
            {
                   //結(jié)束與相應的客戶端的通信,釋放相應資源
            }

            void CSocketSeverDlg::OnSend(SOCET CurSock)
            {
                   //在給客戶端發(fā)數(shù)據(jù)時做相關(guān)預處理
            }

            void CSocketSeverDlg::OnReceive(SOCET CurSock)
            {
                   //讀出網(wǎng)絡緩沖區(qū)中的數(shù)據(jù)包
            }       

                   
              用同樣的方法建立一個客戶端應用程序。初始化網(wǎng)絡部分,不需要將套接字設置為監(jiān)聽模式。注冊異步事件時,沒有FD_ACCEPT,但增加了FD_CONNECT事件,因此沒有OnAccept()函數(shù),但增加了OnConnect()函數(shù)。向服務器發(fā)出連接請求時,使用connect()函數(shù),連接成功后,會響應到OnConnect()函數(shù)中。下面是OnConnect()函數(shù)的定義,傳進來的參數(shù)是客戶端Socket和服務器端發(fā)回來的連接是否成功的標志。
            void CSocketClntDlg::OnConnect(SOCKET CurSock, int error)
            {
                   if(0 = = error)
                   {
                       if(CurSock = = ClntSock)
                       MessageBox('連接服務器成功!');
                   }
            }

              定義OnReceive()函數(shù),處理網(wǎng)絡數(shù)據(jù)到達事件;
              定義OnSend()函數(shù),處理發(fā)送網(wǎng)絡數(shù)據(jù)事件;
              定義OnClose()函數(shù),處理服務器的關(guān)閉事件。
                        
              以上就是用基于Windows消息機制的異步I/O模型做服務器和客戶端應用程序的基本方法。另外還可以用事件模型、重疊模型或完成端口模型,讀者可以參考有關(guān)書籍。
              在實現(xiàn)了上面的例子后,你將對Winsock編網(wǎng)絡通信程序的機制有了一定的了解。接下來你可以進行更精彩的編程, 不僅可以在網(wǎng)上傳輸普通數(shù)據(jù),而且還以傳輸語音、視頻數(shù)據(jù),你還可以自己做一個網(wǎng)絡資源共享的服務器軟件,和你的同學在實驗室的局域網(wǎng)里可以共同分享你的成果。

             

             

            同步服務器套接字掛起應用程序的執(zhí)行,直到套接字上接收到連接請求。同步服務器套接字不適用于在操作中大量使用網(wǎng)絡的應用程序,但它們可能適用于簡單的網(wǎng)絡應用程序。使用 BindListen 方法設置 Socket 以在終結(jié)點上偵聽之后,Socket 就可以隨時使用 Accept 方法接受傳入的連接請求了。應用程序被掛起,直到調(diào)用 Accept 方法時接收到連接請求。

            接收到連接請求時,Accept 返回一個與連接客戶端關(guān)聯(lián)的新 Socket 實例。下面的示例讀取客戶端數(shù)據(jù),在控制臺上顯示該數(shù)據(jù),然后將該數(shù)據(jù)回顯到客戶端。Socket 不指定任何消息協(xié)議,因此字符串“<EOF>”標記消息數(shù)據(jù)的結(jié)尾。它假定一個名為 listener 的 Socket 已初始化,并綁定到一個終結(jié)點。

            Console.WriteLine("Waiting for a connection...");
            Socket handler = listener.Accept();
            String data = null;

            while (true) {
                 bytes = new byte[1024];
                 int bytesRec = handler.Receive(bytes);
                 data += Encoding.ASCII.GetString(bytes,0,bytesRec);
                 if (data.IndexOf("<EOF>") > -1) {
                     break;
                 }
            }

            Console.WriteLine( "Text received : {0}", data);

            byte[] msg = Encoding.ASCII.GetBytes(data);
            handler.Send(msg);
            handler.Shutdown(SocketShutdown.Both);
            handler.Close();

            msdn官方說明:http://msdn2.microsoft.com/zh-cn/library/80z2essb(VS.80).aspx

            posted on 2009-07-16 15:56 Sandy 閱讀(2306) 評論(0)  編輯 收藏 引用 所屬分類: 網(wǎng)絡學習Windows Mobile
            久久亚洲AV成人出白浆无码国产| 久久精品国产半推半就| 九九热久久免费视频| 99久久精品国产毛片| 天堂无码久久综合东京热| 亚洲女久久久噜噜噜熟女| 国产亚洲欧美精品久久久| 日韩AV毛片精品久久久| 国产成人精品久久免费动漫| 久久亚洲国产精品五月天婷| 欧美喷潮久久久XXXXx| 久久国产三级无码一区二区| 伊人久久精品无码二区麻豆| 国产精品美女久久久久av爽| 久久AV无码精品人妻糸列| 国产一级持黄大片99久久| 狠狠色婷婷久久综合频道日韩| 久久高潮一级毛片免费| 久久亚洲美女精品国产精品| 欧美午夜A∨大片久久 | 国产99久久久久久免费看| 久久久久久久女国产乱让韩| 国产精久久一区二区三区| 国产精品9999久久久久| 亚洲国产精品无码久久98| 中文字幕久久精品 | 精品综合久久久久久98| 色综合久久中文字幕综合网| 久久青草国产手机看片福利盒子| 狠狠综合久久综合88亚洲| 久久频这里精品99香蕉久| 久久伊人影视| 综合久久给合久久狠狠狠97色 | 久久精品黄AA片一区二区三区| 青青草原综合久久大伊人导航| 久久精品成人影院| 久久精品国产亚洲Aⅴ蜜臀色欲| 99久久精品免费国产大片| 国产—久久香蕉国产线看观看| 99久久精品免费| 少妇被又大又粗又爽毛片久久黑人|