使用Libevent创建TCP连接的入门指南

文章 目录

介绍
安装Libevent
创建TCP连接
- TCP服务器
- TCP客户端
应用场景

介绍

Li b event是一个用于事件驱动编程的开源库，它提供了跨平台的事件处理和网络编程功能。在本篇博文中，我们将重点介绍如何使用Li b event来创建TCP连接。通过这个简单的入门指南，你将学会如何使用Li b event建立起基础的网络通信，为更复杂的应用场景打下基础。

Lib event 概述
Lib event是一个C语言编写的事件驱动库，用于异步I/O、定时器、信号处理等。它在处理大量并发连接时表现出色，适用于构建高性能的网络应用。Lib event的主要组成部分包括事件循环、事件处理器、缓冲区管理等。

安装Libevent

在开始之前，首先确保你的系统中已经安装了Libevent。你可以通过包管理器或者从官方网站（https://libevent.org/）下载源代码并进行编译安装。

使用apt安装Libevent（以Ubuntu为例）

sudo apt-get update
sudo apt-get install libevent-dev

创建TCP连接

接下来，我们将演示如何使用Libev ent 创建一个简单的TCP服务器和客户端。我们将使用Libe v ent提供的buffer e v ent来处理缓冲区，简化数据的读写操作。

TCP服务器


#include &lt;event2/event.h&gt;
#include <event2/listener.h&gt;
#include <event2/bufferevent.h&gt;

void on_read(struct bufferevent* bev, void* ctx) {
    struct evbuffer* input = bufferevent_get_input(bev);
    struct evbuffer* output = bufferevent_get_output(bev);
    
    // 从输入缓冲区读取数据
    size_t len = evbuffer_get_length(input);
    char* data = malloc(len + 1);
    evbuffer_remove(input, data, len);
    data[len] = '';
    
    printf("Received data: %sn", data);
    
    // 将数据写入输出缓冲区
    evbuffer_add(output, data, len);
    
    free(data);
}

void on_accept(struct evconnlistener* listener, evutil_socket_t fd,
               struct sockaddr* address, int socklen, void* ctx) {
    struct event_base* base = evconnlistener_get_base(listener);
    struct bufferevent* bev = bufferevent_socket_new(base, fd, BEV_OPT_CLOSE_ON_FREE);
    
    bufferevent_setcb(bev, on_read, NULL, NULL, NULL);
    bufferevent_enable(bev, EV_READ | EV_WRITE);
}

int main() {
    struct event_base* base = event_base_new();
    
    struct sockaddr_in sin;
    memset(&amp;sin, 0, sizeof(sin));
    sin.sin_family = AF_INET;
    sin.sin_port = htons(12345);
    
    struct evconnlistener* listener = evconnlistener_new_bind(
        base, on_accept, NULL,
        LEV_OPT_REUSEABLE | LEV_OPT_CLOSE_ON_FREE, -1,
        (struct sockaddr*)&amp;sin, sizeof(sin)
    );
    
    event_base_dispatch(base);
    
    evconnlistener_free(listener);
    event_base_free(base);
    
    return 0;
}

TCP客户端


#include <event2/event.h>
#include <event2/bufferevent.h>

void on_read(struct bufferevent* bev, void* ctx) {
    struct evbuffer* input = bufferevent_get_input(bev);
    struct evbuffer* output = bufferevent_get_output(bev);
    
    // 从输入缓冲区读取数据
    size_t len = evbuffer_get_length(input);
    char* data = malloc(len + 1);
    evbuffer_remove(input, data, len);
    data[len] = '';
    
    printf("Received data: %sn", data);
    
    // 将数据写入输出缓冲区
    evbuffer_add(output, data, len);
    
    free(data);
}

void on_event(struct bufferevent* bev, short events, void* ctx) {
    if (events &amp; BEV_EVENT_EOF) {
        printf("Connection closed.n");
    } else if (events &amp; BEV_EVENT_ERROR) {
        printf("Error on connection.n");
    }
    
    bufferevent_free(bev);
}

int main() {
    struct event_base* base = event_base_new();
    struct bufferevent* bev = bufferevent_socket_new(
        base, -1, BEV_OPT_CLOSE_ON_FREE | BEV_OPT_THREADSAFE
    );
    
    bufferevent_setcb(bev, on_read, NULL, on_event, NULL);
    bufferevent_enable(bev, EV_READ | EV_WRITE);
    
    struct sockaddr_in sin;
    memset(&amp;sin, 0, sizeof(sin));
    sin.sin_family = AF_INET;
    sin.sin_port = htons(12345);
    
    bufferevent_socket_connect(bev, (struct sockaddr*)&amp;sin, sizeof(sin));
    
    event_base_dispatch(base);
    
    bufferevent_free(bev);
    event_base_free(base);
    
    return 0;
}