I/O多路復用中select指的是什麼
select是用于监视多个文件描述符状态的变化的。即用来监视文件描述符读/写/异常状态是否就绪。
函数原型：int select(int nfds,fd_set *readfds,fd_set *writefds,fd_set *exceptfds,struct timeval *timeout);
select的几大缺点：
（1）每次调用select，都需要把fd集合从用户态拷贝到内核态，这个开销在fd很多时会很大
（2）同时每次调用select都需要在内核遍历传递进来的所有fd，这个开销在fd很多时也很大
（3）select支持的文件描述符数量太小了
1 #include<stdio.h>
2 #include<string.h>
3 #include<stdlib.h>
4 #include<unistd.h>
5 #include<sys/select.h>
6
7 int main()
8 {
9 int std_in = 0;
10 // int std_out = 1;
11 fd_set reads;
12 // fd_set writes;
13 //int max_nums = std_out;
14 int max_nums = std_in;
15 FD_ZERO(&reads);
16 // FD_ZERO(&writes);
17 FD_SET(std_in,&reads);
18 // FD_SET(std_out,&writes);
19 struct timeval _timeout = {5,0};
20 int done = 0;
21 while(!done)
22 {
23 _timeout.tv_sec = 5;
24 _timeout.tv_usec = 0;
25 //switch(select(max_nums+1,&reads,&writes,NULL,&_timeout))
26 switch(select(max_nums+1,&reads,NULL,NULL,&_timeout))
27 {
28 case -1:
29 perror("select");
30 break;
31 case 0:
32 printf("timeout...\n");
33 break;
34 default://success
35 {
36 if(FD_ISSET(std_in,&reads))
37 {//read
38 char buf[1024];
39 memset(buf,'\0',sizeof(buf));
40 ssize_t size = read(std_in,buf,sizeof(buf)-1);
41 if(size<0)
42 {
43 perror("read");
44 exit(1);
45 }
46 if(strncmp(buf,"quit",4)==0)
47 {
48 done =1;
49 continue;
50 }
51 printf("echo: %s",buf);
52
53 }
54 // if(FD_ISSET(std_out,&writes))
55 // {//writes
56 // char buf[1024];
57 // while(1)
58 // {
59 // memset(buf,'\0',sizeof(buf));
60 // strcpy(buf,"hello world");
61 //write(1,buf,sizeof(buf)-1);
62 // printf("%s\n",buf);
63 // }
64 // }
65 break;
66 }
67 }
68 }
69 return 0;
70 }
[fbl@localhost select]$ ./select
hello
echo: hello
hi
echo: hi
nihao
echo: nihao
ahhau
echo: ahhau
quit
[fbl@localhost select]$ 1 #include<stdio.h>
2 #include<string.h>
3 #include<stdlib.h>
4 #include<unistd.h>
5 #include<sys/socket.h>
6 #include<sys/select.h>
7 #include<sys/types.h>
8 #include<netinet/in.h>
9 #include<arpa/inet.h>
10 #include<assert.h>
11
12 #define _BACKLOG_ 5
13 int fd[64];
14 void usage(char *_port)
15 {
16 printf("%s,[ip],[port]\n",_port);
17 }
18 int startup(char *ip,int port)
19 {
20 assert(ip);
21 int sock = socket(AF_INET,SOCK_STREAM,0);
22 if(sock<0)
23 {
24 perror("socket");
25 exit(1);
26 }
27 struct sockaddr_in local;
28 local.sin_family = AF_INET;
29 local.sin_port = htons(port);
30 local.sin_addr.s_addr = inet_addr(ip);
31 if(bind(sock,(struct sockaddr*)&local,sizeof(local))<0)
32 {
33 perror("bind");
34 exit(2);
35 }
36 if(listen(sock,_BACKLOG_)<0)
37 {
38 perror("listen");
39 exit(3);
40 }
41 return sock;
42
43
44 }
45 int main(int argc,char *argv[])
46 {
47 if(argc!=3)
48 {
49 usage(argv[0]);
50 return 1;
51 }
52 int port = atoi(argv[2]);
53 char *ip = argv[1];
54 int listen_sock = startup(ip,port);
55 int new_sock = -1;
56 struct sockaddr_in client;
57 socklen_t len = sizeof(client);
58 fd_set reads;
59 fd_set writes;
60 int max_nums;
61 struct timeval _timeout = {5,0};
62 int done = 0;
63 int i =0;
64 int fd_nums = sizeof(fd)/sizeof(fd[0]);
65 for(;i<fd_nums;++i)
66 {
67 fd[i]=-1;
68 }
69 fd[0] = listen_sock;
70 while(!done)
71 {
72 _timeout.tv_sec = 5;
73 _timeout.tv_usec = 0;
74 FD_ZERO(&reads);
75 FD_ZERO(&writes);
76 for(i=0;i<fd_nums;++i)
77 {
78 if(fd[i]>0)
79 {
80 FD_SET(fd[i],&reads);
81 if(fd[i]>max_nums)
82 {
83 max_nums = fd[i];
84 }
85
86 }
87 }
88 switch(select(max_nums+1,&reads,&writes,NULL,&_timeout))
89 {
90 case -1:
91 perror("select");
92 break;
93 case 0:
94 printf("timeout...\n");
95 break;
96 default:
97 {
98
99 for(i=0;i<fd_nums;++i)
100 {
101 if(fd[i]==listen_sock && FD_ISSET(fd[i],&reads))
102 {
103 new_sock = accept(listen_sock,(struct sockaddr*) &client,&len);
104 if(new_sock<0)
105 {
106 perror("accept");
107 continue;
108 }
109 for(i=0;i<fd_nums;++i)
110 {
111 if(fd[i]==-1)
112 {
113 fd[i]=new_sock;
114 }
115 }
116
117 }
118 else if(fd[i]>0 && FD_ISSET(fd[i],&reads))
119 {
120 char buf[1024];
121 memset(buf,'\0',sizeof(buf));
122 ssize_t size = read(new_sock,buf,sizeof(buf)-1);
123 if(size<0)
124 {
125 perror("read");
126 exit(4);
127 }
128 else if(size==0)
129 {
130 printf("client close...\n");
131 close(fd[i]);
132 fd[i]=-1;
133 }
134 else
135 {
136 buf[size]='\0';
137 }
138 printf("client:%s\n",buf);
139 }
140 else
141 {}
142 }
143
144 break;
145 }
146
147 }
148 }
149 return 0;
150 }
1 #include<stdio.h>
2 #include<string.h>
3 #include<stdlib.h>
4 #include<unistd.h>
5 #include<sys/socket.h>
6 #include<sys/select.h>
7 #include<sys/types.h>
8 #include<netinet/in.h>
9 #include<arpa/inet.h>
10 void usage(char *_port)
11 {
12 printf("%s,[ip],[port]\n",_port);
13 }
14 int main(int argc,char *argv[])
15 {
16 if(argc!=3)
17 {
18 usage(argv[0]);
19 return 1;
20 }
21 int port = atoi(argv[2]);
22 char *ip = argv[1];
23 int sock = socket(AF_INET,SOCK_STREAM,0);
24 if(sock<0)
25 {
26 perror("socket");
27 exit(1);
28 }
29 struct sockaddr_in remote;
30 remote.sin_family = AF_INET;
31 remote.sin_port = htons(port);
32 remote.sin_addr.s_addr = inet_addr(ip);
33 int ret = connect(sock,(struct sockaddr*)&remote,sizeof(remote));
34 if(ret<0)
35 {
36 perror("connect");
37 exit(1);
38 }
39 char buf[1024];
40 while(1)
41 {
42
43 memset(buf,'\0',sizeof(buf));
44 printf("please say:");
45 scanf("%s",buf);
46 ssize_t size = write(sock,buf,sizeof(buf)-1);
47 if(size<0)
48 {
49 perror("write");
50 exit(2);
51 }
52 else if(size ==0)
53 {}
54 else
55 {
56 printf("client : %s\n",buf);
57 }
58 }
59 return 0;
60 }
[fbl@localhost select_socket]$ ./server 192.168.1.106 8080
timeout...
client:hello
client:hi
client:huowo
client close...
client:
read: Bad file descriptor
[fbl@localhost select_socket]$
[fbl@localhost select_socket]$ ./client 192.168.1.106 8080
please say:hello
client : hello
please say:hi
client : hi
please say:huowo
client : huowo
please say:^C
[fbl@localhost select_socket]$以上是I/O多路復用中select指的是什麼的詳細內容。更多資訊請關注PHP中文網其他相關文章！
熱AI工具
Undresser.AI Undress
人工智慧驅動的應用程序，用於創建逼真的裸體照片
AI Clothes Remover
用於從照片中去除衣服的線上人工智慧工具。
Undress AI Tool
免費脫衣圖片
Clothoff.io
AI脫衣器
Video Face Swap
使用我們完全免費的人工智慧換臉工具，輕鬆在任何影片中換臉！
熱門文章
熱工具
記事本++7.3.1
好用且免費的程式碼編輯器
SublimeText3漢化版
中文版，非常好用
禪工作室 13.0.1
強大的PHP整合開發環境
Dreamweaver CS6
視覺化網頁開發工具
SublimeText3 Mac版
神級程式碼編輯軟體(SublimeText3)
jquery如何隱藏select元素
Aug 15, 2023 pm 01:56 PM
jquery隱藏select元素的方法：1、hide()方法，在HTML頁面中引入jQuery庫，可以使用不同選擇器來隱藏select元素，ID選擇器將selectId替換為你實際使用的select元素的ID；2、 css()方法，使用ID選擇器選擇需要隱藏的select元素，使用css()方法將display屬性設為none，並將selectId替換為select元素的ID。
使用golang進行Select Channels Go並發式程式設計的非同步處理方法
Sep 28, 2023 pm 05:27 PM
使用golang進行SelectChannelsGo並發式程式設計的非同步處理方法引言：並發式程式設計是現代軟體開發中的重要領域，它可以有效地提高應用程式的效能和回應能力。在Go語言中，使用Channels和Select語句可以簡單而有效率地實現並發程式設計。本文將介紹如何使用golang進行SelectChannelsGo並發式程式設計的非同步處理方法，並提供具體的
jQuery中如何實作select元素的改變事件綁定
Feb 23, 2024 pm 01:12 PM
jQuery是一個受歡迎的JavaScript函式庫，可以用來簡化DOM操作、事件處理、動畫效果等。在web開發中，常常會遇到需要對select元素進行改變事件綁定的情況。本文將介紹如何使用jQuery實作對select元素改變事件的綁定，並提供具體的程式碼範例。首先，我們需要使用標籤來建立一個包含選項的下拉式選單：
linux要用select的原因是什麼
May 19, 2023 pm 03:07 PM
因為select可以讓開發者同時等待多個檔案緩衝區，可減少IO等待的時間，能夠提高進程的IO效率。 select()函數是IO多路復用的函數，允許程式監視多個檔案描述符，等待所監視的一個或多個檔案描述符變成「準備好」的狀態；所謂的」準備好「狀態是指：檔案描述子不再是阻塞狀態，可以用於某類IO操作了，包括可讀，可寫，發生異常三種。 select是一個電腦函數，位於頭檔#include。此函數用於監視文件描述符的變化情況－讀寫或是異常。 1.select函數介紹select函數是IO多工的函
mysql的select語法怎麼使用
Jun 01, 2023 pm 07:37 PM
1.SQL語句中的關鍵字對大小寫不敏感，SELECT等效於SELECT，FROM等效於from。 2.從users表中選擇所有列的，可以用符號*代替列的名稱。語法--這是註解--從FEOM指定的[表中],查詢出[所有的]資料.*表示[所有列]SELECT*FROM--透過從FROM從指定的[表中],查詢出指定列名稱(字段)的資料SELECT列名稱FROM表名稱實例--注意:多個列之間,使用英文的逗號來分隔selectusername,passwordfrom
透過golang實現Select Channels Go並發式程式設計的效能優化
Sep 27, 2023 pm 01:09 PM
透過golang實現SelectChannelsGo並發式程式設計的效能優化在Go語言中，使用goroutine和channel實現並發程式設計是非常常見的。而在處理多個channel的情況下，我們通常會使用select語句來進行多重化。但是，在大規模並發的情況下，使用select語句可能會導致效能下降。在本文中，我們將介紹一些透過golang實作select
使用golang實現可靠性和穩健性的Select Channels Go並發式編程
Sep 28, 2023 pm 05:37 PM
使用Golang實現可靠性和穩健性的SelectChannelsGo並發式程式設計引言：在現代軟體開發中，並發性已經成為了一個非常重要的主題。使用並發程式設計可以使得程式更有反應性、更有效率地利用運算資源，並且能夠更好地處理大規模的平行運算任務。 Golang是一種非常強大的並發程式語言，它透過go協程和channel機制，提供了一種簡單而有效的方式來實現並發程式設計
如何使用golang進行Select Channels Go並發式編程
Sep 27, 2023 pm 09:07 PM
如何使用golang進行SelectChannelsGo並發式程式設計Go語言是一種非常適合進行並發程式設計的語言，其中的通道（Channel）和Select語句是實現並發的兩個重要要素。本文將介紹如何使用golang的SelectChannels進行並發編程，並提供具體的程式碼範例。一、通道（Channel）的概念通道是用來在goroutine之間進行通訊和數
