libevent库学习（1）

一、初识

1、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等等。

2、安装

官网：libevent

我这里用的是2.1.8版本，linux使用的是ubuntu20.4。使用原码安装。

（1）解压
（2）./configure              # 检查安装环境 生成 makefile
（3）make                     # 生成 .o 和 可执行文件
（4）sudo make install        # 将必要的资源cp置系统指定目录。

3、检查是否安装成功

进入sample路径下

这里有一些小demo可以测试书否安装成功

这样即表示安装成功。

4、查看安装路径

头文件在include里面

5、框架相关的不常用函数

查看支持哪些多路io

/*************************************************************************> File Name: 01event.c> Author: Winter> Created Time: 2022年02月17日 星期四 20时58分11秒************************************************************************/#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <event2/event.h>int main(int argc, char* argv[])
{struct event_base* base = event_base_new();               // 创建baseint i;const char** buff1;buff1 = event_get_supported_methods();       // 查看支持哪些多路iofor (i  = 0; i < 10; i++) {printf("buff1[i] = %s\n", buff1[i]);}return 0;
}

注意编译时，添加-levent

查看当前使用的多路IO

/*************************************************************************> File Name: 01event.c> Author: Winter> Created Time: 2022年02月17日 星期四 20时58分11秒************************************************************************/#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <event2/event.h>int main(int argc, char* argv[])
{struct event_base* base = event_base_new();               // 创建basconst char *buff2;buff2 = event_base_get_method(base);                      // 查看当前使用的多路IOprintf("buff2 = %s\n", buff2);return 0;
}

二、libevent封装的框架思想

1、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_new）和带缓冲区的事件（bufferevent_socket_new）

常规事件            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);

（5）释放 event_base

event_base_free(base);

2、使用fifo读写（常规事件）

创建事件event

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

读操作

/*************************************************************************> File Name: myread.c> Author: Winter> Created Time: 2022年02月18日 星期五 21时07分03秒************************************************************************/#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <fcntl.h>
#include <sys/stat.h>
#include <sys/types.h>
#include <event2/event.h>// 回调函数
void read_cb(evutil_socket_t fd, short what, void* arg) {// 读管道char buff[1024] = {0};int len = read(fd, buff, sizeof(buff));printf("read event : %s \n", what & EV_READ ? "YES" : "NO");printf("data len = %d, buff = %s\n", len, buff);sleep(1);
}int main(int argc, char* argv[])
{unlink("myfifo");// 创建有名fifoint res = mkfifo("myfifo", 0664);if (res == -1) {perror("mkfifo error\n");exit(1);}// 打开fifoint fd = open("myfifo", O_RDONLY | O_NONBLOCK);        // 非阻塞只读if (fd == -1) {perror("open error\n");exit(1);}// 创建event_basestruct event_base* base = event_base_new();// 创建事件     EV_PERSIST是持续读struct event* ev = event_new(base, fd, EV_READ | EV_PERSIST, read_cb, NULL);// struct event* ev = event_new(base, fd, EV_READ, 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;
}

写操作

/*************************************************************************> File Name: mywrite.c> Author: Winter> Created Time: 2022年02月18日 星期五 21时24分04秒************************************************************************/#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <unistd.h>
#include <pthread.h>
#include <event2/event.h>
#include <fcntl.h>// 回调函数
void write_cb(evutil_socket_t fd, short what, void* arg) {// 写管道char buff[1024] = {0};static int num = 0;sprintf(buff, "hello world - %d", num++);write(fd, buff, strlen(buff) + 1);sleep(1);
}int main(int argc, char* argv[])
{// 与myread.c配套，但是要先打开myread程序// 打开管道int fd = open("myfifo", O_WRONLY | O_NONBLOCK);if (fd == -1) {perror("open error\n");exit(1);}// 创建event_basestruct event_base* base = event_base_new();// 创建写事件   EV_PERSIST是持续写struct event* ev = event_new(base, fd, EV_WRITE | EV_PERSIST, write_cb, NULL);// struct event* ev = event_new(base, fd, EV_WRITE, write_cb, NULL);// 添加事件event_add(ev, NULL);// 事件循环event_base_dispatch(base);// 释放资源event_free(ev);event_base_free(base);close(fd);return 0;
}

测试

这里只测试了带有EV_PERSIST参数的event_new函数。