Linux select epoll網路模型

select,epoll網路模型經常在面試中出現,epoll是對poll的優化,是linux下最優秀的網路模型

epoll優點:

# 相對select,沒有最大併發數限制 /proc/sys/file-max

# 資料傳遞(使用者空間跟核心空間)通過共享記憶體(mmap)方式

# epoll_wait 直接返回被觸發的fd對應的一塊buffer,不需要遍歷所有的fd

一.linux select模型

流程:1. 宣告陣列fd_a,新增多個socket client fd

2. 監聽埠

3. 將sock_fd 和 陣列fd不為0描述符放入select將檢查的fd_set中

4. 處理 fdsr可以接收資料的連線; 如是sock_fd,新增新連線至fd_a;  

詳見:

// select_tcp_server.c   

#include #include #include #include #include #include #include #include #include #define myport 1234 // the port users will be connecting to 
#define backlog 5 // how many pending connections queue will hold 
#define buf_size 200 
int fd_a[backlog]; // accepted connection fd 
int conn_amount; // current connection amount 
void showclient() 
printf("\n\n"); 
} 
int main(void) 
if (setsockopt(sock_fd, sol_socket, so_reuseaddr, &yes, sizeof(int)) == -1) 
server_addr.sin_family = af_inet; // host byte order 
server_addr.sin_port = htons(myport); // short, network byte order 
server_addr.sin_addr.s_addr = inaddr_any; // automatically fill with my ip 
memset(server_addr.sin_zero, '\0', sizeof(server_addr.sin_zero)); 
if (bind(sock_fd, (struct sockaddr *)&server_addr, sizeof(server_addr)) == -1) 
if (listen(sock_fd, backlog) == -1) 
printf("listen port %d\n", myport); 
fd_set fdsr; 
int maxsock; 
struct timeval tv; 
conn_amount = 0; 
sin_size = sizeof(client_addr); 
maxsock = sock_fd; 
while (1) 
} ret = select(maxsock + 1, &fdsr, null, null, &tv); 
if (ret < 0) else if (ret == 0) 
// check every fd in the set 
for (i = 0; i < conn_amount; i++) else 
} } 
// check whether a new connection comes 
if (fd_isset(sock_fd, &fdsr)) 
// add to fd queue 
if (conn_amount < backlog) 
else 
} showclient(); 
} // close other connections 
for (i = 0; i < backlog; i++) 
} exit(0); 
}

//epoll_tcp_server.c

#include #include #include #include #include #include #include #include #include #include #include #include #define buf_size 1024
#define serv_port 1234
#define epoll_run_timeout -1
#define epoll_size 10000
#define str_welcome "welcome to sechat! you id is:client #%d"
#define str_message "client #%d>>%s"
#define str_noone_connected "noone connected to server except you"
#define chk(eval) if(eval<0)
#define chk2(res,eval) if((res = eval)<0)
using namespace std;
listclients_list;
// 設定非阻塞
int setnoblocking(int sockfd)
// 處理訊息
int handlemsg(int client)
else
sprintf(message,str_message,client,buf);
list::iterator it;
for(it = clients_list.begin(); it!=clients_list.end();it++)
}} return len;
}int main(int argc,char **argv)
printf("test passed:.2fs\n",(double)(clock()-tstart)/clocks_per_sec);
printf("total server connections:%d\n",epoll_size);
return 0;
}

Android網路程式設計selector模式

下面上 socketchannel ch null socketaddress addr new inetsocketaddress 172.16 3.194,11904 ch socketchannel.open addr selector selector selector.open ch.co...

Linux Apache和Nginx網路模型詳解

程序阻塞和掛起的定義 阻塞是由於程序所需資源得不到滿足，並會最終導致程序被掛起 程序掛起的原因並不一定是由於阻塞，也有可能是時間片得不到滿足，掛起狀態是程序從記憶體排程到外存中的一種狀態，若在就緒態時，從記憶體調出到外存中，就是就緒掛起態，若在阻塞態時，從記憶體調出到外存中，就轉換成了阻塞掛起態 n...

框架篇 linux網路I O Reactor模型

網路i o，可以理解為網路上的資料流。通常我們會基於socket與遠端建立一條tcp或者udp通道，然後進行讀寫。單個socket時，使用乙個執行緒即可高效處理 然而如果是10k個socket連線，或者更多，我們如何做到高效能處理？程序 執行緒 的阻塞 檔案描述符 linux訊號處理 在零拷貝機制篇...