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

   C++ 技術中心

   :: 首頁 :: 聯系 ::  :: 管理
  160 Posts :: 0 Stories :: 87 Comments :: 0 Trackbacks

公告

鄭重聲明:本BLOG所發表的原創文章,作者保留一切權利。必須經過作者本人同意后方可轉載,并注名作者(天空)和出處(CppBlog.com)。作者Email:coder@luckcoder.com

留言簿(27)

搜索

  •  

最新隨筆

最新評論

評論排行榜

在linux的網絡編程中,很長的時間都在使用select來做事件觸發。在linux新的內核中,有了一種替換它的機制,就是epoll。
相比于select,epoll最大的好處在于它不會隨著監聽fd數目的增長而降低效率。因為在內核中的select實現中,它是采用輪詢來處理的,輪詢的fd數目越多,自然耗時越多。并且,在linux/posix_types.h頭文件有這樣的聲明:
#define __FD_SETSIZE 1024
表示select最多同時監聽1024個fd,當然,可以通過修改頭文件再重編譯內核來擴大這個數目,但這似乎并不治本。

epoll的接口非常簡單,一共就三個函數:
1. int epoll_create(int size);
創建一個epoll的句柄,size用來告訴內核這個監聽的數目一共有多大。這個參數不同于select()中的第一個參數,給出最大監聽的fd+1的值。需要注意的是,當創建好epoll句柄后,它就是會占用一個fd值,在linux下如果查看/proc/進程id/fd/,是能夠看到這個fd的,所以在使用完epoll后,必須調用close()關閉,否則可能導致fd被耗盡。


2. int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event);
epoll的事件注冊函數,它不同與select()是在監聽事件時告訴內核要監聽什么類型的事件,而是在這里先注冊要監聽的事件類型。第一個參數是epoll_create()的返回值,第二個參數表示動作,用三個宏來表示:
EPOLL_CTL_ADD:注冊新的fd到epfd中;
EPOLL_CTL_MOD:修改已經注冊的fd的監聽事件;
EPOLL_CTL_DEL:從epfd中刪除一個fd;
第三個參數是需要監聽的fd,第四個參數是告訴內核需要監聽什么事,struct epoll_event結構如下:

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 */
};

events可以是以下幾個宏的集合:
EPOLLIN :表示對應的文件描述符可以讀(包括對端SOCKET正常關閉);
EPOLLOUT:表示對應的文件描述符可以寫;
EPOLLPRI:表示對應的文件描述符有緊急的數據可讀(這里應該表示有帶外數據到來);
EPOLLERR:表示對應的文件描述符發生錯誤;
EPOLLHUP:表示對應的文件描述符被掛斷;
EPOLLET: 將EPOLL設為邊緣觸發(Edge Triggered)模式,這是相對于水平觸發(Level Triggered)來說的。
EPOLLONESHOT:只監聽一次事件,當監聽完這次事件之后,如果還需要繼續監聽這個socket的話,需要再次把這個socket加入到EPOLL隊列里


3. int epoll_wait(int epfd, struct epoll_event * events, int maxevents, int timeout);
等待事件的產生,類似于select()調用。參數events用來從內核得到事件的集合,maxevents告之內核這個events有多大,這個 maxevents的值不能大于創建epoll_create()時的size,參數timeout是超時時間(毫秒,0會立即返回,-1將不確定,也有說法說是永久阻塞)。該函數返回需要處理的事件數目,如返回0表示已超時。

4、關于ET、LT兩種工作模式:
可以得出這樣的結論:
ET模式僅當狀態發生變化的時候才獲得通知,這里所謂的狀態的變化并不包括緩沖區中還有未處理的數據,也就是說,如果要采用ET模式,需要一直read/write直到出錯為止,很多人反映為什么采用ET模式只接收了一部分數據就再也得不到通知了,大多因為這樣;而LT模式是只要有數據沒有處理就會一直通知下去的.


那么究竟如何來使用epoll呢?其實非常簡單。
通過在包含一個頭文件#include <sys/epoll.h> 以及幾個簡單的API將可以大大的提高你的網絡服務器的支持人數。

首先通過create_epoll(int maxfds)來創建一個epoll的句柄,其中maxfds為你epoll所支持的最大句柄數。這個函數會返回一個新的epoll句柄,之后的所有操作將通過這個句柄來進行操作。在用完之后,記得用close()來關閉這個創建出來的epoll句柄。

之后在你的網絡主循環里面,每一幀的調用epoll_wait(int epfd, epoll_event events, int max events, int timeout)來查詢所有的網絡接口,看哪一個可以讀,哪一個可以寫了。基本的語法為:
nfds = epoll_wait(kdpfd, events, maxevents, -1);
其中kdpfd為用epoll_create創建之后的句柄,events是一個epoll_event*的指針,當epoll_wait這個函數操作成功之后,epoll_events里面將儲存所有的讀寫事件。max_events是當前需要監聽的所有socket句柄數。最后一個timeout是 epoll_wait的超時,為0的時候表示馬上返回,為-1的時候表示一直等下去,直到有事件范圍,為任意正整數的時候表示等這么長的時間,如果一直沒有事件,則范圍。一般如果網絡主循環是單獨的線程的話,可以用-1來等,這樣可以保證一些效率,如果是和主邏輯在同一個線程的話,則可以用0來保證主循環的效率。

epoll_wait范圍之后應該是一個循環,遍利所有的事件。

幾乎所有的epoll程序都使用下面的框架:

 for( ; ; )
{
nfds = epoll_wait(epfd,events,20,500);
for(i=0;i<nfds;++i)
{
if(events[i].data.fd==listenfd) //有新的連接
{
connfd = accept(listenfd,(sockaddr *)&clientaddr, &clilen); //accept這個連接
ev.data.fd=connfd;
ev.events=EPOLLIN|EPOLLET;
epoll_ctl(epfd,EPOLL_CTL_ADD,connfd,&ev); //將新的fd添加到epoll的監聽隊列中
}
else if( events[i].events&EPOLLIN ) //接收到數據,讀socket
{
n = read(sockfd, line, MAXLINE)) < 0 //讀
ev.data.ptr = md; //md為自定義類型,添加數據
ev.events=EPOLLOUT|EPOLLET;
epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev);//修改標識符,等待下一個循環時發送數據,異步處理的精髓
}
else if(events[i].events&EPOLLOUT) //有數據待發送,寫socket
{
struct myepoll_data* md = (myepoll_data*)events[i].data.ptr; //取數據
sockfd = md->fd;
send( sockfd, md->ptr, strlen((char*)md->ptr), 0 ); //發送數據
ev.data.fd=sockfd;
ev.events=EPOLLIN|EPOLLET;
epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev); //修改標識符,等待下一個循環時接收數據
}
else
{
//其他的處理
}
}
}
#include <iostream>
#include 
<sys/socket.h>
#include 
<sys/epoll.h>
#include 
<netinet/in.h>
#include 
<arpa/inet.h>
#include 
<fcntl.h>
#include 
<unistd.h>
#include 
<stdio.h>
#include 
<errno.h>

using namespace std;

#define MAXLINE 5
#define OPEN_MAX 100
#define LISTENQ 20
#define SERV_PORT 5000
#define INFTIM 1000

void setnonblocking(int sock)
{
    
int opts;
    opts
=fcntl(sock,F_GETFL);
    
if(opts<0)
    
{
        perror(
"fcntl(sock,GETFL)");
        exit(
1);
    }

    opts 
= opts|O_NONBLOCK;
    
if(fcntl(sock,F_SETFL,opts)<0)
    
{
        perror(
"fcntl(sock,SETFL,opts)");
        exit(
1);
    }

}


int main(int argc, char* argv[])
{
    
int i, maxi, listenfd, connfd, sockfd,epfd,nfds, portnumber;
    ssize_t n;
    
char line[MAXLINE];
    socklen_t clilen;


    
if ( 2 == argc )
    
{
        
if( (portnumber = atoi(argv[1])) < 0 )
        
{
            fprintf(stderr,
"Usage:%s portnumber/a/n",argv[0]);
            
return 1;
        }

    }

    
else
    
{
        fprintf(stderr,
"Usage:%s portnumber/a/n",argv[0]);
        
return 1;
    }




    
//聲明epoll_event結構體的變量,ev用于注冊事件,數組用于回傳要處理的事件

    
struct epoll_event ev,events[20];
    
//生成用于處理accept的epoll專用的文件描述符

    epfd
=epoll_create(256);
    
struct sockaddr_in clientaddr;
    
struct sockaddr_in serveraddr;
    listenfd 
= socket(AF_INET, SOCK_STREAM, 0);
    
//把socket設置為非阻塞方式

    
//setnonblocking(listenfd);

    
//設置與要處理的事件相關的文件描述符

    ev.data.fd
=listenfd;
    
//設置要處理的事件類型

    ev.events
=EPOLLIN|EPOLLET;
    
//ev.events=EPOLLIN;

    
//注冊epoll事件

    epoll_ctl(epfd,EPOLL_CTL_ADD,listenfd,
&ev);
    bzero(
&serveraddr, sizeof(serveraddr));
    serveraddr.sin_family 
= AF_INET;
    
char *local_addr="127.0.0.1";
    inet_aton(local_addr,
&(serveraddr.sin_addr));//htons(portnumber);

    serveraddr.sin_port
=htons(portnumber);
    bind(listenfd,(sockaddr 
*)&serveraddr, sizeof(serveraddr));
    listen(listenfd, LISTENQ);
    maxi 
= 0;
    
for ( ; ; ) {
        
//等待epoll事件的發生

        nfds
=epoll_wait(epfd,events,20,500);
        
//處理所發生的所有事件

        
for(i=0;i<nfds;++i)
        
{
            
if(events[i].data.fd==listenfd)//如果新監測到一個SOCKET用戶連接到了綁定的SOCKET端口,建立新的連接。

            
{
                connfd 
= accept(listenfd,(sockaddr *)&clientaddr, &clilen);
                
if(connfd<0){
                    perror(
"connfd<0");
                    exit(
1);
                }

                
//setnonblocking(connfd);

                
char *str = inet_ntoa(clientaddr.sin_addr);
                cout 
<< "accapt a connection from " << str << endl;
                
//設置用于讀操作的文件描述符

                ev.data.fd
=connfd;
                
//設置用于注測的讀操作事件

                ev.events
=EPOLLIN|EPOLLET;
                
//ev.events=EPOLLIN;

                
//注冊ev

                epoll_ctl(epfd,EPOLL_CTL_ADD,connfd,
&ev);
            }

            
else if(events[i].events&EPOLLIN)//如果是已經連接的用戶,并且收到數據,那么進行讀入。

            
{
                cout 
<< "EPOLLIN" << endl;
                
if ( (sockfd = events[i].data.fd) < 0)
                    
continue;
                
if ( (n = read(sockfd, line, MAXLINE)) < 0{
                    
if (errno == ECONNRESET) {
                        close(sockfd);
                        events[i].data.fd 
= -1;
                    }
 else
                        std::cout
<<"readline error"<<std::endl;
                }
 else if (n == 0{
                    close(sockfd);
                    events[i].data.fd 
= -1;
                }

                line[n] 
= '/0';
                cout 
<< "read " << line << endl;
                
//設置用于寫操作的文件描述符

                ev.data.fd
=sockfd;
                
//設置用于注測的寫操作事件

                ev.events
=EPOLLOUT|EPOLLET;
                
//修改sockfd上要處理的事件為EPOLLOUT

                
//epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,&ev);

            }

            
else if(events[i].events&EPOLLOUT) // 如果有數據發送

            
{
                sockfd 
= events[i].data.fd;
                write(sockfd, line, n);
                
//設置用于讀操作的文件描述符

                ev.data.fd
=sockfd;
                
//設置用于注測的讀操作事件

                ev.events
=EPOLLIN|EPOLLET;
                
//修改sockfd上要處理的事件為EPOLIN

                epoll_ctl(epfd,EPOLL_CTL_MOD,sockfd,
&ev);
            }

        }

    }

    
return 0;
}




posted on 2013-01-07 14:17 C++技術中心 閱讀(5125) 評論(0)  編輯 收藏 引用 所屬分類: Linux 編程
青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <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>
            性视频1819p久久| 亚洲日本一区二区三区| 国产偷自视频区视频一区二区| 欧美电影免费观看高清完整版| 久久黄金**| 老司机精品视频一区二区三区| 性久久久久久久| 欧美激情第六页| 99一区二区| 亚洲欧美一区二区原创| 午夜在线播放视频欧美| 久久亚洲综合| 亚洲福利久久| 一本色道久久99精品综合| 亚洲裸体在线观看| 亚洲制服av| 欧美成人免费全部观看天天性色| 欧美搞黄网站| 国产乱码精品一区二区三| 亚洲国产精品va| 亚洲成人在线视频播放 | 久久精品国产精品亚洲精品| 久久久久久久91| 欧美日韩视频在线第一区| 国产伦精品一区二区三| 亚洲高清视频在线观看| 亚洲女同精品视频| 亚洲电影免费观看高清完整版在线观看 | 久久亚洲高清| 国产精品99一区二区| 国内成人精品视频| 艳女tv在线观看国产一区| 久久精品国产第一区二区三区最新章节 | 在线中文字幕一区| 久久只精品国产| 国产精品最新自拍| 99riav1国产精品视频| 欧美在线精品一区| 一本色道综合亚洲| 欧美激情视频在线播放| 激情综合网址| 欧美一区二区免费| 亚洲精品网址在线观看| 99国产精品一区| 欧美黑人国产人伦爽爽爽| 亚洲欧美激情视频在线观看一区二区三区 | 亚洲午夜高清视频| 亚洲成色777777在线观看影院| 亚洲欧美一区二区三区极速播放 | 久久久在线视频| 国产乱码精品一区二区三区五月婷 | 久久久久久一区| 亚洲手机在线| 欧美日韩久久久久久| 亚洲人成网站精品片在线观看| 久久一区二区精品| 久久成人人人人精品欧| 国产视频欧美| 久久久久亚洲综合| 性欧美xxxx视频在线观看| 国产精品免费区二区三区观看| 亚洲一区二区在线播放| 夜夜嗨av色一区二区不卡| 欧美女同视频| 中文精品一区二区三区| 亚洲一区二区成人在线观看| 国产精品亚洲一区二区三区在线| 午夜精品久久一牛影视| 亚洲欧美日韩久久精品| 国产日韩欧美三区| 欧美福利一区| 欧美理论大片| 亚洲欧美日韩精品久久久久| 亚洲欧美日韩第一区| 韩日欧美一区二区| 欧美激情一区二区三区成人| 欧美精品一区二区视频| 亚洲免费小视频| 欧美亚洲视频在线观看| 在线欧美视频| 日韩视频免费观看高清在线视频 | 美女精品国产| 日韩视频免费| 亚洲一级一区| 在线播放不卡| 亚洲精品一区二区三区在线观看 | 麻豆精品精华液| 免费成人美女女| 99综合电影在线视频| 中文欧美字幕免费| 国模吧视频一区| 亚洲激情午夜| 国产欧美一区二区三区国产幕精品| 久久久国产精品亚洲一区 | 影音欧美亚洲| 99国产精品久久久久老师| 国产无遮挡一区二区三区毛片日本| 麻豆精品91| 国产精品久久久久久户外露出 | 亚洲香蕉在线观看| 尤物精品国产第一福利三区| 亚洲精品中文字幕女同| 激情综合在线| 亚洲男女自偷自拍| 9色porny自拍视频一区二区| 午夜一区二区三区不卡视频| 亚洲美女在线看| 欧美在线观看一二区| 中国亚洲黄色| 免费欧美日韩| 久久永久免费| 国产欧美日韩亚州综合| 亚洲精品影院| 亚洲区一区二| 巨乳诱惑日韩免费av| 欧美制服丝袜| 欧美亚男人的天堂| 亚洲精品一区二区三| 亚洲精品一区二区三| 久久久久久夜| 久久久人成影片一区二区三区| 欧美涩涩视频| 日韩系列欧美系列| av成人天堂| 欧美日韩aaaaa| 亚洲国内精品| 亚洲日本一区二区| 免费在线成人| 亚洲高清一区二| 亚洲破处大片| 欧美精品videossex性护士| 欧美成人亚洲成人| 亚洲高清免费在线| 蜜臀久久99精品久久久久久9 | 亚洲女人天堂av| 欧美视频你懂的| 一本色道久久综合| 亚洲午夜一区二区| 欧美性大战久久久久久久蜜臀| 亚洲精品免费在线播放| 亚洲精选在线| 国产日韩欧美一区二区三区四区| 亚洲欧美怡红院| 亚洲影音一区| 欧美午夜性色大片在线观看| 日韩视频在线永久播放| 亚洲制服丝袜在线| 国产精品毛片大码女人| 亚洲免费影院| 美女黄色成人网| 亚洲人成网站精品片在线观看 | 亚洲一区二区三区四区五区午夜| 欧美人与性动交cc0o| 一区二区三区日韩欧美精品| 亚洲欧美另类在线| 国产亚洲综合精品| 久久综合999| 最新日韩精品| 亚洲欧美日产图| 激情成人亚洲| 欧美理论电影在线播放| 亚洲综合日本| 欧美不卡在线| 亚洲自拍偷拍色片视频| 国产在线拍偷自揄拍精品| 另类激情亚洲| 中文在线一区| 麻豆freexxxx性91精品| 一区二区久久| 激情综合视频| 国产精品免费看| 欧美大尺度在线| 亚洲欧美日本在线| 亚洲精品日韩激情在线电影| 欧美专区在线| 亚洲免费观看在线视频| 国产麻豆9l精品三级站| 欧美成人精品高清在线播放| 亚洲在线成人| 亚洲九九九在线观看| 久久在线91| 欧美伊久线香蕉线新在线| 亚洲精品乱码久久久久| 国产日韩在线一区二区三区| 欧美精品午夜| 久久综合久久综合这里只有精品 | 欧美日韩伦理在线| 久久久久久久国产| 亚洲一区二区三区三| 亚洲国产女人aaa毛片在线| 欧美一区二区性| 亚洲综合日本| 一本一本久久a久久精品牛牛影视| 国产一区二区剧情av在线| 国产精品成人一区二区三区夜夜夜| 另类av一区二区| 久久女同精品一区二区| 久久er精品视频| 亚洲欧美在线aaa| 亚洲一区二区精品在线|