poll处理过程，遍历所以事件集， epoll：遍历被内核IO事件异步唤醒的事件集 epoll_creat():创建epoll epoll_ctl(): epoll_wait(): 实验代码 Servertest.h ``` #ifndef SERVERTEST_H_INCLUDED #define SERVERTEST_H_INCLUDED #include #include #include #include #include #include #include #include #include #include #include #include #include #include #define SERVER_IP "0.0.0.0" #define SERVER_PORT 6666 #define EPOLL_SIZE 100 #define BUFF_SIZE 2048 #define LISTEN_NUM 10 class Servertest { public: int serverSocket; //服务器socket struct sockaddr_in serverAddr; struct epoll_event event; struct epoll_event events[EPOLL_SIZE]; //事件监听队列 std::list clientSocket; //客户端socket struct sockaddr_in clientAddr; int epollFd; //epoll句柄 char buf[BUFF_SIZE]; //数据缓冲 void serverRun(); Servertest(); ~Servertest(); }; #endif ``` Servertest.cpp ``` #include "Servertest.h" Servertest::Servertest(){ memset(&serverAddr,0,sizeof(serverAddr)); serverAddr.sin_family = PF_INET; serverAddr.sin_port = htons(SERVER_PORT); serverAddr.sin_addr.s_addr = inet_addr(SERVER_IP); if((serverSocket = socket(PF_INET, SOCK_STREAM, 0))<0){ perror("socket create error"); exit(-1); } if((bind(serverSocket, (struct sockaddr *)&serverAddr, sizeof(serverAddr)))<0){ perror("socket bind error"); exit(-1); } if(listen(serverSocket, LISTEN_NUM)<0){ perror("socket listen error"); exit(-1); } if((epollFd = epoll_create(EPOLL_SIZE))<0){ perror("epoll create error"); exit(-1); } event.events = EPOLLIN | EPOLLET; //设置监听事件 event.data.fd = serverSocket; //监听socket epoll_ctl(epollFd, EPOLL_CTL_ADD, serverSocket, &event); } void Servertest::serverRun(){ std::cout<<"serverRun..."<serverRun(); return 0; } ```

“C语言利用epoll实现高并发聊天室”实验报告