文章来自官方文档的部分翻译:http://www.wangafu.net/~nickm/libevent-book/

通过这部分的了解,基本上可以使用libevent的常用功能了。有时间建议直接看官方文档。

一、简介

  1、Libevent组成

1)evutil:抽象各个平台上的网络实现。

2)event and event_baselibevent的核心部分,实现了异步的时间回调机制。可用于监听何时socket可读写,与超时,检测系统信号。

3)buffereventlibevent事件核心的一种封装,以实现更简便的使用。该模块允许应用程序访问缓存起来的读写事件,以代替socket准备好时马上通知的方式。

4)evbuffer:实现bufferevent中的基本缓存功能,提供一些有效与简便的访问。

二、Setup the Libevent library

1、指定日志输出,可以通过event_set_log_callback指定日志输出(注意指定的日志输出函数中不应该调用任何libevent中的函数,否则将出现不确定的问题)。

2、处理致命错误,可以通过event_set_log_callback指定当发生不可恢复错误时的回调函数,在该函数之后不应在调用libevent中的函数。

3、内存管理,可以通过 event_set_mem_functions 指定内存分配函数

4、多线程与锁,当在多线程环境下使用libevent时,需要告知libevent使用哪种锁版本的函数,目前支持pthread与windows锁

event_set_mem_functions、evthread_use_pthreads

5、Debug锁的异常使用,evthread_enable_lock_debugging 

6、Debug event的异常使用,event_enable_debug_mode 

7、检测libevent版本信息

8、释放所有的全局对象libevent_global_shutdown

三、获取一个event_base对象

1、在开始libevent之前需要有event_base对象,event_base对象可以持有多个的event对象,并且可以轮询以获取那个事件已经就绪。

2、创建默认配置的event_base:event_base_new

3、创建可配置的event_base:event_config_new、event_base_new_with_config、event_config_free

4、检查event_base后端的方法:event_get_supported_method

5、释放event_base:event_base_free,注意其持有的event不对释放

6、设置event_base支持event的优先级:event_base_priority_init

7、调用系统的fork后需要reinitevent_base:event_base_reinit

四、启动事件循环

  1、运行循环,可以对已经注册了事件的event_base进行事件等待,并得到通知。  

#define EVLOOP_ONCE             0x01
#define EVLOOP_NONBLOCK         0x02
#define EVLOOP_NO_EXIT_ON_EMPTY 0x04
int event_base_loop(struct event_base *base, int flags);

  默认情况下,event_base_loop将循环执行直到其中没有注册任何事件为止。当检测到事件被触发时,该事件被标记为active,并且在循环的后面调用相应的处理函数。EVLOOP_ONCE用于指定执行一次,loop将等待事件触发,待这些触发的事件处理完成后loop退出。EVLOOP_NONBLOCK立即检查是否有事件触发,若有则处理,然后返回。EVLOOP_NO_EXIT_ON_EMPTY即使event_base中没有注册的事件也不退出,直到调用了event_base_loopbreak函数。

  简化函数evebt_base_dispatch,循环将执行直到没有事件被注册,或者调用了event_base_loopbreak或者event_base_loopexit。

2、重新检查事件

  有时在事件的回调函数中,希望event_base马上检查新的事件而不是继续处理后面已触发的事件函数,可以调用event_base_loopcontinue函数。

3、获取libevent内部时间戳:Event_base_gettimeofday_cached、event_base_update_cache_time

4、到处event_base结构内容:Event_base_dump_events

5、遍历event_base中的所有事件:event_base_foreach_event

五、处理事件

1、事件生命周期:

初始化的:创建event后并且将其关联到某个event_base;

未决的:当调用了add函数后,该事件变成未决的(即处于等待状态)

激活的:关联的等待触发时,变成激活状态,随后对应的回调函数被调用。

若事件的属性为persistent,则激活后该事件再次变成未决,否则在回调函数返回时结束。

可以通过delete来删除未决事件,或者通过add将初始转换成未决状态

2、创建事件

#define EV_TIMEOUT      0x01
#define EV_READ         0x02
#define EV_WRITE        0x04
#define EV_SIGNAL       0x08
#define EV_PERSIST      0x10
#define EV_ET           0x20
typedef void (*event_callback_fn)(evutil_socket_t, short, void *);
struct event *event_new(struct event_base *base, evutil_socket_t fd,short what, event_callback_fn cb,void *arg);
void event_free(struct event *event);

事件创建之初为non-pending,只有调用了event_add之后才变成pending。

使用示例:

#include <event2/event.h>j 

void cb_func(evutil_socket_t fd, short what, void *arg)
{
        const char *data = arg;
        printf("Got an event on socket %d:%s%s%s%s [%s]",
            (int) fd,
            (what&EV_TIMEOUT) ? " timeout" : "",
            (what&EV_READ)    ? " read" : "",
            (what&EV_WRITE)   ? " write" : "",
            (what&EV_SIGNAL)  ? " signal" : "",
            data);
}

void main_loop(evutil_socket_t fd1, evutil_socket_t fd2)
{
    struct event *ev1, *ev2;
    struct timeval five_seconds = {5,0};
    struct event_base *base = event_base_new();
    ev1 = event_new(base, fd1, EV_TIMEOUT|EV_READ|EV_PERSIST, cb_func,(char*)"Reading event");
    ev2 = event_new(base, fd2, EV_WRITE|EV_PERSIST, cb_func, (char*)"Writing event");
    event_add(ev1, &five_seconds);
    event_add(ev2, NULL);
    event_base_dispatch(base);
}

事件类型:

EV_TIMEOUT:指定超时事件,在创建事件的时候timeout事件被忽略,超时事件在event_add函数中指定。

EV_READ:指定可读事件

EV_WRITE:指定可写事件

EV_SIGNAL:指定信号事件

EV_PERSISTENT:指定事件为永久的(即触发后会再次进入等待)

EV_ET:指定读写事件

3、创建自己为回调函数参数的事件:event_self_cbarg

ev = event_new(base, -1, EV_PERSIST, cb_func, event_self_cbarg());

该函数对如下函数event_new(), evtimer_new(), evsignal_new(), event_assign(), evtimer_assign(), and evsignal_assign().同样有效。

4、超时事件

为了方便使用,libevent提供了以evtime_开头的宏定义如下:

#define evtimer_new(base, callback, arg) 
    event_new((base), -1, 0, (callback), (arg))
#define evtimer_add(ev, tv) 
    event_add((ev),(tv))
#define evtimer_del(ev) 
    event_del(ev)
#define evtimer_pending(ev, tv_out) 
    event_pending((ev), EV_TIMEOUT, (tv_out))

5、信号事件

Libevent执行POSIX_style的信号。

#define evsignal_new(base, signum, callback, arg) 
    event_new(base, signum, EV_SIGNAL|EV_PERSIST, cb, arg)
struct event *hup_event;
struct event_base *base = event_base_new();

/* call sighup_function on a HUP signal */
hup_event = evsignal_new(base, SIGHUP, sighup_function, NULL);
#define evsignal_add(ev, tv) 
    event_add((ev),(tv))
#define evsignal_del(ev) 
    event_del(ev)
#define evsignal_pending(ev, what, tv_out) 
    event_pending((ev), (what), (tv_out))

注意:1)不要使用信号的方式来监听超时;2)信号事件只会被一个event_base捕捉,即使为多个event_base添加信号事件也只有一个event_base会得到通知。

6、非对分配的event

7、标记事件的pending与non-pending状态

int event_add(struct event *ev, const struct timeval *tv);

使用event_add将事件从non-pending状态变成pending状态。若事件已经处于pending状态,并且tv非null则更新该事件的tv事件,若tv为null则对原有状态没有任何影响(即还是保留之前的超时设置)。另外tv为等待超时毫秒数。

int event_remove_timer(struct event *ev);

使用event_del将事件状态变成pending,若已经是pending则不操作。

int event_remove_timer(struct event *ev);

使用event_remove_timer来去除事件的超时事件设置。若事件本身是一个超时事件则该函数相当于event_del函数。

8、事件属性

int event_priority_set(struct event *event, int priority);

用于设置事件的优先级,数值为从0到event_base支持优先级减一之间。

当有高优先级事件触发时,将得到先处理,然后再次检查所有事件,当没有高优先级事件触发后才能处理低优先级事件。

优先级数值越低,优先级越高。

9、检查事件状态

int event_pending(const struct event *ev, short what, struct timeval *tv_out);

返回事件监听的处于pending或active状态的flag。若tv_out非空并且社会自了EV_TIMEOUT则返回剩余的超时事件。(不是很清楚)。   

#define event_get_signal(ev) /* ... */
evutil_socket_t event_get_fd(const struct event *ev);
struct event_base *event_get_base(const struct event *ev);
short event_get_events(const struct event *ev);
event_callback_fn event_get_callback(const struct event *ev);
void *event_get_callback_arg(const struct event *ev);
int event_get_priority(const struct event *ev);
void event_get_assignment(const struct event *event,
        struct event_base **base_out,
        evutil_socket_t *fd_out,
        short *events_out,
        event_callback_fn *callback_out,
        void **arg_out);

10、一次性事件

int event_base_once(struct event_base *, evutil_socket_t, short,  void (*)(evutil_socket_t, short, void *), void *, const struct timeval *);

该事件不支持EV_SIGNAL与EV_PERSISTENT属性,并且使用默认优先级,当该事件触发一次后,有libevent自动删除。

该函数创建的事件不能手动删除与激活。

11、手动激活事件

void event_active(struct event *ev, int what, short ncalls);