libevent簡介和使用

libevent是一個基于事件觸發的網絡庫，memcached底層也是使用libevent庫。

總體來說，libevent有下面一些特點和優勢：

• 事件驅動，高性能；
  
• 輕量級，專注于網絡； 
  
• 跨平臺，支持 Windows、Linux、Mac Os等； 
  
• 支持多種 I/O多路復用技術， epoll、poll、dev/poll、select 和kqueue 等； 
  

  * 支持 I/O，定時器和信號等事件；

   

  libevent有下面幾大部分組成：

  * 事件管理包括各種IO（socket）、定時器、信號等事件，也是libevent應用最廣的模塊；

  * 緩存管理是指evbuffer功能；

  * DNS是libevent提供的一個異步DNS查詢功能；

  * HTTP是libevent的一個輕量級http實現，包括服務器和客戶端

   

  一些資料：
  

• libevent官網：http://libevent.org/ 
  
• libevent API：http://www.monkey.org/~provos/libevent/doxygen-2.0.1/index.html
  

• CSDN上剖析得很贊的文章：http://blog.csdn.net/sparkliang/article/details/4957667</p>

   

  // =============================================================================================

   

  下面寫了2個簡單的使用例子，一個是定時器，一個是TCP服務器，都只涉及到libevent的事件管理模塊。

   

  一、簡單定時器：實現程序每秒輸出一個“Game Over!”

  event_init() => evtimer_set() => event_add() =>event_dispatch()

      #include <stdio.h>  
    #include <iostream>  
  
    // libevent頭文件  
    #include <event.h>  
    using namespace std;  
  
    // 定時事件回調函數  
    void onTime(int sock, short event, void *arg)  
    {  
        cout << "Game Over!" << endl;  
  
        struct timeval tv;  
        tv.tv_sec = 1;  
        tv.tv_usec = 0;  
        // 重新添加定時事件（定時事件觸發后默認自動刪除）  
        event_add((struct event*)arg, &tv);  
    }  
  
    int main()  
    {  
        // 初始化  
        event_init();  
  
        struct event evTime;  
        // 設置定時事件  
        evtimer_set(&evTime, onTime, &evTime);  
  
        struct timeval tv;  
        tv.tv_sec = 1;  
        tv.tv_usec = 0;  
        // 添加定時事件  
        event_add(&evTime, &tv);  
  
        // 事件循環  
        event_dispatch();  
  
        return 0;  
    }  

  編譯并執行，編譯加 -levent：

      gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # mv time.cpp timer.cpp  
    gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # g++ -o timer timer.cpp -levent  
    gapp_devnet_1:/data/home/andyawang/code/2013_11/LibeventTest # ./timer   
    Game Over!  
    Game Over!  
    Game Over!  
    Game Over!  

  二、TCP服務器：實現監聽本機8888端口并輸出客戶端發送過來的信息
  event_base_new()=>event_set()=>event_base_set()=>event_add()=>event_base_dispatch()

      #include <stdio.h>  
    #include <string.h>  
    #include <iostream>  
    #include <sys/socket.h>      
    #include <netinet/in.h>      
    #include <arpa/inet.h>      
    #include <netdb.h>  
  
    #include <event.h>  
    using namespace std;  
  
    // 事件base  
    struct event_base* base;  
  
    // 讀事件回調函數  
    void onRead(int iCliFd, short iEvent, void *arg)  
    {  
        int iLen;  
        char buf[1500];  
  
        iLen = recv(iCliFd, buf, 1500, 0);  
  
        if (iLen <= 0) {  
            cout << "Client Close" << endl;  
  
            // 連接結束(=0)或連接錯誤(<0)，將事件刪除并釋放內存空間  
            struct event *pEvRead = (struct event*)arg;  
            event_del(pEvRead);  
            delete pEvRead;  
  
            close(iCliFd);  
            return;  
        }  
  
        buf[iLen] = 0;  
        cout << "Client Info:" << buf << endl;  
    }  
  
    // 連接請求事件回調函數  
    void onAccept(int iSvrFd, short iEvent, void *arg)  
    {  
        int iCliFd;  
        struct sockaddr_in sCliAddr;  
  
        socklen_t iSinSize = sizeof(sCliAddr);  
        iCliFd = accept(iSvrFd, (struct sockaddr*)&sCliAddr, &iSinSize);  
  
        // 連接注冊為新事件 (EV_PERSIST為事件觸發后不默認刪除)  
        struct event *pEvRead = new event;  
        event_set(pEvRead, iCliFd, EV_READ|EV_PERSIST, onRead, pEvRead);  
        event_base_set(base, pEvRead);  
        event_add(pEvRead, NULL);  
    }  
  
    int main()  
    {  
  
        int iSvrFd;    
        struct sockaddr_in sSvrAddr;  
  
        memset(&sSvrAddr, 0, sizeof(sSvrAddr));    
        sSvrAddr.sin_family = AF_INET;    
        sSvrAddr.sin_addr.s_addr = inet_addr("127.0.0.1");      
        sSvrAddr.sin_port = htons(8888);     
  
        // 創建tcpSocket（iSvrFd），監聽本機8888端口    
        iSvrFd = socket(AF_INET, SOCK_STREAM, 0);    
        bind(iSvrFd, (struct sockaddr*)&sSvrAddr, sizeof(sSvrAddr));    
        listen(iSvrFd, 10);  
  
        // 初始化base  
        base = event_base_new();  
  
        struct event evListen;  
        // 設置事件  
        event_set(&evListen, iSvrFd, EV_READ|EV_PERSIST, onAccept, NULL);  
        // 設置為base事件  
        event_base_set(base, &evListen);  
        // 添加事件  
        event_add(&evListen, NULL);  
  
        // 事件循環  
        event_base_dispatch(base);  
  
        return 0;  
    }  

  來自：http://blog.csdn.net/yyyiran/article/details/12219737