EPOLLET模式下事件仅触发一次，TCP epoll收发消息问题咨询

嘿，我来帮你捋清楚这个epoll客户端的问题——EPOLLOUT只触发一次其实是epoll的正常行为，咱们一步步拆解解决：

不管你用的是默认的水平触发（LT）还是边缘触发（ET）模式，epoll的EPOLLOUT事件只会在socket的可写状态发生变化时触发一次。比如连接建立成功后，socket处于可写状态，会触发一次EPOLLOUT；但如果之后你没修改事件掩码，且socket一直保持可写，它就不会再触发了。

• 读操作（recv/read）：必须放在EPOLLIN事件的处理分支里。当epoll返回EPOLLIN，说明服务端发来了数据，这时调用读函数读取。如果是ET模式，要循环读到EAGAIN才停止；LT模式下读完当前可用数据即可。
• 写操作（send/write）：别一开始就挂在EPOLLOUT里，正确的姿势是：
  1. 当你有数据要发送时，先直接调用send/write尝试发送。
  2. 如果返回EAGAIN（意味着发送缓冲区满了，暂时发不出去），再通过epoll_ctl把EPOLLOUT事件注册到该socket上。
  3. 当epoll触发EPOLLOUT时，在这个分支里继续发送剩余数据，直到发送完成或者再次遇到EAGAIN。

当然需要，要根据你的操作需求动态调整事件掩码：

• 连接成功后，初始只需要注册EPOLLIN事件就行——毕竟你首先要监听服务端发来的消息，没必要一开始就监听可写事件（不然LT模式下会一直触发EPOLLOUT，空耗CPU）。
• 当发送数据遇到EAGAIN时，调用epoll_ctl(EPOLL_CTL_MOD)，把EPOLLOUT添加到该socket的监听事件中。
• 数据全部发送完成后，再调用epoll_ctl(EPOLL_CTL_MOD)，移除EPOLLOUT事件，只保留EPOLLIN（如果还需要接收消息的话）。

#define MAX_EVENTS 10
#define BUF_SIZE 1024

int main() {
    // 省略创建socket、连接服务端的代码...
    int connfd = ...;
    int epfd = epoll_create1(0);
    struct epoll_event ev, events[MAX_EVENTS];
    
    // 连接成功后，先注册EPOLLIN事件
    ev.events = EPOLLIN;
    ev.data.fd = connfd;
    epoll_ctl(epfd, EPOLL_CTL_ADD, connfd, &ev);

    char send_buf[BUF_SIZE] = "Hello server!";
    ssize_t send_len = strlen(send_buf);
    char* send_ptr = send_buf;

    // 先尝试发送数据
    ssize_t ret = send(connfd, send_ptr, send_len, 0);
    if (ret < 0) {
        if (errno == EAGAIN) {
            // 缓冲区满了，注册EPOLLOUT等待可写
            ev.events = EPOLLIN | EPOLLOUT;
            epoll_ctl(epfd, EPOLL_CTL_MOD, connfd, &ev);
            send_ptr += ret;
            send_len -= ret;
        } else {
            perror("send failed");
            close(connfd);
            return -1;
        }
    } else {
        send_len = 0; // 发送完成
    }

    while (1) {
        int nfds = epoll_wait(epfd, events, MAX_EVENTS, -1);
        for (int i = 0; i < nfds; i++) {
            if (events[i].data.fd == connfd) {
                if (events[i].events & EPOLLIN) {
                    // 处理读事件
                    char recv_buf[BUF_SIZE];
                    ret = recv(connfd, recv_buf, BUF_SIZE, 0);
                    if (ret <= 0) {
                        printf("Connection closed or error\n");
                        close(connfd);
                        goto cleanup;
                    }
                    recv_buf[ret] = '\0';
                    printf("Received from server: %s\n", recv_buf);
                }
                if (events[i].events & EPOLLOUT) {
                    // 处理写事件
                    ret = send(connfd, send_ptr, send_len, 0);
                    if (ret < 0) {
                        if (errno == EAGAIN) {
                            // 还有数据没发，更新指针和长度，继续等EPOLLOUT
                            send_ptr += ret;
                            send_len -= ret;
                        } else {
                            perror("send failed");
                            close(connfd);
                            goto cleanup;
                        }
                    } else {
                        // 发送完成，移除EPOLLOUT事件
                        ev.events = EPOLLIN;
                        epoll_ctl(epfd, EPOLL_CTL_MOD, connfd, &ev);
                        send_len = 0;
                        send_ptr = send_buf;
                    }
                }
            }
        }
    }

cleanup:
    close(epfd);
    return 0;
}

• 如果用边缘触发（ET）模式，处理EPOLLIN和EPOLLOUT时都要循环操作直到返回EAGAIN，不然会漏掉数据或者未完成发送。
• 永远不要一开始就把EPOLLIN | EPOLLOUT都注册上，LT模式下会导致EPOLLOUT一直触发，CPU占用飙升。只有当发送遇到阻塞时才临时注册EPOLLOUT，用完就取消。

内容的提问来源于stack exchange，提问作者Maadiah