linux select 多路复用机制
生活随笔
收集整理的這篇文章主要介紹了
linux select 多路复用机制
小編覺得挺不錯的,現在分享給大家,幫大家做個參考.
函數作用：
系統提供select函數來實現多路復用輸入/輸出模型。select系統調用是用來讓我們的程序監視多個文件句柄的狀態變化的。程序會停在select這里等待，直到被監視的文件句柄有一個或多個發生了狀態改變。關于文件句柄，其實就是一個整數，我們最熟悉的句柄是0、1、2三個，0是標準輸入，1是標準輸出，2是標準錯誤輸出。0、1、2是整數表示的，對應的FILE *結構的表示就是stdin、stdout、stderr。
函數原型：
[cpp]?view plaincopy
參數說明：
參數maxfd是需要監視的最大的文件描述符值+1；rdset,wrset,exset分別對應于需要檢測的可讀文件描述符的集合，可寫文件描述符的集 合及異常文件描述符的集合。struct timeval結構用于描述一段時間長度，如果在這個時間內，需要監視的描述符沒有事件發生則函數返回，返回值為0。
下面的宏提供了處理這三種描述詞組的方式:
FD_CLR(inr fd,fd_set* set)；用來清除描述詞組set中相關fd 的位
FD_ISSET(int fd,fd_set *set)；用來測試描述詞組set中相關fd 的位是否為真
FD_SET（int fd,fd_set*set）；用來設置描述詞組set中相關fd的位
FD_ZERO（fd_set *set）；用來清除描述詞組set的全部位
參數timeout為結構timeval，用來設置select()的等待時間，其結構定義如下：
[cpp]?view plaincopy
如果參數timeout設為：
NULL，則表示select（）沒有timeout，select將一直被阻塞，直到某個文件描述符上發生了事件。
0：僅檢測描述符集合的狀態，然后立即返回，并不等待外部事件的發生。
特定的時間值：如果在指定的時間段里沒有事件發生，select將超時返回。
函數返回值：
執行成功則返回文件描述詞狀態已改變的個數，如果返回0代表在描述詞狀態改變前已超過timeout時間，沒有返回；當有錯誤發生時則返回-1，錯誤原因存于errno，此時參數readfds，writefds，exceptfds和timeout的值變成不可預測。錯誤值可能為：
EBADF 文件描述詞為無效的或該文件已關閉
EINTR 此調用被信號所中斷
EINVAL 參數n 為負值。
ENOMEM 核心內存不足
常見的程序片段如下：
fs_set readset；
FD_ZERO(&readset);
FD_SET(fd,&readset);
select(fd+1,&readset,NULL,NULL,NULL);
if(FD_ISSET(fd,readset){……}
理解select模型：
理解select模型的關鍵在于理解fd_set,為說明方便，取fd_set長度為1字節，fd_set中的每一bit可以對應一個文件描述符fd。則1字節長的fd_set最大可以對應8個fd。
（1）執行fd_set set; FD_ZERO(&set);則set用位表示是0000,0000。
（2）若fd＝5,執行FD_SET(fd,&set);后set變為0001,0000(第5位置為1)
（3）若再加入fd＝2，fd=1,則set變為0001,0011
（4）執行select(6,&set,0,0,0)阻塞等待
（5）若fd=1,fd=2上都發生可讀事件，則select返回，此時set變為0000,0011。注意：沒有事件發生的fd=5被清空。
基于上面的討論，可以輕松得出select模型的特點：
（1)可監控的文件描述符個數取決與sizeof(fd_set)的值。我這邊服務 器上sizeof(fd_set)＝512，每bit表示一個文件描述符，則我服務器上支持的最大文件描述符是512*8=4096。據說可調，另有說雖 然可調，但調整上限受于編譯內核時的變量值。本人對調整fd_set的大小不太感興趣，參考http://www.cppblog.com?/CppExplore/archive/2008/03/21/45061.html中的模型2（1）可以有效突破select可監控的文件描述符上 限。
（2）將fd加入select監控集的同時，還要再使用一個數據結構array保存放到select監控集中的fd，一是用于再select 返回后，array作為源數據和fd_set進行FD_ISSET判斷。二是select返回后會把以前加入的但并無事件發生的fd清空，則每次開始 select前都要重新從array取得fd逐一加入（FD_ZERO最先），掃描array的同時取得fd最大值maxfd，用于select的第一個 參數。
（3）可見select模型必須在select前循環array（加fd，取maxfd），select返回后循環array（FD_ISSET判斷是否有時間發生）。
下面給一個偽碼說明基本select模型的服務器模型：
[cpp]?view plaincopy
[cpp]?view plaincopy
利用Select模型，設計的web服務器：
[cpp]?view plaincopy
1 基本原理
注：select 原理圖，摘自?IBM iSeries 信息中心。
1 數據結構與函數原型
1.1 select
- 函數原型 int select(int nfds,fd_set *readset,fd_set *writeset,fd_set* exceptset,struct timeval *timeout);
- 頭文件
- select位于： #include <sys/select.h>
- struct timeval位于： #include <sys/time.h>
- 返回值
返回對應位仍然為1的fd的總數。
- 參數
- nfds：第一個參數是：最大的文件描述符值+1；
- readset：可讀描述符集合；
- writeset：可寫描述符集合；
- exceptset：異常描述符；
- timeout：select 的監聽時長，如果這短時間內所監聽的 socket 沒有事件發生。
1.2 fd_set
1.2.1 清空描述符集合
FD_ZERO(fd_set *)1.2.2 向描述符集合添加指定描述符
FD_SET(int, fd_set *)1.2.3 從描述符集合刪除指定描述符
FD_CLR(int, fd_set *)1.2.4 檢測指定描述符是否在描述符集合中
FD_ISSET(int, fd_set *)1.2.5 描述符最大數量
#define FD_SETSIZE 10241.3 描述符集合
可讀描述符集合中可讀的描述符，為1，其他為0；可寫也類似。異常描述符集合中有異常等待處理的描述符的值為1，其他為0。
1.4 ioctl
-
函數原型：
int ioctl(int handle, int cmd,[int *argdx, int argcx]); -
頭文件：
#include <sys/ioctl.h> -
返回值：
- 0 - 成功
- 1 - 失敗
2 示例
程序各部分的解釋在注釋中。
#include <sys/socket.h> #include <string.h> #include <sys/time.h> #include <netinet/in.h> #include <sys/ioctl.h> #include <stdlib.h> #include <errno.h> #include <stdio.h> #include <unistd.h>#define TRUE 1 #define FALSE 0int main(int argc, char *argv[]) {int i, len, rc, on = TRUE;int listen_sd, new_sd = 0, max_sd;int desc_ready;char buffer[80];int close_conn, end_server = FALSE;struct sockaddr_in server_addr;struct timeval timeout;struct fd_set master_set, working_set;// Listenlisten_sd = socket(AF_INET, SOCK_STREAM, 0);if (listen_sd < 0){perror("socket() failed");exit(-1);}// Set socket optionsrc = setsockopt(listen_sd, SOL_SOCKET, SO_REUSEADDR, (char *) &on, sizeof(on));if (rc < 0){perror("setsockopt() failed");close(listen_sd);exit(-1);}// Set IO controlrc = ioctl(listen_sd, FIONBIO, (char *) &on);if (rc < 0){perror("ioctl() failed");close(listen_sd);exit(-1);}// Bindmemset(&server_addr, 0, sizeof(server_addr));server_addr.sin_family = AF_INET;server_addr.sin_addr.s_addr = htonl(INADDR_ANY);server_addr.sin_port = htons(atoi(argv[1]));rc = bind(listen_sd, (struct sockaddr *) &server_addr, sizeof(server_addr));if (rc < 0){perror("bind() failed\n");close(listen_sd);exit(-1);}// Listenrc = listen(listen_sd, 32);if (rc < 0){perror("listen() failed\n");close(listen_sd);exit(-1);}// Intialize sd setFD_ZERO(&master_set);max_sd = listen_sd;FD_SET(listen_sd, &master_set);timeout.tv_sec = 3 * 60;timeout.tv_usec = 0;// Startdo{// Copy master_set into working_setmemcpy(&working_set, &master_set, sizeof(master_set));printf("Waiting on select()...\n");rc = select(max_sd + 1, &working_set, NULL, NULL, &timeout);if (rc < 0){perror(" select() failed\n");break;}if (rc == 0){printf(" select() timed out. End program.\n");break;}desc_ready = rc; // number of sds ready in working_set// Check each sd in working_setfor (i = 0; i <= max_sd && desc_ready > 0; ++i){// Check to see if this sd is readyif (FD_ISSET(i, &working_set)){--desc_ready;// Check to see if this is the listening sdif (i == listen_sd){printf(" Listeing socket is readable\n");do{// Acceptnew_sd = accept(listen_sd, NULL, NULL);// Nothing to be acceptedif (new_sd < 0){// All have been acceptedif (errno != EWOULDBLOCK){perror(" accept() failed\n");end_server = TRUE;}break;}// Insert new_sd into master_setprintf(" New incoming connection - %d\n", new_sd);FD_SET(new_sd, &master_set);if (new_sd > max_sd){max_sd = new_sd;}}while (new_sd != -1);}// This is not the listening sdelse{close_conn = FALSE;printf(" Descriptor %d is avaliable\n", i);do{rc = recv(i, buffer, sizeof(buffer), 0);// Receive data on sd "i", until failure occursif (rc < 0){// Normal failureif (errno != EWOULDBLOCK){perror(" recv() failed\n");close_conn = TRUE;}break;}// The connection has been closed by the clientif (rc == 0){printf(" Connection closed\n");close_conn = TRUE;break;}/* Receiving data succeeded and echo it backthe to client */len = rc;printf(" %d bytes received\n", len);rc = send(i, buffer, len, 0);if (rc < 0){perror(" send() failed");close_conn = TRUE;break;}}while (TRUE);// If unknown failure occuredif (close_conn){// Close the sd and remove it from master_setclose(i);FD_CLR(i, &master_set);// If this is the max sdif (i == max_sd){// Find the max sd in master_set nowwhile (FD_ISSET(max_sd, &master_set) == FALSE){--max_sd;}} // End of if (i == max_sd)} // End of if (close_conn)}}}}while (end_server == FALSE);/* Close each sd in master_set */for (i = 0; i < max_sd; ++i){if (FD_ISSET(i, &master_set)){close(i);}}return 0; }總結
以上是生活随笔為你收集整理的linux select 多路复用机制的全部內容，希望文章能夠幫你解決所遇到的問題。
- 上一篇： Linux中kill，pkill，kil
- 下一篇： Linux服务器文件描述符最大值修改