服务器并发编程--libevent

本文主要是介绍服务器并发编程--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;
}