libevent编译安装，官网下载安装包并解压。进入解压目录执行：

代码语言：Bash

自动换行

AI代码解释

wget https://github.com/libevent/libevent/releases/download/release-2.1.12-stable/libevent-2.1.12-stable.tar.gz tar -zxvf libevent-2.1.12-stable.tar.gz cd libevent-2.1.12-stable ./configure make sudo make install

三、libevent库的封装层级

3.1、reactor对象封装struct event_base

reactor对象封装为struct event_base；通过：

（1）event_base_new()构造对象。

（2）event_base_free()销毁对象。

3.2、事件对象struct event

事件对象通过struct event的结构体封装使用。

展开

代码语言：C

自动换行

AI代码解释

struct event { struct event_callback ev_evcallback; /* for managing timeouts */ union { TAILQ_ENTRY(event) ev_next_with_common_timeout; int min_heap_idx; } ev_timeout_pos; evutil_socket_t ev_fd; struct event_base *ev_base; union { /* used for io events */ struct { LIST_ENTRY (event) ev_io_next; struct timeval ev_timeout; } ev_io; /* used by signal events */ struct { LIST_ENTRY (event) ev_signal_next; short ev_ncalls; /* Allows deletes in callback */ short *ev_pncalls; } ev_signal; } ev_; short ev_events; short ev_res; /* result passed to event callback */ struct timeval ev_timeout; };

变量	含义
ev_evcallback	回调函数。事件是异步处理的，需要回调函数。
min_heap_idx	时间事件的最小堆的索引。
ev_fd	定时事件的fd。
ev_base	事件对象所属的reactor的对象。
ev_io	网络事件关注的事情。
ev_signal	信号事件关注的事情。
ev_timeout	超时。
ev_timeout_pos和ev_fd	定时任务处理的事情。
ev_events	具体注册的事件。
ev_	具体的信号。

通常，event对象可以自己处理IO。

（1）event_new()：构建事件对象、绑定、事件回调。

（2）event_free()：销毁事件对象。

bufferevent和evconnlistener对象只需要关注业务逻辑的处理，由libevent内部处理IO操作。

bufferevent是在event对象上面封装的缓冲区。

3.3、struct bufferevent对象

struct bufferevent中的重要成员变量：

变量	含义
ev_base	事件对象所属的reactor的对象。
be_ops	bufferevent的具体操作。控制某个事件的打开、关闭、移除等，其中input是用户态读缓冲区，output是用户态写缓冲区
readcb	读事件的回调函数
writecb	注意不是写事件回调，而是低水平触发的回调函数。这是涉及到写失败时的处理，内部会处理写事件发送出去。通常不需要设置写回调函数。
errorcb	所有错误事件的回调函数。被动关闭连接或其他异常的回调函数。
wm_read	读水平线，里面分有高水平和低水平。低水平是指buffer中有多少数据就要触发回调，默认为0，即每次读事件都会触发回调；高水平是指缓冲区中达到多大的数据就要关闭读事件，即buffer数据比较多的时候不再处理读事件。
wm_write	写水平线，写只有低水平没有高水平。低水平默认值是0，即用户态缓冲区为空时回调写回调函数。

struct bufferevent_ops中的重要成员变量：

变量	含义
input	用户态读缓冲区。
output	用户态写缓冲区。

（1）bufferevent_socket_new()：构建bufferevent对象。（2）bufferevent_free()：销毁bufferevent对象。

3.4、evconnlistener对象

evconnlistener是专门处理listenfd的对象，使我们不需要关注bind、listen、accept的具体操作。

展开

代码语言：C

自动换行

AI代码解释

struct evconnlistener_ops { int (*enable)(struct evconnlistener *); int (*disable)(struct evconnlistener *); void (*destroy)(struct evconnlistener *); void (*shutdown)(struct evconnlistener *); evutil_socket_t (*getfd)(struct evconnlistener *); struct event_base *(*getbase)(struct evconnlistener *); }; struct evconnlistener { const struct evconnlistener_ops *ops; void *lock; evconnlistener_cb cb; evconnlistener_errorcb errorcb; void *user_data; unsigned flags; short refcnt; int accept4_flags; unsigned enabled : 1; };

（1）evconnlistener_new()：构建evconnlistener对象、绑定、事件回调。

（2）evconnlistener_free()：销毁evconnlistener对象。

（3）evconnlistener_bind_new()：创建listenfd、bind、listen、注册读事件。

3.5、事件循环

（1）事件循环：event_base_dispatch()，event_base_loop()。

（2）事件循环退出：event_base_loopexit()，event_base_break()。

3.6、事件处理

设置事件相对应的回调。

（1）如果是使用event对象，在event_new()会设置相对应的回调。

（2）如果IO由libevent处理，那么使用bufferevent_setcb()来设置回调。

展开

代码语言：C

自动换行

AI代码解释

void bufferevent_setcb(struct bufferevent *bufev, bufferevent_data_cb readcb, bufferevent_data_cb writecb, bufferevent_event_cb eventcb, void *cbarg) { BEV_LOCK(bufev); bufev->readcb = readcb; bufev->writecb = writecb; bufev->errorcb = eventcb; bufev->cbarg = cbarg; BEV_UNLOCK(bufev); }

四、完整示例代码

展开

代码语言：C

自动换行

AI代码解释

#include <event.h> #include <event2/listener.h> #include <event2/buffer.h> #include <sys/socket.h> #include <functional> #include <cstring> #include <stdlib.h> #define SOCKET_LISTEN_PORT 9703 #define SOCKET_BACKLOG_NUM 128 class asyn_event { private: /* data */ struct event_base *base; struct evconnlistener *listener; public: asyn_event(/* args */); ~asyn_event(); static void accept_cb(struct evconnlistener *listen,evutil_socket_t fd,struct sockaddr *sock,int socklen,void *arg); static void socket_event_callback(struct bufferevent *bev, short events, void *arg); static void socket_read_callback(struct bufferevent *bev, void *arg); void loop_run(); }; asyn_event::asyn_event(/* args */) { base=event_base_new(); struct sockaddr_in server={0}; server.sin_family=AF_INET; server.sin_addr.s_addr=htonl(INADDR_ANY); server.sin_port=htons(SOCKET_LISTEN_PORT); listener=evconnlistener_new_bind( base, &asyn_event::accept_cb, base, LEV_OPT_REUSEABLE|LEV_OPT_CLOSE_ON_FREE, SOCKET_BACKLOG_NUM, (struct sockaddr*)&server, sizeof(server) ); } asyn_event::~asyn_event() { // 销毁evconnlistener对象 evconnlistener_free(listener); // 销毁事件对象 event_base_free(base); } void asyn_event::accept_cb(struct evconnlistener *listen,evutil_socket_t fd,struct sockaddr *sock,int socklen,void *arg) { struct event_base *base = (struct event_base *)arg; // 连接的建立---接收连接 char ip[32] = { 0 }; evutil_inet_ntop(AF_INET, sock, ip, sizeof(ip) - 1); printf("accept a client fd:%d, ip:%s\n", fd, ip); struct bufferevent *bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE); // 注册读事件 bufferevent_setcb(bev, socket_read_callback, NULL, socket_event_callback, NULL);//写事件回调一般为NULL bufferevent_enable(bev, EV_READ | EV_PERSIST); } void asyn_event::loop_run() { // 事件循环 event_base_dispatch(base); } // 处理连接断开 void asyn_event::socket_event_callback(struct bufferevent *bev, short events, void *arg) { if (events &BEV_EVENT_EOF)//read=0 { printf("connection closed\n"); } else if (events & BEV_EVENT_ERROR)//strerro(errno) { printf("some other error\n"); } else if (events &BEV_EVENT_TIMEOUT) printf("time out\n"); bufferevent_free(bev);// close(fd) } // 读回调 void asyn_event::socket_read_callback(struct bufferevent *bev, void *arg) { struct evbuffer *input = bufferevent_get_input(bev); struct evbuffer *output = bufferevent_get_output(bev); // 从输入缓冲区读取数据 char buf[1024]; size_t len; while ((len = evbuffer_remove(input, buf, sizeof(buf))) > 0) { //printf("Received: %.*s", (int)len, buf); evbuffer_add(output, buf, len); } //bufferevent_write(bev, reply, strlen(reply)); } int main() { asyn_event ev; ev.loop_run(); return 0; }

编译时要指定事件库，添加 -levent 参数。

代码语言：Bash

自动换行

AI代码解释

gcc -o ev ev.c -levent

运行时出现libevent-2.1.so.7。

代码语言：Bash

自动换行

AI代码解释

error while loading shared libraries: libevent-2.1.so.7: cannot open shared object file: No such file or directory

产生原因：libevent动态库在默认安装时，存放的路径在/usr/local/lib下，不在系统的默认查找路径内。

解决办法有两个：

（1）将该路径放在系统查找路径内。这种方法仅永久有效。

代码语言：Bash

自动换行

AI代码解释

sudo echo "/usr/local/lib" >> /etc/ld.so.conf sudo ldconfig

（2）添加环境变量的方法，添加 export LD_LIBRARY_PATH=XXX。这种方法仅当前有效。

代码语言：Bash

自动换行

AI代码解释

export LD_LIBRARY_PATH=/usr/local/lib/

五、总结

（1）有了libevent可以不使用IO函数。因为如果使用IO函数，既需要知道这些IO函数里面的系统调用返回值的含义。

（2）有了libevent就可以不清楚数据拷贝原理。

（3）有了libevent就可以不清楚网络原理以及网络编程流程。

（4）有了libevent只需要知道事件处理，IO操作完全交由libevent处理。

至此，我们实现了使用libevent库开发高并发的服务器程序，但是，这个服务器程序有些局限性，我们还要继续改善、优化。在改进之前，需要开发一个后台日志模块，这是服务器程序必须的，所有，下一个章节将开发一个高效的后台日志模块。