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

   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++技術中心 閱讀(5126) 評論(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>
            欧美成人四级电影| 亚洲自拍另类| 久久精选视频| 久久在线91| 国产精品一区视频网站| 亚洲精品日韩在线观看| 欧美成人免费观看| 麻豆乱码国产一区二区三区| 国产精品丝袜久久久久久app| 亚洲午夜激情网站| 亚洲综合三区| 亚洲精品中文字幕在线观看| 美女主播精品视频一二三四| 激情欧美日韩| 免费久久99精品国产| 亚洲视频一二三| 国产欧美大片| 久久久精品999| 亚洲免费影院| 国产日韩在线播放| 久久综合图片| 免费影视亚洲| 亚洲精品一区二区在线| 亚洲精品日日夜夜| 国产精品a久久久久久| 亚洲一级在线观看| 午夜精品理论片| 影音先锋亚洲精品| 亚洲二区免费| 麻豆视频一区二区| 亚洲麻豆一区| 99视频+国产日韩欧美| 国产精品家教| 久久手机免费观看| 欧美福利一区二区| 亚洲高清视频在线观看| 蜜桃精品久久久久久久免费影院| 久久亚洲综合网| 亚洲免费观看高清完整版在线观看熊 | 91久久香蕉国产日韩欧美9色| 久久久久欧美精品| 亚洲欧美国产视频| 国产一二精品视频| 亚洲精品偷拍| 国产在线拍偷自揄拍精品| 欧美国产欧美亚洲国产日韩mv天天看完整 | 欧美视频一区二区三区…| 日韩午夜视频在线观看| 亚洲视频精品| 在线日韩av永久免费观看| 亚洲精品久久在线| 国产精品外国| 亚洲第一色在线| 国产伦精品一区二区三区视频孕妇| 久久久久久久久一区二区| 欧美激情自拍| 亚洲欧美日韩中文在线制服| 亚洲国产欧美一区二区三区丁香婷| 国产精品免费观看在线| 欧美韩日亚洲| 国产一区二区三区在线免费观看 | 在线视频日韩| 一区二区在线视频| 国产精品99久久久久久久女警 | 国产一区二区三区日韩| 亚洲毛片在线看| 亚洲第一免费播放区| 亚洲小视频在线观看| 亚洲精品久久| 久久久久欧美| 久久久久中文| 国产欧美精品在线观看| 亚洲日本欧美日韩高观看| 国产一区二区三区视频在线观看| 99视频一区二区| 亚洲精品视频免费观看| 久久精品中文字幕一区二区三区| 香蕉免费一区二区三区在线观看| 欧美日韩国产123| 欧美激情久久久| 欧美精品国产一区| 欧美一区二区久久久| 国产精品福利片| 99国产精品国产精品久久| 91久久极品少妇xxxxⅹ软件| 午夜久久久久久| 亚洲午夜精品一区二区| 欧美美女bb生活片| 亚洲人体大胆视频| 亚洲国产成人精品久久| 久久精品国产清自在天天线| 欧美在线免费一级片| 国产精品亚洲网站| 亚洲欧美日韩另类| 亚洲精品网址在线观看| 欧美大片免费观看在线观看网站推荐| 美日韩丰满少妇在线观看| 国产精品视频网站| 午夜亚洲精品| 久久午夜视频| 亚洲精品乱码久久久久久久久 | 一区二区日韩精品| 久久激情五月激情| 日韩亚洲欧美成人| 国产一区二区三区免费观看 | 亚洲欧美一区二区精品久久久| 久久一二三四| 亚洲视频香蕉人妖| 在线日韩av片| 国产免费观看久久黄| 免费日韩av片| 亚洲欧美日韩国产综合| 亚洲激情在线| 久久久另类综合| 亚洲尤物影院| 亚洲精品欧美日韩| 国产一区二区| 国产精品九色蝌蚪自拍| 美女视频黄a大片欧美| 亚洲一区二区三区四区视频| 欧美激情在线观看| 久久精品中文| 香蕉成人啪国产精品视频综合网| 91久久国产自产拍夜夜嗨| 国产精品三级视频| 欧美日韩亚洲一区二区三区| 久久久久久久网站| 香蕉免费一区二区三区在线观看| 亚洲人成艺术| 欧美国产欧美综合| 狂野欧美性猛交xxxx巴西| 欧美亚洲尤物久久| 亚洲在线1234| 在线一区亚洲| 一区二区三区欧美亚洲| 亚洲欧洲一区二区天堂久久 | 欧美黄色一区二区| 久久久午夜视频| 久久久久九九九| 亚洲欧美日韩精品久久| 亚洲一区bb| 亚洲一区尤物| 亚洲尤物视频在线| 亚洲丝袜av一区| 中国亚洲黄色| 亚洲淫片在线视频| 亚洲欧美成人| 欧美一区二区三区在| 亚洲免费中文| 久久成人久久爱| 久久精品国亚洲| 卡一卡二国产精品| 欧美大色视频| 欧美乱人伦中文字幕在线| 欧美日韩亚洲综合在线| 欧美日韩一区二区三区在线看| 欧美日韩成人综合天天影院| 欧美日韩国产一级片| 欧美午夜宅男影院| 国产精品美女久久| 国产一区二区三区自拍| 在线免费观看日本一区| 亚洲精品国产拍免费91在线| aaa亚洲精品一二三区| 亚洲午夜免费视频| 久久av二区| 欧美va亚洲va国产综合| 亚洲欧洲日本在线| 亚洲视频久久| 久久国产精品一区二区三区| 裸体一区二区三区| 欧美日一区二区在线观看 | 亚洲国产成人久久| 一区二区三区视频在线| 欧美一区二区三区男人的天堂| 久久久久久久久久久久久久一区 | av不卡在线观看| 亚洲女性裸体视频| 久久免费精品视频| 欧美日韩精品一区二区三区| 国产精品视频yy9299一区| 红桃视频国产精品| 夜夜爽www精品| 久久精品中文字幕免费mv| 欧美福利小视频| 在线视频精品一区| 久久婷婷久久| 国产精品入口尤物| 日韩午夜在线播放| 久久久久久久久久码影片| 亚洲欧洲一区二区天堂久久| 午夜精品福利一区二区三区av| 欧美a一区二区| 国产女主播一区| 一区二区三区波多野结衣在线观看| 性欧美精品高清| 亚洲精品乱码久久久久久久久| 久久av资源网| 国产精品久久久久久久久| 亚洲欧洲日本专区|