libevent 定時器timer

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

 

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

 

下面寫了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); //初始化事件event，設置回調函數和關注的事件
   
    struct timeval tv; 
    tv.tv_sec = 1; 
    tv.tv_usec = 0; 
    // 添加定時事件 
    event_add(&evTime, &tv); 
   
    // 事件循環 
    event_dispatch(); 
   
    return 0; 
}

_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! 

二、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

http://blog.chinaunix.net/uid-25909722-id-362420.html

http://blog.csdn.net/anghlq/article/details/7217330