Fork Me
Libevent使用简介
03 Jun 2014 - by @ssdr

简介

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实现,包括服务器和客户端

一些资料:

两个例子

简单定时器

实现程序每秒输出一个“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;  
}  

本文转自libevent简介和使用