libevent学习-(I)
IN: C, 编程相关 Tags: C, libevent Comments: 1 libevent是一个异步事件处理软件函式库，以BSD许可证释出。 libevent提供了一组应用程序编程接口（API），让程式设计师可以设定某些事件发生时所执行的函式，也就是说，libevent可以用来取代网络服务器所使用的循环检查架构。 摘自维基百科 http://blog.gslin.info/2005/11/network-programming-using-libevent-i.html 以下分析针对libevent-1.4.3-stable。 来看libevent自带的例子： 我把原来代码中WIN平台相关的去掉了，看起来方便一些，这个例子创建了一个pipe，并且使用libevent来监听是否可读，读有数据可读时调用函数fifo_read。 event_init()里只是对外的一个接口，这个函数调用了event_base_new()，分配了一个event_base类型的空间，设置了一些全局变量，使用detect_monotonic来检测是否支持CLOCK_MONOTONIC类型的时钟，这里不太理解为什么要使用clock_gettime(CLOCK_MONOTONIC, &ts)来获得当前时间，这个与gettimeofday得到的精度是一样的，只是一个是标准的时间（UNIX元年算起），一个是开机时间算起，有什么差别吗？ 结果： [cocobear@cocobear libevent-1.4.3-stable]$ gcc ftime.c -lrt 接下来就检测可使用的事件检测函数，这里与系统相关的调用被封装成了一个结构eventop： 编译时libevent会通过 来“动态”的确定eventops数组，在定义这个eventops数组时确定了使用这些事件驱动模型的顺序，如果你机子上有多种可用的模式，则可以通过修改改数组来自定义使用的模型。 在event_base_new()的最后调用了event_base_priority_init()初始化了消息的优先级队列。主要就是对activequeues变量进行空间分配。默认是分配了一个event_list给activequeues。
这里介绍了libevent相关的网络编程背景，需要带套访问哦。
/*
* Compile with:
* cc -I/usr/local/include -o event-test event-test.c -L/usr/local/lib -levent
*/
static void
fifo_read(int fd, short event, void *arg)
{
char buf[255];
int len;
struct event *ev = arg;
/* Reschedule this event */
event_add(ev, NULL);
fprintf(stderr, "fifo_read called with fd: %d, event: %d, arg: %pn",
fd, event, arg);
len = read(fd, buf, sizeof(buf) - 1);
if (len == -1) {
perror("read");
return;
} else if (len == 0) {
fprintf(stderr, "Connection closedn");
return;
}
buf[len] = '�';
fprintf(stdout, "Read: %sn", buf);
}
int
main (int argc, char **argv)
{
struct event evfifo;
struct stat st;
const char *fifo = "event.fifo";
int socket;
if (lstat (fifo, &st) == 0) {
if ((st.st_mode & S_IFMT) == S_IFREG) {
errno = EEXIST;
perror("lstat");
exit (1);
}
}
unlink (fifo);
if (mkfifo (fifo, 0600) == -1) {
perror("mkfifo");<code></code>
exit (1);
}
/* Linux pipes are broken, we need O_RDWR instead of O_RDONLY */
socket = open (fifo, O_RDWR | O_NONBLOCK, 0);
if (socket == -1) {
perror("open");
exit (1);
}
fprintf(stderr, "Write data to %sn", fifo);
/* Initalize the event library */
event_init();
/* Initalize one event */
event_set(&evfifo, socket, EV_READ, fifo_read, &evfifo);
/* Add it to the active events, without a timeout */
event_add(&evfifo, NULL);
event_dispatch();
return (0);
}
libevent调用比较简单，首先event_init()对event库进行初始化，然后使用event_set()来对某个fd的操作进行监听，接着使用event_add()把这个event激活，这里可以指定超时的时间，最后一步event_dispatch()，开始进行循环。
[cocobear@cocobear libevent-1.4.3-stable]$ ./a.out
sec=1235372220
sec=4621
struct eventop {
const char *name;
void *(*init)(struct event_base *);
int (*add)(void *, struct event *);
int (*del)(void *, struct event *);
int (*dispatch)(struct event_base *, void *, struct timeval *);
void (*dealloc)(struct event_base *, void *);
/* set if we need to reinitialize the event base */
int need_reinit;
};
#ifdef HAVE_SELECT
&selectops,
#endif
