libevent网络库监听unix域套接字接收消息并进行消息处理示例

Libevent是一个高效、跨平台的事件驱动网络I/O库，它允许你在单个线程中处理多个网络连接。对于Unix域套接字（socketpair），你可以创建一个监听套接字，然后当有新的连接请求时，libevent会触发相应的回调函数。

以下是一个简单的示例，演示了如何使用libevent监听Unix域套接字，并在收到消息时进行处理：

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

// Unix域套接字路径
#define UNIX_SOCKET_PATH "/tmp/my_socket"

struct event_base *base;
struct bufferevent *bev;

void handle_event(bufferevent * bev, short events) {
    if (events & BEV_EVENT_CONNECTED) {
        printf("Accepted connection on %s\n", UNIX_SOCKET_PATH);
        // 创建新缓冲事件，用于读取数据
        struct bufferevent_new_connection *conn = bufferevent_newConnection(bev, read_callback, NULL);
        bufferevent_setwatermark(conn, EV_READ, 0, BUFSIZ); // 设置读取水位
    } else if (events & BEV_EVENT_EOF) {
        printf("Client disconnected from %s\n", UNIX_SOCKET_PATH);
        // 关闭连接
        bufferevent_free(bev);
    }
}

int read_callback(bufferevent * bev, char *buf, int len, void *ptr) {
    printf("Received message: %.*s\n", len, buf);
    // 这里可以处理收到的消息
    return len;
}

int main() {
    base = event_base_new();
    struct sockaddr_un addr;
    memset(&addr, 0, sizeof(addr));
    addr.sun_family = AF_UNIX;
    strncpy(addr.sun_path, UNIX_SOCKET_PATH, sizeof(addr.sun_path));

    // 创建监听套接字
    int listen_fd = socket(AF_UNIX, SOCK_STREAM, 0);
    bind(listen_fd, (struct sockaddr*)&addr, sizeof(addr));
    listen(listen_fd, 5);

    bev = bufferevent_socket_new(base, listen_fd, BEV_OPT_CLOSE_ON_FREE);
    bufferevent_setcb(bev, handle_event, NULL, NULL, NULL);
    bufferevent_enable(bev, EV_READ | EV_PERSIST); // 持久监听

    // 启动主循环
    event_base_dispatch(base);

    event_base_free(base);
    return 0;
}

在这个例子中，我们首先初始化event_base，然后创建一个新的Unix域套接字，设置好监听路径。然后创建了一个bufferevent，绑定到这个套接字上，设置了读取事件处理器。当有新的连接请求或接收到数据时，handle_event会被调用。

注意，这只是一个基本示例，实际应用中你需要考虑错误处理和客户端连接的管理。运行此程序后，你可以通过另一个进程通过相同的Unix域名与之通信。