• <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>

            kenlistian

            厚積薄發(fā). 勤為槳,思為帆

               :: 首頁 :: 新隨筆 ::  :: 聚合  :: 管理 ::
              73 隨筆 :: 4 文章 :: 22 評論 :: 0 Trackbacks

               在網(wǎng)絡(luò)通訊中,socket處于阻塞模式運行時,其存在著超時處理。以下總結(jié)下在那些阻塞函數(shù)的處理方法。

            這里摘抄一段描述阻塞函數(shù)的描述,非常到位。

            所謂阻塞函數(shù),是指其完成指定的任務(wù)之前不允許程序調(diào)用另一個函數(shù),在Windows下還會阻塞本線程消息的發(fā)送。

            所謂非阻塞函數(shù),是指操作啟動之后,如果可以立即得到結(jié)果就返回結(jié)果,否則返回表示結(jié)果需要等待的錯誤信息,不等待任務(wù)完成函數(shù)就返回。

            首先,異步函數(shù)是非阻塞函數(shù);

            其次,獲取遠地信息的數(shù)據(jù)庫函數(shù)是阻塞函數(shù)(因此,WinSock提供了其異步版本);

            在Berkeley socket函數(shù)部分中,不涉及網(wǎng)絡(luò)I/O、本地端工作的函數(shù)是非阻塞函數(shù);

            在Berkeley socket函數(shù)部分中,網(wǎng)絡(luò)I/O的函數(shù)是可阻塞函數(shù),也就是它們可以阻塞執(zhí)行,也可以不阻塞執(zhí)行。這些函數(shù)都使用了一個socket,如果它們使用的socket是阻塞的,則這些函數(shù)是阻塞函數(shù);如果它們使用的socket是非阻塞的,則這些函數(shù)是非阻塞函數(shù)

                其實說明阻塞還是非阻塞也是我們可以設(shè)置相關(guān)。這里主要講解下處于阻塞模式下的超時處理。

            1.在我們直接調(diào)用socket創(chuàng)建時,如果不進行特意聲明的話,創(chuàng)建的socket都是阻塞的。這樣當我們調(diào)用accept,recv時,將有可能“block”,如果想設(shè)置為非阻塞,則方法有調(diào)用fcntl,select,WSAAsynSelect 來改變socket的阻塞

            hsocket = socket(AF_INET, SOCK_STREAM, 0)

            fcntl(hsocket, F_SETFL, 0_NONBLOCK);

             注意:

                其中fcntl是Unix系統(tǒng)環(huán)境中使用的,使用ioctl()函數(shù)和fcntl()函數(shù)實現(xiàn)對套接字的控制,而在Windows系統(tǒng)中則應(yīng)使用ioctlsocket()函數(shù)。

             Ioctl和fcntl的區(qū)別是:

              ioctl   -   control   device  
              ioctl()   performs   a   variety   of   control   functions     on     devices  
                        and   STREAMS.     For   non-STREAMS   files,   the   functions   performed  
                        by   this   call   are   device-specific   control   functions.     request  
                        and     an   optional   third   argument   with   varying   type   are   passed  
                        to   the   file   designated   by   fildes   and   are   interpreted   by     the  
                        device   driver.  
                The   fcntl()   function   provides   control   of   open   file   descriptors.   It   is   similar   to   ioctl().

               ( 這些帶著unix的體味的函數(shù),看著就頭大。這個我是摘自某個文檔,設(shè)置超時應(yīng)該采用ioctlsocket。)

            1.調(diào)用MFC的CAsyncSocket和CSocket類

              MFC提供了兩個類CAsyncSocket和CSocket來封裝WinSock API,

              CAsyncSocket在較低層次上封裝了WinSock API,缺省情況下,使用該類創(chuàng)建的socket是非阻塞的socket,所有操作都會立即返回,如果沒有得到結(jié)果,返回WSAEWOULDBLOCK,表示是一個阻塞操作。

              CSocket建立在CAsyncSocket的基礎(chǔ)上,是CAsyncSocket的派生類。也就是缺省情況下使用該類創(chuàng)建的socket是非阻塞的socket,但是CSocket的網(wǎng)絡(luò)I/O是阻塞的,它在完成任務(wù)之后才返回。CSocket的阻塞不是建立在“阻塞”socket的基礎(chǔ)上,而是在“非阻塞”socket上實現(xiàn)的阻塞操作,在阻塞期間,CSocket實現(xiàn)了本線程的消息循環(huán),因此,雖然是阻塞操作,但是并不影響消息循環(huán),即用戶仍然可以和程序交互。(即程序不會freeze)。

              其中設(shè)置超時函數(shù)如下:

            CAsyncSocket::SetSockOpt(   int   nOptionName,   const   void*   lpOptionValue,   int   nOptionLen,   int   nLevel   =   SOL_SOCKET   );  
              nOptionName用SO_SNDTIMEO   or   SO_RCVTIMEO。  

            2.采用select處理超時

            int select(int nfds, fd_set FAR* readfds, fd_set FAR* writefds,fd_set FAR*exceptfds, const struct timeval FAR* timeout)

            其中在windows中,其nfds可以可以設(shè)置為0,沒有實際意義。

            fd_set  fdR;
            struct  timeval timeout = ..; //設(shè)置超時時間
            ...
            for(;;) {
                    FD_ZERO(&fdR);
                    FD_SET(sockfd, &fdR);
                    switch (select(sockfd + 1, &fdR, NULL, &timeout)) {
                            case -1:
                                //錯誤,需要關(guān)閉端口。。。
                            case 0:

                               //  timeout 處理

                            default:
                                    if (FD_ISSET(sockfd)) { 

                                        //或讀寫操作或Accept()操作,按你設(shè)置處理。
                                    }
                    }
            }

            注意的是:

                 由于Windows Sockets 某些函數(shù)在接口上雖然與Unix Sockets一致,但是它們的內(nèi)部實現(xiàn)卻不一樣,例如,在函數(shù)select()的參數(shù)中,Unix Sockets實現(xiàn)套接字集合使用的是位掩碼,但在Windows Sockets中卻是使用一個SOCKET的數(shù)組。雖然套接字的集合仍由fd_set類型表示,但在Unix Sockets 源文件中直接修改fd_set結(jié)構(gòu)的代碼在Windows Sockets環(huán)境下將不能正常工作。故fd_set在微軟中則采用FD_XXX宏處理。

            3.采用WSAsyncSelect() 

               這個是消息事件模式來處理的,通過其中參數(shù)句柄返回一個消息,在自定義消息中處理。

             

            4.采用setsockopt設(shè)置超時

            int PASCAL FAR setsockopt( SOCKET s, int level, int optname,
            const char FAR* optval, int optlen);

            s:標識一個套接口的描述字。
            level:選項定義的層次;目前僅支持SOL_SOCKET和IPPROTO_TCP層次。
            optname:需設(shè)置的選項。
            optval:指針,指向存放選項值的緩沖區(qū)。
            optlen:optval緩沖區(qū)的長度。

                 setsockopt()函數(shù)用于任意類型、任意狀態(tài)套接口的設(shè)置選項值。盡管在不同協(xié)議層上存在選項,但本函數(shù)僅定義了最高的“套接口”層次上的選項。選項影響套接口的操作,諸如加急數(shù)據(jù)是否在普通數(shù)據(jù)流中接收,廣播數(shù)據(jù)是否可以從套接口發(fā)送等等。
              有兩種套接口的選項:

                  一種是布爾型選項,允許或禁止一種特性;

                  一種是整形或結(jié)構(gòu)選項。允許一個布爾型選項,則將optval指向非零整形數(shù);禁止一個選項optval指向一個等于零的整形數(shù)。

                    對于布爾型選項,optlen應(yīng)等于sizeof(int);對其他選項,optval指向包含所需選項的整形數(shù)或結(jié)構(gòu),而optlen則為整形數(shù)或結(jié)構(gòu)的長度。

                  SO_LINGER選項用于控制下述情況的行動:套接口上有排隊的待發(fā)送數(shù)據(jù),且closesocket()調(diào)用已執(zhí)行。參見closesocket()函數(shù)中關(guān)于SO_LINGER選項對closesocket()語義的影響。應(yīng)用程序通過創(chuàng)建一個linger結(jié)構(gòu)來設(shè)置相應(yīng)的操作特性。

                  這個setsockopt的水也太深了,對于一般運用大致運用就行,主要是其中參數(shù)太多,只需要了解幾個就可以了,至于想了解更多,則讀msdn吧,以及相關(guān)的文檔吧,不過感覺這些東西純粹就是個技術(shù)指標細節(jié),不需要動腦筋卻需要了解的一個方面,說白了是這些都是技術(shù)活而不是腦力活。

            常見的命令:

            //確定套接字自動讀入的數(shù)據(jù)量

            #define FIONREAD _IOR(''''f'''', 127, u_long) /* get # bytes to read */

            //允許或禁止套接字的非阻塞模式,允許為非0,禁止為0

            #define FIONBIO _IOW(''''f'''', 126, u_long) /* set/clear non-blocking i/o */

            //確定是否所有帶外數(shù)據(jù)都已被讀入

            #define SIOCATMARK _IOR(''''s'''', 7, u_long) /* at oob mark? */

            設(shè)置接受超時

            posted on 2007-12-27 18:04 kenlistian 閱讀(7599) 評論(0)  編輯 收藏 引用

            只有注冊用戶登錄后才能發(fā)表評論。
            網(wǎng)站導(dǎo)航: 博客園   IT新聞   BlogJava   博問   Chat2DB   管理


            久久人人爽人人爽AV片| 亚洲国产精品无码久久久不卡| 久久91亚洲人成电影网站| 国产ww久久久久久久久久| 久久综合色老色| 久久亚洲精品中文字幕三区| 日日狠狠久久偷偷色综合0| 国产精品99久久久精品无码| 精品久久久久一区二区三区| 久久精品国产亚洲AV蜜臀色欲| 久久精品国产一区二区三区日韩| 18禁黄久久久AAA片| 精品人妻伦一二三区久久| 久久久一本精品99久久精品66 | 久久婷婷五月综合色奶水99啪| 色综合久久中文字幕无码| 国产精品久久永久免费| 亚洲人成网站999久久久综合 | 午夜精品久久久久久99热| 久久免费视频6| 久久午夜电影网| www.久久热| 精品国际久久久久999波多野| 久久99热这里只频精品6| 久久露脸国产精品| 久久精品国产第一区二区| 99久久精品国产一区二区| 青青草原综合久久大伊人精品| 精品久久久噜噜噜久久久| 亚洲国产精品无码成人片久久| 三级三级久久三级久久 | 欧洲成人午夜精品无码区久久| 久久无码高潮喷水| 77777亚洲午夜久久多人| 精品国产99久久久久久麻豆| 99蜜桃臀久久久欧美精品网站| 久久无码专区国产精品发布| 亚洲国产精品成人久久| 亚洲AV日韩AV永久无码久久| 人妻丰满AV无码久久不卡| 久久久久久免费一区二区三区|