epoll

鎖定

使用epoll進行高性能網絡編程

select 最不能忍受的是一個進程所打開的FD是有一定限制的，由FD_SETSIZE設置，默認值是1024。對於那些需要支持的上萬連接數目的IM服務器來説顯然太少了。這時候你一是可以選擇修改這個宏然後重新編譯服務器代碼，不過資料也同時指出這樣會帶來網絡效率的下降，二是可以選擇多進程的解決方案（傳統的Apache方案），不過雖然linux上面創建進程的代價比較小，但仍舊是不可忽視的，加上進程間數據同步遠比不上線程間同步的高效，所以也不是一種完美的方案。不過 epoll則沒有這個限制，它所支持的FD上限是最大可以打開文件的數目，這個數字一般遠大於2048,舉個例子，在1GB內存的機器上大約是10萬左右，具體數目可以cat /proc/sys/fs/file-max查看，一般來説這個數目和系統內存關係很大。

nfds=epoll_wait(kdpfd,events,maxevents,-1);

    int epfd = epoll_create(POLL_SIZE);
    struct epoll_event ev;
    struct epoll_event *events = NULL;
    nfds = epoll_wait(epfd, events, 20, 500);
    {
        for (n = 0; n < nfds; ++n) {
            if (events[n].data.fd == listener) {
                //如果是主socket的事件的話，則表示
                //有新連接進入了，進行新連接的處理。
                client = accept(listener, (structsockaddr *)&local, &addrlen);
                if (client < 0) {
                    perror("accept");
                    continue;
                }
                setnonblocking(client);        //將新連接置於非阻塞模式
                ev.events = EPOLLIN | EPOLLET; //並且將新連接也加入EPOLL的監聽隊列。
                //注意，這裏的參數EPOLLIN|EPOLLET並沒有設置對寫socket的監聽，
                //如果有寫操作的話，這個時候epoll是不會返回事件的，如果要對寫操作
                //也監聽的話，應該是EPOLLIN|EPOLLOUT|EPOLLET
                ev.data.fd = client;
                if (epoll_ctl(epfd, EPOLL_CTL_ADD, client, &ev) < 0) {
                    //設置好event之後，將這個新的event通過epoll_ctl加入到epoll的監聽隊列裏面，
                    //這裏用EPOLL_CTL_ADD來加一個新的epoll事件，通過EPOLL_CTL_DEL來減少一個
                    //epoll事件，通過EPOLL_CTL_MOD來改變一個事件的監聽方式。
                    fprintf(stderr, "epollsetinsertionerror:fd=%d", client);
                    return -1;
                }
            }
            else if(event[n].events & EPOLLIN)
            {
                //如果是已經連接的用户，並且收到數據，
                //那麼進行讀入
                int sockfd_r;
                if ((sockfd_r = event[n].data.fd) < 0)
                    continue;
                read(sockfd_r, buffer, MAXSIZE);
                //修改sockfd_r上要處理的事件為EPOLLOUT
                ev.data.fd = sockfd_r;
                ev.events = EPOLLOUT | EPOLLET;
                epoll_ctl(epfd, EPOLL_CTL_MOD, sockfd_r, &ev)
            }
            else if(event[n].events & EPOLLOUT)
            {
                //如果有數據發送
                int sockfd_w = events[n].data.fd;
                write(sockfd_w, buffer, sizeof(buffer));
                //修改sockfd_w上要處理的事件為EPOLLIN
                ev.data.fd = sockfd_w;
                ev.events = EPOLLIN | EPOLLET;
                epoll_ctl(epfd, EPOLL_CTL_MOD, sockfd_w, &ev)
            }
            do_use_fd(events[n].data.fd);
        }
    }