libevent学习篇之一：libevent快速入门

2023-03-09 14:32| 来源: 网络整理| 查看: 265

LibEvent快速入门简介

基本的socket变成是阻塞/同步的，每个操作除非已经完成，出错，或者超时才会返回，这样对于每一个请求，要使用一个线程或者单独的进程去处理，系统资源没有办法支撑大量的请求。posix定义了可以使用异步的select系统调用，但是因为它采用了轮询的方式来判断某个fd是否变成active，效率不高。于是各系统就分别提出了基于异步的系统调用，例如Linux的epoll，由于在内核层面做了支持，所以可以用O(1)的效率查找到active的fd。基本上，libevent就是对这些高效IO的封装，提供统一的API，简化开发。

原理简介

libevent默认情况下是单线程的，可以配置成多线程，每个线程有且只有一个event_base，对应一个struct event_base结构体以及附于其上的事件管理器，用来调度托管给它的一系列event，可以和操作系统的进程管理类比。当一个事件发生后，event_base会在合适的时间，不一定是立即去调用绑定在这个事件上的函数，直到这个函数执行完，再去调度其他的事件。

//创建一个event_base struct event_base *base = event_base_new(); assert(base != NULL);

event_base内部有一个循环，循环阻塞在epoll等系统调用上，直到有一个/一些时间发生，然后去处理这些事件。当然，这些事件要被绑定在这个event_base上，每个事件对应一个struct event，可以是监听一个fd或者信号量之类的，struct event使用event_new来创建和绑定，使用event_add来将event绑定到event_base中。

// 创建并绑定一个event struct event* listen_event; //参数：event_base,监听的对象，需要监听的事件，事件发生后的回调函数，传给回调函数的参数 listen_event = event_new(base, listener, EV_READ | EV_PERSIST, callback_func, (void*)base); //参数：event，超时时间，NULL表示无超时设置 event_add(listen_event, NULL);

注：libevent支持的事件及属性包括（使用bitfield实现）

EV_TIMEOUT:超时； EV_READ:只要网络缓冲中还有数据，回调函数就会被触发； EV_WRITE:只要塞给网络缓冲的数据被写完，回调函数就会被触发； EV_SIGNAL:POSIX信号量； EV_PERSIST:不指定这个属性，回调函数被触发后事件会被删除； EV_ET:Edge-Trigger边缘触发（这个还不懂是什么意思）

然后启动event_base的循环，开始处理事件。循环地启动使用event_base_dispatch，循环将一直持续，找到不再有需要关注的事件，或者是遇到event_loopbreak()/event_loopexit()函数。

//启动循环，开始处理事件 event_base_dispatch(base);

接下来再来关注事件发生时的回调函数callback_func，callback_func的原型如下所示

typedef void(* event_callback_fn)(evutil_socket_t sockfd, short event_type, void *arg)

传给callback_func的是一个监听的fd，监听的事件类型，以及event_new中最后一个参数。在上述程序中，是将event_base传给了callback_func，实际中更常用的是构造一个结构体，把需要传给回调函数的参数都放进来，然后传给event_new，event_new再传给回调函数。

所以总结一下，对于一个服务器而言，流程大致如下：

获取待监听的内容的fd；创建一个event_base；创建一个event,指定待监听的fd，待监听事件的类型，以及事件放生时的回调函数及传给回调函数的参数；将event添加到event_base的事件管理器中；开启event_base的事件处理循环；（异步）当事件发生的时候，调用前面设置的回调函数。简易版QuickStart

下面的代码实现了一个简单的echo server，server启动后，client端启动并连接，在cmd中输入文字，server端收到后，将文字再返回给client。 server端代码：

/** You need libevent2 to compile this piece of code Please see: http://libevent.org/ Or you can simply run this command to install on Mac: brew install libevent Cmd to compile this piece of code: g++ LibeventQuickStartServer.c -o LibeventQuickStartServer /usr/local/lib/libevent.a **/ #include #include #include #include #include void accept_cb(int fd, short events, void* arg); void socket_read_cb(int fd, short events, void* arg); int tcp_server_init(int port, int listen_num); int main(int argc, char const *argv[]) { /* code */ int listener = tcp_server_init(9999, 10); if (listener == -1) { perror("tcp_server_init error"); return -1; } struct event_base* base = event_base_new(); // 监听客户端请求链接事件 struct event* ev_listen = event_new(base, listener, EV_READ | EV_PERSIST, accept_cb, base); event_add(ev_listen, NULL); event_base_dispatch(base); return 0; } void accept_cb(int fd, short events, void* arg) { evutil_socket_t sockfd; struct sockaddr_in client; socklen_t len = sizeof(client); sockfd = ::accept(fd, (struct sockaddr*)&client, &len); evutil_make_socket_nonblocking(sockfd); printf("accept a client %d\n", sockfd); struct event_base* base = (event_base*)arg; //动态创建一个event结构体，并将其作为回调参数传递给 struct event* ev = event_new(NULL, -1, 0, NULL, NULL); event_assign(ev, base, sockfd, EV_READ | EV_PERSIST, socket_read_cb, (void*)ev); event_add(ev, NULL); } void socket_read_cb(int fd, short events, void* arg) { char msg[4096]; struct event* ev = (struct event*)arg; int len = read(fd, msg, sizeof(msg) - 1); if(len

【本文地址】

公司简介

联系我们