对于一个网络模块来说,一个缓冲模块是必不可少的,缓冲模块主要用于缓冲网络接收的模块,和用户发送的模块。
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:
一个bufferevent包含了一个底层传输的fd,一个输入buffer一个输出buffer,并且bufferevent帮我们完成了从socket 上接收数据写入输入buffer,同时从输出buffer中取出数据通过sicket发送,当输入输出缓冲中的数据达到一定量的时候调用我们设置的回调函数。
bufferevent结构体中主要有
1 两个事件(读,写):基本的event,等待被触发后加入到base的活动队列,然后调用相应的回调函数,
2.两个缓冲区(input output):存储读取和待发送的数据
3三个回调函数(read write error):用户自定义
4两个超时时间:(读、写超时)

bufferevent的socket事件的设置:

一: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 读写监听的流程。
网友评论