• <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>

            XGuru's Blog

            技術,是一種態度。關注:高性能后端技術/服務器架構/C++/C/LAMP

               :: 首頁 :: 聯系 :: 聚合  :: 管理
              20 Posts :: 0 Stories :: 93 Comments :: 0 Trackbacks

            公告





            twitter / xoXGuru

            feedsky
            抓虾
            google reader
            鲜果
            QQ邮箱
            九点

            常用鏈接

            留言簿(12)

            搜索

            •  

            最新評論

            閱讀排行榜

            Libevent簡介

            The libevent API provides a mechanism to execute a callback function when a specific event occurs on a file descriptor or after a timeout has been reached. Furthermore, libevent also support callbacks due to signals or regular timeouts. 

             

            Libevent的API提供了這樣的一套機制:
            當指定文件描述符中一個特定的事件發生,或者超時時間到達后執行指定的回調函數。
            此外,libevent回調功能也支持由信號或者常規的超時觸發。
            注意其許可協議為BSD-style的協議,可以在商業級產品中采用而不必開源。

             

            1.編譯安裝


             

            ubuntu下可以使用apt的方法直接安裝:

             

             ~$  sudo apt-get install libevent

            或者使用

            ~$  wget http://monkey.org/~provos/libevent-1.4.13-stable.tar.gz
            ~$  tar –xzvf  libevent-1.4.13-stable.tar.gz
            ~$  cd libevent-1.4.13-stable
            ~$  ./configure
            ~$  make
            ~$  sudo make install

            2.庫的使用
             

            可以從這幾個簡單的例子中了解到libevent的基本使用方法。編譯時需加上 "-levent"參數。

             

            2.1.I/O事件(對應EV_READ、EV_WRITE)

            下面提供了一個有所省略簡單使用libevent返回系統時間的服務端程序片段。

             1void get_time(int fd,short event,struct event *arg)  /*獲取系統時間并將其往回write*/
             2{
             3……
             4    localtime_r(&now,&t);
             5    asctime_r(&t,buf);
             6    write( fd,buf,strlen(buf) );
             7……
             8}

             9void con_accept(int fd,short event,void *arg) /*提供給事件的回調函數,接收一個連接*/
            10{
            11    struct sockaddr_in s_in;
            12    socklen_t len = sizeof(s_in);
            13    int ns = accept(fd,(struct sockaddr *&s_in,&len);
            14    struct event *ev = malloc(sizeof(struct event));
            15    event_set(ev,ns,EV_WRITE,(void *)get_time,ev);
            16    event_add(ev,NULL);
            17}

            18                
            19int main()
            20{
            21    int sockfd = socket(PF_INET,SOCK_STREAM,0);
            22    struct sockaddr_in s_in;
            23……
            24    bind(sockfd,(struct sockaddr*&s_in,sizeof(s_in));
            25    listen(sockfd,5);
            26    event_init(); //libevent初始化
            27
            28    struct event ev;
            29    event_set(&ev,sockfd,EV_READ|EV_PERSIST,con_accept,&ev);
            30//設置事件屬性為可讀、持續,回調函數為con_accept()
            31    event_add(&ev,NULL);//添加事件,未設置超時時間
            32    event_dispatch();//進入libevent主循環
            33    return 0;
            34}

            35

            2.2. 信號處理事件(對應EV_SIGNAL)

             1 static void signal_cb(int fd, short eventvoid *arg)
             2{
             3    struct event *signal = arg;
             4    printf("%s: got signal %d\n", __func__, EVENT_SIGNAL(signal));
             5    if (called >= 2)
             6        event_del(signal); //如果調用了兩次以上,就刪除這個信號
             7    called++;
             8}

             9
            10int main (int argc, char **argv)
            11{
            12    struct event signal_int;
            13    event_init();//libevent初始化
            14    event_set(&signal_int, SIGINT, EV_SIGNAL|EV_PERSIST, signal_cb, &signal_int); 
            15//設置事件屬性為信號觸發、持續,回調函數為con_accept()
            16    event_add(&signal_int, NULL); //添加事件
            17    event_dispatch();//進入libevent主循環
            18    return 0;
            19}

            20

            2.3.常規超時處理(對應EV_TIMEOUT)
             1static void timeout_cb(int fd, short eventvoid *arg)
             2{
             3    struct timeval tv;
             4    struct event *timeout = arg;
             5    int newtime = time(NULL);
             6    printf("%s: called at %d: %d\n", __func__, newtime,
             7        newtime - lasttime);
             8    lasttime = newtime;
             9    evutil_timerclear(&tv);
            10    tv.tv_sec = 2;
            11    event_add(timeout, &tv);
            12}

            13
            14int main (int argc, char **argv)
            15{
            16    struct event timeout;
            17    struct timeval tv;
            18    event_init();//libevent初始化
            19    evtimer_set(&timeout, timeout_cb, &timeout);
            20//實際上該函數對應的是event_set(timeout, -1, 0, timeout_cb,&timeout)
            21evutil_timerclear(&tv); //如果有時間清理函數則直接對應timerclear(),如果沒有則將tv_sec和tv_usec設置為0
            22
            23    tv.tv_sec = 2;
            24    event_add(&timeout, &tv);
            25    lasttime = time(NULL);
            26    event_dispatch();
            27    return 0;
            28}

            29

            posted on 2010-06-24 00:13 XGuru 閱讀(6063) 評論(0)  編輯 收藏 引用
            久久99精品久久久久久不卡| 伊人久久久AV老熟妇色| 久久人妻AV中文字幕| 亚洲精品乱码久久久久久蜜桃图片| 影音先锋女人AV鲁色资源网久久 | 久久久精品久久久久久| 日韩欧美亚洲综合久久| 精品久久久无码人妻中文字幕豆芽| 国产—久久香蕉国产线看观看| 久久人搡人人玩人妻精品首页| 少妇高潮惨叫久久久久久| 国产精品亚洲美女久久久| 精品久久久无码21p发布| 国产精品成人99久久久久91gav| 思思久久好好热精品国产| 99re久久精品国产首页2020| 热久久最新网站获取| 亚洲综合精品香蕉久久网97| 亚洲精品乱码久久久久久| 国产成人无码精品久久久久免费| 亚洲αv久久久噜噜噜噜噜| 国内精品久久久久久久久电影网| 亚洲AV日韩精品久久久久久久| 嫩草影院久久国产精品| 精品国产VA久久久久久久冰| 超级97碰碰碰碰久久久久最新| 久久久久99精品成人片三人毛片 | 色婷婷综合久久久久中文一区二区| 中文字幕成人精品久久不卡| 97精品国产97久久久久久免费| 久久亚洲av无码精品浪潮| 99久久国产热无码精品免费久久久久| 久久久国产乱子伦精品作者| 伊人久久大香线蕉亚洲| 伊人久久大香线蕉综合影院首页| 亚洲?V乱码久久精品蜜桃| 久久久久一级精品亚洲国产成人综合AV区 | 精品久久人人妻人人做精品| 久久91亚洲人成电影网站| 久久久青草青青亚洲国产免观| 国内精品久久国产大陆|