青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品

doing5552

記錄每日點(diǎn)滴,不枉人生一世

  C++博客 :: 首頁(yè) :: 聯(lián)系 :: 聚合  :: 管理
  73 Posts :: 0 Stories :: 94 Comments :: 0 Trackbacks

公告

常用鏈接

留言簿(24)

我參與的團(tuán)隊(duì)

最新隨筆

搜索

  •  

積分與排名

  • 積分 - 456264
  • 排名 - 49

最新隨筆

最新評(píng)論

閱讀排行榜

評(píng)論排行榜

用epoll實(shí)現(xiàn)異步的Echo服務(wù)器
2010年05月07日 星期五 下午 06:48
epoll是Kernel 2.6后新加入的事件機(jī)制,在高并發(fā)條件下,遠(yuǎn)優(yōu)于select.

用個(gè)硬件中的例子吧,可能不太恰當(dāng):epoll相當(dāng)于I/O中斷(有的時(shí)候才相應(yīng)),而select相當(dāng)于輪詢(總要反復(fù)查詢)。

其實(shí)epoll比slect好用很多,主要一下幾個(gè)用法。

struct epoll_event ; epoll事件體,事件發(fā)生時(shí)候你可以得到一個(gè)它。其中epoll_event.data.fd可以存儲(chǔ)關(guān)聯(lián)的句柄,epoll_event.event 是監(jiān)聽(tīng)標(biāo)志,常用的有EPOLLIN (有數(shù)據(jù),可以讀)、EPOLLOUT(有數(shù)據(jù),可以寫(xiě))EPOLLET(有事件,通用);

(1)創(chuàng)建epoll句柄

int epFd = epoll_create(EPOLL_SIZE);

(2)加入一個(gè)句柄到epoll的監(jiān)聽(tīng)隊(duì)列

ev.data.fd = serverFd;
ev.events = EPOLLIN | EPOLLET;
epoll_ctl(epFd, EPOLL_CTL_ADD, serverFd, &ev);

上面的fd是你要綁定給事件發(fā)生時(shí)候使用的fd,到時(shí)候只能操作這個(gè),下面是事件類(lèi)型。

使用epoll_ctl添加到之中,EPOLL_CTL_ADD是epoll控制類(lèi)型,這里監(jiān)聽(tīng)的fd和給event的fd一般相同。

(3)等待event返回

int nfds = epoll_wait(epFd, evs, EVENT_ARR, -1);

傳入的evs是epoll_event的數(shù)組,EVENT_ARR應(yīng)當(dāng)是不超過(guò)這個(gè)數(shù)組的長(zhǎng)度。返回nfds的是不超過(guò)EVENT_ARR的數(shù)值,表示本次等待到了幾個(gè)事件。

(4)遍歷事件

注意,這里遍歷的事件是肯定已經(jīng)發(fā)生了的,而select中遍歷的是每個(gè)fd,而fd不一定在FDSET中(即不一定有讀事件發(fā)生)!這是效率最大的差別所在!

for (int i = 0; i < nfds; i++)

{

//do something

}

(5)其他技巧

對(duì)事件是否是serverFd判斷,如果是,進(jìn)行accept并加入epoll監(jiān)聽(tīng)隊(duì)列,要設(shè)置異步讀取。

如果evts[i]&EPOLLIN,表示可讀,使用read進(jìn)行試探,如果>0表示連接沒(méi)有關(guān)閉,否則連接已經(jīng)關(guān)閉(出發(fā)事件又讀取不到東西,表示socket關(guān)閉!)。如果<0出錯(cuò)。如果>0,需要繼續(xù)讀取直到為0,但是注意這里的為0是在第一次read不為0的前提下,畢竟我們?cè)O(shè)置了異步讀取,暫時(shí)沒(méi)有數(shù)據(jù)可以讀就返回0了!而如果第一次返回0,那么就是關(guān)閉吧!

注意關(guān)閉要移出出epoll并且close(clientFd)

羅嗦了好多,看代碼!
查看源代碼
打印幫助
001    /*
002     * main.cc
003     *
004     *  Created on: 2009-11-30
005     *      Author: liheyuan
006     *    Describe: epoll實(shí)現(xiàn)阻塞模式服務(wù)器(Echo服務(wù)器)
007     *
008     *   Last Date: 2009-11-30
009     *   CopyRight: 2009 @ ICT LiHeyuan
010     */
011    #include <stdio.h>
012    #include <stdlib.h>
013    #include <unistd.h>
014    #include <fcntl.h>
015    #include <arpa/inet.h>
016    #include <netinet/in.h>
017    #include <sys/epoll.h>
018    #include <errno.h>
019    
020    #define EPOLL_SIZE 10
021    #define EVENT_ARR 20
022    #define BACK_QUEUE 10
023    #define PORT 18001
024    #define BUF_SIZE 16
025    
026    void setnonblocking(int sockFd) {
027        int opt;
028    
029        //獲取sock原來(lái)的flag
030        opt = fcntl(sockFd, F_GETFL);
031        if (opt < 0) {
032            printf("fcntl(F_GETFL) fail.");
033            exit(-1);
034        }
035    
036        //設(shè)置新的flag,非阻塞
037        opt |= O_NONBLOCK;
038        if (fcntl(sockFd, F_SETFL, opt) < 0) {
039            printf("fcntl(F_SETFL) fail.");
040            exit(-1);
041        }
042    }
043    
044    int main() {
045    
046        int serverFd;
047    
048        //創(chuàng)建服務(wù)器fd
049        serverFd = socket(AF_INET, SOCK_STREAM, 0);
050        setnonblocking(serverFd);
051    
052        //創(chuàng)建epoll,并把 serverFd放入監(jiān)聽(tīng)隊(duì)列
053        int epFd = epoll_create(EPOLL_SIZE);
054        struct epoll_event ev, evs[EVENT_ARR];
055        ev.data.fd = serverFd;
056        ev.events = EPOLLIN | EPOLLET;
057        epoll_ctl(epFd, EPOLL_CTL_ADD, serverFd, &ev);
058    
059        //綁定服務(wù)器端口
060        struct sockaddr_in serverAddr;
061        socklen_t serverLen = sizeof(struct sockaddr_in);
062        serverAddr.sin_addr.s_addr = htonl(INADDR_ANY);
063        serverAddr.sin_port = htons(PORT);
064        if (bind(serverFd, (struct sockaddr *) &serverAddr, serverLen)) {
065            printf("bind() fail.\n");
066            exit(-1);
067        }
068    
069        //打開(kāi)監(jiān)聽(tīng)
070        if (listen(serverFd, BACK_QUEUE)) {
071            printf("Listen fail.\n");
072            exit(-1);
073        }
074    
075        //死循環(huán)處理
076        int clientFd;
077        sockaddr_in clientAddr;
078        socklen_t clientLen;
079        char buf[BUF_SIZE];
080        while (1) {
081            //等待epoll事件的到來(lái),最多取EVENT_ARR個(gè)事件
082            int nfds = epoll_wait(epFd, evs, EVENT_ARR, -1);
083            //處理事件
084            for (int i = 0; i < nfds; i++) {
085                if (evs[i].data.fd == serverFd && evs[i].data.fd & EPOLLIN) {
086                    //如果是serverFd,表明有新連接連入
087                    if ((clientFd = accept(serverFd,
088                            (struct sockaddr *) &clientAddr, &clientLen)) < 0) {
089                        printf("accept fail.\n");
090                    }
091                    printf("Connect from %s:%d\n", inet_ntoa(clientAddr.sin_addr),
092                            htons(clientAddr.sin_port));
093                    setnonblocking(clientFd);
094                    //注冊(cè)accept()到的連接
095                    ev.data.fd = clientFd;
096                    ev.events = EPOLLIN | EPOLLET;
097                    epoll_ctl(epFd, EPOLL_CTL_ADD, clientFd, &ev);
098                } else if (evs[i].events & EPOLLIN) {
099                    //如果不是serverFd,則是client的可讀
100                    if ((clientFd = evs[i].data.fd) > 0) {
101                        //先進(jìn)行試探性讀取
102                        int len = read(clientFd, buf, BUF_SIZE);
103                        if (len > 0) {
104                            //有數(shù)據(jù)可以讀,Echo寫(xiě)入
105                            do {
106                                if (write(clientFd, buf, len) < 0) {
107                                    printf("write() fail.\n");
108                                }
109                                len = read(clientFd, buf, BUF_SIZE);
110                            } while (len > 0);
111                        } else if (len == 0) {
112                            //出發(fā)了EPOLLIN事件,卻沒(méi)有可以讀取的,表示斷線
113                            printf("Client closed at %d\n", clientFd);
114                            epoll_ctl(epFd, EPOLL_CTL_DEL, clientFd, &ev);
115                            close(clientFd);
116                            evs[i].data.fd = -1;
117                            break;
118                        } else if (len == EAGAIN) {
119                            continue;
120                        } else {
121                            //client讀取出錯(cuò)
122                            printf("read() fail.");
123                        }
124                    }
125                } else {
126                    printf("other event.\n");
127                }
128            }
129        }
130    
131        return 0;
132    }
posted on 2010-07-18 21:14 doing5552 閱讀(811) 評(píng)論(0)  編輯 收藏 引用

只有注冊(cè)用戶登錄后才能發(fā)表評(píng)論。
網(wǎng)站導(dǎo)航: 博客園   IT新聞   BlogJava   博問(wèn)   Chat2DB   管理


青青草原综合久久大伊人导航_色综合久久天天综合_日日噜噜夜夜狠狠久久丁香五月_热久久这里只有精品
  • <ins id="pjuwb"></ins>
    <blockquote id="pjuwb"><pre id="pjuwb"></pre></blockquote>
    <noscript id="pjuwb"></noscript>
          <sup id="pjuwb"><pre id="pjuwb"></pre></sup>
            <dd id="pjuwb"></dd>
            <abbr id="pjuwb"></abbr>
            久久久综合激的五月天| 免费看亚洲片| 亚洲一卡久久| 久久综合狠狠综合久久综青草| 亚洲欧美日韩国产综合在线 | 亚洲另类自拍| 在线色欧美三级视频| 西西人体一区二区| 亚洲在线视频一区| 欧美日韩在线播放| 亚洲精品偷拍| 99视频+国产日韩欧美| 欧美91大片| 欧美www在线| 亚洲第一毛片| 久久一日本道色综合久久| 久久婷婷成人综合色| 国产亚洲第一区| 欧美怡红院视频一区二区三区| 久久爱91午夜羞羞| 国产日韩欧美亚洲| 欧美在线播放高清精品| 久久久久久久综合色一本| 国产一区二区三区在线观看免费| 午夜免费电影一区在线观看| 欧美亚洲三区| 国产亚洲成精品久久| 久久精品国产综合精品| 久久综合九九| 亚洲精品欧洲精品| 欧美日韩大片| 亚洲免费影院| 久久亚洲电影| 亚洲精品激情| 欧美性猛片xxxx免费看久爱| 亚洲一区二区三区精品在线观看| 亚洲欧美日韩精品综合在线观看| 国产欧美日韩在线| 久久激五月天综合精品| 亚洲二区在线观看| 日韩一本二本av| 国产精品久久99| 小嫩嫩精品导航| 欧美fxxxxxx另类| 在线一区亚洲| 国产亚洲欧美色| 女生裸体视频一区二区三区| 日韩一区二区精品| 欧美一区高清| 亚洲黄色天堂| 国产精品久久久免费| 欧美在线资源| 亚洲精品欧洲| 久久精品国产久精国产思思| 亚洲电影自拍| 国产精品欧美久久| 老妇喷水一区二区三区| 亚洲最新视频在线| 免费国产一区二区| 亚洲午夜精品17c| 伊人精品成人久久综合软件| 欧美三级在线视频| 久久久久久久久久码影片| 亚洲免费av片| 久久综合色天天久久综合图片| 99这里只有久久精品视频| 国内精品久久久久久久影视蜜臀 | 久久综合久色欧美综合狠狠| 99在线|亚洲一区二区| 久久亚洲春色中文字幕| 亚洲自拍电影| 亚洲精品综合久久中文字幕| 国产亚洲欧美一区| 欧美午夜欧美| 欧美激情中文不卡| 久久免费精品视频| 欧美一区二区三区另类| 亚洲美女在线国产| 亚洲第一色中文字幕| 久久av一区二区三区| 国产精品99久久久久久www| 在线欧美三区| 国产永久精品大片wwwapp| 欧美天天视频| 欧美黄色视屏| 另类图片综合电影| 欧美在线视频二区| 亚洲欧美日韩在线一区| 一区二区三区免费网站| 亚洲黄色尤物视频| 欧美国产欧美综合| 老司机一区二区三区| 欧美一区二粉嫩精品国产一线天| 亚洲午夜激情| 中文日韩在线| 这里只有精品视频| 日韩午夜视频在线观看| 亚洲毛片播放| 亚洲精品综合久久中文字幕| 18成人免费观看视频| 精品成人一区| 樱桃国产成人精品视频| 韩国一区二区三区在线观看| 国产一区二区精品久久| 国产欧美婷婷中文| 国产精品一区视频网站| 国产农村妇女毛片精品久久麻豆 | 欧美激情第8页| 免费成人高清视频| 欧美福利在线观看| 亚洲电影在线| 欧美激情第8页| 亚洲人成高清| 一本色道久久88综合日韩精品| 一区二区三区久久精品| 中文久久精品| 性久久久久久久久久久久| 欧美在线免费观看亚洲| 久久黄色网页| 美女视频黄a大片欧美| 欧美高清不卡在线| 欧美日韩你懂的| 国产麻豆综合| 在线观看视频一区| 日韩一区二区久久| 久久精品国产一区二区三区| 亚洲性视频网站| 欧美一区二区三区男人的天堂| 久久精品水蜜桃av综合天堂| 噜噜爱69成人精品| 亚洲高清视频在线| 99视频精品全国免费| 亚洲免费在线播放| 久久久久久久尹人综合网亚洲| 免费一级欧美片在线观看| 欧美日韩精品免费| 国产日韩欧美夫妻视频在线观看| 在线成人av网站| 亚洲视频在线观看一区| 久久久久欧美精品| 亚洲乱码久久| 欧美在线亚洲| 欧美激情中文字幕一区二区| 国产精品综合色区在线观看| 91久久在线视频| 欧美一级在线视频| 亚洲二区视频| 亚洲欧美一区二区三区极速播放| 久热综合在线亚洲精品| 国产精品婷婷| 日韩亚洲不卡在线| 久久久久久久一区二区三区| 亚洲片在线资源| 久久国产精品99久久久久久老狼| 欧美久久久久久久久久| 国产在线精品一区二区夜色| 亚洲美女中出| 女同性一区二区三区人了人一| 亚洲视频一起| 麻豆精品精华液| 国产私拍一区| 亚洲小说区图片区| 亚洲电影免费观看高清完整版| 午夜亚洲影视| 国产精品av免费在线观看| 亚洲青涩在线| 美日韩精品视频| 午夜亚洲福利| 国产精品久久久久aaaa| 99国产精品视频免费观看| 久久综合五月天婷婷伊人| 亚洲欧美日韩国产| 国产精品久久久久久久久久妞妞| 91久久久久久国产精品| 麻豆久久久9性大片| 午夜亚洲一区| 国产精品亚洲成人| 亚洲在线黄色| 一区二区福利| 欧美日韩在线看| 亚洲午夜电影在线观看| 亚洲乱码国产乱码精品精可以看| 美女久久网站| 亚洲日本国产| 亚洲国产精品精华液2区45| 久久综合伊人| 亚洲日韩中文字幕在线播放| 免费亚洲一区| 美女脱光内衣内裤视频久久影院| 狠狠色狠狠色综合日日91app| 久久精品免费| 欧美一区视频| 激情婷婷欧美| 欧美电影免费观看高清完整版| 麻豆精品在线观看| 亚洲黑丝一区二区| 亚洲国产福利在线| 欧美日韩精品免费看| 亚洲一区二区三区777| 亚洲午夜成aⅴ人片|