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

posts - 297,  comments - 15,  trackbacks - 0

名詞解釋:man epoll之后,得到如下結(jié)果:

NAME
       epoll - I/O event notification facility

SYNOPSIS
       #include <sys/epoll.h>

DESCRIPTION
       epoll is a variant of poll(2) that can be used either as Edge or Level
       Triggered interface and scales well to large numbers of  watched  fds.
       Three  system  calls  are provided to set up and control an epoll set:
       epoll_create(2), epoll_ctl(2), epoll_wait(2).

       An epoll set is connected to a file descriptor created  by  epoll_cre-
       ate(2).   Interest for certain file descriptors is then registered via
       epoll_ctl(2).  Finally, the actual wait is started by epoll_wait(2).

其實(shí),一切的解釋都是多余的,按照我目前的了解,EPOLL模型似乎只有一種格式,所以大家只要參考我下面的代碼,就能夠?qū)POLL有所了解了,代碼的解釋都已經(jīng)在注釋中:

while (TRUE)
 {
  int nfds = epoll_wait (m_epoll_fd, m_events, MAX_EVENTS, EPOLL_TIME_OUT);//等待EPOLL時間的發(fā)生,相當(dāng)于監(jiān)聽,至于相關(guān)的端口,需要在初始化EPOLL的時候綁定。
  if (nfds <= 0)
   continue;
  m_bOnTimeChecking = FALSE;
  G_CurTime = time(NULL);
  for (int i=0; i<nfds; i++)
  {
   try
   {
    if (m_events[i].data.fd == m_listen_http_fd)//如果新監(jiān)測到一個HTTP用戶連接到綁定的HTTP端口,建立新的連接。由于我們新采用了SOCKET連接,所以基本沒用。
    {
     OnAcceptHttpEpoll ();
    }
    else if (m_events[i].data.fd == m_listen_sock_fd)//如果新監(jiān)測到一個SOCKET用戶連接到了綁定的SOCKET端口,建立新的連接。
    {
     OnAcceptSockEpoll ();
    }
    else if (m_events[i].events & EPOLLIN)//如果是已經(jīng)連接的用戶,并且收到數(shù)據(jù),那么進(jìn)行讀入。
    {
     OnReadEpoll (i);
    }

    OnWriteEpoll (i);//查看當(dāng)前的活動連接是否有需要寫出的數(shù)據(jù)。
   }
   catch (int)
   {
    PRINTF ("CATCH捕獲錯誤\n");
    continue;
   }
  }
  m_bOnTimeChecking = TRUE;
  OnTimer ();//進(jìn)行一些定時的操作,主要就是刪除一些短線用戶等。
 }

 其實(shí)EPOLL的精華,按照我目前的理解,也就是上述的幾段短短的代碼,看來時代真的不同了,以前如何接受大量用戶連接的問題,現(xiàn)在卻被如此輕松的搞定,真是讓人不得不感嘆。

今天搞了一天的epoll,想做一個高并發(fā)的代理程序。剛開始真是郁悶,一直搞不通,網(wǎng)上也有幾篇介紹epoll的文章。但都不深入,沒有將一些注意的地方講明。以至于走了很多彎路,現(xiàn)將自己的一些理解共享給大家,以少走彎路。 

epoll用到的所有函數(shù)都是在頭文件sys/epoll.h中聲明,有什么地方不明白或函數(shù)忘記了可以去看一下。 
epoll和select相比,最大不同在于: 

1epoll返回時已經(jīng)明確的知道哪個sokcet fd發(fā)生了事件,不用再一個個比對。這樣就提高了效率。 
2select的FD_SETSIZE是有限止的,而epoll是沒有限止的只與系統(tǒng)資源有關(guān)。
 

1、epoll_create函數(shù)
函數(shù)聲明:int epoll_create(int size)
該 函數(shù)生成一個epoll專用的文件描述符。它其實(shí)是在內(nèi)核申請一空間,用來存放你想關(guān)注的socket fd上是否發(fā)生以及發(fā)生了什么事件。size就是你在這個epoll fd上能關(guān)注的最大socket fd數(shù)。隨你定好了。只要你有空間。可參見上面與select之不同2. 

22、epoll_ctl函數(shù) 
函數(shù)聲明:int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event) 
該函數(shù)用于控制某個epoll文件描述符上的事件,可以注冊事件,修改事件,刪除事件。 
參數(shù): 
epfd:由 epoll_create 生成的epoll專用的文件描述符; 
op:要進(jìn)行的操作例如注冊事件,可能的取值EPOLL_CTL_ADD 注冊、EPOLL_CTL_MOD 修 改、EPOLL_CTL_DEL 刪除 

fd:關(guān)聯(lián)的文件描述符; 
event:指向epoll_event的指針; 
如果調(diào)用成功返回0,不成功返回-1 

用到的數(shù)據(jù)結(jié)構(gòu) 
typedef union epoll_data { 
void *ptr;
int fd;
__uint32_t u32;
__uint64_t u64;
} epoll_data_t; 

struct epoll_event {
__uint32_t events; /* Epoll events */
epoll_data_t data; /* User data variable */
};


如: 
struct epoll_event ev;
//設(shè)置與要處理的事件相關(guān)的文件描述符
ev.data.fd=listenfd;
//設(shè)置要處理的事件類型
ev.events=EPOLLIN|EPOLLET;
//注冊epoll事件
epoll_ctl(epfd,EPOLL_CTL_ADD,listenfd,&ev);


常用的事件類型:
EPOLLIN :表示對應(yīng)的文件描述符可以讀;
EPOLLOUT:表示對應(yīng)的文件描述符可以寫;
EPOLLPRI:表示對應(yīng)的文件描述符有緊急的數(shù)據(jù)可讀
EPOLLERR:表示對應(yīng)的文件描述符發(fā)生錯誤;
EPOLLHUP:表示對應(yīng)的文件描述符被掛斷;
EPOLLET:表示對應(yīng)的文件描述符有事件發(fā)生;


3、epoll_wait函數(shù)
函數(shù)聲明:int epoll_wait(int epfd,struct epoll_event * events,int maxevents,int timeout)
該函數(shù)用于輪詢I/O事件的發(fā)生;
參數(shù):
epfd:由epoll_create 生成的epoll專用的文件描述符;
epoll_event:用于回傳代處理事件的數(shù)組;
maxevents:每次能處理的事件數(shù);
timeout:等待I/O事件發(fā)生的超時值(單位我也不太清楚);-1相當(dāng)于阻塞,0相當(dāng)于非阻塞。一般用-1即可
返回發(fā)生事件數(shù)。

  1. #include <stdio.h>  
  2. #include <stdlib.h>  
  3. #include <errno.h>  
  4. #include <string.h>  
  5. #include <sys/types.h>  
  6. #include <netinet/in.h>  
  7. #include <sys/socket.h>  
  8. #include <sys/wait.h>  
  9. #include <unistd.h>  
  10. #include <arpa/inet.h>  
  11. #include <openssl/ssl.h>  
  12. #include <openssl/err.h>  
  13. #include <fcntl.h>  
  14. #include <sys/epoll.h>  
  15. #include <sys/time.h>  
  16. #include <sys/resource.h>  
  1. #define MAXBUF 1024  
  2. #define MAXEPOLLSIZE 10000  
  1. /* 
  2. setnonblocking - 設(shè)置句柄為非阻塞方式 
  3. */  
  4. int setnonblocking(int sockfd)  
  5. {  
  6.     if (fcntl(sockfd, F_SETFL, fcntl(sockfd, F_GETFD, 0)|O_NONBLOCK) == -1)  
  7.  {  
  8.         return -1;  
  9.     }  
  10.     return 0;  
  11. }  
  1. /* 
  2. handle_message - 處理每個 socket 上的消息收發(fā) 
  3. */  
  4. int handle_message(int new_fd)  
  5. {  
  6.     char buf[MAXBUF + 1];  
  7.     int len;  
  8.       
  9.  /* 開始處理每個新連接上的數(shù)據(jù)收發(fā) */  
  10.     bzero(buf, MAXBUF + 1);  
  11.      
  12.  /* 接收客戶端的消息 */  
  13.     len = recv(new_fd, buf, MAXBUF, 0);  
  14.     if (len > 0)  
  15.  {  
  16.         printf  
  17.             ("%d接收消息成功:'%s',共%d個字節(jié)的數(shù)據(jù)\n",  
  18.              new_fd, buf, len);  
  19.  }  
  20.     else  
  21.  {  
  22.         if (len < 0)  
  23.      printf  
  24.                 ("消息接收失敗!錯誤代碼是%d,錯誤信息是'%s'\n",  
  25.                  errno, strerror(errno));  
  26.         close(new_fd);  
  27.         return -1;  
  28.     }  
  29.     /* 處理每個新連接上的數(shù)據(jù)收發(fā)結(jié)束 */  
  30.     return len;  
  31. }  
  32. /************關(guān)于本文檔******************************************** 
  33. *filename: epoll-server.c 
  34. *purpose: 演示epoll處理海量socket連接的方法 
  35. *wrote by: zhoulifa(<a href="mailto:zhoulifa@163.com"& gt;zhoulifa@163.com</a>) 周立發(fā)(<a href="http: //zhoulifa.bokee.com">http://zhoulifa.bokee.com</a>) 
  36. Linux愛好者 Linux知識傳播者 SOHO族 開發(fā)者 最擅長C語言 
  37. *date time:2007-01-31 21:00 
  38. *Note: 任何人可以任意復(fù)制代碼并運(yùn)用這些文檔,當(dāng)然包括你的商業(yè)用途 
  39. * 但請遵循GPL 
  40. *Thanks to:Google 
  41. *Hope:希望越來越多的人貢獻(xiàn)自己的力量,為科學(xué)技術(shù)發(fā)展出力 
  42. * 科技站在巨人的肩膀上進(jìn)步更快!感謝有開源前輩的貢獻(xiàn)! 
  43. *********************************************************************/  
  44. int main(int argc, char **argv)  
  45. {  
  46.     int listener, new_fd, kdpfd, nfds, n, ret, curfds;  
  47.     socklen_t len;  
  48.     struct sockaddr_in my_addr, their_addr;  
  49.     unsigned int myport, lisnum;  
  50.     struct epoll_event ev;  
  51.     struct epoll_event events[MAXEPOLLSIZE];  
  52.     struct rlimit rt;  
  53.  myport = 5000;  
  54.  lisnum = 2;   
  55.       
  56.  /* 設(shè)置每個進(jìn)程允許打開的最大文件數(shù) */  
  57.     rt.rlim_max = rt.rlim_cur = MAXEPOLLSIZE;  
  58.     if (setrlimit(RLIMIT_NOFILE, &rt) == -1)   
  59.  {  
  60.         perror("setrlimit");  
  61.         exit(1);  
  62.     }  
  63.     else   
  64.     {  
  65.         printf("設(shè)置系統(tǒng)資源參數(shù)成功!\n");  
  66.     }  
  1.     /* 開啟 socket 監(jiān)聽 */  
  2.     if ((listener = socket(PF_INET, SOCK_STREAM, 0)) == -1)  
  3.     {  
  4.         perror("socket");  
  5.         exit(1);  
  6.     }  
  7.     else  
  8.     {  
  9.         printf("socket 創(chuàng)建成功!\n");  
  10.  }  
  11.    
  12.     setnonblocking(listener);  
  1.     bzero(&my_addr, sizeof(my_addr));  
  2.     my_addr.sin_family = PF_INET;  
  3.     my_addr.sin_port = htons(myport);  
  4.     my_addr.sin_addr.s_addr = INADDR_ANY;  
  1.     if (bind(listener, (struct sockaddr *) &my_addr, sizeof(struct sockaddr)) == -1)   
  2.     {  
  3.         perror("bind");  
  4.         exit(1);  
  5.     }   
  6.     else  
  7.     {  
  8.         printf("IP 地址和端口綁定成功\n");  
  9.     }  
  10.     if (listen(listener, lisnum) == -1)   
  11.     {  
  12.         perror("listen");  
  13.         exit(1);  
  14.     }  
  15.     else  
  16.     {  
  17.         printf("開啟服務(wù)成功!\n");  
  18.      }  
  19.       
  20.  /* 創(chuàng)建 epoll 句柄,把監(jiān)聽 socket 加入到 epoll 集合里 */  
  21.     kdpfd = epoll_create(MAXEPOLLSIZE);  
  22.     len = sizeof(struct sockaddr_in);  
  23.     ev.events = EPOLLIN | EPOLLET;  
  24.     ev.data.fd = listener;  
  25.     if (epoll_ctl(kdpfd, EPOLL_CTL_ADD, listener, &ev) < 0)   
  26.    {  
  27.         fprintf(stderr, "epoll set insertion error: fd=%d\n", listener);  
  28.         return -1;  
  29.     }  
  30.  else  
  31.     {  
  32.   printf("監(jiān)聽 socket 加入 epoll 成功!\n");  
  33.  }  
  34.     curfds = 1;  
  35.     while (1)   
  36.     {  
  37.         /* 等待有事件發(fā)生 */  
  38.         nfds = epoll_wait(kdpfd, events, curfds, -1);  
  39.         if (nfds == -1)  
  40.         {  
  41.             perror("epoll_wait");  
  42.             break;  
  43.         }  
  44.         /* 處理所有事件 */  
  45.         for (n = 0; n < nfds; ++n)  
  46.        {  
  47.             if (events[n].data.fd == listener)   
  48.             {  
  49.                    new_fd = accept(listener, (struct sockaddr *) &their_addr,&len);  
  50.                    if (new_fd < 0)   
  51.                   {  
  52.                        perror("accept");  
  53.                        continue;  
  54.                   }   
  55.                   else  
  56.                {  
  57.                         printf("有連接來自于: %d:%d, 分配的 socket 為:%d\n",  
  58.                              inet_ntoa(their_addr.sin_addr), ntohs(their_addr.sin_port), new_fd);  
  59.                   }  
  60.                   setnonblocking(new_fd);  
  61.                   ev.events = EPOLLIN | EPOLLET;  
  62.                   ev.data.fd = new_fd;  
  63.                   if (epoll_ctl(kdpfd, EPOLL_CTL_ADD, new_fd, &ev) < 0)  
  64.                   {  
  65.                         fprintf(stderr, "把 socket '%d' 加入 epoll 失敗!%s\n",  
  66.                             new_fd, strerror(errno));  
  67.                         return -1;  
  68.                   }  
  69.                   curfds++;  
  70.             }   
  71.             else  
  72.            {  
  73.                  ret = handle_message(events[n].data.fd);  
  74.                  if (ret < 1 && errno != 11)  
  75.                 {  
  76.                     epoll_ctl(kdpfd, EPOLL_CTL_DEL, events[n].data.fd,&ev);  
  77.                     curfds--;  
  78.                 }  
  79.             }  
  80.         }  
  81.     }  
  82.     close(listener);  
  83.     return 0;  
  84. }  

 epoll_wait 運(yùn)行的原理是 等侍注冊在epfd上的socket fd的事件的發(fā)生,如果發(fā)生則將發(fā)生的sokct fd和事件類型放入到events數(shù)組中。 并且將注冊在epfd上的socket fd的事件類型給清空,所以如果下一個循環(huán)你還要關(guān)注這個socket fd的話,則需要用epoll_ctl(epfd,EPOLL_CTL_MOD,listenfd,&ev)來重新設(shè)置socket fd的事件類型。這時不用EPOLL_CTL_ADD,因?yàn)閟ocket fd并未清空,只是事件類型清空。這一步非常重要。 


轉(zhuǎn)自:

http://blog.chinaunix.net/u/17928/showart.php?id=2098011

posted on 2010-01-10 22:46 chatler 閱讀(2130) 評論(0)  編輯 收藏 引用 所屬分類: Socket
<2010年6月>
303112345
6789101112
13141516171819
20212223242526
27282930123
45678910

常用鏈接

留言簿(10)

隨筆分類(307)

隨筆檔案(297)

algorithm

Books_Free_Online

C++

database

Linux

Linux shell

linux socket

misce

  • cloudward
  • 感覺這個博客還是不錯,雖然做的東西和我不大相關(guān),覺得看看還是有好處的

network

OSS

  • Google Android
  • Android is a software stack for mobile devices that includes an operating system, middleware and key applications. This early look at the Android SDK provides the tools and APIs necessary to begin developing applications on the Android platform using the Java programming language.
  • os161 file list

overall

搜索

  •  

最新評論

閱讀排行榜

評論排行榜

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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>
            亚洲一本视频| 精品福利av| 欧美mv日韩mv亚洲| 国产精品手机在线| 亚洲精品在线观看免费| 一区二区三区在线视频播放| 一区二区黄色| 亚洲另类春色国产| 久久久噜久噜久久综合| 久久激情视频| 国产精品在线看| 亚洲午夜高清视频| 亚洲欧美999| 欧美午夜剧场| 亚洲毛片网站| 一本到高清视频免费精品| 欧美aaaaaaaa牛牛影院| 欧美大片免费久久精品三p| 国产一区二区三区久久| 欧美一区二区三区在线看| 午夜日韩视频| 国产精品一区免费在线观看| 亚洲亚洲精品三区日韩精品在线视频| 亚洲免费av电影| 欧美精品在线视频| 日韩午夜免费视频| 亚洲自拍高清| 国产欧美婷婷中文| 亚洲欧美在线高清| 久久久久久电影| 伊人精品成人久久综合软件| 老鸭窝91久久精品色噜噜导演| 久久综合九九| 亚洲高清久久| 欧美精品一区二区三| 99精品视频一区| 欧美一区二区成人6969| 国产日韩精品在线观看| 久久精品盗摄| 亚洲国产精品久久久久久女王| 亚洲国内精品在线| 欧美日韩www| 亚洲伊人网站| 久久在线免费| 一本色道久久88综合日韩精品| 欧美视频在线免费看| 亚洲自拍偷拍麻豆| 欧美va亚洲va香蕉在线| 艳妇臀荡乳欲伦亚洲一区| 国产精品久久久久久影视 | 国产精品www.| 欧美一区二区三区视频在线观看| 久久中文字幕一区| 夜夜爽www精品| 国产三区精品| 欧美福利电影在线观看| 亚洲一区二区伦理| 免费久久99精品国产自| 亚洲一区二区三区中文字幕| 国产一区二区观看| 欧美二区乱c少妇| 亚洲在线免费观看| 亚洲电影在线观看| 欧美一区二区三区电影在线观看| 亚洲国产电影| 国产精品每日更新| 欧美sm重口味系列视频在线观看| 亚洲一区在线免费观看| 亚洲国产高清自拍| 欧美在线免费| 一区二区三区成人精品| 国产一区二区三区在线观看网站| 欧美精品日韩综合在线| 久久精品国产亚洲精品| 99这里只有精品| 欧美成年视频| 久久国产欧美| 亚洲一区二区三区四区在线观看| 亚洲国产精品激情在线观看| 国产日韩三区| 欧美私人网站| 欧美区二区三区| 巨胸喷奶水www久久久免费动漫| 亚洲一区二区三区免费观看| 亚洲精品免费看| 欧美高清在线精品一区| 久久久久久久一区二区三区| 亚洲欧美日韩第一区| 一区二区三区色| 亚洲激情啪啪| 亚洲第一福利社区| 精品成人久久| 国产综合欧美在线看| 国产伦理一区| 国产精品久久久久久户外露出| 欧美激情亚洲精品| 欧美黄色一区二区| 欧美成人一品| 欧美顶级少妇做爰| 欧美国产日产韩国视频| 欧美1区3d| 裸体女人亚洲精品一区| 久久综合国产精品台湾中文娱乐网| 欧美一区不卡| 久久精品国产v日韩v亚洲 | 免费观看久久久4p| 免费高清在线视频一区·| 久久综合99re88久久爱| 美女啪啪无遮挡免费久久网站| 久久亚洲二区| 欧美福利一区| 亚洲国产日韩欧美| 亚洲人成毛片在线播放| 亚洲精品综合精品自拍| 99精品久久久| 亚洲伊人观看| 久久国产精品久久久久久久久久 | 篠田优中文在线播放第一区| 亚洲尤物精选| 久久国产精品一区二区三区四区| 久久aⅴ国产欧美74aaa| 久久另类ts人妖一区二区| 免费亚洲视频| 欧美日精品一区视频| 国产精品嫩草99av在线| 国产综合一区二区| 亚洲日本中文字幕| 制服丝袜激情欧洲亚洲| 欧美一区国产在线| 看片网站欧美日韩| 最新国产成人在线观看| 亚洲影院污污.| 久久久久se| 欧美理论在线播放| 国产精品视频免费一区| 在线电影欧美日韩一区二区私密| 亚洲精品一区二区三区av| 亚洲欧美高清| 欧美91福利在线观看| 亚洲理伦在线| 久久久久久一区| 欧美日韩在线一区二区| 国内精品视频在线观看| 一区二区免费看| 久久久噜噜噜久久| 亚洲欧洲在线视频| 欧美一区二区高清| 欧美精品在线视频观看| 国产一区二区黄| 一区二区三区不卡视频在线观看| 久久不见久久见免费视频1| 欧美大片在线观看一区二区| 中文国产成人精品久久一| 老巨人导航500精品| 国产精品久久久久久久久免费 | 欧美日产国产成人免费图片| 国产亚洲在线| 亚洲视频观看| 欧美激情欧美激情在线五月| 亚洲欧美在线播放| 欧美理论在线| 亚洲国产成人一区| 久久成人18免费网站| 亚洲免费观看高清在线观看| 久久久久成人精品| 国产欧美一区视频| 亚洲中字在线| 亚洲日韩成人| 欧美成年人视频网站欧美| 国产一区99| 性感少妇一区| 一区二区三区免费观看| 欧美激情在线有限公司| 亚洲国产导航| 久久裸体艺术| 欧美一区国产在线| 国产欧美1区2区3区| 亚洲一区二区三区免费在线观看 | 一区二区三区自拍| 久久成人国产| 亚洲欧美日韩国产综合| 欧美性事在线| 亚洲一区二区三区四区五区午夜| 亚洲啪啪91| 欧美二区在线观看| 亚洲国产精品嫩草影院| 美女尤物久久精品| 久久久人成影片一区二区三区观看 | 欧美大尺度在线| 久久香蕉国产线看观看av| 国产亚洲精品资源在线26u| 欧美一区二区精品在线| 亚洲综合三区| 国产女精品视频网站免费 | 久久伊人一区二区| 亚洲韩国一区二区三区| 亚洲二区在线观看| 欧美日韩不卡视频| 亚洲欧美成人| 午夜精品影院在线观看|