libevent实战学习

news2025/1/11 2:52:01

目录

编译安装libevent

libevent

事件对象

事件操作

事件循环

事件处理

libevent 客户端demo

libevent 服务端demo

libevent 服务端升级demo

 libevent完整demo

总结


C/C++Linux服务器开发/后台架构师【零声教育】-学习视频教程-腾讯课堂

编译安装libevent

git上下载https://github.com/libevent/libevent/releases/tag/release-2.1.12-stable

# 解压

root@kaka:/# tar -zxvf libevent-2.1.12-stable

root@kaka:/# cd libevent-2.1.12-stable/

# 执行配置./configure, 检测安装环境, 生成makefile.

# 执行./configure的时候也可以指定路径, ./configure --\prefix=/usr/local

# 这样就可以安装到指定的目录下, 但是这样在进行源代码编译的时候

# 需要指定用-I头文件的路径和用-L库文件的路径. 若默认安装不指定--prefix,

# 则会安装到系统默认的路径下, 编译的时候可以不指定头文件和库文件所在的路径.

root@kaka:/libevent-2.1.12-stable# ./configure

# 执行make命令编译整个项目文件

root@kaka:/libevent-2.1.12-stable# make

# make install进行安装

# 头文件拷贝到了/usr/local/include目录下

# 库文件拷贝到了/usr/local/lib目录下

root@kaka:/libevent-2.1.12-stable# make install 

gcc hello-world.c -levent 。由于安装的时候已经将头文件和库文件拷贝到了系统头文件所在路径/usr/local/include和系统库文件所在路径/usr/local/lib, 所以这里编译的时候可以不用指定-I和-L.

libevent

libevent是由 c 实现的异步事件库,封装了reactor;注册异步事件,检测异步事件,根据事件的触发先后顺序,调用相对应回调函数处理事件;

处理的事件包括:网络 io 事件、定时事件以及信号事件;

事件对象

reactor对象封装为struct event_base;通过:

(1)event_base_new()构造对象。
(2)event_base_free()销毁对象。

event对象可以自己处理IO。

(1)event_new():构建事件对象、绑定、事件回调。
(2)event_free():销毁事件对象。

bufferevent是在event对象上面封装的缓冲区。

(1)bufferevent_socket_new():构建bufferevent对象。
(2)bufferevent_free():销毁bufferevent对象。

evconnlistener是专门处理listenfd的对象,使我们不需要关注bind、listen、accept的具体操作。

(1)evconnlistener_new():构建evconnlistener对象、绑定、事件回调。
(2)evconnlistener_free():销毁evconnlistener对象。
(3)evconnlistener_new_bind():创建listenfd、bind、listen、注册读事件。

事件操作

event对象:

(1)event_add(),注册事件。
(2)event_del(),注销事件。

bufferevent对象:

(1)bufferevent_enable(),注册事件。
(2)bufferevent_disable(),注销事件。

事件循环

(1)事件循环:event_base_dispatch(),event_base_loop()。
(2)事件循环退出:event_base_loopexit(),event_base_break()。

事件处理

设置事件相对应的回调。

(1)如果是使用event对象,在event_new()会设置相对应的回调。

(2)如果IO由libevent处理,那么使用bufferevent_setcb()来设置回调。

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

    BEV_LOCK(bufev);

    bufev->readcb = readcb;
    bufev->writecb = writecb;
    bufev->errorcb = eventcb;

    bufev->cbarg = cbarg;

    BEV_UNLOCK(bufev);
}

libevent 客户端demo

主动连接

#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#include <event.h>
#include <event2/listener.h>

// typedef void (*bufferevent_event_cb)(struct bufferevent *bev, short what, void *ctx);
void connected_cb(struct bufferevent *bev, short what, void *ctx) {
    if (what == BEV_EVENT_CONNECTED) {	//连接建立成功
        printf("connect server successed\n");
    } else {
        printf("connect server failed\n");
    }
}

int main() {
	// 创建事件对象
    struct event_base * base = event_base_new();

    struct sockaddr_in sin = {0};
    sin.sin_addr.s_addr = inet_addr("192.168.181.1");
    sin.sin_family = AF_INET;
    sin.sin_port = htons(8080);

	// 连接的建立---主动连接
	//构建bufferevent对象
    struct bufferevent *ev = bufferevent_socket_new(base, -1, BEV_OPT_CLOSE_ON_FREE);//-1表示自动创建fd
    bufferevent_socket_connect(ev, (struct sockaddr *)&sin, sizeof(sin));
	//设置回调
    bufferevent_setcb(ev, NULL, NULL, connected_cb, NULL);

	// 事件循环
	event_base_dispatch(base);

	// 销毁bufferevent对象
	bufferevent_free(ev);
	
	// 销毁事件对象
	event_base_free(base);
    return 0;
}

 

libevent 服务端demo

#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

#include <event.h>
#include <event2/listener.h>

// typedef void (*evconnlistener_cb)(struct evconnlistener *, evutil_socket_t, struct sockaddr *, int socklen, void *);
void  accept_cb(struct evconnlistener *listen, evutil_socket_t fd, struct sockaddr *sock, int socklen, void *arg) {
    char ip[32] = {0};
    evutil_inet_ntop(AF_INET, sock, ip, sizeof(ip)-1);
    printf("accept a client fd:%d ip:%s\n", fd, ip);

}

int main() {
	// 创建事件对象
    struct event_base * base = event_base_new();

	// listener
    struct sockaddr_in sin = {0};
    sin.sin_family = AF_INET;
    sin.sin_port = htons(8888);

	//创建listenfd、bind、listen、注册读事件。
    struct evconnlistener *listen = evconnlistener_new_bind(base, accept_cb, base,
        LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE, 512, (struct sockaddr*)&sin, sizeof(sin));

    // 事件循环
	event_base_dispatch(base);

	// 销毁evconnlistener对象
	evconnlistener_free(listen);

	// 销毁事件对象
	event_base_free(base);
    return 0;
}

libevent 服务端升级demo

#include <event.h>
#include <event2/listener.h>
#include <stdio.h>

#include <string.h>
#include <stdlib.h>

#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

void socket_read_callback(struct bufferevent *bev, void *arg) {
    // 操作读缓冲当中的数据
    //struct evbuffer *evbuf = bufferevent_get_input(bev); // 封装了读缓冲区
    
    //char *msg = evbuffer_readln(evbuf, NULL, EVBUFFER_EOL_LF);// \n作为数据包分隔符
    //if (!msg) return;
    //printf("server read the data: %s\n", msg);
	//char reply[4096] = {0};
    //sprintf(reply, "recvieced msg: %s\n", msg);//echo
    //free(msg);
    //bufferevent_write(bev, reply, strlen(reply));
    

	// 也可以直接用 bufferevent_read 读数据
    // bufferevent_read(struct bufferevent *bufev, void *data, size_t size)
    char msg[256] = {0};
	bufferevent_read(bev, msg, 256);
	printf("server read the data: %s\n", msg);

	char reply[4096] = {0};
    sprintf(reply, "recvieced msg: %s\n", msg);//echo
    bufferevent_write(bev, reply, strlen(reply));
}


// 处理连接断开
void socket_event_callback(struct bufferevent *bev, short events, void *arg) {
    if (events & BEV_EVENT_EOF)
        printf("connection closed\n");
    else if (events & BEV_EVENT_ERROR)
        printf("some other error\n");
    else if (events & BEV_EVENT_TIMEOUT)
        printf("timeout\n");
    bufferevent_free(bev); // close
}


// accept的回调函数封装
void listener_callback(struct evconnlistener *listener, evutil_socket_t fd,
                       struct sockaddr *sock, int socklen, void *arg) {
    char ip[32] = {0};
    evutil_inet_ntop(AF_INET, sock, ip, sizeof(ip) - 1);
    printf("accept a client fd:%d ip:%s\n", fd, ip);
	
    struct event_base* base = (struct event_base*) arg;
	
    //创建一个bufferevent
    struct bufferevent *bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);
	
    // 设置读、写、以及异常时的回调函数
    bufferevent_setcb(bev, socket_read_callback, NULL, socket_event_callback, NULL);
	
    // 使能这个bufferevent开启读事件
    bufferevent_enable(bev, EV_READ | EV_PERSIST);
}


int main()
{
	// listener
	struct sockaddr_in sin = { 0 };
	sin.sin_family = AF_INET;
	sin.sin_port = htons(8888);

	/* 底层IO多路复用抽象 */
    struct event_base *base = event_base_new();
    /* evconnlistener 监听 */
    struct evconnlistener *listener =
            evconnlistener_new_bind(base, listener_callback, base,
                                    LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE,
                                    10, (struct sockaddr *) &sin,
                                    sizeof(struct sockaddr_in));

	// 事件循环
	event_base_dispatch(base);

	// 销毁evconnlistener对象
	evconnlistener_free(listener);

	// 销毁事件对象
	event_base_free(base);

	return 0;
}

 

 libevent完整demo

包含网络事件,io事件,定时事件,信号事件

#include <netinet/in.h>
#include <sys/socket.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <event.h>
#include <time.h>
#include <signal.h>
#include <event2/listener.h>
#include <event2/bufferevent.h>
#include <event2/buffer.h>

void socket_read_callback(struct bufferevent *bev, void *arg) {
    // 操作读缓冲当中的数据
    struct evbuffer *evbuf = bufferevent_get_input(bev); // 封装了读缓冲区
    char *msg = evbuffer_readln(evbuf, NULL, EVBUFFER_EOL_LF);
    // 也可以直接用 bufferevent_read 读数据
    // bufferevent_read(struct bufferevent *bufev, void *data, size_t size)
    if (!msg) return;

    printf("server read the data: %s\n", msg);

    char reply[4096] = {0};
    sprintf(reply, "recvieced msg: %s\n", msg);//echo
    // -WRN: 需要自己释放资源
    free(msg);
    bufferevent_write(bev, reply, strlen(reply));
}

// stdio标准输入触发读事件时的回调
void stdio_callback(struct bufferevent *bev, void *arg) {
    // 获取读缓冲区并操作读缓冲中的数据
    struct evbuffer *evbuf = bufferevent_get_input(bev); // 封装了读缓冲区
    // 从中读一行,需要指定换行符
    char *msg = evbuffer_readln(evbuf, NULL, EVBUFFER_EOL_LF);

    if (!msg) return;

    if (strcmp(msg, "quit") == 0) {
        printf("safe exit!!!\n");
        event_base_loopbreak(arg);
    }

    printf("stdio read the data: %s\n", msg);
}

// socket出现如错误、关闭等异常事件时的回调
void socket_event_callback(struct bufferevent *bev, short events, void *arg) {
    if (events & BEV_EVENT_EOF)
        printf("connection closed\n");
    else if (events & BEV_EVENT_ERROR)
        printf("some other error\n");
    else if (events & BEV_EVENT_TIMEOUT)
        printf("timeout\n");
    bufferevent_free(bev); // close
}

// accept的回调函数封装
void listener_callback(struct evconnlistener *listener, evutil_socket_t fd,
                       struct sockaddr *sock, int socklen, void *arg) {
    char ip[32] = {0};
    evutil_inet_ntop(AF_INET, sock, ip, sizeof(ip) - 1);
    printf("accept a client fd:%d ip:%s\n", fd, ip);
    struct event_base *base = (struct event_base *) arg;
    //创建一个bufferevent
    struct bufferevent *bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);
    // 设置读、写、以及异常时的回调函数
    bufferevent_setcb(bev, socket_read_callback, NULL, socket_event_callback, NULL);
    // 使能这个bufferevent开启读事件
    bufferevent_enable(bev, EV_READ | EV_PERSIST);
}

static void do_timer(int fd, short events, void *arg) {
    struct event *timer = (struct event *) arg;
    time_t now = time(NULL);
    printf("do_timer %s", (char *) ctime(&now));
    //event_del(timer);
    // struct timeval tv = {1,0};
    // event_add(timer, &tv);
}

static void do_sig_int(int fd, short event, void *arg) {
    struct event *si = (struct event *) arg;
    event_del(si);
    printf("do_sig_int SIGINT\n");//CTRL + C
}

// 建立连接的事件封装   
int main() {
    struct sockaddr_in sin;
    memset(&sin, 0, sizeof(struct sockaddr_in));
    sin.sin_family = AF_INET;
    sin.sin_port = htons(8080);
    /* 底层IO多路复用抽象 */
    struct event_base *base = event_base_new();
    /* evconnlistener 监听 */
    struct evconnlistener *listener =
            evconnlistener_new_bind(base, listener_callback, base,
                                    LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE,
                                    10, (struct sockaddr *) &sin,
                                    sizeof(struct sockaddr_in));

    /* 普通 fd 的 IO 事件管理,此处以标准输入 stdin 为例 */
    struct bufferevent *ioev = bufferevent_socket_new(base, 0, BEV_OPT_CLOSE_ON_FREE);
    bufferevent_setcb(ioev, stdio_callback, NULL, NULL, base);
    bufferevent_enable(ioev, EV_READ | EV_PERSIST);
	
    /* 定时事件 */
    struct event evtimer;
    struct timeval tv = {1, 0}; // {秒, 微秒}
    event_set(&evtimer, -1, EV_PERSIST, do_timer, &evtimer); // tv 为超时时间
    event_base_set(base, &evtimer);
    event_add(&evtimer, &tv);
	
    /* 信号事件 */
    struct event evint;
    event_set(&evint, SIGINT, EV_SIGNAL, do_sig_int, &evint);
    event_base_set(base, &evint);
    event_add(&evint, NULL);

    /* 开启主循环 */
    event_base_dispatch(base);
    /* 结束释放资源 */
    evconnlistener_free(listener);
    event_base_free(base);
    return 0;
}

/*
gcc ev2.c -o ev2 -levent
client:
    telnet 127.0.0.1 8080
*/

总结

libevent是一个事件通知库,目标是对事件编程,封装了reactor。

使用层次:在事件中自己处理IO和只需要处理业务逻辑(libevent内部处理IO)两种方式。

封装层次:把事件对象绑定到reactor对象上面;需要熟悉事件操作、事件处理、事件循环。

libevent 主要封装了异步事件库与操作系统的交互;让用户无需关注平台检测处理事件的机制的差异,只需关注事件的具体处理;

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处:http://www.coloradmin.cn/o/94905.html

如若内容造成侵权/违法违规/事实不符,请联系多彩编程网进行投诉反馈,一经查实,立即删除!

相关文章

十分钟彻底搞懂python异常

异常 目标 异常的概念捕获异常异常的传递抛出异常 01. 异常的概念 程序在运行时&#xff0c;如果 Python 解释器 遇到 到一个错误&#xff0c;会停止程序的执行&#xff0c;并且提示一些错误信息&#xff0c;这就是 异常程序停止执行并且提示错误信息 这个动作&#xff0c;…

真无线耳机哪个品牌音质最好?半入耳式真无线蓝牙耳机推荐

对于社恐的人来说&#xff0c;出门在外都会选择佩戴上耳机&#xff0c;那么这种情况下&#xff0c;一款高品质的耳机真的是必不可少的&#xff0c;选择了一款性能优秀的耳机&#xff0c;不光能够让自己听音乐的过程中有更好的体验感&#xff0c;同时还能舒缓身心&#xff0c;让…

编程常见的问题(三) 线程池

编程常见的问题(三) 线程池 今天&#xff0c;我来讲讲使用线程池需要注意的一些问题。 在程序中&#xff0c;我们会用各种池化技术来缓存创建昂贵的对象&#xff0c;比如线程池、连接池、内存池。一般是预先创建一些对象放入池中&#xff0c;使用的时候直接取出使用&#xff…

[附源码]Node.js计算机毕业设计高校运动会管理系统Express

项目运行 环境配置&#xff1a; Node.js最新版 Vscode Mysql5.7 HBuilderXNavicat11Vue。 项目技术&#xff1a; Express框架 Node.js Vue 等等组成&#xff0c;B/S模式 Vscode管理前后端分离等等。 环境需要 1.运行环境&#xff1a;最好是Nodejs最新版&#xff0c;我…

阿里三面,mmap 没答好!

1、mmap基础概念 mmap 是一种内存映射文件的方法&#xff0c;即将一个文件或者其他对象映射到进程的地址空间&#xff0c;实现文件磁盘地址和进程虚拟地址空间中一段虚拟地址的一一映射关系。 实现这样的映射关系后&#xff0c;进程就可以采用指针的方式读写操作这一段内存&a…

给你30s,如何跟面试官讲清楚跳表

查找 假设有如下这样一个有序链表&#xff1a; 想要查找 24、43、59&#xff0c;按照顺序遍历&#xff0c;分别需要比较的次数为 2、4、6 目前查找的时间复杂度是 O(N)&#xff0c;如何提高查找效率&#xff1f; 很容易想到二分查找&#xff0c;将查找的时间复杂度降到 O(Lo…

MipNeRF:多尺度、抗混叠NeRF

Mip-NeRF: A Multiscale Representation for Anti-Aliasing Neural Radiance Fields ​ ICCV 2021 文章目录Mip-NeRF: A Multiscale Representation for Anti-Aliasing Neural Radiance Fields原始NeRF的问题重点componentsCone TracingIPE-integrated positional encodingPE与…

微服务框架 SpringCloud微服务架构 多级缓存 47 Lua 语法入门 47.2 变量和循环

微服务框架 【SpringCloudRabbitMQDockerRedis搜索分布式&#xff0c;系统详解springcloud微服务技术栈课程|黑马程序员Java微服务】 多级缓存 文章目录微服务框架多级缓存47 Lua 语法入门47.2 变量和循环47.2.1 数据类型47.2.2 变量47.2.3 循环47 Lua 语法入门 47.2 变量和…

人脸识别Face Recognition综述

综述&#xff1a;https://arxiv.org/pdf/2009.13290.pdf 人脸识别整个系统一般由三个关键要素构成&#xff1a;人脸检测&#xff08;face detection&#xff09;、人脸预处理&#xff08;face preprocess&#xff09;&#xff0c;人脸表征&#xff08;face representation&…

EtherCAT设备协议详解一、EtherCAT概述

EtherCAT简介&#xff1a; • 用于控制自动化技术的以太网&#xff08;EtherCAT&#xff09; 是一种基于以太网的现场总线系统 – 由倍福自动化™于2003年发明 – Beckhoff 创建了 EtherCAT 技术集团&#xff08;ETG&#xff09;于2004年推广议定书 –…

DBCO 点击化学:DBCO-PEG-COOH,DBCO-PEG-acid,羧基聚乙二醇环辛炔

一、产品描述&#xff1a; 西安凯新生物科技有限公司供应的&#xff1a;​DBCO-PEG-COOH&#xff0c;末端羧酸在活化剂&#xff08;如EDC或HATU&#xff09;存在下可与伯胺基反应&#xff0c;形成稳定的酰胺键。DBCO 点击化学可以在水性缓冲液中运行&#xff0c;也可以在有机溶…

来啦|深度讲解风控模型中的参数调优

大数据时代的风控体系必有模型部分的参与&#xff0c;用策略贯穿整个风控体系&#xff0c;以数据为驱动&#xff0c;模型一定是标配内容。于是在模型的建设上&#xff0c;如何精细化地输出一套有效的模型&#xff0c;就是在精细化管理上非常重要的一个差异点。不管传统的逻辑回…

MATLAB处理语音信号基本函数、模块

目录 一、sound函数 二、symerr函数用来计算错误码元数目和误码率 三、From Workspace 模块 四、To Workspace模块 一、sound函数 sound函数可以用来播放音频数据&#xff0c;将矩阵变为立体声播放。 二、symerr函数用来计算错误码元数目和误码率 三、From Workspace 模…

【High 翻天】Higer-order Networks with Battiston Federico (2)

目录测量矩阵表示中心化测度度&#xff08;degree&#xff09;路径&#xff08;path&#xff09;特征向量中心三元闭包和聚类系数单纯同调高阶Lapalacian算子超图拉普拉斯组合拉普拉斯接上回说到了高阶的表示方法&#xff0c;接下来开始高阶系统的测量方法。 测量 具体来说就…

逻辑越权总结(超详细总结涉及各类越权)

逻辑越权总结&#xff08;超详细总结涉及各类越权&#xff09;1.逻辑越权1.1.漏洞原理1.2.漏洞原因1.3.水平越权1.3.1.原理1.3.2.漏洞出现位置1.3.3.危害1.3.4.案例1.3.4.1.登录账号1.3.4.2.获取信息1.3.4.3.修改信息1.4.垂直越权1.4.1.原理1.4.2.漏洞出现位置1.4.3.条件1.4.4.…

艾美捷CpG ODN——ODN 1585说明书

艾美捷CpG ODN系列——ODN 1585&#xff1a;CpG寡脱氧核苷酸&#xff08;A型&#xff09;优化用于NK细胞活化&#xff0c;具有混合的磷酸二酯酶/硫代磷酸酯主链。小鼠TLR9&#xff08;Toll样受体9&#xff09;的特异性配体。 艾美捷CpG ODN 丨ODN 1585化学性质&#xff1a; 序…

kruskalCase克鲁斯卡尔算法

介绍 它的特点和Prim算法不一样&#xff0c;Prim是以点为主&#xff0c;通过顶点遍历没有访问的节点计算最小权重直至一条最小边出来&#xff1b;而Kruskal算法是以边为主&#xff0c;时间复杂度要低一些0(edge); 什么是最小生成树 最小生成树&#xff1a;在一个有n个结点的…

blender教程

文章目录Three的部分课件blender相关资源模型下载地址视图基本操作实现甜甜圈下落的动画day01笔记Three的部分课件 blender相关资源 模型下载地址 视图基本操作 shiftd 复制多个 g键移动 x y z锁定方向 A可以全选 然后选择大小 s 键 拖拽大小 ctrl a 全部应用 切换到不同的编…

Python 图表利器 pyecharts

随着互联网的高速发展&#xff0c;数据量也在疯狂增长&#xff0c;近几年数据分析&#xff0c;数据挖掘的岗位越来越吃香。说到数据分析&#xff0c;就离不开数据的可视化&#xff0c;毕竟图表比冷冰冰的数字直观&#xff0c;一眼就可以看出趋势和结论&#xff0c;毕竟一图胜千…

【AIOT】BLE Paper Relative

Billah, Md Fazlay Rabbi Masum, et al. “BLE Can See: A Reinforcement Learning Approach for RF-based Indoor Occupancy Detection.” Proceedings of the 20th International Conference on Information Processing in Sensor Networks (co-located with CPS-IoT Week 20…