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

posts - 297,  comments - 15,  trackbacks - 0

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

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).

其實,一切的解釋都是多余的,按照我目前的了解,EPOLL模型似乎只有一種格式,所以大家只要參考我下面的代碼,就能夠對EPOLL有所了解了,代碼的解釋都已經在注釋中:

while (TRUE)
 {
  int nfds = epoll_wait (m_epoll_fd, m_events, MAX_EVENTS, EPOLL_TIME_OUT);//等待EPOLL時間的發生,相當于監聽,至于相關的端口,需要在初始化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)//如果新監測到一個HTTP用戶連接到綁定的HTTP端口,建立新的連接。由于我們新采用了SOCKET連接,所以基本沒用。
    {
     OnAcceptHttpEpoll ();
    }
    else if (m_events[i].data.fd == m_listen_sock_fd)//如果新監測到一個SOCKET用戶連接到了綁定的SOCKET端口,建立新的連接。
    {
     OnAcceptSockEpoll ();
    }
    else if (m_events[i].events & EPOLLIN)//如果是已經連接的用戶,并且收到數據,那么進行讀入。
    {
     OnReadEpoll (i);
    }

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

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

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

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

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

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

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

fd:關聯的文件描述符; 
event:指向epoll_event的指針; 
如果調用成功返回0,不成功返回-1 

用到的數據結構 
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;
//設置與要處理的事件相關的文件描述符
ev.data.fd=listenfd;
//設置要處理的事件類型
ev.events=EPOLLIN|EPOLLET;
//注冊epoll事件
epoll_ctl(epfd,EPOLL_CTL_ADD,listenfd,&ev);


常用的事件類型:
EPOLLIN :表示對應的文件描述符可以讀;
EPOLLOUT:表示對應的文件描述符可以寫;
EPOLLPRI:表示對應的文件描述符有緊急的數據可讀
EPOLLERR:表示對應的文件描述符發生錯誤;
EPOLLHUP:表示對應的文件描述符被掛斷;
EPOLLET:表示對應的文件描述符有事件發生;


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

  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 - 設置句柄為非阻塞方式 
  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 上的消息收發 
  3. */  
  4. int handle_message(int new_fd)  
  5. {  
  6.     char buf[MAXBUF + 1];  
  7.     int len;  
  8.       
  9.  /* 開始處理每個新連接上的數據收發 */  
  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個字節的數據\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.     /* 處理每個新連接上的數據收發結束 */  
  30.     return len;  
  31. }  
  32. /************關于本文檔******************************************** 
  33. *filename: epoll-server.c 
  34. *purpose: 演示epoll處理海量socket連接的方法 
  35. *wrote by: zhoulifa(<a href="mailto:zhoulifa@163.com"& gt;zhoulifa@163.com</a>) 周立發(<a href="http: //zhoulifa.bokee.com">http://zhoulifa.bokee.com</a>) 
  36. Linux愛好者 Linux知識傳播者 SOHO族 開發者 最擅長C語言 
  37. *date time:2007-01-31 21:00 
  38. *Note: 任何人可以任意復制代碼并運用這些文檔,當然包括你的商業用途 
  39. * 但請遵循GPL 
  40. *Thanks to:Google 
  41. *Hope:希望越來越多的人貢獻自己的力量,為科學技術發展出力 
  42. * 科技站在巨人的肩膀上進步更快!感謝有開源前輩的貢獻! 
  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.  /* 設置每個進程允許打開的最大文件數 */  
  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("設置系統資源參數成功!\n");  
  66.     }  
  1.     /* 開啟 socket 監聽 */  
  2.     if ((listener = socket(PF_INET, SOCK_STREAM, 0)) == -1)  
  3.     {  
  4.         perror("socket");  
  5.         exit(1);  
  6.     }  
  7.     else  
  8.     {  
  9.         printf("socket 創建成功!\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("開啟服務成功!\n");  
  18.      }  
  19.       
  20.  /* 創建 epoll 句柄,把監聽 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("監聽 socket 加入 epoll 成功!\n");  
  33.  }  
  34.     curfds = 1;  
  35.     while (1)   
  36.     {  
  37.         /* 等待有事件發生 */  
  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 運行的原理是 等侍注冊在epfd上的socket fd的事件的發生,如果發生則將發生的sokct fd和事件類型放入到events數組中。 并且將注冊在epfd上的socket fd的事件類型給清空,所以如果下一個循環你還要關注這個socket fd的話,則需要用epoll_ctl(epfd,EPOLL_CTL_MOD,listenfd,&ev)來重新設置socket fd的事件類型。這時不用EPOLL_CTL_ADD,因為socket fd并未清空,只是事件類型清空。這一步非常重要。 


轉自:

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

posted on 2010-01-10 22:46 chatler 閱讀(2131) 評論(0)  編輯 收藏 引用 所屬分類: Socket
<2009年2月>
25262728293031
1234567
891011121314
15161718192021
22232425262728
1234567

常用鏈接

留言簿(10)

隨筆分類(307)

隨筆檔案(297)

algorithm

Books_Free_Online

C++

database

Linux

Linux shell

linux socket

misce

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

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| 亚洲黑丝在线| 欧美在线观看你懂的| 亚洲自拍偷拍色片视频| 欧美a级片网站| 美女国产一区| 国产主播一区二区| 亚洲午夜视频| 一区二区三区 在线观看视频| 久久久夜精品| 久久亚洲不卡| 国产最新精品精品你懂的| 亚洲婷婷综合久久一本伊一区| 亚洲黄色免费网站| 久久综合狠狠综合久久综合88| 久久精品麻豆| 国产亚洲人成a一在线v站| 中文一区字幕| 亚洲欧美中文另类| 国产精品国产三级国产专区53| 亚洲美女在线观看| 亚洲视频在线观看一区| 欧美日韩在线另类| 一本色道久久综合狠狠躁篇怎么玩| 日韩一级精品| 欧美日韩p片| 亚洲美洲欧洲综合国产一区| 夜夜嗨av一区二区三区免费区| 欧美高清自拍一区| 亚洲精品一区久久久久久| 洋洋av久久久久久久一区| 欧美日韩国产片| 亚洲视频狠狠| 久久精品国产2020观看福利| 国产午夜亚洲精品羞羞网站 | 久久视频国产精品免费视频在线| 久久国产黑丝| 狠狠色丁香婷婷综合久久片| 久久综合久久久久88| 亚洲国产精品热久久| 一区二区国产精品| 国产精品久久久久999| 欧美一区二区在线免费观看| 麻豆乱码国产一区二区三区| 91久久久在线| 欧美三级中文字幕在线观看| 亚洲欧美欧美一区二区三区| 久久久美女艺术照精彩视频福利播放 | 久久精品亚洲一区二区| 黄色日韩在线| 欧美99在线视频观看| 亚洲欧洲日本专区| 亚洲欧美日韩爽爽影院| 黄色成人av在线| 欧美日韩国产成人在线免费| 亚洲男人的天堂在线观看| 久久一区二区三区四区| 亚洲国产日韩欧美| 国产精品进线69影院| 久久一区二区三区av| 夜夜嗨av色一区二区不卡| 久久精品国产96久久久香蕉| 亚洲乱码国产乱码精品精天堂 | 欧美激情综合在线| 亚洲欧美美女| 亚洲全部视频| 久久精品毛片| 亚洲午夜性刺激影院| 伊人成人在线| 国产精品三级久久久久久电影| 久久九九国产精品| 亚洲一品av免费观看| 亚洲国产99| 久久久国产成人精品| 亚洲图片欧美日产| 亚洲黄网站在线观看| 国产亚洲一区二区三区在线观看 | 久久综合九色综合欧美狠狠| 一区二区三区高清在线观看| 欧美电影打屁股sp| 久久久久久亚洲综合影院红桃| 亚洲午夜日本在线观看| 亚洲黄色精品| 一区二区在线观看av| 国产欧美日韩在线视频| 欧美日韩精品伦理作品在线免费观看| 久久精品一本久久99精品| 亚洲私人影院在线观看| 亚洲片区在线| 亚洲高清资源| 久久嫩草精品久久久精品| 午夜精品久久久久久99热| 中文有码久久| 一区二区冒白浆视频| 亚洲精品一区中文| 亚洲国产一区视频| 亚洲高清久久网| 在线高清一区| 精品动漫3d一区二区三区| 黑人巨大精品欧美黑白配亚洲 | 亚洲影视在线| 亚洲网站在线观看| 这里是久久伊人| 亚洲婷婷在线| 亚洲中午字幕| 亚洲欧美综合国产精品一区| 亚洲欧美国产精品专区久久| 性欧美8khd高清极品| 亚洲一区日韩| 欧美亚洲综合另类| 久久久91精品| 六月婷婷一区| 欧美激情精品久久久六区热门| 男人的天堂亚洲| 欧美激情一区二区三级高清视频| 欧美国产日韩一二三区| 亚洲国产视频直播| 99精品国产99久久久久久福利| 中国av一区| 亚洲欧美激情诱惑| 久久九九久久九九| 欧美成人免费小视频| 欧美日韩精品高清| 国产麻豆精品视频| 激情文学综合丁香| 亚洲青色在线| 午夜精品理论片| 久久综合九色欧美综合狠狠| 亚洲国产精品va在看黑人| 亚洲另类在线一区| 午夜视频在线观看一区| 久久中文欧美| 欧美日韩亚洲三区| 国产拍揄自揄精品视频麻豆| 亚洲电影有码| 亚洲尤物精选| 欧美 日韩 国产 一区| 99re8这里有精品热视频免费 | 亚洲图中文字幕| 午夜视频一区在线观看| 噜噜噜久久亚洲精品国产品小说| 欧美日本乱大交xxxxx| 国产欧美精品在线| 亚洲国产天堂久久国产91| 亚洲香蕉伊综合在人在线视看| 久久久久久久一区| 日韩午夜视频在线观看| 久久不见久久见免费视频1| 欧美人成在线| 韩日成人av| 亚洲欧美国内爽妇网| 亚洲第一中文字幕| 欧美一级久久| 欧美三级日韩三级国产三级| 黄色一区二区三区四区| 亚洲一品av免费观看| 欧美黄色免费网站| 性久久久久久久| 欧美日韩国产a| 在线成人亚洲| 欧美永久精品| 一区二区三区欧美成人| 你懂的成人av| 一区在线视频| 久久精品人人做人人爽| 在线午夜精品| 欧美剧在线观看| 亚洲国产一区二区a毛片| 久久九九久久九九| 亚洲一区二区三区高清不卡| 欧美好吊妞视频| 亚洲第一精品在线| 久久久久久97三级| 午夜久久久久| 国产精品欧美风情| 亚洲已满18点击进入久久| 亚洲日本中文字幕免费在线不卡| 久久久久综合| 狠狠色狠狠色综合日日91app| 午夜欧美理论片| 亚洲图片欧美午夜| 欧美亚洲成人免费| 亚洲夜晚福利在线观看| 亚洲精品在线一区二区| 欧美精品精品一区| 日韩午夜免费视频| 亚洲欧洲精品一区二区精品久久久 | 欧美午夜不卡影院在线观看完整版免费| 亚洲第一精品夜夜躁人人爽| 麻豆久久婷婷| 久久久久.com| 在线日韩视频| 欧美黄色aaaa| 欧美日本亚洲| 亚洲视频一区在线| 亚洲永久字幕| 国产在线拍偷自揄拍精品|