#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> int main() {// 1 創建套接字int lfd = socket(AF_INET, SOCK_STREAM, 0);// 2 端口復用int opt = 1;setsockopt(lfd, SOL_SOCKET, SO_REUSEADDR, &opt, sizeof(opt));// 3 綁定struct sockaddr_in server_addr;bzero(&server_addr, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_port = htons(8888);server_addr.sin_addr.s_addr = htonl(INADDR_ANY);bind(lfd, (struct sockaddr*)&server_addr, sizeof(server_addr));// 4 同時訪問上限listen(lfd, 128);// 5 創建epoll句柄int epfd = epoll_create(1000); // lfd結點上樹struct epoll_event tep;tep.data.fd = lfd;tep.events = EPOLLIN;epoll_ctl(epfd, EPOLL_CTL_ADD, lfd, &tep);// 6 監聽讀事件int cfd; // 定義lfd通信描述符struct sockaddr_in client_addr;socklen_t client_len = sizeof(client_addr); // 用于接收客戶端信息struct epoll_event ep[1000]; // 用于接收變化的結點while(1){int nready = epoll_wait(epfd, ep, 1000, -1); // 阻塞等待結點變化for(int i = 0; i < nready; i++){if(!(ep[i].events & EPOLLIN))continue; // 因為只要有事件發生，就會計入ep[]中，如果不是讀事件，繼續循環if(ep[i].data.fd == lfd){// 是連接請求cfd = accept(lfd, (struct sockaddr*)&client_addr, &client_len);char ip[16] = {0};printf("conn from %s at %d\n", inet_ntop(AF_INET, &client_addr.sin_addr.s_addr, ip, sizeof(ip)), ntohs(client_addr.sin_port)); // 打印客戶端信息// cfd 上樹tep.data.fd = cfd;tep.events = EPOLLIN;epoll_ctl(epfd, EPOLL_CTL_ADD, cfd, &tep);}else{// 普通讀事件int sockfd = ep[i].data.fd;char buf[BUFSIZ] = {0};int n = read(sockfd, buf, sizeof(buf));if(n < 0) { perror("read err");epoll_ctl(epfd, EPOLL_CTL_DEL, sockfd, NULL); // 下樹close(sockfd);}else if(n == 0) { printf("client[%d] closed\n", sockfd);epoll_ctl(epfd, EPOLL_CTL_DEL, sockfd, NULL); // 下樹close(sockfd);}else{write(sockfd, buf, n);write(STDOUT_FILENO,buf, n);}} // 普通讀事件結束} // for循環，解決變化結點事件結束 } // while循環結束close(lfd);close(epfd);return 0; } 與50位技術專家面對面20年技術見證，附贈技術全景圖

總結

以上是生活随笔為你收集整理的epoll 版 高并发服务器的全部內容，希望文章能夠幫你解決所遇到的問題。

如果覺得生活随笔網站內容還不錯，歡迎將生活随笔推薦給好友。