libevent 异步IO 示例

在libevent中，异步I/O（Asynchronous I/O）是通过回调函数来实现的。下面是一个简单的libevent异步I/O示例，假设我们有一个HTTP客户端，想要非阻塞地发送一个GET请求：

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

void read_callback(bufferevent *bev, void *ctx) {
    char *data = bufferevent_get_output(bev);
    size_t len = strlen(data);

    // 这里处理接收到的数据
    printf("Received %zu bytes: %s\n", len, data);

    // 清理缓冲区并关闭连接
    free(data);
    bufferevent_free(bev);
}

int main() {
    event_base *base = event_base_new();
    evdns_base *evdns_base = evdns_base_new();

    // 创建一个socket连接
    int fd = socket(AF_INET, SOCK_STREAM, 0);
    struct sockaddr_in addr;
    // 初始化地址...

    bufferevent * bev = bufferevent_socket_new(base, fd, EV_READ | EV_WRITE);
    bufferevent_setcb(bev, read_callback, NULL, NULL, ctx); // 注册读取回调

    // 设置DNS解析
    evutil_make_socket_nonblocking(fd);
    evutil_addrinfo(&addr, "www.example.com", EVUTIL_DEFAULT_TIMEOUT, evdns_base, &res);
    evdns_base_set_reuse_port(evdns_base, 1);

    // 开始监听
    event_add(bev, NULL);
    event_loop(event_base, -1); // 阻塞直到事件循环结束

    event_base_free(base);
    evdns_base_free(evdns_base);
    return 0;
}

在这个例子中，当数据从socket接收时，`read_callback`会被调用。这允许程序在不阻塞主线程的情况下处理网络I/O。一旦数据读取完成，libevent会自动清理缓冲区，并关闭连接，实现了真正的异步操作。