转载自:
1. struct epoll_event
结构体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 event */ epoll_data_t data; /* User data variable */ }; 其中events表示感兴趣的事件和被触发的事件,可能的取值为: EPOLLIN :表示对应的文件描述符可以读; EPOLLOUT:表示对应的文件描述符可以写; EPOLLPRI: 表示对应的文件描述符有紧急的数可读;EPOLLERR:表示对应的文件描述符发生错误;
EPOLLHUP:表示对应的文件描述符被挂断; EPOLLET: ET的epoll工作模式;
所涉及到的函数有:
1、epoll_create函数
函数声明:int epoll_create(int size) 功能:该函数生成一个epoll专用的文件描述符,其中的参数是指定生成描述符的最大范围;这个参数自从Linux 2.6.8之后开始就没有使用了(被忽略了)
2、epoll_ctl函数
函数声明:int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event)
功能:用于控制某个文件描述符上的事件,可以注册事件,修改事件,删除事件。 @epfd:由 epoll_create 生成的epoll专用的文件描述符; @op:要进行的操作,EPOLL_CTL_ADD 注册、EPOLL_CTL_MOD 修改、EPOLL_CTL_DEL 删除; @fd:关联的文件描述符; @event:指向epoll_event的指针; 成功:0;失败:-1 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
应用举例:
1 #define SERV_PORT 4466 //服务端口号 2 const char *LOCAL_ADDR = "127.0.0.1";//绑定服务地址 3 4 bool setnonblocking(int sock)//设置socket为非阻塞方式 5 { 6 int opts; 7 8 opts=fcntl(sock,F_GETFL); 9 if(opts<0) 10 { 11 perror("fcntl(sock,GETFL)"); 12 return false; 13 } 14 opts = opts|O_NONBLOCK; 15 if(fcntl(sock,F_SETFL,opts)<0) 16 { 17 perror("fcntl(sock,SETFL,opts)"); 18 return false; 19 } 20 return true; 21 } 22 23 int main() 24 { 25 int i, maxi, listenfd, new_fd, sockfd,epfd,nfds; 26 ssize_t n; 27 char line[MAXLINE]; 28 socklen_t clilen; 29 struct epoll_event ev,events[20];//ev用于注册事件,数组用于回传要处理的事件 30 struct sockaddr_in clientaddr, serveraddr; 31 32 listenfd = socket(AF_INET, SOCK_STREAM, 0);//生成socket文件描述符 33 setnonblocking(listenfd);//把socket设置为非阻塞方式 34 35 epfd=epoll_create(256);//生成用于处理accept的epoll专用的文件描述符 36 ev.data.fd=listenfd;//设置与要处理的事件相关的文件描述符 37 ev.events=EPOLLIN|EPOLLET;//设置要处理的事件类型 38 epoll_ctl(epfd,EPOLL_CTL_ADD,listenfd,&ev);//注册epoll事件 39 40 //设置服务器端地址信息 41 bzero(&serveraddr, sizeof(serveraddr)); 42 serveraddr.sin_family = AF_INET; 43 char *local_addr= LOCAL_ADDR; 44 inet_aton(local_addr,&(serveraddr.sin_addr)); 45 serveraddr.sin_port=htons(SERV_PORT); 46 47 bind(listenfd,(sockaddr *)&serveraddr, sizeof(serveraddr));//绑定socket连接 48 listen(listenfd, LISTENQ);//监听 49 50 maxi = 0; 51 for ( ; ; ) 52 { 53 /* epoll_wait:等待epoll事件的发生,并将发生的sokct fd和事件类型放入到events数组中; 54 * nfds:为发生的事件的个数。 55 * 注:事件发生后,注册在epfd上的socket fd的事件类型会被清空,所以如果下一个循环你 56 * 还要关注这个socket fd的话,则需要用epoll_ctl(epfd,EPOLL_CTL_MOD,listenfd,&ev)来 57 * 重新设置socket fd的事件类型 58 */ 59 nfds=epoll_wait(epfd,events,20,500); 60 61 //处理所发生的所有事件 62 for(i=0;i< 0) 83 continue; 84 85 if ( (n = read(sockfd, line, MAXLINE)) < 0) 86 { 87 if (errno == ECONNRESET) 88 { 89 close(sockfd); 90 events[i].data.fd = -1; 91 } 92 else 93 std::cout<<"readline error"<