当前位置：首页 > article >正文

Libevent TCP开发指南

article 2026/2/5 11:44:02

一、概念

Libevent 提供了高效的 TCP 网络编程接口，使开发者能够轻松构建高性能的 TCP 服务器和客户端。本指南将详细介绍如何使用 Libevent 进行 TCP 网络开发。

核心组件

事件基 (event_base) - 事件处理的核心结构
事件 (event) - 表示单个事件
缓冲区事件 (bufferevent) - 带缓冲的 I/O 事件
监听器 (evconnlistener) - TCP 连接监听器
缓冲区 (evbuffer) - 高效的数据缓冲区

常用 API

事件基

event_base_new() - 创建新的事件基
event_base_free() - 释放事件基
event_base_dispatch() - 开始事件循环
event_base_loopexit() - 退出事件循环

事件

event_new() - 创建新事件
event_free() - 释放事件
event_add() - 添加事件到事件基
event_del() - 从事件基中删除事件

缓冲区事件

bufferevent_socket_new() - 创建新的缓冲区事件
bufferevent_setcb() - 设置回调函数
bufferevent_enable() - 启用事件
bufferevent_write() - 写入数据
bufferevent_read() - 读取数据

event与bufferevent

普通事件(event)‌：基础事件类型，用于监听文件描述符的可读/可写状态、信号、定时器等单一事件触发。用户需手动管理I/O操作和缓冲区的数据读写‌。比如：监听socket的可读事件后，需自行调用read()读取数据并处理粘包/分包问题‌。
缓冲区事件(bufferevent)：高级封装的事件类型，内置输入/输出缓冲区（evbuffer结构体），自动处理底层I/O的读写操作和数据缓冲。用户只需通过回调函数处理已就绪的数据‌。比如：收到数据时自动填充输入缓冲区，触发读回调；用户调用bufferevent_write()时，数据先写入输出缓冲区，由libevent自动发送‌。

‌特性‌	‌普通事件(event)‌	‌缓冲区事件(bufferevent)‌
数据缓冲	需用户手动管理	内置输入/输出缓冲区，自动管理
水位控制	不支持	支持设置高/低水位标记‌
适用场景	信号、定时器、低层I/O控制	流式网络通信（如TCP服务）
多线程支持	需额外同步机制	提供线程安全的缓冲区操作接口‌

二、TCP 服务器开发

1. 基本服务器框架

#include <event2/listener.h>
#include <event2/bufferevent.h>
#include <event2/buffer.h>
#include <arpa/inet.h>// 定义回调函数
void read_cb(struct bufferevent *bev, void *ctx);
void event_cb(struct bufferevent *bev, short events, void *ctx);
void accept_conn_cb(struct evconnlistener *listener, evutil_socket_t fd,struct sockaddr *address, int socklen,void *ctx);int main() {// 1. 创建事件基struct event_base *base = event_base_new();if (!base) {fprintf(stderr, "Could not initialize libevent!\n");return 1;}// 2. 配置服务器地址struct sockaddr_in sin;memset(&sin, 0, sizeof(sin));sin.sin_family = AF_INET;sin.sin_port = htons(8080);  // 监听8080端口sin.sin_addr.s_addr = htonl(INADDR_ANY);  // 监听所有接口// 3. 创建监听器struct evconnlistener *listener = evconnlistener_new_bind(base, accept_conn_cb, NULL,LEV_OPT_CLOSE_ON_FREE | LEV_OPT_REUSEABLE, -1,(struct sockaddr*)&sin, sizeof(sin));if (!listener) {fprintf(stderr, "Could not create a listener!\n");return 1;}// 4. 启动事件循环event_base_dispatch(base);// 5. 清理资源evconnlistener_free(listener);event_base_free(base);return 0;
}

2. 连接接受回调

void accept_conn_cb(struct evconnlistener *listener, evutil_socket_t fd,struct sockaddr *address, int socklen,void *ctx) {struct event_base *base = evconnlistener_get_base(listener);// 为新的客户端连接创建buffereventstruct bufferevent *bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);if (!bev) {fprintf(stderr, "Error constructing bufferevent!");event_base_loopbreak(base);return;}// 设置回调函数bufferevent_setcb(bev, read_cb, NULL, event_cb, NULL);// 启用读写事件bufferevent_enable(bev, EV_READ | EV_WRITE);// 可选: 设置水位标记bufferevent_setwatermark(bev, EV_READ, 0, 4096); // 最大读取4096字节
}

3. 数据读取回调

void read_cb(struct bufferevent *bev, void *ctx) {struct evbuffer *input = bufferevent_get_input(bev);size_t len = evbuffer_get_length(input);// 分配缓冲区unsigned char *buffer = malloc(len + 1);// 从输入缓冲区读取数据bufferevent_read(bev, buffer, len);buffer[len] = '\0';printf("Received %zu bytes: %s\n", len, buffer);// 回显数据bufferevent_write(bev, buffer, len);free(buffer);
}

4. 事件处理回调

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