libevent & bufferevent

libevent & bufferevent,第1张

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

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 读写监听的流程。

很多小伙伴在安装讯搜(XunSearch)时都出现过如下错误提示:

这个Error2错误经经过测试基本都是因为linux的版本与讯搜安装需要的libeven版本不一致导致的。

现在基本常用的linux发行版已经把系统的openssl升级到了1.1.0+,但是讯搜解压的安装目录里面的是libeven2.0.x需要的是openssl<1.1.0才行,所以导致在安装讯搜(XunSearch)时会出现libeven错误。我们可以通过升级讯搜(XunSearch)中libeven2.0.x版本来实现一致。步骤如下:

1、下载libevent2.1.12安装包并上传到xunsearch文件夹中;

2、libevent解压

tar -zxvf libevent-2.1.12-stable.tar.gz

3、压缩成bz2格式,这是讯搜(XunSearch)安装包的支持的格式

tar -cjf libevent-2.1.12-stable.tar.bz2 libevent-2.1.12-stable

4、复制到xunsearch下的packages文件夹内

cp libevent-2.1.12-stable.tar.bz2 xunsearch-full-1.4.15/packages/

5、删除讯搜(XunSearch)自带的安装包

cd xunsearch-full-1.4.15/packages/ rm -f libevent-2.0.X

6、重新安装讯搜(XunSearch)即可

./setup.sh


欢迎分享,转载请注明来源:内存溢出

原文地址: http://outofmemory.cn/tougao/12007160.html

(0)
打赏 微信扫一扫 微信扫一扫 支付宝扫一扫 支付宝扫一扫
上一篇 2023-05-20
下一篇 2023-05-20

发表评论

登录后才能评论

评论列表(0条)

保存