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        : [email protected]
 *
 */

#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;

    // 建立套接字1
    fd1 = 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上克隆：

[email protected]:FuYuanDe/epoll.git

參考資料：

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