EPOLLET必须搭配非阻塞fd使用,且需循环read/write/accept直到EAGAIN/EWOULDBLOCK,否则会漏事件;新fd须显式设非阻塞并注册EPOLLET;EPOLLONESHOT需手动MOD恢复。

EPOLLET 必须搭配非阻塞 fd 使用
边缘触发模式下,epoll_wait 只在 fd 状态**从无就绪变为有就绪**时通知一次。如果应用没一次性读完所有可用数据,后续再调用 epoll_wait 就不会再次触发——除非新数据到达。这意味着你必须确保每次 read 或 write 都能处理“数据突发”,而阻塞 fd 在 read 无数据时会挂起,直接卡死事件循环。
实操上,必须在 epoll_ctl 添加 fd 前,用 fcntl 设置 O_NONBLOCK:
int flags = fcntl(fd, F_GETFL, 0); fcntl(fd, F_SETFL, flags | O_NONBLOCK);
- 漏掉这步是 EPOLLET 下最常见崩溃/卡顿原因
- 即使服务器只处理短连接,也要设;TCP 连接建立后默认仍是阻塞的
- UDP socket 同样适用,
recvfrom也需循环读直到EAGAIN/EWOULDBLOCK
EPOLLET 的 read 循环必须读到 EAGAIN
使用 EPOLLET 时,不能像水平触发那样读一次就收手。必须持续 read 直到返回 -1 且 errno == EAGAIN(或 EWOULDBLOCK),才算本次就绪彻底处理完毕。
典型错误写法:
// ❌ 错误:只读一次,残留数据再也收不到通知 ssize_t n = read(fd, buf, sizeof(buf)); if (n > 0) handle_data(buf, n);
正确写法:
// ✅ 正确:循环读,直到 EAGAIN
while (1) {
ssize_t n = read(fd, buf, sizeof(buf));
if (n > 0) {
handle_data(buf, n);
} else if (n == 0) {
close_connection(fd); // 对端关闭
break;
} else {
if (errno == EAGAIN || errno == EWOULDBLOCK) break;
else { /* 处理真实错误,如 ECONNRESET */ }
break;
}
}
- Linux 下
EAGAIN和EWOULDBLOCK值相同,但语义不同,建议都判断 - 如果
read返回 0,说明对端已close,不是临时无数据 - 写操作(
write)同理:要循环写直到全部发出或遇到EAGAIN
EPOLLET 下 accept 必须循环调用直到 EAGAIN
监听 socket 触发可读,往往意味着有多个新连接排队等待 accept。EPOLLET 模式下只通知一次,不循环 accept 就会漏掉后续连接请求,且这些连接不会再次触发事件。
Linux 安全审计工具,检查 SSH 配置、开放/监听端口、防火墙规则(ufw/iptables/nftables)、失败登录尝试、sudoers 权限...
正确处理方式:
while (1) {
int client_fd = accept(listen_fd, nullptr, nullptr);
if (client_fd >= 0) {
set_nonblocking(client_fd);
add_to_epoll(epoll_fd, client_fd, EPOLLIN | EPOLLET);
} else {
if (errno == EAGAIN || errno == EWOULDBLOCK) break;
else if (errno == EMFILE || errno == ENFILE) {
// 资源耗尽,需降级或告警
} else {
// 其他错误,如 EINTR 可重试,ECONNABORTED 可忽略
}
break;
}
}
- 不要假设每次
accept只成功一次;内核 backlog 队列可能积压多个连接 - 新
client_fd也必须设为非阻塞,并显式带上EPOLLET标志 - 忽略
ECONNABORTED是安全的(连接被对端中止),但别忽略EMFILE
EPOLLET 的事件注册和修改要小心 EPOLLONESHOT
EPOLLONESHOT 和 EPOLLET 经常一起用,但它会禁用 fd 后续所有事件,除非你主动用 epoll_ctl(EPOLL_CTL_MOD) 重新启用。很多人忘了这步,导致连接“静默失联”。
例如,一个连接既要读又要写,但你想避免读写混杂干扰逻辑:
// 注册时启用 EPOLLONESHOT + EPOLLET struct epoll_event ev; ev.events = EPOLLIN | EPOLLET | EPOLLONESHOT; ev.data.fd = fd; epoll_ctl(epoll_fd, EPOLL_CTL_ADD, fd, &ev);
处理完读事件后,若还需继续监听读,必须手动恢复:
// 处理完 read 后,重新启用读事件 ev.events = EPOLLIN | EPOLLET | EPOLLONESHOT; epoll_ctl(epoll_fd, EPOLL_CTL_MOD, fd, &ev);
-
EPOLLONESHOT不是“自动重置”,它是一次性开关 - 如果同时需要读写,建议拆成两个独立事件注册,或用
EPOLLIN | EPOLLOUT并自己控制读写时机 -
EPOLLONESHOT主要用于多线程分发场景,单线程通常不需要
边缘触发的真正难点不在设置标志,而在状态完整性保障:每次就绪必须彻底消费,否则数据就沉底了。很多人调试时发现“偶尔丢包”或“连接卡住”,八成是某个 read 或 accept 没循环到 EAGAIN。
C++免费学习笔记(深入):立即使用
在学习笔记中,你将探索 C++ 的入门与实战技巧!










