libevent的使用

文章目录

  • libevent封装的框架思想
  • 常用函数分析
  • 使用fifo的读写
  • 未决和非未决
  • bufferevent特性
  • bufferevent函数
  • 客户端和服务器连接和监听
  • libevent实现socket通信


libevent封装的框架思想

libevent框架:
	1. 创建 event_base		(乐高底座)
	2. 创建 事件evnet	
	3. 将事件 添加到 base上	
	4. 循环监听事件满足
	5. 释放 event_base


1. 创建 event_base		(乐高底座)

		struct event_base *event_base_new(void);

		struct event_base *base = event_base_new();

2. 创建 事件evnet	

		常规事件 event	--> event_new(); 

		bufferevent --> bufferevent_socket_new();

3. 将事件 添加到 base上	

		int event_add(struct event *ev, const struct timeval *tv)

4. 循环监听事件满足

		int event_base_dispatch(struct event_base *base);

			event_base_dispatch(base);

5. 释放 event_base

		event_base_free(base);

常用函数分析

创建事件event:

	struct event *ev;

	struct event *event_new(struct event_base *base,evutil_socket_t fd,short what,event_callback_fn cb;  void *arg);

		base: event_base_new()返回值。

		 fd: 绑定到 event 上的 文件描述符

		what:对应的事件(r、w、e)

	在		EV_READ		一次 读事件

			EV_WRTIE	一次 写事件

			EV_PERSIST	持续触发。 结合 event_base_dispatch 函数使用,生效。

		cb:一旦事件满足监听条件,回调的函数。

		typedef void (*event_callback_fn)(evutil_socket_t fd,  short,  void *)	

		arg: 回调的函数的参数。

		返回值:成功创建的 event
事件event操作:

添加事件到 event_base

	int event_add(struct event *ev, const struct timeval *tv);

		ev: event_new() 的返回值。

		tv:为NULL,不会超时。意为:一直等到事件被触发,回调函数会被调用。
			为非0,等待期间,检查事件没有被触发,时间到,回调函数依旧会被调用。

将事件从base上拿下
	int event_del(struct event *ev);
		ev: event_new() 的返回值。


释放事件
	int event_free(struct event *ev);
		ev: event_new() 的返回值。

使用fifo的读写

read.c

#include <stdio.h>  
#include <unistd.h>  
#include <stdlib.h>  
#include <sys/types.h>  
#include <sys/stat.h>  
#include <string.h>  
#include <fcntl.h>  
#include <event2/event.h>  
  
// 对操作处理函数  
void read_cb(evutil_socket_t fd, short what, void *arg)  
{  
    // 读管道  
    char buf[1024] = {0};  
      
    int len = read(fd, buf, sizeof(buf));  
      
    printf("read event: %s \n", what & EV_READ ? "Yes" : "No");  
    printf("data len = %d, buf = %s\n", len, buf);  
      
    sleep(1);  
}  
  
  
// 读管道  
int main(int argc, const char* argv[])  
{  
    unlink("myfifo");  
  
    //创建有名管道  
    mkfifo("myfifo", 0664);  
  
    // open file  
    //int fd = open("myfifo", O_RDONLY | O_NONBLOCK);  
    int fd = open("myfifo", O_RDONLY);  
    if(fd == -1)  
    {  
        perror("open error");  
        exit(1);  
    }  
  
    // 创建个event_base  
    struct event_base* base = NULL;  
    base = event_base_new();  
  
    // 创建事件  
    struct event* ev = NULL;  
    ev = event_new(base, fd, EV_READ | EV_PERSIST, read_cb, NULL);  
  
    // 添加事件  
    event_add(ev, NULL);  
  
    // 事件循环  
    event_base_dispatch(base);  // while(1) { epoll();}  
  
    // 释放资源  
    event_free(ev);  
    event_base_free(base);  
    close(fd);  
      
    return 0;  
}  

write.c

#include <stdio.h>  
#include <unistd.h>  
#include <stdlib.h>  
#include <sys/types.h>  
#include <sys/stat.h>  
#include <string.h>  
#include <fcntl.h>  
#include <event2/event.h>  
  
// 对操作处理函数  
void write_cb(evutil_socket_t fd, short what, void *arg)  
{  
    // write管道  
    char buf[1024] = {0};  
      
    static int num = 0;  
    sprintf(buf, "hello,world-%d\n", num++);  
    write(fd, buf, strlen(buf)+1);  
      
    sleep(1);  
}  
  
  
// 写管道  
int main(int argc, const char* argv[])  
{  
    // open file  
    //int fd = open("myfifo", O_WRONLY | O_NONBLOCK);  
    int fd = open("myfifo", O_WRONLY);  
    if(fd == -1)  
    {  
        perror("open error");  
        exit(1);  
    }  
  
    // 写管道  
    struct event_base* base = NULL;  
    base = event_base_new();  
  
    // 创建事件  
    struct event* ev = NULL;  
    // 检测的写缓冲区是否有空间写  
    //ev = event_new(base, fd, EV_WRITE , write_cb, NULL);  
    ev = event_new(base, fd, EV_WRITE | EV_PERSIST, write_cb, NULL);  
  
    // 添加事件  
    event_add(ev, NULL);  
  
    // 事件循环  
    event_base_dispatch(base);  
  
    // 释放资源  
    event_free(ev);  
    event_base_free(base);  
    close(fd);  
      
    return 0;  
}  

未决和非未决

非未决: 没有资格被处理

未决: 有资格被处理,但尚未被处理

event_new --> event ---> 非未决 --> event_add --> 未决 --> dispatch() && 监听事件被触发 --> 激活态 

--> 执行回调函数 --> 处理态 --> 非未决 event_add && EV_PERSIST --> 未决 --> event_del --> 非未决

在这里插入图片描述

bufferevent特性

带缓冲区的事件 bufferevent

#include <event2/bufferevent.h> 
读:有数据-->读回调函数被调用-->bufferevent_read()-->读数据
写:使用bufferevent_write()-->向写缓冲中写数据-->该缓冲区有数据自动写出-->写完,回调函数被调用

在这里插入图片描述

bufferevent函数

创建、销毁bufferevent:

	struct bufferevent *ev;

	struct bufferevent *bufferevent_socket_new(struct event_base *base, evutil_socket_t fd, enum bufferevent_options options);

		base: event_base

		fd:	封装到bufferevent内的 fd

		options:BEV_OPT_CLOSE_ON_FREE

	返回: 成功创建的 bufferevent事件对象。

	
	void  bufferevent_socket_free(struct bufferevent *ev);
给bufferevent设置回调:
	对比event:	event_new( fd, callback );  	event_add() -- 挂到 event_base 上。

			bufferevent_socket_new(base,fd)  bufferevent_setcb( callback )

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

	bufev: bufferevent_socket_new() 返回值

	readcb: 设置 bufferevent 读缓冲,对应回调  read_cb{  bufferevent_read() 读数据  }

	writecb: 设置 bufferevent 写缓冲,对应回调 write_cb {  } -- 给调用者,发送写成功通知。  可以 NULL

	eventcb: 设置 事件回调。   也可传NULL
		events: BEV_EVENT_CONNECTED

	cbarg:	上述回调函数使用的 参数。

event回调函数类型
		typedef void (*bufferevent_event_cb)(struct bufferevent *bev,  short events, void *ctx);

		void event_cb(struct bufferevent *bev,  short events, void *ctx)
		{
			...
		}

	
read 回调函数类型:

		typedef void (*bufferevent_data_cb)(struct bufferevent *bev, void*ctx);

		void read_cb(struct bufferevent *bev, void *cbarg )
		{
			.....
			bufferevent_read();   --- 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的 缓冲区:

默认:新建的bufferevent的写缓冲是 enable、读缓冲是 disable

void bufferevent_enable(struct bufferevent *bufev, short events);   启动	
	通常用来启动bufferevent的read缓冲

void bufferevent_disable(struct bufferevent *bufev, short events); 禁用

	events: EV_READ、EV_WRITE、EV_READ|EV_WRITE

void bufferevent_get_enabled(struct bufferevent *bufev);
	获取缓冲区的禁用状态,需要借助&来得到

客户端和服务器连接和监听

客户端:

	socket();connect(fd,addr,addr_len);

	int bufferevent_socket_connect(struct bufferevent *bev, struct sockaddr *address, int addrlen);

		bev: bufferevent 事件对象(其中封装了fd)

		address、addresslen:等同于 connect() 的第二个参数和第三个参数


创建监听服务器:

	#include<event2/listener.h>

	//这个函数相当于socket、bind、listen、accept的作用
	struct evconnlistener *evconnlistener_new_bind (	
		struct event_base *base,
		evconnlistener_cb cb, 
		void *ptr, 
		unsigned flags,
		int backlog,
		const struct sockaddr *sa,
		int socklen);

	base: event_base

	cb: 回调函数。 一旦被回调,说明在其内部应该与客户端完成数据读写操作,进行通信。

	ptr: 回调函数的参数

	flags: 可识别的标志 
		LEV_OPT_CLOSE_ON_FREE:释放bufferevent时关闭底层传输端口。
		这将关闭底层套接字、释放底层bufferevent等
		LEV_OPT_REUSEABLE:端口服用

	backlog: listen()的第2个参数。 -1 表最大值

	sa:服务器自己的地址结构体

	socklen:服务器自己的地址结构体大小。

	返回值:成功创建的监听器。

	回调函数类型:
	typedef void(*evconnlistner_cb)(
	struct evconnlistener *listener, 
	evutil_socket_t sock,
	struct sockaddr* addr, 
	int len, 
	void *ptr);
	
	listener: evconnlistener_new_bind函数返回值
	sock: 用于通信的文件描述符
	addr: 客户端的IP+端口
	len: addr的len
	ptr: 外部ptr传递进来的值


释放监听服务器:

	void evconnlistener_free(struct evconnlistener *lev);

libevent实现socket通信

服务器端
在这里插入图片描述
server.c

#include <stdio.h>  
#include <unistd.h>  
#include <stdlib.h>  
#include <sys/types.h>  
#include <sys/stat.h>  
#include <string.h>  
#include <event2/event.h>  
#include <event2/listener.h>  
#include <event2/bufferevent.h>  
  
// 读缓冲区回调  
void read_cb(struct bufferevent *bev, void *arg)  
{  
    char buf[1024] = {0};     
    bufferevent_read(bev, buf, sizeof(buf));  
    printf("client say: %s\n", buf);  
  
    char *p = "我是服务器, 已经成功收到你发送的数据!";  
    // 发数据给客户端  
    bufferevent_write(bev, p, strlen(p)+1);  
    sleep(1);  
}  
  
// 写缓冲区回调  
void write_cb(struct bufferevent *bev, void *arg)  
{  
    printf("I'm服务器, 成功写数据给客户端,写缓冲区回调函数被回调...\n");   
}  
  
// 事件  
void event_cb(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");  
    }  
      
    bufferevent_free(bev);      
    printf("buffevent 资源已经被释放...\n");   
}  
  
  
  
void cb_listener(  
        struct evconnlistener *listener,   
        evutil_socket_t fd,   
        struct sockaddr *addr,   
        int len, void *ptr)  
{  
   printf("connect new client\n");  
  
   struct event_base* base = (struct event_base*)ptr;  
   // 通信操作  
   // 添加新事件  
   struct bufferevent *bev;  
   bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);  
  
   // 给bufferevent缓冲区设置回调  
   bufferevent_setcb(bev, read_cb, write_cb, event_cb, NULL);  
   bufferevent_enable(bev, EV_READ);  
}  
  
  
int main(int argc, const char* argv[])  
{  
  
    // init server   
    struct sockaddr_in serv;  
  
    memset(&serv, 0, sizeof(serv));  
    serv.sin_family = AF_INET;  
    serv.sin_port = htons(9876);  
    serv.sin_addr.s_addr = htonl(INADDR_ANY);  
  
    struct event_base* base;  
    base = event_base_new();  
    // 创建套接字  
    // 绑定  
    // 接收连接请求  
    struct evconnlistener* listener;  
    listener = evconnlistener_new_bind(base, cb_listener, base,   
                                  LEV_OPT_CLOSE_ON_FREE | LEV_OPT_REUSEABLE,   
                                  36, (struct sockaddr*)&serv, sizeof(serv));  
  
    event_base_dispatch(base);  
  
    evconnlistener_free(listener);  
    event_base_free(base);  
  
    return 0;  
}  

客户端
在这里插入图片描述

#include <stdio.h>  
#include <unistd.h>  
#include <stdlib.h>  
#include <sys/types.h>  
#include <sys/stat.h>  
#include <string.h>  
#include <event2/bufferevent.h>  
#include <event2/event.h>  
#include <arpa/inet.h>  
  
void read_cb(struct bufferevent *bev, void *arg)  
{  
    char buf[1024] = {0};   
    bufferevent_read(bev, buf, sizeof(buf));  
  
    printf("fwq say:%s\n", buf);  
  
    bufferevent_write(bev, buf, strlen(buf)+1);  
    sleep(1);  
}  
  
void write_cb(struct bufferevent *bev, void *arg)  
{  
    printf("----------我是客户端的写回调函数,没卵用\n");   
}  
  
void event_cb(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_CONNECTED)  
    {  
        printf("已经连接服务器...\\(^o^)/...\n");  
        return;  
    }  
      
    // 释放资源  
    bufferevent_free(bev);  
}  
  
// 客户端与用户交互,从终端读取数据写给服务器  
void read_terminal(evutil_socket_t fd, short what, void *arg)  
{  
    // 读数据  
    char buf[1024] = {0};  
    int len = read(fd, buf, sizeof(buf));  
  
    struct bufferevent* bev = (struct bufferevent*)arg;  
    // 发送数据  
    bufferevent_write(bev, buf, len+1);  
}  
  
int main(int argc, const char* argv[])  
{  
    struct event_base* base = NULL;  
    base = event_base_new();  
  
    int fd = socket(AF_INET, SOCK_STREAM, 0);  
  
    // 通信的fd放到bufferevent中  
    struct bufferevent* bev = NULL;  
    bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);  
  
    // init server info  
    struct sockaddr_in serv;  
    memset(&serv, 0, sizeof(serv));  
    serv.sin_family = AF_INET;  
    serv.sin_port = htons(9876);  
    inet_pton(AF_INET, "127.0.0.1", &serv.sin_addr.s_addr);  
  
    // 连接服务器  
    bufferevent_socket_connect(bev, (struct sockaddr*)&serv, sizeof(serv));  
  
    // 设置回调  
    bufferevent_setcb(bev, read_cb, write_cb, event_cb, NULL);  
  
    // 设置读回调生效  
    // bufferevent_enable(bev, EV_READ);  
  
    // 创建事件  
    struct event* ev = event_new(base, STDIN_FILENO, EV_READ | EV_PERSIST,  
                                 read_terminal, bev);  
    // 添加事件                       
    event_add(ev, NULL);  
  
    event_base_dispatch(base);  
  
    event_free(ev);  
      
    event_base_free(base);  
  
    return 0;  
}  

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

如若内容造成侵权/违法违规/事实不符,请联系我们进行投诉反馈qq邮箱809451989@qq.com,一经查实,立即删除!

相关文章

【C++练级之路】【Lv.20】位图和布隆过滤器(揭开大数据背后的神秘面纱)

快乐的流畅&#xff1a;个人主页 个人专栏&#xff1a;《算法神殿》《数据结构世界》《进击的C》 远方有一堆篝火&#xff0c;在为久候之人燃烧&#xff01; 文章目录 引言一、位图1.1 位图的概念1.2 位图的优势1.3 位图的模拟实现1.3.1 成员变量与默认成员函数1.3.2 test1.3.3…

AI智能分析视频监控行业的发展趋势和市场发展浅析

监控视频AI智能分析技术的现状呈现出蓬勃发展的态势&#xff0c;这一技术源于计算机视觉和人工智能的研究&#xff0c;旨在将图像与事件描述之间建立映射关系&#xff0c;使计算机能够从视频图像中分辨出目标信息。 在技术上&#xff0c;监控视频AI智能分析技术已经实现了对视…

Jenkins 2.164.3 安装插件(当前官网正式版本: 2.440.3 LTS)

Jenkins 2.164.3安装插件 1. 安装jenkins1.1 宿主机安装1.2 docker安装(linux) 2. 登录jenkins3. 修改配置文件 这篇文章如果放在5、6年前写出来毫无意义&#xff0c;因为安装2.164.3之后&#xff0c;推荐的插件即可自动安装。但是在2024年&#xff0c;当前正式版本是2.440.3 L…

【论文阅读】 Loss Functions for Image Restoration with Neural Networks

Loss Functions for Image Restoration with Neural Networks 论文地址摘要I. 引言II 相关工作用于图像恢复的神经网络B 找到更好的解决方案。 三、图像恢复的损失层A. l1 错误 The l1 ErrorB. SSIMC. MS-SSIMD. The Best of Both Worlds: MS-SSIM L1 四、结果A. Joint Denois…

四化智造MES(WEB)对接打通金蝶云星空余料入库查询(入库记录查询)接口与生产退料单新增接口

四化智造MES&#xff08;WEB&#xff09;对接打通金蝶云星空余料入库查询&#xff08;入库记录查询&#xff09;接口与生产退料单新增接口 接通系统&#xff1a;四化智造MES&#xff08;WEB&#xff09; “MES助力智能制造过程控制:MES管理生产订单的整个生产流程,通过对生产过…

npm install 及使用cordova打包常见错误大全(附解决方案)

问题1、cb() 这是我们在install过程中最最常见问题&#xff0c;网络上的解决方式也都是大同小异&#xff0c;要么就是升级node(误人子弟)&#xff0c;项目里的node是不可以随意升级的&#xff0c;它有可能会导致其他依赖又不适配&#xff0c;起始很多时候就是由于咱们配置的镜像…

Linux基础之git与调试工具gdb

目录 一、git的简单介绍和使用方法 1.1 git的介绍 1.2 git的使用方法 1.2.1 三板斧之git add 1.2.2 三板斧之git commit 1.2.3 三板斧之git push 二、gdb的介绍和一些基本使用方法 2.1 背景介绍 2.2 基本的使用方法 一、git的简单介绍和使用方法 1.1 git的介绍 Git是一…

记录一下3月底到4月的前端开发工程师面经

文章会持续更新 1.https 原理&#xff08;加密 证书&#xff09; 客户端使用https的url访问web服务器&#xff0c;要求与服务器建立ssl连接web服务器收到客户端请求后&#xff0c;会将网站的证书&#xff08;包含公钥&#xff09;传送一份给客户端客户端收到网站证书后会检查证…

学术咸鱼入门指南(2)

巧用思维导图阅读文献 化整为零&#xff1a;读文献&#xff0c;从拆分文章的结构开始 大家在初步接触自己学科的论文时&#xff0c;要了解清楚基本的范式&#xff0c;日后读起来就比较顺了。 科研论文的第一部分&#xff0c;是文章的标题&#xff0c;摘要和关键词&#xff0…

HNU-人工智能-作业1

人工智能-作业1 计科210x 甘晴void 第1题 考虑一个实时的在线电话翻译系统&#xff0c;该系统实现英语与日语之间的实时在线翻译&#xff0c;讨论该系统的性能度量&#xff0c;环境&#xff0c;执行器&#xff0c;感知器&#xff0c;并对该环境的属性进行分析。&#xff08;10…

革新品质检测,质构科技重塑肉类行业新篇章

革新品质检测&#xff0c;质构科技重塑肉类行业新篇章 在现代社会&#xff0c;消费者对食品安全和品质的要求日益提升&#xff0c;特别是在肉类行业。为了满足这一市场需求&#xff0c;质构科技凭借其精准、高效的优势&#xff0c;正逐渐成为肉类品质检测的新星。今天&#xf…

网络安全的未来:挑战、策略与创新

引言&#xff1a; 在数字化时代&#xff0c;网络安全已成为个人和企业不可忽视的议题。随着网络攻击的日益频繁和复杂化&#xff0c;如何有效保护数据和隐私成为了一个全球性的挑战。 一、网络安全的现状与挑战 网络安全面临的挑战多种多样&#xff0c;包括但不限于恶意软件、…

iPhone查看本机号码只需要这3招,不再为号码忘记犯愁!

在日常生活中&#xff0c;我们经常需要使用手机号码进行各种通讯活动&#xff0c;但有时候会忘记自己的手机号码&#xff0c;让人感到非常尴尬。不过&#xff0c;如果您是iPhone用户&#xff0c;那么您可以放心了&#xff01;因为在iphone查看本机号码只需要简单的几个步骤&…

ShardingSphere 5.x 系列【27】 数据分片原理之 SQL 改写

有道无术,术尚可求,有术无道,止于术。 本系列Spring Boot 版本 3.1.0 本系列ShardingSphere 版本 5.4.0 源码地址:https://gitee.com/pearl-organization/study-sharding-sphere-demo 文章目录 1. 概述2. 正确性改写2.1 标识符改写2.1.1 表名称2.1.2 索引名称2.1.3 Schem…

618好物节不知道买什么?快收下这份好物推荐指南!

随着618好物节的临近&#xff0c;你是否在为选择什么产品而犹豫不决&#xff1f;不用担忧&#xff0c;我精心准备了一份购物指南&#xff0c;旨在帮助你发现那些性价比高、口碑爆棚的商品。无论是科技新品还是生活小物件&#xff0c;这份指南都能帮你快速定位到那些值得投资的好…

若依前后端分离部署nginx

1、v.sj 2、生产环境修改 3、退出登录修改 4、路由改为hash模式 5、nginx配置 location /gldhtml/ {alias D:/java/tool/nginx-1.19.6/project/jxal/html/; } location /jxal/ {proxy_pass http://localhost:8081/; }

软信天成:CDMP数据管理专业人员认证9大要点【干货篇】

软信天成在上期文章中为大家分享了CDMP认证的基础内容。 上期文章&#xff1a;软信天成&#xff1a;CDMP数据管理专业人员认证详细介绍&#xff08;基础篇&#xff09;-CSDN博客 为方便诸位报考&#xff0c;软信根据考过CDMP的小伙伴经验分享&#xff0c;帮大家梳理了详细的考…

使用Beego创建API项目并自动化文档

最近需要使用Go写一个Web API项目&#xff0c;可以使用Beego与Gin来写此类项目&#xff0c;还是非常方便的&#xff0c;这里就介绍一下使用Beego来创建的Web API项目并自动化文档的方法。 使用Gin创建API项目并自动化文档参见&#xff1a;使用Gin编写Web API项目并自动化文档 …

软考 系统架构设计师系列知识点之软件可靠性基础知识(11)

接前一篇文章&#xff1a;软考 系统架构设计师系列知识点之软件可靠性基础知识&#xff08;10&#xff09; 所属章节&#xff1a; 第9章. 软件可靠性基础知识 第2节 软件可靠性建模 9.2.3 软件可靠性模型模型分类 一个有效的软件可靠性模型应尽可能地将前文所述的因素在软件可…

电感啸叫如何处理

一&#xff0e;电感啸叫现象 电感啸叫是指在20Hz~20kHz的电流激励频率下&#xff0c;电感会发出人耳所能听见的吱吱声。周期性电流经过电感线圈产生交变磁场&#xff0c;电感现象在交变磁场作用下产生振动而发出声音&#xff0c;这种周期性频率如果落在人耳听觉范围内&#xf…
最新文章