Libevent库的介绍与应用

article/2025/9/10 13:10:07

Libevent库

  • Libevent概述
  • Libevent使用模型
  • Libevent库使用示例
  • Libevent事件类型和框架结构
  • 使用Libevent完成tcp服务端

Libevent概述

Libevent是开源社区的一款高性能的I/O框架库,使用Libevent的著名案例有:高性能的分布式内存对象缓存软件memcached,Googlo浏览器Chromium的Linux版本。作为一个I/O框架库,Libevent具有如下特点:

  • 跨平台支持 Libevent支持Linux、Unix和Windows
  • 统一事件源 Libevent对I/O事件、信号和定时事件提供统一的处理。
  • 线程安全 Libevent使用libevent_pthread库来提供线程安全支持
  • 基于Reactor模式的实现

Libevent使用模型

在这里插入图片描述
libevent主框架提供注册方法,通过事件循环去检测事件就绪并通知libevent框架去调用回调函数

Libevent库使用示例

#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<string.h>
#include<signal.h>
#include<event.h>
#include<assert.h>void signal_cd(int fd,short event,void* arg)
{//fd与事件类型 系统传入,其他参数在argprintf("sig = %d\n",fd);
}
void timeout_ev(int fd,short event,void* arg)
{printf("Time out\n");
}int main()
{//实例初始化struct event_base* base = event_init();assert(base != NULL);//定义信号事件//参数://哪个实例//信号是谁//如何处理信号,回调函数//传入参数struct event* sig_ev = evsignal_new(base,SIGINT,signal_cb,NULL);assert(sig_ev != NULL);//注册//参数://添加事件//事件超时事件event_add(sig_ev,NULL);//定义定时事件struct event* timeout_ev = evtimer_new(base,timeout_cb,NULL);struct timeval tv = {3,0};//指3秒0微秒event_add(timeout_ev,&tv);//启动事件循环event_base_dispatch(base);//阻塞在这里 内部进行循环 并且libevent会根据情况去选择使用select,poll,或eopll//释放事件与实例event_free(sig_ev);event_free(timeout_ev);event_base_free(base);
}

编译代码
直接编译会显示错误,需要链接libevent库
在这里插入图片描述
运行查看
在这里插入图片描述

Libevent事件类型和框架结构

在这里插入图片描述
在这里插入图片描述
设置事件,将事件添加至libevent,其中有三个队列(数据结构为链表)分别存放读写时间、定时器、与信号事件,通过底层I\O复用方法检测,若事件产生就将事件挪至就绪队列中,然后将就绪队列中对应的回调函数一一执行,来相应事件

永久事件需要配合其他事件进行辅助,当我们将事件添加至队列中,当事件产生挪至就绪队列,响应后队列中该事件将不复存在,只相应一次,而永久事件在处理完后,还会再将该事件放回队列,可以将该事件继续检测而不是只检测一次

启动事件循环后,I\O函数会循环检测三个队列上有没有事件产生,若三个队列都为空则会直接退出;或者三个队列不为空,我们调用了退出事件循环的方法退出

在上面的示例中,我们并没有主动去使用事件类型,这是因为我们使用evsignal_new方法以及evtimer_new方法来实现,这两种方法实际上是对event_new方法的封装
在这里插入图片描述
在这里插入图片描述

在这里我们并没有看到我们的事件类型,现在我们将它展开,将创建信号与定时器的事件表现出来
在这里插入图片描述
在这里插入图片描述
修改后的完整代码如下,编译运行查看

#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<string.h>
#include<signal.h>
#include<event.h>
#include<assert.h>void signal_cb(int fd,short event,void* arg)
{if(event & EV_SIGNAL){//fd与事件类型 系统传入,其他参数在argprintf("sig = %d\n",fd);}
}
void timeout_cb(int fd,short event,void* arg)
{if(event & EV_TIMEOUT){printf("Time out\n");}
}int main()
{//实例初始化struct event_base* base = event_init();assert(base != NULL);//定义信号事件//参数://哪个实例//信号是谁//如何处理信号,回调函数//传入参数//struct event* sig_ev = evsignal_new(base,SIGINT,signal_cb,NULL);struct event* sig_ev = event_new(base,SIGINT,EV_SIGNAL|EV_PERSIST,signal_cb,NULL);assert(sig_ev != NULL);//注册//参数://添加事件//事件超时事件event_add(sig_ev,NULL);//定义定时事件//struct event* timeout_ev = evtimer_new(base,timeout_cb,NULL);struct event* timeout_ev = event_new(base,-1,EV_TIMEOUT,timeout_cb,NULL);struct timeval tv = {3,0};//指3秒0微秒event_add(timeout_ev,&tv);//启动事件循环event_base_dispatch(base);//阻塞在这里 内部进行循环 并且libevent会根据情况去选择使用select,poll,或eopll//释放事件与实例event_free(sig_ev);event_free(timeout_ev);event_base_free(base);
}

在这里插入图片描述
定时器不是永久事件,触发一次后就会被移除,而信号事件是永久时间则会一直触发

如果我们删除在添加信号时间时,加入的永久事件

struct event* sig_ev = event_new(base,SIGINT,EV_SIGNAL|EV_PERSIST,signal_cb,NULL);
struct event* sig_ev = event_new(base,SIGINT,EV_SIGNAL,signal_cb,NULL);

在这里插入图片描述
这时当程序启动,当libevent内部读写事件,定时事件以及信号事件的队列都为空时,事件循环结束,程序结束,而不像上面会不断循环去检测信号事件
在这里插入图片描述

使用Libevent完成tcp服务端

客户端代码

首先创建监听队列去监听读事件来自客户端的连接,然后继续监听读事件来自客户段发送来的消息

#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<string.h>
#include<assert.h>
#include<sys/socket.h>
#include<arpa/inet.h>
#include<netinet/in.h>
#include<event.h>void recv_cb(int fd, short ev, void* arg)
{if(ev & EV_READ){char buff[128] = {0};int n = recv(fd,buff,127,0);if(n<=0){close(fd);printf("client close\n");return;}printf("buff=%s\n",buff);send(fd,"ok",2,0);}
}
void accept_cb(int fd, short ev, void* arg)
{struct event_base * base = (struct event_base*)arg;if(ev & EV_READ){struct sockaddr_in caddr;int len = sizeof(caddr);int c = accept(fd,(struct sockaddr*)&caddr,&len);if(c < 0){return;}printf("accept c = %d\n",c);struct event* c_ev = event_new(base,c,EV_READ|EV_PERSIST,recv_cb,NULL);//无法将c_ev指针传入进函数,函数返回才会产生c_evif(c_ev == NULL){close(c);return;}event_add(c_ev,NULL);}
}
int create_socket();
int main()
{int sockfd = create_socket();assert(sockfd != -1);struct event_base * base = event_init();assert(base != NULL);//监听读事件struct event * sock_ev = event_new(base,sockfd,EV_READ|EV_PERSIST,accept_cb,base);assert(sock_ev != NULL);event_add(sock_ev,NULL);event_base_dispatch(base);event_free(sock_ev);event_base_free(base);exit(0);}
int create_socket()
{int sockfd = socket(AF_INET,SOCK_STREAM,0);if(sockfd == -1){return -1;}struct sockaddr_in saddr;memset(&saddr,0,sizeof(saddr));saddr.sin_family = AF_INET;saddr.sin_port = htons(6000);saddr.sin_addr.s_addr = inet_addr("127.0.0.1");int res = bind(sockfd,(struct sockaddr*)&saddr,sizeof(saddr));if(res == -1){return -1;}res = listen(sockfd,5);if(res == -1){return -1;}return sockfd;
}

客户端代码

#include<stdio.h>
#include<stdlib.h>
#include<unistd.h>
#include<string.h>
#include<assert.h>
#include<sys/socket.h>
#include<arpa/inet.h>
#include<netinet/in.h>int main()
{int sockfd = socket(AF_INET,SOCK_STREAM,0);assert(sockfd!=-1);assert(sockfd != -1);struct sockaddr_in saddr;memset(&saddr,0,sizeof(saddr));saddr.sin_family = AF_INET;saddr.sin_port = htons(6000);saddr.sin_addr.s_addr = inet_addr("127.0.0.1");int res = connect(sockfd,(struct sockaddr*)&saddr,sizeof(saddr));assert(res != -1);while(1){printf("input:\n");char buff[128] = {0};fgets(buff,128,stdin);if(strncmp(buff,"end", 3) == 0){break;}send(sockfd,buff,strlen(buff),0);memset(buff,0,128);recv(sockfd,buff,127,0);printf("buff = %s\n",buff);}close(sockfd);
}

运行结果查看
在这里插入图片描述
以上代码存在一个问题

其中event_free(sock_ev)在释放过程中,不仅释放了空间同时会在libevent中移除,而在监听来自客户端发送消息的读事件,无法将其释放,因为我们并没有创建该监听事件的指针(c_ev),想要解决这个问题需要我们间接的将c_ev的指针传入进去(malloc),或者定义一个数组,根据描述符做下标,c_ev来做值实现映射关系。


http://chatgpt.dhexx.cn/article/i119YsmE.shtml

相关文章

Linux c 开发 - libevent

目录 一、event_base 1. 创建event_base 2. 查看IO模型 3. 销毁event_base 4. 事件循环 event loop 5. event_base的例子 二、event 事件 1. 创建一个事件event 2. 释放event_free 3. 注册event 4.event_assign 5. 信号事件 6. event细节 三、Socket实例 四、Bu…

安装svn客户端

下载地址 下载 TortoiseSVN 我的网盘地址&#xff1a; 百度网盘 请输入提取码 提取码&#xff1a; em9s 1、安装客户端 双击运行&#xff1a; 点击【next】 点击【next】 选择好路径后&#xff0c;点击【next】 点击【install】安装 点击【finish】完成安装。安装完成后重…

SVN客户端配置--客户端

一、使用客户端软件连接SVN服务器 在项目文件夹中单击右键–>TortoiseSVN–>Repo-browser,并在弹出框中贴入URL&#xff08;svn://服务器IP&#xff09; 在图中指定的位置单击右键选择checkput 点击OK点击OK SVN的三大指令 指令名称Checkout①连接到SVN服务器②更新服务…

SVN客户端(TortoiseSVN)安装及使用说明

&#x1f60a; 作者&#xff1a; 一恍过去 &#x1f496; 主页&#xff1a; https://blog.csdn.net/zhuocailing3390 &#x1f38a; 社区&#xff1a; Java技术栈交流 &#x1f389; 主题&#xff1a; SVN客户端(TortoiseSVN)安装及使用说明 ⏱️ 创作时间&#xff1a; 20…

ubuntu搭建SVN客户端,右击提交或更新

有时候我们会在Linux系统上搞开发&#xff0c;项目在SVN上&#xff0c;不搭建SVN环境搞起来比较麻烦&#xff0c;不用其他软件为载体实现右击提交更新等其他操作&#xff0c;不使用VsCode,IDE全家桶等为载体搭建插件形式的SVN&#xff0c;完全独立搭建 1&#xff1a;安装SVN客…

SVN客户端下载及安装

SVN客户端地址&#xff1a;https://osdn.net/projects/tortoisesvn/# 方法/步骤 官网下载tortoisesvn&#xff0c;下载完成之后&#xff0c;如下图所示&#xff1a; 点击安装进入安装界面&#xff0c;点击接受协议&#xff0c;如下图所示&#xff1a; 选择安装的地址&…

【转】Ubuntu中SVN客户端安装+使用

转自&#xff1a;Ubuntu中SVN客户端安装使用_三少GG-CSDN博客 1、 安装 svn客户端&#xff1a; apt-get install subversion&#xff0c;然后根据提示一步一步&#xff0c;就完成了 svn的安装。当然&#xff0c;也可以源码安装 svn&#xff0c;下载 subversion 一个最新版本的源…

SVN客户端

SVN是Subversion的简称&#xff0c;是一个开源的代码版本控制系统 SVN客户端操作 checkout 检出&#xff1a;初次下载-第一次连接svn服务器时候需要下载对应仓库的数据&#xff08;如果仓库中有数据的话&#xff09;add 新增&#xff1a;新增数据到svn服务器update 更新&#x…

【SVN】windows下的SVN客户端访问ubuntu下的SVN服务器

目录 第一部分 windows创建本地版本库、连接ubuntu的SVN服务器 步骤0&#xff1a; 步骤一&#xff1a;创建windows本地版本库 步骤二&#xff1a;checkout检测 步骤三&#xff1a;输入之前配置的用户名和密码 第二部分 windows上传文件至SVN服务器 步骤一&#xff1a;添加…

SVN 客户端下载与安装

SVN 客户端下载与安装 svn 客户端下载地址&#xff1a;https://tortoisesvn.net/downloads.zh.html 1. 网址截图 2. 汉化包下载安装 下载完毕&#xff0c;双击安装&#xff0c;下一步即可&#xff08;可根据需要进行安装路径选择&#xff09;

windows环境下的svn客户端(VisualSVN Server),服务端(TortoiseSVN),中文化(TortoiseSVN LanguagePack_1.9.7.2)安装和使用(超详细)

一、下载安装包 1.VisualSVN server 服务端下载&#xff1a;VisualSVN Server 2.svn客户端下载&#xff1a;TortoiseSVN 3.中文化包下载&#xff1a;TortoiseSVN LanguagePack_1.9.7.27907-x64-zh_CN中文包 二、安装软件 1.安装VisualSVN server 服务端&#xff1a; &#xf…

SVN客户端安装及操作文档

第一部分&#xff1a;客户端安装 1 在D盘创建svnclient文件夹&#xff0c;并将svn安装包复制到svnclient文件夹中 2 客户端安装 双击文件“TortoiseSVN-1.14.1.29085-x64-svn-1.14.1.msi” 点击“Next” 点击“Next” 点击“Browse”选择安装路径&#xff0c;这里将安装路径…

12306图片验证码效果实现

效果如下&#xff1a; 原理&#xff1a;从服务器获取的图片上&#xff0c;我们画上自己的图片&#xff0c;然后再显示出来。 核心代码如下在处理imageview点击事件前做如下操作&#xff1a; Bitmap bitmap BitmapFactory.decodeResource(getResources(), R.mipmap.yanzheng)…

利用神经网络识别12306验证码—(六)模型应用以及12306实战测试

模型训练好之后&#xff0c;就可以应用于新图片的预测了。比如现在有下面这么一张12306的验证码&#xff0c;预测工作也分为两部分&#xff1a;上半部分的文字预测、下半部分的图片预测&#xff0c;将两部分划分开之后分别加载各自的模型进行预测。 文字预测&#xff1a;需要把…

php实现12306验证码,PHP仿12306图片验证码

生成验证码的demo使用模型model读取图库&#xff0c;有需要对接框架的朋友可以自己修改&#xff0c;如下&#xff1a; # 引入测试的数据库model require_once dirname(__FILE__)./Model.php; # 引入验证码核心类库 require_once dirname(dirname(__FILE__))./vendor/Vif.php; $…

python 爬取12306验证码

一个简单的验证码爬取程序 本文介绍了在Python2.7环境下爬取网站验证码&#xff1a; 思路就是获取验证码对应的url&#xff0c;然后发起requst请求&#xff0c;读取该URL对应的内容&#xff0c;然后写入到一个本地文件&#xff0c;实现一个验证码的保存。大量下载可以把以上程…

利用百度AI平台识别12306验证码

简单的利用百度AI平台做一个12306的验证码识别。 第一步&#xff1a;先进行图片预处理 提取文字部分 import numpy as np#分割文字 def get_img_text(img,offset0):return img[3:22,120offset:177offset]#分割图片 def _get_imgs(img):interval 5length 66img_array np.em…

12306验证码为什么那么变态?都是这项深度学习应用给逼的

导读&#xff1a;12306为什么要设置那么复杂的验证码机制呢&#xff1f;就是因为OCR。 今天聊OCR。 OCR是人工智能、机器学习特别是深度学习&#xff0c;在图像识别方向最为重要的应用之一。OCR全称Optical Chararcter Recogition&#xff0c;中文翻译为光学字符识别&#xff0…

12306验证码的一些思考

12306的验证码长这个样子: 让选择图片.看起来非常完美的图片验证码.比那些简单又没有实用的字母数字验证码组合强太多了.那些字母数字组合直接获取图片光学识别然后填进表单就可以攻破. 我也想实现这样的. 怎么去实现呢? 设计一个简单点的吧. 1.我先收集图片.收集200张.分…

12306 验证码代码分析

验证码是一个很有趣的问题&#xff0c;其目的是谁是一个人或机器输入来区分&#xff0c;这个问题的实质是一个图灵测试&#xff08;推荐电影《模仿游戏》&#xff09;&#xff0c;验证码是一种简单而有效的验证方法&#xff0c;由CMU在教授2000在有关创建。后来这头牛谁又将收集…