Libevent简介
libevent是一个基于事件触发的网络库,适用于windows、linux、bsd等多种平台,内部使用select、epoll、kqueue等系统调用管理事件机制。
官网:
特点:
-
事件驱动,高性能;
-
轻量级,专注于网络,不如ACE那么臃肿庞大,只提供了简单的网络API的封装,线程池,内存池,递归锁等均需要自己实现;
-
开放源码,代码相当精炼、易读;
-
跨平台,支持Windows、Linux、BSD和Mac OS;
-
支持多种I/O多路复用技术(epoll、poll、dev/poll、select和kqueue等),在不同的操作系统下,做了多路复用模型的抽象,可以选择使用不同的模型,通过事件函数提供服务;
-
支持I/O,定时器和信号等事件;
-
采用Reactor模式;
源码组织结构
Libevent的源代码虽然都在一层文件夹下面,但是其代码分类还是相当清晰的,主要可分为头文件、内部使用的头文件、辅助功能函数、日志、libevent框架、对系统I/O多路复用机制的封装、信号管理、定时事件管理、缓冲区管理、基本数据结构和基于libevent的两个实用库等几个部分,有些部分可能就是一个源文件。
源代码中的test部分就不在我们关注的范畴了。
1)头文件
主要就是event.h:事件宏定义、接口函数声明,主要结构体event的声明;
2)内部头文件
xxx-internal.h:内部数据结构和函数,对外不可见,以达到信息隐藏的目的;
3)libevent框架
event.c:event整体框架的代码实现;
4)对系统I/O多路复用机制的封装
epoll.c:对epoll的封装;
select.c:对select的封装;
devpoll.c:对dev/poll的封装;
kqueue.c:对kqueue的封装;
5)定时事件管理
min-heap.h:其实就是一个以时间作为key的小根堆结构;
6)信号管理
signal.c:对信号事件的处理;
7)辅助功能函数
evutil.h 和evutil.c:一些辅助功能函数,包括创建socket pair和一些时间操作函数:加、减和比较等。
8)日志
log.h和log.c:log日志函数
9)缓冲区管理
evbuffer.c和buffer.c:libevent对缓冲区的封装;
10)基本数据结构
compat/sys下的两个源文件:queue.h是libevent基本数据结构的实现,包括链表,双向链表,队列等;_libevent_time.h:一些用于时间操作的结构体定义、函数和宏定义;
11)实用网络库
http和evdns:是基于libevent实现的http服务器和异步dns查询库;
linux下源码安装
这里以libevent-2.0.19为例,最新版本详见官网(http://libevent.org/)。
wget https://github.com/downloads/libevent/libevent/libevent-2.0.19-stable.tar.gztar zxvf libevent-2.0.19-stable.tar.gzcd libevent-2.0.19-stable./configure && make && make install
报错:
error while loading shared libraries: libevent-2.0.so.5: cannot open shared object file: No such file or directory
解决办法:
On a 32 bit system:
ln -s /usr/local/lib/libevent-2.0.so.5 /usr/lib/libevent-2.0.so.5
On a 64 bit system:
ln -s /usr/local/lib/libevent-2.0.so.5 /usr/lib64/libevent-2.0.so.5
示例
1、获取版本
// gcc getVersion.c -o getVersion -levent#include#include int main(){ const char *version = event_get_version(); printf("%s\n",version); return 0;}
2、一个timer程序
// gcc timer.c -o timer -levent#include#include #include #include #include #include #define N 300#define BUFLEN 256struct timeval lasttime;struct ST_EventWithDescription{ struct event *p_event; int time_interval; char lable[BUFLEN];};static void timeout_cb(evutil_socket_t fd, short event, void *arg){ struct timeval newtime, difference; struct ST_EventWithDescription *pSTEvent = arg; struct event *timeout = pSTEvent->p_event; double elapsed; evutil_gettimeofday(&newtime, NULL); evutil_timersub(&newtime, &lasttime, &difference); elapsed = difference.tv_sec + (difference.tv_usec / 1.0e6); printf("%s called at %d: %.3f seconds since my last work.\n", (char*)pSTEvent->lable,(int)newtime.tv_sec, elapsed); lasttime = newtime; struct timeval tv; evutil_timerclear(&tv); tv.tv_sec = pSTEvent->time_interval; event_add(timeout, &tv);}void setParam(struct ST_EventWithDescription *stEventDescription, struct event *m_event,int time_interval,char* m_lable){ stEventDescription->p_event = m_event; stEventDescription->time_interval = time_interval; memset(stEventDescription->lable,0,sizeof(stEventDescription->lable)); memcpy(stEventDescription->lable,m_lable,strlen(m_lable)+1);}void setTimeIntervalArr(int *arr,int n){ int i; srand(time(NULL)); for(i=0; i
demo的完整地址: