linux epoll機制用于IO多路復用，能夠同時監聽多個接字，使用起來比較簡單。

相關接口：

#include <sys/epoll.h>int epoll_create(int size);int epoll_create1(int flags); //創建epoll實例int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event); //添加、刪除或修改epoll監聽描述符int epoll_wait(int epfd, struct epoll_event *events,int maxevents, int timeout);//監聽事件發生

其中epoll_ctl參數op有如下選項：分別對應添加、刪除、修改

EPOLL_CTL_ADD，EPOLL_CTL_MOD，EPOLL_CTL_DEL ???????????? //結構體，在添加到epoll中去的時候可以傳遞參數，參數可以是指針 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 */};

下面給出一個簡單的使用例子，在例子中創建了兩個套接字，分別監聽不同的端口，將兩個套接字添加到epoll中，每當套接字上有讀事件發生的時候，就可以進行處理。

/** Description : linux IO多路復用epoll實例* Date ：20180605* Author ：mason* Mail : mrsonko@126.com**/#include <netinet/in.h> #include <sys/socket.h> #include <sys/epoll.h> #include <sys/types.h> #include <arpa/inet.h> #include <sys/errno.h> #include <stdint.h> #include <stdlib.h> #include <string.h> #include <stdio.h>#define BUFFER_SIZE 512 #define log(fmt, arg...) printf("[udptest] %s:%d "fmt, __FUNCTION__, __LINE__, ##arg)void main(){int fd1, fd2, efd, fds, i, fd;int ret, addr_len;struct epoll_event g_event; // epoll事件struct epoll_event *epoll_events_ptr; char buffer[BUFFER_SIZE] = {0};struct sockaddr_in addr1, addr2;// 創建套接字1fd1 = socket(AF_INET, SOCK_DGRAM, 0);if (fd1 == -1) {log("create socket fail \r\n");return ;} // 創建套接字2 fd2 = socket(AF_INET, SOCK_DGRAM, 0);if (fd2 == -1) {log("create socket fail \r\n");close(fd1);return ;} // 設置監聽地址,不同套接字監聽不同的地址addr1.sin_family = AF_INET;addr1.sin_addr.s_addr = INADDR_ANY; addr1.sin_port = htons(3500);addr2.sin_family = AF_INET;addr2.sin_addr.s_addr = INADDR_ANY; addr2.sin_port = htons(3501);addr_len = sizeof(struct sockaddr_in);// 套接字綁定地址if (0 != bind(fd1, (struct sockaddr *)&addr1, sizeof(struct sockaddr_in))) {log("bind local listening addr fail，errno : %d \r\n", errno);goto err;}if (0 != bind(fd2, (struct sockaddr *)&addr2, sizeof(struct sockaddr_in))) {log("bind local listening addr fail，errno : %d \r\n", errno);goto err;}//創建epoll實例efd = epoll_create1(0);if (efd == -1) {log("create epoll fail \r\n");goto err;}log("create epoll instance success \r\n");epoll_events_ptr = (struct epoll_event *)calloc(2, sizeof(struct epoll_event));if (epoll_events_ptr == NULL) {log("calloc fail \r\n");goto err;}//添加套接字到epoll中，并監控讀事件//注意這里傳給epoll的參數中可以是指針g_event.data.fd = fd1; g_event.events = EPOLLIN;epoll_ctl(efd, EPOLL_CTL_ADD, fd1, &g_event); g_event.data.fd = fd2; g_event.events = EPOLLIN;epoll_ctl(efd, EPOLL_CTL_ADD, fd2, &g_event); //監聽epoll事件while(1) {log("Starting waiting epoll event \n");fds = epoll_wait(efd, epoll_events_ptr, 2, -1); //阻塞for (i = 0; i<fds; i++){ fd = epoll_events_ptr[i].data.fd;if (epoll_events_ptr[i].events & EPOLLIN){ ret = read(fd, buffer, BUFFER_SIZE);if(ret != -1)log("recv msg : %s \n", buffer);} memset(buffer, 0, BUFFER_SIZE);} } err:close(fd1);close(fd2);if(epoll_events_ptr) free(epoll_events_ptr);return ;}

測試結果：

有一點值得注意的是，我在測試用例中當收到epoll事件的時候直接進行了讀取操作，實際應用中這一步可能會阻塞，更好的做法是收到事件發送消息到相關的線程或者是消息隊列中，由它們來進行業務處理，epoll只負責通知，這樣能夠提高處理速度。

代碼可以在gihub上克隆：

git@github.com:FuYuanDe/epoll.git

參考資料：

http://www.man7.org/linux/man-pages/man7/epoll.7.html

《新程序員》：云原生和全面數字化實踐50位技術專家共同創作，文字、視頻、音頻交互閱讀

總結

以上是生活随笔為你收集整理的linux epoll监听套接字实例的全部內容，希望文章能夠幫你解決所遇到的問題。

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