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

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時(shí)間的發(fā)生,相當(dāng)于監(jiān)聽(tīng),至于相關(guān)的端口,需要在初始化EPOLL的時(shí)候綁定。
  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)測(cè)到一個(gè)HTTP用戶連接到綁定的HTTP端口,建立新的連接。由于我們新采用了SOCKET連接,所以基本沒(méi)用。
    {
     OnAcceptHttpEpoll ();
    }
    else if (m_events[i].data.fd == m_listen_sock_fd)//如果新監(jiān)測(cè)到一個(gè)SOCKET用戶連接到了綁定的SOCKET端口,建立新的連接。
    {
     OnAcceptSockEpoll ();
    }
    else if (m_events[i].events & EPOLLIN)//如果是已經(jīng)連接的用戶,并且收到數(shù)據(jù),那么進(jìn)行讀入。
    {
     OnReadEpoll (i);
    }

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

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

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

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

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

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

22、epoll_ctl函數(shù) 
函數(shù)聲明:int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event) 
該函數(shù)用于控制某個(gè)epoll文件描述符上的事件,可以注冊(cè)事件,修改事件,刪除事件。 
參數(shù): 
epfd:由 epoll_create 生成的epoll專用的文件描述符; 
op:要進(jìn)行的操作例如注冊(cè)事件,可能的取值EPOLL_CTL_ADD 注冊(cè)、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;
//注冊(cè)epoll事件
epoll_ctl(epfd,EPOLL_CTL_ADD,listenfd,&ev);


常用的事件類型:
EPOLLIN :表示對(duì)應(yīng)的文件描述符可以讀;
EPOLLOUT:表示對(duì)應(yīng)的文件描述符可以寫(xiě);
EPOLLPRI:表示對(duì)應(yīng)的文件描述符有緊急的數(shù)據(jù)可讀
EPOLLERR:表示對(duì)應(yīng)的文件描述符發(fā)生錯(cuò)誤;
EPOLLHUP:表示對(duì)應(yīng)的文件描述符被掛斷;
EPOLLET:表示對(duì)應(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ā)生的超時(shí)值(單位我也不太清楚);-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 - 處理每個(gè) socket 上的消息收發(fā) 
  3. */  
  4. int handle_message(int new_fd)  
  5. {  
  6.     char buf[MAXBUF + 1];  
  7.     int len;  
  8.       
  9.  /* 開(kāi)始處理每個(gè)新連接上的數(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個(gè)字節(jié)的數(shù)據(jù)\n",  
  18.              new_fd, buf, len);  
  19.  }  
  20.     else  
  21.  {  
  22.         if (len < 0)  
  23.      printf  
  24.                 ("消息接收失敗!錯(cuò)誤代碼是%d,錯(cuò)誤信息是'%s'\n",  
  25.                  errno, strerror(errno));  
  26.         close(new_fd);  
  27.         return -1;  
  28.     }  
  29.     /* 處理每個(gè)新連接上的數(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愛(ài)好者 Linux知識(shí)傳播者 SOHO族 開(kāi)發(fā)者 最擅長(zhǎng)C語(yǔ)言 
  37. *date time:2007-01-31 21:00 
  38. *Note: 任何人可以任意復(fù)制代碼并運(yùn)用這些文檔,當(dāng)然包括你的商業(yè)用途 
  39. * 但請(qǐng)遵循GPL 
  40. *Thanks to:Google 
  41. *Hope:希望越來(lái)越多的人貢獻(xiàn)自己的力量,為科學(xué)技術(shù)發(fā)展出力 
  42. * 科技站在巨人的肩膀上進(jìn)步更快!感謝有開(kāi)源前輩的貢獻(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è)置每個(gè)進(jìn)程允許打開(kāi)的最大文件數(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.     /* 開(kāi)啟 socket 監(jiān)聽(tīng) */  
  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("開(kāi)啟服務(wù)成功!\n");  
  18.      }  
  19.       
  20.  /* 創(chuàng)建 epoll 句柄,把監(jiān)聽(tīng) 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)聽(tīng) 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("有連接來(lái)自于: %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)行的原理是 等侍注冊(cè)在epfd上的socket fd的事件的發(fā)生,如果發(fā)生則將發(fā)生的sokct fd和事件類型放入到events數(shù)組中。 并且將注冊(cè)在epfd上的socket fd的事件類型給清空,所以如果下一個(gè)循環(huán)你還要關(guān)注這個(gè)socket fd的話,則需要用epoll_ctl(epfd,EPOLL_CTL_MOD,listenfd,&ev)來(lái)重新設(shè)置socket fd的事件類型。這時(shí)不用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 閱讀(2126) 評(píng)論(0)  編輯 收藏 引用 所屬分類: Socket
<2010年1月>
272829303112
3456789
10111213141516
17181920212223
24252627282930
31123456

常用鏈接

留言簿(10)

隨筆分類(307)

隨筆檔案(297)

algorithm

Books_Free_Online

C++

database

Linux

Linux shell

linux socket

misce

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

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

搜索

  •  

最新評(píng)論

閱讀排行榜

評(píng)論排行榜

青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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>
            99综合精品| 午夜亚洲视频| 国产精品久久久久久久7电影| 久久福利电影| 欧美中文在线视频| 久久亚洲欧美| 欧美大片在线观看一区| 免费一区视频| 欧美婷婷久久| 国产午夜精品一区理论片飘花| 国产专区精品视频| 亚洲国产精品www| 日韩一区二区久久| 亚洲欧美久久久久一区二区三区| 午夜激情综合网| 久久久久久久97| 亚洲国产二区| 亚洲伦理网站| 欧美在线免费观看视频| 久久综合狠狠| 欧美日韩国产欧| 国产手机视频一区二区| 亚洲国内在线| 香蕉久久一区二区不卡无毒影院| 久热精品视频在线免费观看| 亚洲精品欧美日韩| 欧美在线91| 欧美日韩午夜在线| 在线播放豆国产99亚洲| 亚洲免费影院| 亚洲国产美女| 久久不射中文字幕| 欧美顶级少妇做爰| 久久久精品一品道一区| 欧美中文字幕在线观看| 欧美精品18+| 国内免费精品永久在线视频| 亚洲乱亚洲高清| 久久天天躁夜夜躁狠狠躁2022| 亚洲人成在线播放| 久久久精品性| 国产日韩欧美另类| 亚洲一区精品视频| 亚洲国产一区二区三区青草影视| 亚洲在线视频| 欧美日韩不卡在线| 亚洲人成网在线播放| 久久综合影音| 先锋影音国产一区| 国产精品日本精品| 一本到12不卡视频在线dvd| 久久免费视频在线| 午夜在线成人av| 国产九九精品| 欧美一区2区视频在线观看| 一区二区三区国产在线观看| 欧美另类女人| 一区二区黄色| 亚洲免费观看视频| 欧美精品一区二| 亚洲美女在线国产| 亚洲国产精品久久久久秋霞影院| 久热国产精品视频| 亚洲激情女人| 亚洲三级国产| 欧美日韩亚洲国产一区| 日韩一级黄色大片| 亚洲人成网站在线播| 欧美激情一区二区三区四区| 日韩视频一区二区| 一本大道久久a久久精二百| 欧美日韩精品一区二区在线播放 | 99成人精品| 亚洲大胆av| 欧美精品在线看| 中日韩在线视频| 亚洲一区二区三区影院| 国产日韩精品一区二区| 久久久久一区| 久久伊人一区二区| 最新中文字幕一区二区三区| 亚洲国产精品久久久久秋霞蜜臀 | 欧美激情按摩| 亚洲一区二区精品在线| 亚洲欧美www| 亚洲成色777777女色窝| 亚洲精品一区二区三区四区高清 | 久久人人爽国产| 亚洲国产美女| 欧美午夜精品一区| 欧美亚洲一区| 久久婷婷久久| 夜夜嗨一区二区三区| 亚洲综合三区| 亚洲人成啪啪网站| 亚洲欧美久久久| 永久域名在线精品| 一本一道久久综合狠狠老精东影业| 国产精品老牛| 美女尤物久久精品| 欧美体内she精视频| 久久久欧美精品sm网站| 欧美日韩成人一区二区| 欧美mv日韩mv亚洲| 国产欧美日韩三区| 亚洲精品日韩在线观看| 国产一区美女| 中文高清一区| 亚洲精品午夜精品| 久久精品国产亚洲a| 亚洲午夜成aⅴ人片| 久久午夜影视| 久久精品国产欧美激情| 欧美日韩精品一区二区天天拍小说 | 亚洲每日在线| 在线欧美亚洲| 午夜欧美大尺度福利影院在线看| 亚洲精品老司机| 久久免费观看视频| 久久三级视频| 国产精品一区二区久久国产| 亚洲人体大胆视频| 亚洲国产美女精品久久久久∴| 亚洲欧美一区二区三区极速播放| 99精品视频免费| 欧美xxx成人| 欧美成人精品不卡视频在线观看 | 亚洲国产乱码最新视频| 欧美一区成人| 欧美一区三区三区高中清蜜桃| 欧美日韩国产另类不卡| 欧美xxx在线观看| 韩国三级在线一区| 欧美在线在线| 久久久久综合网| 国产午夜精品久久久久久久| 亚洲欧美日韩中文视频| 性久久久久久久久久久久| 欧美日韩一区在线视频| 亚洲另类黄色| 亚洲一区二区三区精品动漫| 欧美调教视频| 亚洲福利视频网| 美女任你摸久久| 欧美一区二区免费视频| 欧美日韩精品二区第二页| 91久久综合亚洲鲁鲁五月天| 亚洲国产精品va在线观看黑人 | 久久成人精品视频| 久久久久99精品国产片| 国产一区二区在线免费观看| 欧美一区二区高清| 美女脱光内衣内裤视频久久网站| 亚洲第一区色| 欧美不卡视频一区| 日韩一级黄色av| 性欧美超级视频| 激情久久综合| 欧美激情综合在线| 在线午夜精品| 久久9热精品视频| 国内精品视频久久| 蜜臀av一级做a爰片久久| 亚洲日本在线视频观看| 在线一区二区视频| 国产区日韩欧美| 免费中文日韩| 亚洲天堂成人在线视频| 看片网站欧美日韩| 亚洲视频碰碰| 激情成人中文字幕| 欧美日韩和欧美的一区二区| 亚洲欧美不卡| 亚洲精品韩国| 久久精品亚洲国产奇米99| 91久久久久久久久久久久久| 国产精品v亚洲精品v日韩精品| 欧美一区深夜视频| 亚洲精品中文字幕有码专区| 久久精品亚洲一区| 亚洲午夜国产成人av电影男同| 一区二区在线视频播放| 国产精品福利网| 欧美a级一区二区| 亚洲欧美日韩一区二区三区在线观看 | 亚洲日本免费| 久久久五月婷婷| 亚洲一区免费观看| 亚洲青色在线| 国产一区二区三区四区五区美女| 欧美国产一区二区| 久久国产免费| 亚洲免费人成在线视频观看| 亚洲激情一区二区三区| 麻豆久久婷婷| 欧美一区国产在线| 午夜欧美大片免费观看| 亚洲视频国产视频| 99热这里只有成人精品国产| 在线观看一区二区精品视频|