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

doing5552

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

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

公告

常用鏈接

留言簿(24)

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

最新隨筆

搜索

  •  

積分與排名

  • 積分 - 455849
  • 排名 - 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ù),可以寫)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è),下面是事件類型。

使用epoll_ctl添加到之中,EPOLL_CTL_ADD是epoll控制類型,這里監(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寫入
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 閱讀(809) 評(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>
            欧美日韩一区二区三区四区在线观看| 日韩亚洲在线观看| 久久精品女人的天堂av| 亚洲一区二区黄| 亚洲视频1区| 亚洲一区二区视频在线观看| 亚洲欧美日韩综合aⅴ视频| 午夜伦理片一区| 午夜激情一区| 久久综合福利| 欧美日韩成人一区| 国产精品亚洲第一区在线暖暖韩国| 国产精品成人一区| 国产亚洲一级高清| 亚洲黄色成人| 亚洲香蕉网站| 久久国内精品自在自线400部| 久久亚洲欧洲| 亚洲精品中文字幕在线观看| 亚洲视频在线看| 久久久久久久欧美精品| 欧美日韩大片| 国产亚洲欧美一区| 亚洲另类一区二区| 欧美一区二区三区男人的天堂| 免费成人美女女| 一本色道久久88亚洲综合88| 久久久久久欧美| 欧美日韩一区二区免费视频| 黄色综合网站| 亚洲一区二三| 欧美韩日一区二区| 在线一区二区三区四区| 国产精品99久久久久久人| 国产精品欧美激情| 亚洲尤物视频网| 欧美77777| 亚洲电影免费观看高清完整版| 麻豆国产精品777777在线| 亚洲高清成人| 亚洲综合色视频| 欧美成人精品| 国语自产偷拍精品视频偷 | 亚洲精品国产精品国自产观看| 日韩小视频在线观看专区| 欧美伊人久久久久久久久影院| 欧美激情视频一区二区三区不卡| 国产精品美女久久久| 99视频精品免费观看| 另类人畜视频在线| 欧美一区二区三区婷婷月色| 欧美视频一区二区三区四区| 亚洲免费av片| 亚洲高清不卡| 欧美大片一区二区| 在线精品视频免费观看| 欧美在线网址| 亚洲一级电影| 国产精品福利久久久| 一区二区av| 亚洲美女视频网| 欧美日韩国产一区二区| 一本色道久久精品| 亚洲精品久久久蜜桃| 欧美伦理在线观看| 日韩视频免费观看高清完整版| 欧美成人精品在线播放| 久久九九久久九九| 伊人久久婷婷| 欧美成人激情在线| 免费欧美日韩| 一本久道久久综合中文字幕| 一本一道久久综合狠狠老精东影业| 欧美日韩国产一中文字不卡 | 国产精品jizz在线观看美国| 99亚洲视频| 99精品国产99久久久久久福利| 欧美日韩一本到| 亚洲综合日韩在线| 亚洲免费视频一区二区| 亚洲精品欧美| 欧美不卡福利| 99精品欧美一区| 一区二区三区 在线观看视| 国产精品久久久久久av下载红粉 | 亚洲国产成人av好男人在线观看| 免费观看成人www动漫视频| 欧美成人午夜剧场免费观看| 在线一区二区日韩| 亚洲一区二区三区欧美| 韩国av一区二区三区在线观看| 欧美激情亚洲一区| 国产精品福利在线| 美玉足脚交一区二区三区图片| 欧美精品在线免费| 欧美中文字幕久久| 欧美国产日韩一区二区| 久久成人这里只有精品| 欧美二区不卡| 久久精品一区二区三区不卡| 欧美成人xxx| 欧美一区2区视频在线观看| 免费成人美女女| 久久成人精品一区二区三区| 欧美麻豆久久久久久中文| 久久久久国产一区二区三区四区| 久久资源av| 欧美一区网站| 欧美日韩国产在线观看| 蜜桃av一区二区三区| 国产精品乱码| 欧美激情中文字幕一区二区| 国产日韩专区| 亚洲午夜影视影院在线观看| 最新成人av在线| 西西人体一区二区| 亚洲自拍偷拍视频| 欧美激情精品久久久久久| 久久国产日韩欧美| 欧美日精品一区视频| 亚洲国产精品第一区二区| 红桃视频成人| 欧美一区二区三区的| 午夜精品久久久久久99热| 免费成人av在线| 免费看的黄色欧美网站| 国内外成人免费激情在线视频| 亚洲自拍16p| 亚洲尤物精选| 国产精品www| 一区二区三区视频在线观看| 亚洲最新在线视频| 欧美国产视频在线| 欧美大片在线影院| 在线观看亚洲视频| 久久精品国产成人| 久久久久久久999| 国产日韩一区二区三区在线| 亚洲一区亚洲| 欧美专区在线观看一区| 国产欧美日韩综合一区在线观看| 一二美女精品欧洲| 一本色道久久99精品综合| 亚洲人成网站精品片在线观看| 亚洲国产精品v| 美女视频黄 久久| 免费欧美日韩| 亚洲国产美国国产综合一区二区| 久久躁日日躁aaaaxxxx| 亚洲高清自拍| 亚洲精品免费看| 欧美日韩午夜剧场| 在线亚洲美日韩| 欧美综合国产| 在线不卡欧美| 欧美精品www| 亚洲深夜福利| 欧美一区二区日韩| 精品51国产黑色丝袜高跟鞋| 久久久久国产精品人| 欧美电影免费观看高清| 亚洲美女视频| 国产麻豆午夜三级精品| 久久久久久香蕉网| 亚洲高清视频在线观看| 亚洲在线免费| 国外成人网址| 欧美精选在线| 午夜视黄欧洲亚洲| 欧美高清视频一区| 亚洲欧美日韩国产成人| 狠狠色丁香婷综合久久| 欧美电影打屁股sp| 亚洲一区二区3| 老巨人导航500精品| 亚洲欧洲综合| 国产日产欧美一区| 欧美成年人网| 亚洲欧美日韩在线不卡| 欧美激情亚洲自拍| 亚洲午夜一区| 在线看片日韩| 国产精品视频精品| 欧美3dxxxxhd| 亚洲自拍高清| 亚洲日本激情| 欧美1区3d| 久久久久久电影| 亚洲欧美日韩成人| 亚洲三级影片| 激情久久五月天| 欧美日韩亚洲免费| 久久精品视频亚洲| 在线亚洲精品| 91久久午夜| 裸体一区二区三区| 亚洲欧美精品一区| 亚洲理伦在线| 1000精品久久久久久久久 | 国产一区二区三区不卡在线观看|