創(chuàng)建一個epoll句柄，參數(shù)size用來告訴內(nèi)核監(jiān)聽的文件描述符的個數(shù)，跟內(nèi)存大小有關(guān)。

　　#include <sys/epoll.h>

　　int epoll_create(int size)　　 size：監(jiān)聽數(shù)目? ? ?通過創(chuàng)建一個size大小的紅黑數(shù)來實現(xiàn)epoll句柄，返回epfd是該樹的根節(jié)點。

?

控制某個epoll監(jiān)控的文件描述符上的事件：注冊、修改、刪除。

?

　　#include <sys/epoll.h>

?

　　int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event)

?

　　epfd： 為epoll_creat的句柄

?

　　op： 表示動作，用3個宏來表示：

?

　　　　EPOLL_CTL_ADD?(注冊新的fd到epfd)，

?

　　　　EPOLL_CTL_MOD?(修改已經(jīng)注冊的fd的監(jiān)聽事件)，

?

　　　　EPOLL_CTL_DEL?(從epfd刪除一個fd)；

?

　　event： 告訴內(nèi)核需要監(jiān)聽的事件，是一個地址

　　struct epoll_event {

　　　　__uint32_t events;　　　　　　//EPOLLIN　　EPOLLOUT　　EPOLLERR

　　　　epoll_data_t data;?

　　};

　　typedef union epoll_data {

　　　　void *ptr;

　　　　int fd;　　　　　　　　　　　　//相當于函數(shù)中使用的fd

　　　　uint32_t u32;

　　　　uint64_t u64;

　　} epoll_data_t;

?

等待所監(jiān)控文件描述符上有事件的產(chǎn)生，類似于select()調(diào)用。

　　#include <sys/epoll.h>

　　int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout)

　　events： 用來存內(nèi)核得到事件的集合，是一個數(shù)組并且是傳出參數(shù)。

　　maxevents： 告之內(nèi)核這個events有多大，這個maxevents的值不能大于創(chuàng)建epoll_create()時的size，

　　timeout： 是超時時間

　　　　-1： 阻塞

　　　　0： 立即返回，非阻塞

　　　　>0： 指定毫秒

　　返回值： 成功返回有多少文件描述符就緒，時間到時返回0，出錯返回-1

?

示例：

#include <stdio.h> #include <unistd.h> #include <stdlib.h> #include <string.h> #include <arpa/inet.h> #include <sys/epoll.h> #include <errno.h> #include <ctype.h>#include "wrap.h"#define MAXLINE 8192 #define SERV_PORT 8000 #define OPEN_MAX 5000int main(int argc, char *argv[]) {int i, listenfd, connfd, sockfd;int n, num = 0;ssize_t nready, efd, res;char buf[MAXLINE], str[INET_ADDRSTRLEN];socklen_t clilen;struct sockaddr_in cliaddr, servaddr;struct epoll_event tep, ep[OPEN_MAX]; //tep: epoll_ctl參數(shù) ep[] : epoll_wait參數(shù) listenfd = Socket(AF_INET, SOCK_STREAM, 0);int opt = 1;setsockopt(listenfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt)); //端口復用 bzero(&servaddr, sizeof(servaddr));servaddr.sin_family = AF_INET;servaddr.sin_addr.s_addr = htonl(INADDR_ANY);servaddr.sin_port = htons(SERV_PORT);Bind(listenfd, (struct sockaddr *) &servaddr, sizeof(servaddr));Listen(listenfd, 20);efd = epoll_create(OPEN_MAX); //創(chuàng)建epoll模型, efd指向紅黑樹根節(jié)點if (efd == -1)perr_exit("epoll_create error");tep.events = EPOLLIN; tep.data.fd = listenfd; //指定lfd的監(jiān)聽時間為"讀"res = epoll_ctl(efd, EPOLL_CTL_ADD, listenfd, &tep); //將lfd及對應(yīng)的結(jié)構(gòu)體設(shè)置到樹上,efd可找到該樹if (res == -1)perr_exit("epoll_ctl error");for ( ; ; ) {/*epoll為server阻塞監(jiān)聽事件, ep為struct epoll_event類型數(shù)組, OPEN_MAX為數(shù)組容量, -1表永久阻塞*/nready = epoll_wait(efd, ep, OPEN_MAX, -1); if (nready == -1)perr_exit("epoll_wait error");for (i = 0; i < nready; i++) {if (!(ep[i].events & EPOLLIN)) //如果不是"讀"事件, 繼續(xù)循環(huán)continue;if (ep[i].data.fd == listenfd) { //判斷滿足事件的fd是不是lfd clilen = sizeof(cliaddr);connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &clilen); //接受鏈接 printf("received from %s at PORT %d\n", inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)), ntohs(cliaddr.sin_port));printf("cfd %d---client %d\n", connfd, ++num);tep.events = EPOLLIN; tep.data.fd = connfd;res = epoll_ctl(efd, EPOLL_CTL_ADD, connfd, &tep);if (res == -1)perr_exit("epoll_ctl error");} else { //不是lfd, sockfd = ep[i].data.fd;n = Read(sockfd, buf, MAXLINE);if (n == 0) { //讀到0,說明客戶端關(guān)閉鏈接res = epoll_ctl(efd, EPOLL_CTL_DEL, sockfd, NULL); //將該文件描述符從紅黑樹摘除if (res == -1)perr_exit("epoll_ctl error");Close(sockfd); //關(guān)閉與該客戶端的鏈接printf("client[%d] closed connection\n", sockfd);} else if (n < 0) { //出錯perror("read n < 0 error: ");res = epoll_ctl(efd, EPOLL_CTL_DEL, sockfd, NULL);Close(sockfd);} else { //實際讀到了字節(jié)數(shù)for (i = 0; i < n; i++)buf[i] = toupper(buf[i]); //轉(zhuǎn)大寫,寫回給客戶端 Write(STDOUT_FILENO, buf, n);Writen(sockfd, buf, n);}}}}Close(listenfd);Close(efd);return 0; }

?

轉(zhuǎn)載于:https://www.cnblogs.com/lr1402585172/p/10754937.html

總結(jié)

以上是生活随笔為你收集整理的多路IO转接服务器 epoll的全部內(nèi)容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網(wǎng)站內(nèi)容還不錯，歡迎將生活随笔推薦給好友。