1、基本概念
io多路復用是指核心一旦發現程序指定的乙個或者多個io條件準備讀取,它就通知該程序。io多路復用適用如下場合:
(1)當客戶處理多個描述字時(一般是互動式輸入和網路套介面),必須使用i/o復用。
(2)當乙個客戶同時處理多個套介面時,而這種情況是可能的,但很少出現。
(3)如果乙個tcp伺服器既要處理監聽套介面,又要處理已連線套介面,一般也要用到i/o復用。
(4)如果乙個伺服器即要處理tcp,又要處理udp,一般要使用i/o復用。
(5)如果乙個伺服器要處理多個服務或多個協議,一般要使用i/o復用。
與多程序和多執行緒技術相比,i/o多路復用技術的最大優勢是系統開銷小,系統不必建立程序/執行緒,也不必維護這些程序/執行緒,從而大大減小了系統的開銷。
2、select函式
該函式准許程序指示核心等待多個事件中的任何乙個傳送,並只在有乙個或多個事件發生或經歷一段指定的時間後才喚醒。函式原型如下:
#include
#include
int select(int maxfdp1,fd_set *readset,fd_set *writeset,fd_set *exceptset,const struct timeval *timeout)
返回值:就緒描述符的數目,超時返回0,出錯返回-1
函式引數介紹如下:
(1)第乙個引數maxfdp1指定待測試的描述字個數,它的值是待測試的最大描述字加1(因此把該引數命名為maxfdp1),描述字0、1、2...maxfdp1-1均將被測試。
(2)中間的三個引數readset、writeset和exceptset指定我們要讓核心測試讀、寫和異常條件的描述字。如果對某乙個的條件不感興趣,就可以把它設為空指標。struct fd_set可以理解為乙個集合,這個集合中存放的是檔案描述符,可通過以下四個巨集進行設定:
void fd_zero(fd_set *fdset); //清空集合
void fd_set(int fd, fd_set *fdset); //將乙個給定的檔案描述符加入集合之中
void fd_clr(int fd, fd_set *fdset); //將乙個給定的檔案描述符從集合中刪除
int fd_isset(int fd, fd_set *fdset); // 檢查集合中指定的檔案描述符是否可以讀寫
(3)timeout告知核心等待所指定描述字中的任何乙個就緒可花多少時間。其timeval結構用於指定這段時間的秒數和微秒數。
struct timeval
35 36 static int socket_bind(const char* ip,int port)
37 46 bzero(&servaddr,sizeof(servaddr));
47 servaddr.sin_family = af_inet;
48 inet_pton(af_inet,ip,&servaddr.sin_addr);
49 servaddr.sin_port = htons(port);
50 if (bind(listenfd,(struct sockaddr*)&servaddr,sizeof(servaddr)) == -1)
51
55 return listenfd;
56 }
57 58 static void do_select(int listenfd)
59 87 //測試監聽描述符是否準備好
88 if (fd_isset(listenfd,&rset))
89
101 }
102 fprintf(stdout,"accept a new client: %s:%d\n", inet_ntoa(cliaddr.sin_addr),cliaddr.sin_port);
103 //將新的連線描述符新增到陣列中
104 for (i = 0;i maxfd ? connfd : maxfd);
121 //記錄客戶連線套接字的個數
122 maxi = (i > maxi ? i : maxi);
123 if (--nready <= 0)
124 continue;
125 }
126 //處理客戶連線
127 handle_connection(clientfds,maxi,&rset,&allset);
128 }
129 }
130
131 static void handle_connection(int *connfds,int num,fd_set *prset,fd_set *pallset)
132
152 printf("read msg is: ");
153 write(stdout_fileno,buf,n);
154 //向客戶端傳送buf
155 write(connfds[i],buf,n);
156 }
157 }
158 }客戶端程式如下:
1 #include
2 #include
3 #include
4 #include
5 #include
6 #include
7 #include
8 #include
9 #include
10 11 #define maxline 1024
12 #define ipaddress "127.0.0.1"
13 #define serv_port 8787
14 15 #define max(a,b) (a > b) ? a : b
16 17 static void handle_connection(int sockfd);
18 19 int main(int argc,char *ar**)
20 33
34 static void handle_connection(int sockfd)
35 60 write(stdout_fileno,recvline,n);
61 }
62 //測試標準輸入是否準備好
63 if (fd_isset(stdin_fileno,&rset))
64
71 write(sockfd,sendline,n);
72 }
73 }
74 }
4、程式結果啟動服務程式,執行兩個客戶程式進行測試,結果如下圖所示:
IO多路復用之select總結
1 基本概念 io多路復用是指核心一旦發現程序指定的乙個或者多個io條件準備讀取,它就通知該程序。io多路復用適用如下場合 1 當客戶處理多個描述字時 一般是互動式輸入和網路套介面 必須使用i o復用。2 當乙個客戶同時處理多個套介面時,而這種情況是可能的,但很少出現。3 如果乙個tcp伺服器既要處...
IO多路復用之select總結
io 多路復用是指核心一旦發現程序指定的乙個或者多個io條件準備讀取,它就通知該程序。io多路復用適用如下場合 1 當客戶處理多個描述字時 一般是互動式輸入和網路套介面 必須使用i o復用。2 當乙個客戶同時處理多個套介面時,而這種情況是可能的,但很少出現。3 如果乙個tcp伺服器既要處理監聽套介面...
IO多路復用之select總結
io多路復用是指核心一旦發現程序指定的乙個或者多個io條件準備讀取,它就通知該程序。io多路復用適用如下場合 1 當客戶處理多個描述字時 一般是互動式輸入和網路套介面 必須使用i o復用。2 當乙個客戶同時處理多個套介面時,而這種情況是可能的,但很少出現。3 如果乙個tcp伺服器既要處理監聽套介面,...