epoll实现客户端群聊

首先，我们需要了解什么是epoll。epoll是Linux系统下的一种高效的事件通知机制，主要用于处理大量的连接和事件通知。与传统的select和poll模型相比，epoll具有更高的性能和更好的扩展性。

接下来，我们可以通过以下步骤实现客户端群聊：

1. 创建一个监听socket，用于接受客户端连接请求。
2. 使用epoll_create函数创建一个epoll实例，并将监听socket添加到epoll实例中。
3. 开始循环调用epoll_wait函数，等待事件发生。
4. 如果监听socket有事件发生，说明有新的客户端连接请求，我们需要接受连接，并将新的客户端socket添加到epoll实例中。
5. 如果客户端有数据到达，我们需要读取数据，并将数据广播给所有连接的客户端。

下面是一个简单的示例代码：

#include <sys/epoll.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <unistd.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>

#define MAX_EVENTS 10
#define PORT 8888

int main()
{
    int listen_fd, conn_fd, epoll_fd, nfds;
    struct sockaddr_in serv_addr, cli_addr;
    struct epoll_event ev, events[MAX_EVENTS];
    socklen_t cli_len = sizeof(cli_addr);
    char buf[1024];

    // 创建监听socket
    if ((listen_fd = socket(AF_INET, SOCK_STREAM, 0)) < 0) {
        perror("socket");
        exit(1);
    }

    // 绑定地址和端口号
    memset(&serv_addr, 0, sizeof(serv_addr));
    serv_addr.sin_family = AF_INET;
    serv_addr.sin_addr.s_addr = htonl(INADDR_ANY);
    serv_addr.sin_port = htons(PORT);
    if (bind(listen_fd, (struct sockaddr *)&serv_addr, sizeof(serv_addr)) < 0) {
        perror("bind");
        exit(1);
    }

    // 开始监听
    if (listen(listen_fd, 10) < 0) {
        perror("listen");
        exit(1);
    }

    // 创建epoll实例
    if ((epoll_fd = epoll_create(10)) < 0) {
        perror("epoll_create");
        exit(1);
    }

    // 将监听socket添加到epoll实例中
    ev.events = EPOLLIN;
    ev.data.fd = listen_fd;
    if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, listen_fd, &ev) < 0) {
        perror("epoll_ctl");
        exit(1);
    }

    while (1) {
        // 等待事件发生
        if ((nfds = epoll_wait(epoll_fd, events, MAX_EVENTS, -1)) < 0) {
            perror("epoll_wait");
            exit(1);
        }

        // 处理所有事件
        for (int i = 0; i < nfds; i++) {
            if (events[i].data.fd == listen_fd) {
                // 有新的客户端连接
                if ((conn_fd = accept(listen_fd, (struct sockaddr *)&cli_addr, &cli_len)) < 0) {
                    perror("accept");
                    exit(1);
                }

                // 将新的客户端socket添加到epoll实例中
                ev.events = EPOLLIN;
                ev.data.fd = conn_fd;
                if (epoll_ctl(epoll_fd, EPOLL_CTL_ADD, conn_fd, &ev) < 0) {
                    perror("epoll_ctl");
                    exit(1);
                }

                printf("client %s:%d connected\n", inet_ntoa(cli_addr.sin_addr), ntohs(cli_addr.sin_port));
            } else {
                // 有客户端数据到达
                int n = read(events[i].data.fd, buf, sizeof(buf));
                if (n < 0) {
                    perror("read");
                    exit(1);
                } else if (n == 0) {
                    // 客户端关闭连接
                    close(events[i].data.fd);
                    epoll_ctl(epoll_fd, EPOLL_CTL_DEL, events[i].data.fd, NULL);
                    printf("client %d closed\n", events[i].data.fd);
                } else {
                    // 广播数据给所有连接的客户端
                    for (int j = 0; j < nfds; j++) {
                        if (events[j].data.fd != listen_fd && events[j].data.fd != events[i].data.fd) {
                            write(events[j].data.fd, buf, n);
                        }
                    }
                }
            }
        }
    }

    return 0;
}

这段代码使用了epoll实现了一个简单的客户端群聊的功能。当有新的客户端连接时，我们将新的客户端socket添加到epoll实例中。当有客户端的数据到达时，我们将数据广播给所有连接的客户端。