Libevent3——bufferevent的特性、其事件对象的创建和销毁、给事件对象设置回调、缓冲区开启和关闭、并⭐网络通信开个头(转载)

本文主要是介绍Libevent3——bufferevent的特性、其事件对象的创建和销毁、给事件对象设置回调、缓冲区开启和关闭、并⭐网络通信开个头(转载),希望对大家解决编程问题提供一定的参考价值,需要的开发者们随着小编来一起学习吧!

bufferevent的特性:
bufferevent是带有buf的事件:
头文件#include<event2/bufferevent.h>
原理:bufferevent有两个缓冲区,用队列实现,先进先出
读:有数据—> 读的回调函数被调用 —> 使用bufferevent_read() —>读数据
写:使用bufferevent_write() —> 向缓冲区中写数 —> 该缓冲区有数据自动写出 —> 写完,回调函数被调用

带缓冲区的事件创建、销毁
创建: struct bufferevent bufferevent_socket_new(struct event_base base, evutil_socket_t fd, enum bufferevent_options options);
1,base;
2,fd封装到bufferevent内的fd;
3,options:基本就用BEV_OPT_CLOSE_ON_FREE,表示释放bufferevent时关闭底层传输端口,即关闭底层套接字,释放底层bufferevent等
返回:成功创建bufferevent事件对象

销毁void bufferevent_socket_free(struct bufferevent *ev);

给bufferevent事件对象设置回调
对比event:
event_new(fd, callback);------->创建ev中自带cb,event_add再挂到event_base上即可
bufferevent_socket_new(fd) 没有cb所以需要再一个函数用于来专门设置回调bufferevent_setcb(callback)
因为有两个缓冲区,所以要设置读写回调函数,并加一个事件回调函数

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

bufev:缓冲区事件
readcb:设置bufferevent读缓冲,对应回调read_cb{bufferevent_read() 读数据 }
writecb:设置bufferevent写缓冲,对应回调write_cb{ }—给调用者发送写成功通知,可以NULL
eventcb:设置事件回调。也可传NULL

回调函数类型:typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void *ctx);

read回调函数:

void read_cb(struct bufferevent *bev, void *cbarg)
{

bufferevent_read();
}

其中bufferevent_read()函数的原型:size_t bufferevent_read(struct bufferevent *bev, void buf, size_t bufsize);

写回调函数其实意义不大,因为它就是在写完之后再发送一个写完的信号而已,我们只需要一个代替write的写函数即可int bufferevent_write(struct bufferevent *bufev, const void *data, size_t size);

禁用和启用缓冲区
默认: 新建的bufferevent写缓冲是enable,而读缓冲是disable的
1,void bufferevent_enable(struct bufferevent *bufev, short events);启用缓冲区
2,void bufferevent_disable(struct bufferevent * bufev, short events);禁用
3,short bufferevent_get_enabled(struct bufferevent *bufev);获取缓冲区的禁用状态,需要借助&来得到
其中第二个参数events可以取EV_READ、EV_WRITE、EV_READ|EV_WRITE

bufferevent的网络通信知识前提:

客户端和服务器连接和监听⭐
客户端:
socket(); connect() ----->
int bufferevent_socket_connect(struct bufferevent *bev, struct sockaddr *address, int addrlen);
参数1; bev = bufferevent 事件对象(封装了fd)
参数2/3的 address、len等同于connect()的参数2/3

服务器:
socket(); bind(); listen(); accept(); ----->
evconnlistener_new_bind()这个函数可以完成系统调用socket(); bind(); listen(); accept();四个函数的作用

#include<event2/listener.h>

//服务器创建监听器
struct evconnlistener *evconnlistener_new_bind(
struct event_base *base,
evconnlistener_cb cb,//监听回调函数,接收连接之后,用户要做的操作
void *ptr,//回调函数的参数
unsigned flags,//可以识别的标志
int backlog,//时listen()函数的第二个参数,即同时连接的最大数,传-1就表示使用默认的最大值128
const struct sockaddr *sa,//服务器+Port,是一个传入函数,是服务器自己的地址结构
int socklen//sa的大小
);

flags可取值:
LEV_OPT_CLOSE_ON_FREE 释放bufferevent时关闭底层传输端口,这将关闭底层套接字,释放底层bufferevent等
LEV_OPT_REUSEABLE 端口复用,可以“|”

返回值:struct evconnlistener *listener成功创建的监听器

回调函数,一旦被回调,说明在其内部应该与客户端完成数据读写操作进行通信
回调函数类型👇:【注意】该回调函数不是由我们调用的,是框架自动调用

typedef void (*evconnlistener_cb)(
struct evconnlistener *listener,//上面监听器evconnlistener_new_bind函数的返回值
evutil_socket sock,//用于通信的文件描述符
struct sockaddr *addr,//客户端IP+端口
int len,//客户端地址的长度
void *ptr;//外部传来的回调函数要用的参数
);

原文链接:https://blog.csdn.net/qq_37299596/article/details/106093049

这篇关于Libevent3——bufferevent的特性、其事件对象的创建和销毁、给事件对象设置回调、缓冲区开启和关闭、并⭐网络通信开个头(转载)的文章就介绍到这儿,希望我们推荐的文章对编程师们有所帮助!



http://www.chinasem.cn/article/480967

相关文章

CentOS和Ubuntu系统使用shell脚本创建用户和设置密码

《CentOS和Ubuntu系统使用shell脚本创建用户和设置密码》在Linux系统中,你可以使用useradd命令来创建新用户,使用echo和chpasswd命令来设置密码,本文写了一个shell... 在linux系统中,你可以使用useradd命令来创建新用户,使用echo和chpasswd命令来设

Java并发编程之如何优雅关闭钩子Shutdown Hook

《Java并发编程之如何优雅关闭钩子ShutdownHook》这篇文章主要为大家详细介绍了Java如何实现优雅关闭钩子ShutdownHook,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起... 目录关闭钩子简介关闭钩子应用场景数据库连接实战演示使用关闭钩子的注意事项开源框架中的关闭钩子机制1.

SpringBoot3.4配置校验新特性的用法详解

《SpringBoot3.4配置校验新特性的用法详解》SpringBoot3.4对配置校验支持进行了全面升级,这篇文章为大家详细介绍了一下它们的具体使用,文中的示例代码讲解详细,感兴趣的小伙伴可以参考... 目录基本用法示例定义配置类配置 application.yml注入使用嵌套对象与集合元素深度校验开发

使用Python和Pyecharts创建交互式地图

《使用Python和Pyecharts创建交互式地图》在数据可视化领域,创建交互式地图是一种强大的方式,可以使受众能够以引人入胜且信息丰富的方式探索地理数据,下面我们看看如何使用Python和Pyec... 目录简介Pyecharts 简介创建上海地图代码说明运行结果总结简介在数据可视化领域,创建交互式地

Java对象转换的实现方式汇总

《Java对象转换的实现方式汇总》:本文主要介绍Java对象转换的多种实现方式,本文通过实例代码给大家介绍的非常详细,对大家的学习或工作具有一定的参考借鉴价值,需要的朋友参考下吧... 目录Java对象转换的多种实现方式1. 手动映射(Manual Mapping)2. Builder模式3. 工具类辅助映

springboot项目如何开启https服务

《springboot项目如何开启https服务》:本文主要介绍springboot项目如何开启https服务方式,具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑完全的地方,望不吝赐教... 目录springboot项目开启https服务1. 生成SSL证书密钥库使用keytool生成自签名证书将

基于Java实现回调监听工具类

《基于Java实现回调监听工具类》这篇文章主要为大家详细介绍了如何基于Java实现一个回调监听工具类,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... 目录监听接口类 Listenable实际用法打印结果首先,会用到 函数式接口 Consumer, 通过这个可以解耦回调方法,下面先写一个

Python中判断对象是否为空的方法

《Python中判断对象是否为空的方法》在Python开发中,判断对象是否为“空”是高频操作,但看似简单的需求却暗藏玄机,从None到空容器,从零值到自定义对象的“假值”状态,不同场景下的“空”需要精... 目录一、python中的“空”值体系二、精准判定方法对比三、常见误区解析四、进阶处理技巧五、性能优化

C#TextBox设置提示文本方式(SetHintText)

《C#TextBox设置提示文本方式(SetHintText)》:本文主要介绍C#TextBox设置提示文本方式(SetHintText),具有很好的参考价值,希望对大家有所帮助,如有错误或未考虑... 目录C#TextBox设置提示文本效果展示核心代码总结C#TextBox设置提示文本效果展示核心代

Pyserial设置缓冲区大小失败的问题解决

《Pyserial设置缓冲区大小失败的问题解决》本文主要介绍了Pyserial设置缓冲区大小失败的问题解决,文中通过示例代码介绍的非常详细,对大家的学习或者工作具有一定的参考学习价值,需要的朋友们下面... 目录问题描述原因分析解决方案问题描述使用set_buffer_size()设置缓冲区大小后,buf