1. 引言在Linux網(wǎng)絡(luò)編程中IO模型決定了程序如何與內(nèi)核進(jìn)行數(shù)據(jù)交互而多路復(fù)用技術(shù)則是高并發(fā)服務(wù)器的核心基礎(chǔ)。本文將從IO模型的基本概念出發(fā)深入講解阻塞IO、非阻塞IO、IO多路復(fù)用、信號驅(qū)動(dòng)IO和異步IO五種模型并重點(diǎn)剖析select、poll、epoll三種多路復(fù)用函數(shù)的原理、用法與區(qū)別配合具體代碼示例幫助讀者徹底理解。2. 基本概念2.1 用戶空間與內(nèi)核空間操作系統(tǒng)為了安全將內(nèi)存劃分為用戶空間和內(nèi)核空間。用戶程序運(yùn)行在用戶空間不能直接訪問硬件和內(nèi)核數(shù)據(jù)結(jié)構(gòu)所有IO操作都必須通過系統(tǒng)調(diào)用進(jìn)入內(nèi)核空間完成。因此一次完整的IO操作通常分為兩個(gè)階段等待數(shù)據(jù)就緒內(nèi)核等待數(shù)據(jù)從網(wǎng)卡、磁盤等設(shè)備到達(dá)。數(shù)據(jù)拷貝將數(shù)據(jù)從內(nèi)核緩沖區(qū)拷貝到用戶緩沖區(qū)。不同的IO模型區(qū)別就在于這兩個(gè)階段中程序是否阻塞、以及由誰等待。2.2 文件描述符在Linux中一切皆文件。socket、管道、普通文件等都以文件描述符File Descriptor簡稱fd表示它是一個(gè)非負(fù)整數(shù)。多路復(fù)用函數(shù)的核心工作就是同時(shí)監(jiān)聽多個(gè)fd上的事件。3. 五種IO模型3.1 阻塞IOBlocking IO阻塞IO是最常見的模型。當(dāng)用戶進(jìn)程調(diào)用recvfrom等系統(tǒng)調(diào)用后進(jìn)程會(huì)一直阻塞直到內(nèi)核數(shù)據(jù)準(zhǔn)備好并完成數(shù)據(jù)拷貝才返回結(jié)果。// 阻塞IO示例 int sockfd socket(AF_INET, SOCK_STREAM, 0); char buf[1024]; // 進(jìn)程在此阻塞直到有數(shù)據(jù)到達(dá)并拷貝完成 ssize_t n recv(sockfd, buf, sizeof(buf), 0); if (n 0) { printf(收到數(shù)據(jù): %s\n, buf); }阻塞IO的優(yōu)點(diǎn)是編程簡單缺點(diǎn)是當(dāng)需要同時(shí)處理多個(gè)連接時(shí)一個(gè)線程只能服務(wù)一個(gè)連接必須為每個(gè)連接創(chuàng)建線程導(dǎo)致資源消耗巨大。3.2 非阻塞IONon-blocking IO非阻塞IO下用戶進(jìn)程發(fā)起recvfrom調(diào)用后如果內(nèi)核數(shù)據(jù)尚未準(zhǔn)備好會(huì)立即返回EWOULDBLOCK錯(cuò)誤而不會(huì)阻塞進(jìn)程。進(jìn)程需要不斷輪詢檢查數(shù)據(jù)是否就緒這種方式稱為忙等待。// 非阻塞IO示例 int flags fcntl(sockfd, F_GETFL, 0); fcntl(sockfd, F_SETFL, flags | O_NONBLOCK); // 設(shè)置為非阻塞 char buf[1024]; while (1) { ssize_t n recv(sockfd, buf, sizeof(buf), 0); if (n 0) { printf(收到數(shù)據(jù): %s\n, buf); break; } else if (errno EWOULDBLOCK) { // 數(shù)據(jù)未就緒繼續(xù)輪詢 usleep(1000); } else { perror(recv); break; } }非阻塞IO避免了線程阻塞但輪詢會(huì)消耗大量CPU時(shí)間實(shí)際應(yīng)用中很少單獨(dú)使用通常與多路復(fù)用結(jié)合。3.3 IO多路復(fù)用IO MultiplexingIO多路復(fù)用通過select、poll、epoll等系統(tǒng)調(diào)用讓一個(gè)進(jìn)程同時(shí)監(jiān)聽多個(gè)fd。當(dāng)其中任意一個(gè)fd就緒時(shí)內(nèi)核通知進(jìn)程進(jìn)程再對就緒的fd進(jìn)行讀寫。這是本文的重點(diǎn)將在第4節(jié)詳細(xì)展開。3.4 信號驅(qū)動(dòng)IOSignal-driven IO信號驅(qū)動(dòng)IO中進(jìn)程先通過sigaction系統(tǒng)調(diào)用注冊SIGIO信號處理函數(shù)然后繼續(xù)執(zhí)行其他任務(wù)。當(dāng)內(nèi)核數(shù)據(jù)準(zhǔn)備好時(shí)發(fā)送SIGIO信號通知進(jìn)程進(jìn)程在信號處理函數(shù)中調(diào)用recvfrom讀取數(shù)據(jù)。// 信號驅(qū)動(dòng)IO示例簡化 void sigio_handler(int sig) { char buf[1024]; ssize_t n recv(sockfd, buf, sizeof(buf), 0); if (n 0) { printf(收到數(shù)據(jù): %s\n, buf); } } int main() { signal(SIGIO, sigio_handler); fcntl(sockfd, F_SETOWN, getpid()); // 設(shè)置socket歸屬進(jìn)程 int flags fcntl(sockfd, F_GETFL, 0); fcntl(sockfd, F_SETFL, flags | O_ASYNC); // 開啟異步通知 // 主循環(huán)繼續(xù)做其他事情 while (1) { sleep(1); } }信號驅(qū)動(dòng)IO在數(shù)據(jù)準(zhǔn)備階段不阻塞進(jìn)程但數(shù)據(jù)拷貝階段仍然阻塞且信號處理邏輯復(fù)雜實(shí)際使用較少。3.5 異步IOAsynchronous IO異步IO是理論上的理想模型。進(jìn)程發(fā)起aio_read調(diào)用后立即返回內(nèi)核負(fù)責(zé)等待數(shù)據(jù)并完成數(shù)據(jù)拷貝整個(gè)過程完成后通過信號或回調(diào)通知進(jìn)程。進(jìn)程在等待期間完全不被阻塞。// 異步IO示例使用POSIX AIO簡化 struct aiocb cb; cb.aio_fildes sockfd; cb.aio_buf buf; cb.aio_nbytes sizeof(buf); cb.aio_sigevent.sigev_notify SIGEV_SIGNAL; cb.aio_sigevent.sigev_signo SIGIO; aio_read(cb); // 立即返回內(nèi)核后臺完成整個(gè)IO // 進(jìn)程繼續(xù)執(zhí)行其他任務(wù)數(shù)據(jù)就緒后通過信號通知Linux的glibc對POSIX AIO支持有限真正的異步IO通常使用io_uring等高級接口。異步IO編程復(fù)雜度最高但性能潛力最大。3.6 五種模型對比IO模型等待數(shù)據(jù)階段數(shù)據(jù)拷貝階段并發(fā)處理能力編程復(fù)雜度阻塞IO阻塞阻塞低一線程一連接低非阻塞IO輪詢阻塞中需配合多路復(fù)用中IO多路復(fù)用阻塞在select/poll/epoll阻塞高單線程多連接中信號驅(qū)動(dòng)IO不阻塞信號通知阻塞中高異步IO不阻塞不阻塞高高4. IO多路復(fù)用詳解4.1 為什么需要多路復(fù)用阻塞IO無法高效處理大量并發(fā)連接非阻塞IO的忙等待又浪費(fèi)CPU。IO多路復(fù)用讓一個(gè)線程同時(shí)監(jiān)聽成百上千個(gè)fd只有就緒的fd才會(huì)被處理既避免了線程開銷又避免了無意義的輪詢是構(gòu)建高并發(fā)服務(wù)器的核心手段。4.2 select函數(shù)select是最早出現(xiàn)的多路復(fù)用函數(shù)原型如下#include sys/select.h int select(int nfds, fd_set *readfds, fd_set *writefds, fd_set *exceptfds, struct timeval *timeout);參數(shù)說明nfds所有監(jiān)聽fd中的最大值加1用于告訴內(nèi)核需要檢查的fd范圍。readfds監(jiān)聽可讀事件的fd集合傳入時(shí)是用戶關(guān)心的fd返回時(shí)內(nèi)核標(biāo)記哪些fd可讀。writefds監(jiān)聽可寫事件的fd集合。exceptfds監(jiān)聽異常事件的fd集合。timeout超時(shí)時(shí)間NULL表示永久阻塞0表示立即返回非阻塞輪詢。fd_set是一個(gè)位圖結(jié)構(gòu)通過以下宏操作FD_ZERO(fd_set *set); // 清空集合 FD_SET(int fd, fd_set *set); // 將fd加入集合 FD_CLR(int fd, fd_set *set); // 將fd從集合移除 FD_ISSET(int fd, fd_set *set); // 判斷fd是否在集合中就緒select完整示例#include stdio.h #include sys/select.h #include sys/socket.h #include netinet/in.h #include string.h #include unistd.h int main() { // 1. 創(chuàng)建監(jiān)聽socket int listenfd socket(AF_INET, SOCK_STREAM, 0); struct sockaddr_in addr; memset(addr, 0, sizeof(addr)); addr.sin_family AF_INET; addr.sin_port htons(8888); addr.sin_addr.s_addr htonl(INADDR_ANY); bind(listenfd, (struct sockaddr *)addr, sizeof(addr)); listen(listenfd, 128); // 2. 初始化fd集合readfds用于select調(diào)用allfds保存所有需要監(jiān)聽的fd fd_set readfds, allfds; int maxfd listenfd; // 記錄當(dāng)前最大fdselect需要用它計(jì)算檢查范圍 int clients[1024] {0}; // 記錄所有客戶端fd int client_count 0; FD_ZERO(allfds); // 清空集合 FD_SET(listenfd, allfds); // 將監(jiān)聽fd加入集合 while (1) { readfds allfds; // 每次循環(huán)都要重新賦值因?yàn)閟elect會(huì)修改集合 struct timeval tv {5, 0}; // 5秒超時(shí) int ret select(maxfd 1, readfds, NULL, NULL, tv); if (ret -1) { perror(select); break; } else if (ret 0) { printf(超時(shí)無事件\n); continue; } // 3. 檢查監(jiān)聽fd是否可讀有新連接到來 if (FD_ISSET(listenfd, readfds)) { int connfd accept(listenfd, NULL, NULL); if (connfd 0) { clients[client_count] connfd; // 保存新客戶端fd FD_SET(connfd, allfds); // 加入監(jiān)聽集合 if (connfd maxfd) maxfd connfd; // 更新最大fd printf(新連接: %d\n, connfd); } } // 4. 遍歷所有客戶端fd檢查是否有數(shù)據(jù)可讀 char buf[1024]; for (int i 0; i client_count; i) { int fd clients[i]; if (fd 0 FD_ISSET(fd, readfds)) { // 該fd就緒可讀 ssize_t n recv(fd, buf, sizeof(buf), 0); if (n 0) { // 連接關(guān)閉或出錯(cuò)清理該fd close(fd); FD_CLR(fd, allfds); clients[i] 0; printf(連接 %d 關(guān)閉\n, fd); } else { buf[n] \0; printf(來自 %d: %s\n, fd, buf); send(fd, buf, n, 0); // 回顯給客戶端 } } } } close(listenfd); return 0; }select的缺點(diǎn)fd數(shù)量受限fd_set位圖大小由FD_SETSIZE決定通常為1024無法支持更多連接。效率隨fd數(shù)量線性下降每次調(diào)用都需要將整個(gè)fd集合從用戶態(tài)拷貝到內(nèi)核態(tài)內(nèi)核也要線性掃描所有fd。需要重新設(shè)置集合select會(huì)修改傳入的fd_set每次循環(huán)都必須重新賦值。不知道具體哪個(gè)fd就緒返回后需要遍歷所有fd用FD_ISSET逐個(gè)判斷。4.3 poll函數(shù)poll解決了select的fd數(shù)量限制問題使用pollfd數(shù)組代替位圖不再受FD_SETSIZE限制。原型如下#include poll.h // pollfd結(jié)構(gòu)體描述一個(gè)要監(jiān)聽的fd及其關(guān)心的事件 struct pollfd { int fd; // 要監(jiān)聽的fd short events; // 關(guān)心的事件輸入由用戶設(shè)置 short revents; // 實(shí)際發(fā)生的事件輸出由內(nèi)核填寫 }; // poll函數(shù)同時(shí)監(jiān)聽多個(gè)fd上的事件 // fds: pollfd數(shù)組首地址 // nfds: 數(shù)組長度要監(jiān)聽的fd個(gè)數(shù) // timeout: 超時(shí)時(shí)間毫秒-1表示永久阻塞0表示立即返回 int poll(struct pollfd *fds, nfds_t nfds, int timeout);常用事件標(biāo)志POLLIN可讀事件。POLLOUT可寫事件。POLLERR錯(cuò)誤事件。POLLHUP掛起對端關(guān)閉。poll完整示例#include stdio.h #include poll.h #include sys/socket.h #include netinet/in.h #include string.h #include unistd.h #define MAX_CLIENTS 2048 // 最大客戶端數(shù)量 int main() { // 1. 創(chuàng)建監(jiān)聽socket int listenfd socket(AF_INET, SOCK_STREAM, 0); struct sockaddr_in addr; memset(addr, 0, sizeof(addr)); addr.sin_family AF_INET; addr.sin_port htons(8888); addr.sin_addr.s_addr htonl(INADDR_ANY); bind(listenfd, (struct sockaddr *)addr, sizeof(addr)); listen(listenfd, 128); // 2. 初始化pollfd數(shù)組 struct pollfd fds[MAX_CLIENTS]; int nfds 1; // 當(dāng)前監(jiān)聽的fd個(gè)數(shù)初始只有監(jiān)聽socket fds[0].fd listenfd; // 第一個(gè)元素監(jiān)聽listenfd fds[0].events POLLIN; // 關(guān)心可讀事件新連接到來 while (1) { // 3. 調(diào)用poll等待事件5秒超時(shí) int ret poll(fds, nfds, 5000); if (ret -1) { perror(poll); break; } else if (ret 0) { printf(超時(shí)無事件\n); continue; } // 4. 檢查監(jiān)聽socket是否有新連接fds[0]的revents被內(nèi)核填充 if (fds[0].revents POLLIN) { int connfd accept(listenfd, NULL, NULL); if (connfd 0 nfds MAX_CLIENTS) { // 將新客戶端fd加入pollfd數(shù)組 fds[nfds].fd connfd; fds[nfds].events POLLIN; // 關(guān)心該fd的可讀事件 nfds; // 監(jiān)聽數(shù)量加1 printf(新連接: %d\n, connfd); } } // 5. 遍歷所有客戶端fd檢查是否有數(shù)據(jù)可讀 char buf[1024]; for (int i 1; i nfds; i) { // 通過revents判斷該fd是否就緒可讀 if (fds[i].revents POLLIN) { ssize_t n recv(fds[i].fd, buf, sizeof(buf), 0); if (n 0) { // 連接關(guān)閉或出錯(cuò)關(guān)閉fd并從數(shù)組中移除 close(fds[i].fd); // 用最后一個(gè)fd填補(bǔ)空缺避免數(shù)組空洞 fds[i] fds[nfds - 1]; nfds--; // 監(jiān)聽數(shù)量減1 i--; // 回退索引繼續(xù)檢查填補(bǔ)過來的fd printf(連接關(guān)閉\n); } else { buf[n] \0; printf(收到: %s\n, buf); send(fds[i].fd, buf, n, 0); // 回顯給客戶端 } } } } close(listenfd); return 0; }poll相比select的改進(jìn)無fd數(shù)量限制使用數(shù)組只受內(nèi)存限制。事件與就緒分離events和revents分開不需要每次重新設(shè)置。poll的缺點(diǎn)效率問題依舊每次調(diào)用仍需將整個(gè)fd數(shù)組從用戶態(tài)拷貝到內(nèi)核態(tài)內(nèi)核線性掃描所有fd。不知道具體哪個(gè)fd就緒仍需遍歷整個(gè)數(shù)組檢查revents。4.4 epoll函數(shù)epoll是Linux特有的高效多路復(fù)用機(jī)制專為處理大量fd而設(shè)計(jì)。它解決了select和poll的兩個(gè)核心痛點(diǎn)每次調(diào)用都要全量拷貝fd集合、以及內(nèi)核需要線性掃描所有fd。epoll通過事件驅(qū)動(dòng)和內(nèi)核維護(hù)就緒鏈表的方式實(shí)現(xiàn)了接近O(1)的復(fù)雜度是構(gòu)建高并發(fā)服務(wù)器的首選方案。epoll由三個(gè)系統(tǒng)調(diào)用組成分工明確#include sys/epoll.h // 1. 創(chuàng)建epoll實(shí)例返回一個(gè)文件描述符epfd // size參數(shù)在Linux 2.6.8之后已不再使用但必須大于0 int epoll_create(int size); // 2. 控制epoll實(shí)例注冊/修改/刪除要監(jiān)聽的fd // epfd: epoll_create返回的實(shí)例fd // op: EPOLL_CTL_ADD添加、EPOLL_CTL_MOD修改、EPOLL_CTL_DEL刪除 // fd: 要操作的fd // event: 描述要監(jiān)聽的事件類型 int epoll_ctl(int epfd, int op, int fd, struct epoll_event *event); // 3. 等待事件發(fā)生返回就緒的fd數(shù)量 // epfd: epoll實(shí)例fd // events: 輸出參數(shù)內(nèi)核將就緒的事件填入該數(shù)組 // maxevents: events數(shù)組容量必須大于0 // timeout: 超時(shí)時(shí)間毫秒-1表示永久阻塞 int epoll_wait(int epfd, struct epoll_event *events, int maxevents, int timeout);epoll_event結(jié)構(gòu)體定義如下// epoll_event結(jié)構(gòu)體描述一個(gè)fd上關(guān)心的事件及攜帶的用戶數(shù)據(jù) struct epoll_event { uint32_t events; // 感興趣的事件輸入或就緒的事件輸出 epoll_data_t data; // 用戶數(shù)據(jù)通常存放fd或指針 }; // epoll_data聯(lián)合體用于存放用戶自定義數(shù)據(jù) typedef union epoll_data { void *ptr; // 指向任意用戶數(shù)據(jù) int fd; // 文件描述符 uint32_t u32; uint64_t u64; } epoll_data_t;常用事件標(biāo)志EPOLLIN可讀事件對端有數(shù)據(jù)到達(dá)或連接關(guān)閉。EPOLLOUT可寫事件發(fā)送緩沖區(qū)有空間。EPOLLERR錯(cuò)誤事件通常無需手動(dòng)設(shè)置內(nèi)核自動(dòng)監(jiān)聽。EPOLLHUP掛起事件對端關(guān)閉連接。EPOLLET邊緣觸發(fā)Edge Triggered模式默認(rèn)是水平觸發(fā)Level Triggered。epoll完整服務(wù)器示例包含LT和ET兩種觸發(fā)模式的對比注釋#include stdio.h #include sys/epoll.h #include sys/socket.h #include netinet/in.h #include string.h #include unistd.h #include fcntl.h #include errno.h #define MAX_EVENTS 1024 // epoll_wait一次最多返回的就緒事件數(shù) #define MAX_BUF 1024 // 接收緩沖區(qū)大小 // 將fd設(shè)置為非阻塞模式ET模式必須配合非阻塞IO使用 int set_nonblocking(int fd) { int flags fcntl(fd, F_GETFL, 0); // 獲取當(dāng)前fd狀態(tài)標(biāo)志 return fcntl(fd, F_SETFL, flags | O_NONBLOCK); // 追加非阻塞標(biāo)志 } int main() { // 1. 創(chuàng)建監(jiān)聽socket int listenfd socket(AF_INET, SOCK_STREAM, 0); struct sockaddr_in addr; memset(addr, 0, sizeof(addr)); addr.sin_family AF_INET; addr.sin_port htons(8888); addr.sin_addr.s_addr htonl(INADDR_ANY); bind(listenfd, (struct sockaddr *)addr, sizeof(addr)); listen(listenfd, 128); set_nonblocking(listenfd); // 監(jiān)聽socket也設(shè)為非阻塞配合ET模式 // 2. 創(chuàng)建epoll實(shí)例 int epfd epoll_create(1); // size參數(shù)已廢棄傳大于0即可 struct epoll_event ev, events[MAX_EVENTS]; ev.events EPOLLIN; // 水平觸發(fā)LT默認(rèn)模式 // ev.events EPOLLIN | EPOLLET; // 邊緣觸發(fā)ET改為這行即可切換 ev.data.fd listenfd; // 將listenfd存入data事件返回時(shí)通過data.fd識別 epoll_ctl(epfd, EPOLL_CTL_ADD, listenfd, ev); // 注冊監(jiān)聽socket while (1) { // 3. 等待事件永久阻塞timeout-1 int n epoll_wait(epfd, events, MAX_EVENTS, -1); if (n -1) { perror(epoll_wait); break; } // 4. 遍歷所有就緒的事件 for (int i 0; i n; i) { int fd events[i].data.fd; // 取出就緒的fd // 處理新連接 if (fd listenfd) { // 循環(huán)accept直到EAGAINET模式下必須一次性處理完所有連接 while (1) { int connfd accept(listenfd, NULL, NULL); if (connfd -1) { // EAGAIN表示沒有更多待處理的連接 if (errno EAGAIN || errno EWOULDBLOCK) break; perror(accept); break; } set_nonblocking(connfd); // 新連接也設(shè)為非阻塞 ev.events EPOLLIN; // LT模式 // ev.events EPOLLIN | EPOLLET; // ET模式 ev.data.fd connfd; // 保存客戶端fd epoll_ctl(epfd, EPOLL_CTL_ADD, connfd, ev); // 注冊到epoll printf(新連接: %d\n, connfd); } continue; } // 處理客戶端數(shù)據(jù) char buf[MAX_BUF]; ssize_t n recv(fd, buf, sizeof(buf), 0); if (n 0) { // 連接關(guān)閉或出錯(cuò) close(fd); epoll_ctl(epfd, EPOLL_CTL_DEL, fd, NULL); // 從epoll中移除 printf(連接 %d 關(guān)閉\n, fd); } else { buf[n] \0; printf(來自 %d: %s\n, fd, buf); send(fd, buf, n, 0); // 回顯 // LT與ET模式的關(guān)鍵區(qū)別 // LT水平觸發(fā)只要緩沖區(qū)還有數(shù)據(jù)epoll_wait就會(huì)持續(xù)返回該fd // 即使一次沒讀完下次調(diào)用仍會(huì)通知編程簡單但可能重復(fù)喚醒。 // ET邊緣觸發(fā)只有狀態(tài)發(fā)生變化從無數(shù)據(jù)到有數(shù)據(jù)時(shí)才通知一次 // 必須一次性把數(shù)據(jù)讀完循環(huán)recv直到EAGAIN否則數(shù)據(jù)會(huì)丟失。 // 因此ET模式必須配合非阻塞IO且讀取要循環(huán)到EAGAIN為止。 // // 下面演示ET模式下必須循環(huán)讀取 // while (1) { // ssize_t m recv(fd, buf, sizeof(buf), 0); // if (m 0) { // send(fd, buf, m, 0); // } else if (m -1 errno EAGAIN) { // break; // 數(shù)據(jù)讀完退出循環(huán) // } else { // close(fd); // epoll_ctl(epfd, EPOLL_CTL_DEL, fd, NULL); // break; // } // } } } } close(listenfd); close(epfd); return 0; }epoll相比select/poll的優(yōu)勢事件驅(qū)動(dòng)無需全量掃描select/poll每次調(diào)用都要把整個(gè)fd集合從用戶態(tài)拷貝到內(nèi)核態(tài)內(nèi)核線性掃描所有fdepoll通過紅黑樹管理fd內(nèi)核只把就緒的fd放入就緒鏈表epoll_wait直接返回就緒fd復(fù)雜度接近O(1)。無fd數(shù)量限制select受FD_SETSIZE通常1024限制poll雖用數(shù)組但仍有性能瓶頸epoll的fd數(shù)量只受系統(tǒng)內(nèi)存限制可輕松支持?jǐn)?shù)十萬連接。mmap內(nèi)存映射減少拷貝epoll通過mmap在內(nèi)核和用戶空間共享一塊內(nèi)存用于傳遞就緒事件避免了select/poll每次調(diào)用都全量拷貝fd集合的開銷。支持LT和ET兩種觸發(fā)模式LT模式編程簡單ET模式配合非阻塞IO可減少重復(fù)喚醒進(jìn)一步提升性能?；卣{(diào)機(jī)制epoll為每個(gè)fd注冊回調(diào)函數(shù)當(dāng)fd就緒時(shí)內(nèi)核直接調(diào)用回調(diào)將其加入就緒鏈表而不是像select/poll那樣輪詢檢查。5. 總結(jié)本文系統(tǒng)梳理了 Linux 網(wǎng)絡(luò)編程中的五種 IO 模型并重點(diǎn)剖析了 select、poll、epoll 三種多路復(fù)用函數(shù)的原理與用法。核心要點(diǎn)如下五種 IO 模型阻塞 IO、非阻塞 IO、IO 多路復(fù)用、信號驅(qū)動(dòng) IO 和異步 IO其本質(zhì)區(qū)別在于「等待數(shù)據(jù)就緒」和「數(shù)據(jù)拷貝」兩個(gè)階段中程序是否阻塞、以及由誰等待。select最早出現(xiàn)的多路復(fù)用函數(shù)使用 fd_set 位圖受 FD_SETSIZE通常 1024限制每次調(diào)用需全量拷貝并線性掃描適合連接數(shù)較少的場景。poll用 pollfd 數(shù)組替代位圖突破了 fd 數(shù)量限制但效率問題依舊仍需全量拷貝和線性掃描。epollLinux 特有的高效方案通過紅黑樹管理 fd、就緒鏈表和回調(diào)機(jī)制實(shí)現(xiàn)接近 O(1) 的復(fù)雜度支持 LT 和 ET 兩種觸發(fā)模式是高并發(fā)服務(wù)器的首選。在實(shí)際開發(fā)中建議優(yōu)先選擇 epoll 構(gòu)建高并發(fā)服務(wù)若連接數(shù)較少或需要跨平臺兼容select 和 poll 仍是可行的選擇。理解這五種 IO 模型的內(nèi)在差異是寫出高性能網(wǎng)絡(luò)程序的重要基礎(chǔ)。