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

kenlistian

厚積薄發. 勤為槳,思為帆

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

未命名

在其中,要注意的是:

  1.關于服務端在客戶端連接之前

      如果沒有客戶端連接時,在調用accept()時程序將會出現freeze,即阻塞,而一旦有客戶端連接過來,accept將會新建一Socket與客戶端的Socket相通,原先Socket繼續進入監聽狀態,等待他人的連接要求。
     該函數調用成功返回一個新產生的Socket對象,否則返回INVALID_SOCKET,該新socket就是一個和一個客戶端對話的套接字。有點類似孫悟空對陣天兵天將時,當遇到某個具體敵手來,拔出一根毫毛變出一個孫行者去應付,再來再拔毫毛一樣。accept()定義如下:
SOCKET PASCAL FAR accept( SCOKET s, struct sockaddr FAR *addr,int FAR *addrlen );
s:Socket的識別碼;
addr:存放來連接的客戶端的地址;
addrlen:addr的長度

  當客戶端連接上后一直沒有斷開情況下,如果連接越來越多時,則創建的Socket也越多,其最大上限在listen中已經設置。

2.關于服務端的accept()使用

  accept過后才是真正的和客戶端進行交互,在accept時,由于程序會freeze,在調用accept時有多種方法,其中方法有:

*事件處理模式:

     通過WSAAsyncSelect()函數,其異步通知有accept信號來,然后在一個窗體自定義事件中處理accept信號。   

   如下在listen()之后調用:

        WSAAsyncSelect(m_hSocket, m_hWnd, WM_CLIENT_ACCEPT,FD_ACCEPT);  //wm_xxx_xxz自定義消息。

  這樣在構建的自定義消息中處理accept()連接請求。如下,OnAccept()單元

       LRESULT CPublicNetSoftDlg::OnAccept(WPARAM wParam,LPARAM lParam)
       {

             。。。。
               if(WSAGETSELECTEVENT(lParam) == FD_ACCEPT)//如果
                {
                         Client = accept(ServerSocket,(LPSOCKADDR)&m_sockServerAddr,0);

                        if (Client == INVALID_SOCKET) 
                            return 0L;
                }

            。。。。。
    }

*線程處理模式:將accept放在線程中讓其freeze,一旦來了連接,則自然從freeze中出來進行處理下一步。下面就是直接把accetp放在線程中處于等待狀態。

//連接請求隊列長度為1,即只允許有一個請求,若有多個請求, 則出現錯誤,給出錯誤代碼WSAECONNREFUSED。
listen(sock,1);
//開啟線程避免主程序的阻塞
AfxBeginThread(Server,NULL);
……

//處理線程,等待客戶端連接
UINT Server(LPVOID lpVoid)
{
……
   int nLen = sizeof(SOCKADDR);
   connSocket = accept(ListSocket,(LPSOCKADDR)& sockin,(LPINT)& nLen);
   ……
    WSAAsyncSelect(connSocket,
                 m_hWnd,
                 WM_SOCKET_MSG,
                 FD_READ|FD_CLOSE);
    return 1;
}
  把accept()放到線程中去是因為在執行到該函數時如沒有客戶連接請求到來,服務器就會停在accept語句上處于等待阻塞,這勢必會引起進程的阻塞,雖然也可以通過設置套接字為非阻塞方式使在沒有客戶等待時可以使accept()函數調用立即返回,但這種輪詢套接字的方式會使CPU處于忙等待方式,從而降低程序的運行效率大大浪費系統資源(我覺得做法很多,暫不考慮非阻塞情況)。
      在阻塞工作方式,為其單獨開辟一個子線程,將其阻塞控制在子線程范圍內而不會造成整個應用程序的阻塞。對于網絡事件的響應顯然要采取異步選擇機制,只有采取這種方式才可以在由網絡對方所引起的不可預知的網絡事件發生時能馬上在進程中做出及時的響應處理,而在沒有網絡事件到達時則可以處理其他事件,這種效率是很高的。前面那段代碼中的WSAAsyncSelect()函數便是實現網絡事件異步選擇的核心函數。
    第4個參數注冊應用程序關心的網絡事件,在這里通過FD_READ|FD_CLOSE指定了網絡讀和網絡斷開兩種事件,當這種事件發生時變會發出由第三個參數指定的自定義消息 WM_SOCKET_MSG,接收該消息的窗口通過第二個參數指定其句柄。

其響應函數如下:

void CNetServerView::OnSocket(WPARAM wParam,LPARAM lParam)
{
    int iReadLen=0;
   int message=lParam & 0x0000FFFF;
   switch(message)
   {
     case FD_READ:     //讀事件發生。此時有字符到達,需要進行接收處理
        char cDataBuffer[MTU*10];
        //通過套接字接收信息
        iReadLen = recv(newskt,cDataBuffer,MTU*10,0);
       //將信息保存到文件
        if(!file.Open("ServerFile.txt",CFile::modeReadWrite))
             file.Open("E:ServerFile.txt",
                 CFile::modeCreate|CFile::modeReadWrite);
         file.SeekToEnd();
         file.Write(cDataBuffer,iReadLen);
         file.Close();
         break;
         case FD_CLOSE://網絡斷開事件發生。此時客戶機關閉或退出。
             ……//進行相應的處理
                break;
         default:
               break;
      }
}

   對于recv和send的處理一般就是在事件中處理,通過WSAAsySelect()來傳遞信號,這種方式形成一種固定寫socket方式,比如有的人喜歡把recv和send各自放入一個線程中通過輪詢+阻塞模式,或者采用事件通知模式,一般來說采用I/O模型是較為專業的做法。

3.客戶端的connect()

    客戶端連接時存在阻塞現象,就是程序在connect會出現freeze,一般可以容忍。但若想通過超時設置來解決這個問題,可采用在vckbase中,對于connect()超時的處理辦法。不過覺得有時調用封裝好的socket,直接是指connectionTimeout屬性倒是簡單的方法。

WSADATA wsd;
SOCKET cClient;
int ret;
struct sockaddr_in server;
hostent *host=NULL;

if(WSAStartup(MAKEWORD(2,0),&wsd))

{

   return 0;

}
cClient = socket(AF_INET,SOCK_STREAM,IPPROTO_TCP);
if(cClient == INVALID_SOCKET){return 0;}
//set Recv and Send time out
int TimeOut=6000; //設置發送超時6秒
if(::setsockopt(cClient,SOL_SOCKET,SO_SNDTIMEO,(char *)&TimeOut,sizeof(TimeOut))==SOCKET_ERROR){
     return 0;
}
TimeOut = 6000;//設置接收超時6秒
if(::setsockopt(cClient,SOL_SOCKET,SO_RCVTIMEO,(char *)&TimeOut,sizeof(TimeOut))==SOCKET_ERROR){
return 0;
}
//設置非阻塞方式連接
unsigned long ul = 1;
ret = ioctlsocket(cClient, FIONBIO, (unsigned long*)&ul);
if(ret==SOCKET_ERROR)  return 0;

//連接
server.sin_family = AF_INET;
server.sin_port = htons(25);
server.sin_addr .s_addr = inet_addr((LPCSTR)pSmtp);
if(server.sin_addr.s_addr == INADDR_NONE){return 0;}

//運行這里將不會阻塞,而是直接運行下去,通過select中設置的 timeval結構參數設定連接超時處理。

connect(cClient,(const struct sockaddr *)&server,sizeof(server));

//select 模型,即設置超時
struct timeval timeout ;
fd_set r;

FD_ZERO(&r);
FD_SET(cClient, &r);
timeout.tv_sec = 15; //連接超時15秒
timeout.tv_usec =0;
ret = select(0, 0, &r, 0, &timeout);            //超時socket將關閉
if ( ret <= 0 )
{
         ::closesocket(cClient);
          return 0;
}
//一般非鎖定模式套接比較難控制,可以根據實際情況考慮 再設回阻塞模式,又把狀態設置為 阻塞狀態。
unsigned long ul1= 0 ;
ret = ioctlsocket(cClient, FIONBIO, (unsigned long*)&ul1);
if(ret==SOCKET_ERROR){
         ::closesocket (cClient);
          return 0;
}

 

4.select()

a. 當你希望服務器監聽連接服務請求,而又不想通過輪詢的方式,則理想的方式是調用select().它運行你把程序本身掛起來,而同時使系統內核監聽所要求的一組文件描述符的任何活動,只要確認在任何被監控的文件描述符上出現了活動,select()調用將返回指示該文件描述符已準備好的信息,從而實現了程序的選出是隨機變化的,而不必由程序本身對輸入進行測試而浪費cpu開銷,

    在socket編程中,select函數一般在非阻塞的socket中,用來檢查socket緩沖區中是否有數據可讀,或是否可以寫數據到socket緩沖區。  
  有時,select()也被用來當作延時函數使用。sleep()延時會釋放cpu,用select的話,可以在占用cpu的情況下,延時。

   select()是用來進行多路轉接的函數。它可以同時等待n(n大于等于1)個文件描述字或者socket套接口。只要它等待的任意描述字準備好或者等待時間超過了設定時間程序就往下執行。可以防止進程長時間阻塞,占用資源。

b.簡單說法:

  如果你要發數據用select(sock+1,&s,NULL,NULL,NULL);  
     if(FD_ISSET(sock,&s)   ,你可以發了。send   it  
  如果你要收數據用select(sock+1,NULL,&s,NULL,NULL);  
  if(FD_ISSET(sock,&s)   ,你可以收了。recv   it  

socket默認情況下是阻塞的,除非你用WSAAsyncSelect   OR   select   就變成NOBBLOCKING,  
  將阻塞設為非阻塞如下:  
  int   opt=1;  
  ioctlsocket(sock,FIONBIO,&opt)  
  若opt=0就是阻塞的了

 

c.用法一

  fd_set m_readfds;  
  fd_set m_exceptfds;  
  timeval m_tmOut;  
  m_tmOut.tv_sec =   120;     //接收時間如果超過120秒,即認為網絡連接已經中斷,  
  m_tmOut.tv_usec =   0;      //客戶端應該定時每40秒發送一次空閑信號,以防止被誤認為是網絡連接中斷。  
  FD_ZERO(   &m_readfds   );  
  FD_ZERO(   &m_exceptfds   );  
  FD_SET(   m_scSocket,   &m_exceptfds   );  
  FD_SET(   m_scSocket,   &m_readfds   );  
  int CNet::Receive(   char   *   szBuff,   int   iSize   )  
  {  
        int   iRet;  
        if(   m_ntType   ==   _NET_SERVER_   )  
        {  
              iRet   =   select(   m_scSocket   +   1,   &m_readfds,   NULL,   &m_exceptfds,   &m_tmOut   );  
              if(   iRet   ==   0   )  
             {  
                   m_iError =   13; //超時  
                   return   -2;  
             }  
             if(   iRet   ==   SOCKET_ERROR   )  
            {  
                 GetLastError(   );  
                  return   -1;  
            }  
            if(   FD_ISSET(   m_scSocket,   &m_exceptfds   )   )  
            {  
                  m_iError =   14; //連接被終止  
                  return   -1;  
           }  
      }  
      iRet   =   recv(   m_scSocket,   szBuff,   iSize,   0   );  
      if(   iRet   ==   0   )  
     {  
               m_iError =   14; //連接被終止  
              return   -1;  
    }  
   if(   iRet   ==   SOCKET_ERROR   )  
   {  
          GetLastError(   );  
          return   -1;  
   }  
    return   iRet;  
  }  

用法二

int   recvex_sock(SOCKET   sock,   void*   buf,   int   len,   int   sec)  
  {  
                  int   rs;  
                  fd_set   fd;  
                  struct   timeval   tv;  
                  memset(&tv,   0,   sizeof(tv));  
                  if   (   sec   >   0   )  
                                  tv.tv_sec   =   sec;  
                  FD_ZERO(&fd);  
                  FD_SET(sock,   &fd);  
                  rs   =   select(sock   +   1,   &fd,   0,   0,   sec   >=   0   ?   &tv   :   NULL);  
                  if   (   rs   ==   0   )  
                                  return   SOCKET_TIMEOUT;  
                  if   (   rs   <   0   )  
                                  return   SOCKET_ERROR;  
                  if   (   !FD_ISSET(sock,   &fd)   )  
                                  return   SOCKET_ERROR;  
                  return   (recv_sock(sock,   buf,   len));  
  } 

posted on 2007-12-06 14:21 kenlistian 閱讀(3060) 評論(0)  編輯 收藏 引用
青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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>
            一区二区三区高清在线| 国产美女一区二区| 亚洲性感激情| 在线视频精品一区| 亚洲欧美区自拍先锋| 午夜伦理片一区| 久久人人超碰| 欧美日韩综合视频网址| 国产精品久久久久999| 国产午夜精品全部视频在线播放| 国产亚洲高清视频| 亚洲日本欧美| 久久国产99| 欧美黑人一区二区三区| 亚洲毛片一区二区| 午夜电影亚洲| 欧美大片一区| 国产日韩综合| 一区二区精品在线观看| 久久www免费人成看片高清 | 午夜欧美大片免费观看| 久久亚洲春色中文字幕| 亚洲欧洲一二三| 99热精品在线观看| 欧美中文字幕第一页| 欧美激情在线狂野欧美精品| 99视频有精品| 欧美成人首页| 狠狠色综合播放一区二区| 亚洲视频在线观看一区| 久久精品欧美日韩精品| 9色国产精品| 久久综合影视| 国产亚洲一区二区三区| 这里只有精品丝袜| 亚洲国产99精品国自产| 午夜精品一区二区在线观看| 欧美激情一区二区三区高清视频| 国产专区一区| 欧美亚洲一级| 在线视频亚洲| 欧美日韩精品综合| 亚洲日产国产精品| 欧美xx69| 久久久人人人| 国模 一区 二区 三区| 亚洲综合大片69999| 亚洲福利视频免费观看| 久久精选视频| 激情久久久久久久| 久久国产精品毛片| 亚洲欧美日韩久久精品| 国产精品一页| 久久成人免费电影| 亚洲免费小视频| 国产精品久久午夜夜伦鲁鲁| 国产精品99久久久久久宅男| 亚洲精品乱码久久久久久| 美女图片一区二区| 亚洲国产高清一区二区三区| 久久婷婷麻豆| 久久婷婷人人澡人人喊人人爽| 国产日韩亚洲欧美综合| 欧美综合77777色婷婷| 性欧美精品高清| 国产精品一级| 久久视频在线免费观看| 久久久久久久激情视频| 亚洲国产高清视频| 亚洲日韩中文字幕在线播放| 欧美精品亚洲| 午夜老司机精品| 欧美在线视屏| 亚洲精品国产精品乱码不99| 亚洲精品乱码久久久久久蜜桃麻豆 | 亚洲精品乱码视频| 国产精品国产自产拍高清av| 欧美激情成人在线视频| 国产精品扒开腿做爽爽爽视频| 国产综合色产| 亚洲电影一级黄| 欧美日韩精品一区二区在线播放 | 欧美日韩视频一区二区| 亚洲女同性videos| 欧美中文字幕视频| 亚洲精品影视| 亚洲欧美中文另类| 亚洲激情在线观看视频免费| 一本一本久久a久久精品综合妖精| 国产麻豆一精品一av一免费| 免费一级欧美片在线播放| 欧美日韩视频在线观看一区二区三区| 亚洲欧美国产高清| 久久久在线视频| 亚洲免费视频观看| 美脚丝袜一区二区三区在线观看 | 午夜精品久久久久影视| 久久精品国产精品亚洲精品| 亚洲麻豆一区| 欧美在线观看日本一区| 一个色综合导航| 久久精品一二三| 亚洲一区日韩| 欧美成人免费大片| 久久久久久九九九九| 欧美视频日韩视频在线观看| 毛片精品免费在线观看| 国产精品欧美久久| 亚洲精品一区二区三区99| 国产主播一区二区| 亚洲一区二区三区精品在线| 亚洲国产日韩欧美一区二区三区| 午夜精品成人在线视频| 亚洲影音一区| 欧美精品免费在线| 亚洲电影天堂av| 雨宫琴音一区二区在线| 午夜亚洲一区| 欧美制服丝袜第一页| 欧美午夜寂寞影院| 日韩视频欧美视频| 亚洲精选视频免费看| 久久亚洲私人国产精品va| 久久都是精品| 国产欧美精品在线播放| 亚洲网站在线观看| 亚洲欧美日韩国产中文在线| 欧美精品综合| 亚洲人成在线免费观看| 亚洲精品美女91| 免播放器亚洲一区| 亚洲电影免费观看高清完整版在线 | 久久精品一区二区三区不卡| 国产精品国产三级国产a| 91久久在线视频| 亚洲美女在线观看| 欧美精品一区二区三区蜜臀| 国产精品视频网址| 欧美一级精品大片| 国产精品香蕉在线观看| 亚洲欧美色一区| 欧美影院视频| 国产一区二区精品丝袜| 久久久久国色av免费看影院| 久久影院午夜论| 在线精品观看| 欧美高清一区| 亚洲神马久久| 久久精品99国产精品| 在线免费不卡视频| 欧美精品www在线观看| 日韩午夜免费| 久久国产色av| 亚洲国产专区| 国产精品萝li| 久久久久久久综合| 亚洲欧洲日本在线| 欧美在线播放| 亚洲精品黄色| 国产模特精品视频久久久久| 久久久久欧美| 日韩亚洲综合在线| 久久精品五月| 一本久道久久综合婷婷鲸鱼| 国产视频一区三区| 欧美激情精品久久久久久久变态| av成人毛片| 免费精品视频| 午夜国产精品影院在线观看 | 欧美国产综合视频| 国产精品99久久久久久有的能看| 久久久99爱| 亚洲精品在线视频观看| 国产精品亚洲人在线观看| 老司机久久99久久精品播放免费| 一本一本a久久| 欧美国产国产综合| 久久99伊人| 亚洲一区二区三区视频| 激情av一区| 国产精品视频免费在线观看| 欧美a级片网站| 欧美一区二区三区四区在线| 亚洲精品午夜| 亚洲第一福利在线观看| 久久激情网站| 午夜精品久久久| 一区二区免费在线视频| 在线观看欧美黄色| 国产日本亚洲高清| 欧美色精品天天在线观看视频| 久久天天躁狠狠躁夜夜av| 亚洲欧美日韩国产精品| 亚洲精品欧美极品| 欧美激情一区三区| 免费国产一区二区| 久久亚洲综合| 久久久久久久波多野高潮日日| 亚洲女优在线| 亚洲女女做受ⅹxx高潮|