libevent & bufferevent

对于一个网络模块来说，一个缓冲模块是必不可少的，缓冲模块主要用于缓冲网络接收的模块，和用户发送的模块。

libevent在常规事件回调的基础上提供了一个缓冲的IO抽象概念，这个抽象概念被称为bufferevent、bufferevent提供了自动填充和释放的输入输出缓冲区，缓冲事件的用户不再直接处理IO，而是从输入缓冲区读取数据，写入到输出缓冲区。

libevent使用evbuffer作为网络缓冲模块，缓冲区由 evbuffer 和 evbuffer_chain 组成。evbuffer_chain是存储数据的一块内存，通过指针连接在一起，组成内存池，而evbuffer则是管理这个内存池的链表。

evbuffer_chain：属于evbuffer中单个项

evbuffer：

二者的关系

服务器用到libevent中bufferevent 中相关函数流程：

struct evconnlistener * evconnlistener_new_bind (struct event_base *base, evconnlistener_cb cb, void *ptr, unsigned flags, int backlog,   const struct sockaddr *sa, int socklen)

申请一个evconnlistener 对象，在给定的ip地址端口上监听TCP连接。新的连接到来时会触发回调函数 cb；

内部实现是 完成socket(),bind,listen()这些函数之后，将此fd通过event_assign函数添加到event_base中，event_assign函数前篇有所介绍，这里不再详述。

之前说event与event_base进行关联使用的是event_add函数，这个evconnlistener_enable就是做这个这个事情，

libevent中实现了大量的函数指针，初始化时将evconnlistener_event_ops 地址绑定到ops，最后调用evconnlistener_enable 函数里面 *** 作lev->ops->enable(lev)，就执行到了event_listener_enable函数中，次函数中再进行event_add *** 作。

可以理解为 evconnlistener_new_bind 函数封装了socket的API *** 作，然后对event与event_base进行初始化关联 *** 作，用户直接直接在回调中等待新的连接即可。

一个bufferevent包含了一个底层传输的fd，一个输入buffer一个输出buffer，并且bufferevent帮我们完成了从socket    上接收数据写入输入buffer，同时从输出buffer中取出数据通过sicket发送，当输入输出缓冲中的数据达到一定量的时候调用我们设置的回调函数。

bufferevent结构体中主要有

1 两个事件（读，写）：基本的event，等待被触发后加入到base的活动队列，然后调用相应的回调函数，

2.两个缓冲区（input output）：存储读取和待发送的数据

3三个回调函数（read write error）：用户自定义

4两个超时时间：（读、写超时）

一： struct bufferevent * bufferevent_socket_new (struct event_base *base, evutil_socket_t fd, int options)

在给定的socket 上创建一个新的 socket bufferevent。

对bufferevent 结构体进行初始化 *** 作，包含以下几项：

1 读写缓冲区（input，output）的初始化

2.读写事件初始化 *** 作

二 ：void bufferevent_setcb (struct bufferevent *bufev, bufferevent_data_cb readcb, bufferevent_data_cb writecb,    bufferevent_event_cb eventcb, void *cbarg)

 读写以及错误的回调函数的设置

三 ：int bufferevent_enable (struct bufferevent *bufev, short event)

将事件添加到event_base上，

在 bufferevent_socket_new 中 对be_ops 进行了赋值 *** 作 ，&bufferevent_ops_socket，

bufferevent_init_common中 bufev->be_ops = ops即 bufev->be_ops =&bufferevent_ops_socket；

bufferevent_enable 中调用了be_ops

enable函数就是指be_socket_enable函数，

函数调用层层下来之后还是event_add函数，将event添加到event_base上，底层epoll的epoll_ctl *** 作，添加节点到红黑树上。

以上就是使用bufferevent对 socket 读写监听的流程。

设置sock为非阻塞的

[cpp] view plaincopy

eg: evutil_make_socket_nonblocking(fd)

2. 使用bufferevent_socket_new创建一个structbufferevent *bev，关联该sockfd，托管给event_base

函数原型为：

[cpp] view plaincopy

struct bufferevent * bufferevent_socket_new(struct event_base *base, evutil_socket_t fd, int options)

eg: struct bufferevent *bev

bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE)

3. 设置读写对应的回调函数

函数原型为：

[cpp] view plaincopy

void bufferevent_setcb(struct bufferevent *bufev,

bufferevent_data_cb readcb, bufferevent_data_cb writecb,

bufferevent_event_cb eventcb, void *cbarg)

eg. bufferevent_setcb(bev, readcb, NULL, errorcb, NULL)

4. 启用读写事件,其实是调用了event_add将相应读写事件加入事件监听队列poll。正如文档所说，如果相应事件不置为true，bufferevent是不会读写数据的

函数原型：

[cpp] view plaincopy

int bufferevent_enable(struct bufferevent *bufev, short event)

eg. bufferevent_enable(bev, EV_READ|EV_WRITE)

5. 进入bufferevent_setcb回调函数：

在readcb里面从input中读取数据，处理完毕后填充到output中；

writecb对于服务端程序，只需要readcb就可以了，可以置为NULL；

errorcb用于处理一些错误信息。

---