服务器并发编程--libevent

文章目录

  • 一、Libevent概述
    • 1.两个重要的结构体
    • 2.libevent常用接口
  • 二、libevent IO事件
  • 三、libevent信号事件
  • 四、libevent高并发服务器
  • 参考

一、Libevent概述

Libevent 是一个用C语言编写的、轻量级的开源高性能网络库，主要有以下几个亮点：事件驱动（ event-driven），高性能;轻量级，专注于网络，不如 ACE 那么臃肿庞大；源代码相当精炼、易读；跨平台，支持 Windows、 Linux、 *BSD 和 Mac Os；支持多种 I/O 多路复用技术， epoll、 poll、 dev/poll、 select 和 kqueue 等；支持 I/O，定时器和信号等事件；注册事件优先级。
　
　　Libevent 已经被广泛的应用，作为底层的网络库；比如 memcached、 Vomit、 Nylon、 Netchat等等。Libevent之于C语言网络编程，类似于Nettty之于Java Web编程。学习Netty的小伙伴，不防看下Libevent的实现，会加深对Netty框架的理解

安装方式（1）：

$ apt-get download libevent-dev
$ dpkg -x  libevent-dev_2.1.12-stable-1build3_amd64.deb libevent

安装方式（）：

  • libevent的download urls
  • github assert

1.两个重要的结构体

struct event-base

  • 事件集合
  • struct event_base用于创建和管理事件循环，而struct event用于表示具体的事件，并与事件循环相关联。
  • struct event_base 代表一个事件处理的基础框架，它负责管理事件循环（event loop），接收事件并将它们分派给相应的事件处理器。
  • struct event_base 实例典型地代表了一个事件驱动程序的运行环境，它可以被视为事件循环的主体。
  • struct event_base 可以支持多种事件驱动的后端（如select、poll、epoll等），因此在创建 struct event_base 实例时，可以指定使用的后端。

struct event

  • 一个事件（可以是一个fd，也可以是一个signal，也可以是一个定时器事件）
  • struct event 包含了事件的相关信息，比如事件类型（读、写、定时器等）、事件触发时需要执行的回调函数等。
  • 当文件描述符上发生关注的事件时，struct event 将通知 struct event_base，然后 struct event_base 将事件分派给相应的事件处理器执行。

两者关系：

  • struct event结构体中有一个指向struct event_base的指针，用于指示该事件所属的事件循环。这样，当事件发生时，事件循环可以根据事件的描述找到相应的回调函数并执行。

2.libevent常用接口

event_init

  • 用于初始化 libevent 的全局状态。在使用 libevent 前调用此函数是必要的步骤，它会进行一些全局状态的初始化工作。

event_base new

  • event_base_new 用于创建一个新的事件基础框架（struct event_base 实例）。
  • 返回的 event_base 实例将用于管理事件循环和事件处理。

event_set

  • event_set 用于设置事件的相关属性，比如事件关联的文件描述符、事件类型、以及事件触发时执行的回调函数。
    这个函数被废弃了，不建议使用，建议使用 event_assign 替代。

event_assign

  • event_assign 用于将事件与指定的 event_base 关联起来，并设置事件的属性。
  • 这个函数类似于 event_set，但是更加灵活，可以避免一些使用上的混淆。

event_add

  • event_add 用于向事件循环中添加一个事件，让它开始监视文件描述符上的事件。
  • 添加事件后，事件循环将开始监视文件描述符，当有事件发生时，会触发事件的回调函数。

evconnlistener_new_bing

  • evconnlistener_new_bind 是用于创建一个监听器（listener）的函数，用于监听指定地址和端口上的连接请求。
  • 当有连接请求到达时，监听器将接受连接并创建一个新的套接字来处理该连接。

二、libevent IO事件

fifo-read.c


#include <event.h>
#include <fcntl.h>
#include <stdio.h>
#include <stdlib.h>
#include <sys/stat.h>
#include <unistd.h>void fifo_read(evutil_socket_t fd, short events, void *arg) {char buf[32] = {0};int rt = read(fd, buf, sizeof(buf));if (-1 == rt) {perror("read");exit(-1);}printf("read <%s>\n", buf);return;
}int main() {int ret = mkfifo("fifo.tmp", 0700);if (-1 == ret) {perror("mkfifo");exit(-1);}int fd = open("fifo", O_RDONLY);if (-1 == fd) {perror("open");exit(-1);}struct event ev;event_init();event_set(&ev, fd, EV_READ, fifo_read, NULL);event_add(&ev, NULL);event_dispatch();return 0;
}

fifo-write.c

#include <fcntl.h>
#include <stdio.h>
#include <string.h>
#include <unistd.h>
int main() {int fd = open("fifo.tmp", O_WRONLY);if (-1 == fd) {perror("open");exit(-1);}char buf[32] = {0};while (1) {scanf("%s", buf);int ret = write(fd, buf, sizeof(buf));if (-1 == ret) {perror("write");exit(-1);}if (!strcmp(buf, "bye")) {break;}memset(buf, 0, sizeof(buf));}return 0;
}

三、libevent信号事件

signal.c

#include <event2/event_compat.h>
#include <event2/event_struct.h>
#include <signal.h>static int signal_count = 0;void signal_handler(evutil_socket_t fd, short events, void *args) {printf("<sig: %d>\n", fd);++signal_count;if (signal_count >= 2) {event_del((struct event *)args);}
}int main() {struct event_base *base = event_base_new();struct event ev;event_assign(&ev, base, SIGINT, EV_SIGNAL | EV_PERSIST, signal_handler, &ev);event_add(ev, NULL);event_base_dispatch();event_base_free(base);return 0;
}

四、libevent高并发服务器

#include <arpa/inet.h>
#include <cstddef>
#include <event2/bufferevent.h>
#include <event2/bufferevent_struct.h>
#include <event2/event_compat.h>
#include <event2/listener.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>void read_cb(struct bufferevent *bev, void *ctx) {char buf[128] = {0};size_t ret = bufferevent_read(bev, buf, sizeof(buf));if (ret < 0) {exit(-1);}printf("read from: <%d>\n", *(int *)ctx);
}void event_cb(struct bufferevent *bev, short what, void *ctx) {if (what & BEV_EVENT_EOF)printf("Client: <d> down", *(int *)ctx);bufferevent_free(bev);
}void listen_cb(struct evconnlistener *listener, evutil_socket_t fd,struct sockaddr *addr, int socklen, void *arg){static int gFd = -1;printf("Accept: <%d>\n", fd);gFd = fd;struct event_base *base = arg;struct bufferevent *bev =bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);if (NULL == bev) {exit(-1);}bufferevent_setcb(bev, read_cb, NULL, event_cb, &gFd);bufferevent_enable(bev, EV_READ);
}int main() {struct event_base *base = event_base_new();if (NULL == base) {printf("event_base \n");exit(-1);}struct sockaddr_in server_addr;memset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_port = 8000;server_addr.sin_addr.s_addr = inet_addr("127.0.0.1");struct evconnlistener *listen = evconnlistener_new_bind(base, listen_cb, NULL, LEV_OPT_CLOSE_ON_FREE | LEV_OPT_REUSEABLE, 10,(const struct sockaddr *)&server_addr, sizeof(server_addr));event_base_dispatch(base);evconnlistener_free(listen);event_base_free(base);return 0;
}

参考

  • 服务器并发编程–libevent
  • Libevent初探

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈email:809451989@qq.com，一经查实，立即删除！

相关文章

redis集群-主从机连接过程

redis集群-主从机连接过程

首先从机需要发送自身携带的replid和offset向主机请求连接 replid&#xff1a;replid是所有主机在启动时会生成的一个固定标识&#xff0c;它表示当前复制流的id&#xff0c;当从机第一次请求连接时&#xff0c;主机会将自己的replid发送给从机&#xff0c;从机在接下来的请求…
阅读更多...
LAME及 iOS 编译

LAME及 iOS 编译

文章目录 关于 LAME编译 for iOS 关于 LAME 官网&#xff1a;https://lame.sourceforge.io LAME是根据LGPL许可的高质量MPEG音频层III&#xff08;MP3&#xff09;编码器。 LAME的开发始于1998年年中左右。Mike Cheng 最开始将它作为针对8hz-MP3编码器源的补丁。在其他人提出…
阅读更多...
Redis(九)渐进式遍历 | 数据库管理

Redis(九)渐进式遍历 | 数据库管理

文章目录 前言什么是渐进式遍历SCAN数据库管理 前言 前面我们学习了针对 redis 五种基本数据类型和五种特殊数据类型的常用命令&#xff0c;其中通用命令 keys pattern 我们都知道是用来查询当前 redis 服务器中有哪些 key 的&#xff0c;而如果此时 redis 服务器中存在很多的…
阅读更多...
Pspnet

Pspnet

Pyramid Scene Parsing Network
阅读更多...
Linux mount 挂载出现疑难问题；mount can‘t find in /etc/fstab

Linux mount 挂载出现疑难问题；mount can‘t find in /etc/fstab

当挂载出现 “mount cant find in /etc/fstab” 疑难问题时&#xff0c;你需要检查挂载的虚拟文件目录是否已经被创建成功。 或者挂载路径不是一个文件目录&#xff0c;而不是一个文件。 如果是文件你就删除它&#xff0c;并且在重建为目录类型&#xff0c;如果这样都无法解决&…
阅读更多...
mac安装虚拟机linux系统

mac安装虚拟机linux系统

需要下载的有&#xff1a;centos8镜像 , 虚拟器 VMware 软件包 , Termius 或者xshell 1. CentOS系统下载 linux系统一般有&#xff1a; CentOS、ubuntu、redhat&#xff0c;选择一种进行安装就可以 CentOS 2024 年开始停止维护和发布 CentOS8的下载与安装(windows下安装) 镜…
阅读更多...
AI工具大揭秘：如何改变我们的工作和生活

AI工具大揭秘：如何改变我们的工作和生活

文章目录 &#x1f4d1;前言一、常用AI工具&#xff1a;便利与高效的结合1.1 语音助手1.2 智能推荐系统1.3 自然语言处理工具 二、创新AI应用&#xff1a;不断突破与发展2.1 医疗诊断AI2.2 智能家居2.3 无人驾驶技术 三、AI工具在人们生活中的应用和影响3.1 生活方式的变化3.2 …
阅读更多...
夏目友人帐所有妖怪名单

夏目友人帐所有妖怪名单

夏目友人帐妖怪名单 夏目友人帐 第一季 2008.07.07第1话&#xff1a;猫和友人帐 / 猫と友人帐 菱垣 狞影 斑第2话&#xff1a;露神之祠 / 露神の祠 露神 濯第3话&#xff1a;八原的怪人 / 八ツ原の怪人 一只目 牛头&#xff08;中级妖怪&#xff09;第4话&#xff1a;时雨与少女…
阅读更多...
MyBatisPlus @TableLogic实现全局自动逻辑删除

MyBatisPlus @TableLogic实现全局自动逻辑删除

一、背景 有一天&#xff0c;小王在编写代码时实现了一个删除操作&#xff0c;但由于测试场景覆盖不全&#xff0c;上线后不慎删除了系统中的部分业务数据。幸运的是&#xff0c;系统已经开启了binlog日志功能&#xff0c;使得我们能够根据日志来恢复这些误删的数据。这一事故…
阅读更多...
TransUNet或SwinUNet报错指南

TransUNet或SwinUNet报错指南

Transformer与Unet的结合是本人的2024毕设项目&#xff0c;在此之前从未接触过该领域&#xff0c;一切从0开始的过程十分痛苦&#xff0c;希望能帮助到你们 本笔记不定时更新 文章目录 复现报错使用预处理Synapse数据集的通用问题使用预处理ACDC数据集的通用问题找不到require…
阅读更多...
https自签名ssl证书生成流程

https自签名ssl证书生成流程

准备工作&#xff1a; 0.安装完整版的openssl openssl下载官网 安装到C:\OpenSSL32&#xff0c;也可以安装到其它盘&#xff0c;不要包含空格和中文 打开openssl.exe所在目录如:C:\OpenSSL32\bin&#xff0c;输入cmd.exe打开cmd控制台 1.创建ca文件夹 ,证书文件夹 mkdir …
阅读更多...
基于Spring Boot的学生在线答疑系统设计与实现

基于Spring Boot的学生在线答疑系统设计与实现

基于Spring Boot的学生在线答疑系统设计与实现 开发语言&#xff1a;Java框架&#xff1a;springbootJDK版本&#xff1a;JDK1.8数据库工具&#xff1a;Navicat11开发软件&#xff1a;eclipse/myeclipse/idea 系统部分展示 管理员登录界面 教师登陆界面 问题发布信息界面&am…
阅读更多...
堆内存分配策略傻傻不清楚

堆内存分配策略傻傻不清楚

一、概述 1.JVM堆内存分为年轻代、老年代和持久代&#xff08;JDK7及之前版本&#xff09;或元空间&#xff08;JDK8及之后版本&#xff09;。 年轻代用于存放新创建的对象&#xff0c;老年代用于存放存活时间较长的对象。 持久代或元空间主要用于存放类信息、方法信息、常量池…
阅读更多...
【Delphi 爬虫库 3】使用封装好的 HTML 解析库对 HTML 数据进行解析

【Delphi 爬虫库 3】使用封装好的 HTML 解析库对 HTML 数据进行解析

文章目录 解析HTML的意义1、简单解析HTML代码2、实战解析HTML代码 解析HTML的意义 HTML是Web页面的构建语言&#xff0c;每个Web开发者都需要了解HTML的基础知识。但是&#xff0c;通过手动阅读和解析需要极大的心智和时间投入。这时候&#xff0c;我们就需要使用HTML在线解析…
阅读更多...
WPF之XmlDataProvider使用

WPF之XmlDataProvider使用

1&#xff0c;WPF XAML支持数据提供&#xff08;DataProvider&#xff09;&#xff0c;但其提供的数据只供查看不可进行修改&#xff0c;删除&#xff0c;添加等。 数据提供者都继承自System.Windows.DataSourceProvider类&#xff0c;目前&#xff0c;WPF只提供两个数据提供者…
阅读更多...
Transformer中的数据输入构造

Transformer中的数据输入构造

文章目录 1. 文本内容2. 字典构造2.1 定义一个类用于字典构造2.2 拆分文本2.3 构造结果 3. 完整代码 1. 文本内容 假如我们有如下一段文本内容&#xff1a; Optics It is the branch of physics that studies the behaviour and properties of light . Optical Science 这段…
阅读更多...
Java web第五次作业

Java web第五次作业

1.在idea中配置好数据源 2、视频案例中只给出了查询所有结果的示例&#xff0c;请自己完成添加、删除、修改操作的代码。以下供参 考。 Delete("delete from emp where id#{id}") public void delete(Integer id); 测试代码 Test public void testDelete(){ empMa…
阅读更多...
「C++ STL篇 1-0」string类的使用

「C++ STL篇 1-0」string类的使用

目录 〇、概念 一、string类的构造函数 二、赋值运算符重载 三、有关容量的操作 四、string对象的访问 五、遍历string对象的字符数组 六、string对象的修改 七、string对象的常用操作 八、字符串和数字间的转换 拓展】 练习】 源代码】 〇、概念 1. string类是什么&#xff1…
阅读更多...
前后端分离实践：使用 React 和 Express 搭建完整登录注册流程

前后端分离实践：使用 React 和 Express 搭建完整登录注册流程

文章目录 概要整体架构流程技术名词解释ReactExpressReact RouterAnt Design 技术细节前端设计后端逻辑数据交互 小结 概要 本项目是一个基于React和Express的简单登录注册系统。通过前后端分离的方式&#xff0c;实现了用户的注册、登录和查看用户列表等功能。前端使用React框…
阅读更多...
PostgreSQL 14 向量相似度搜索插件 (pgvector) 安装指南

PostgreSQL 14 向量相似度搜索插件 (pgvector) 安装指南

本文是关于在 PostgreSQL 14 中安装并使用向量相似度搜索插件(pgvector)的详细指南。此插件允许用户在数据库中执行高效的向量运算，特别适用于机器学习模型的向量数据存储与检索场景。 环境需求 已安装PostgreSQL 14或更高版本。安装了Visual Studio 2022，用于编译插件。安装…
阅读更多...
最新文章

Copyright @ 2022~2023