系統(tǒng)提供select函數(shù)來實(shí)現(xiàn)多路復(fù)用輸入/輸出模型。
成都創(chuàng)新互聯(lián)長期為上千多家客戶提供的網(wǎng)站建設(shè)服務(wù)，團(tuán)隊(duì)從業(yè)經(jīng)驗(yàn)10年，關(guān)注不同地域、不同群體，并針對不同對象提供差異化的產(chǎn)品和服務(wù)；打造開放共贏平臺，與合作伙伴共同營造健康的互聯(lián)網(wǎng)生態(tài)環(huán)境。為保亭黎族企業(yè)提供專業(yè)的
做網(wǎng)站、網(wǎng)站設(shè)計(jì)，
保亭黎族網(wǎng)站改版等技術(shù)服務(wù)。擁有十載豐富建站經(jīng)驗(yàn)和眾多成功案例,為您定制開發(fā)。
select函數(shù)讓我們的程序監(jiān)視多個(gè)文件描述符的狀態(tài)變化。程序會停在select這里等待，直到被監(jiān)視的文件描述符中有一個(gè)或多個(gè)發(fā)生了狀態(tài)變化
函數(shù)原型如下：
返回值：成功返回就緒描述符的個(gè)數(shù)，超過timeout時(shí)間且沒有任何事件發(fā)生返回0，失敗返回-1
參數(shù)解釋：
nfds： 被監(jiān)視的文件描述符中值大描述符值加1（描述符是從0開始的，描述符0、1、2...nfds-1均將被測試）
下面三個(gè)參數(shù)readset、writeset和exceptset指定我們要讓內(nèi)核測試讀、寫和異常條件的描述符。如果對某一個(gè)的條件不感興趣，就可以把它設(shè)為空指針。
readfds: 讀描述符集（所有關(guān)心讀事件的描述符被用戶添加進(jìn)來），這個(gè)參數(shù)是個(gè)輸入輸出型參數(shù)
writefds: 寫描述符集
exceptfds: 異常描述符集
struct fd_set可以理解為一個(gè)集合，這個(gè)集合中存放的是文件描述符，可通過以下四個(gè)宏進(jìn)行設(shè)置：
void FD_CLR(int fd, fd_set *fdset); //把給定的文件描述符從指定集合刪除
int FD_ISSET(int fd, fd_set *fdset); //判斷指定描述符時(shí)候被加入了指定集合中（是否可讀/可寫）
void FD_SET(int fd, fd_set *fdset); //把一個(gè)給定的文件描述符加入集合之中
void FD_ZERO(fd_set *fdset); //清空集合
timeout: 設(shè)置一段時(shí)間
（1）timeout=NULL時(shí)，當(dāng)前進(jìn)程一直等待，直到有一個(gè)描述符準(zhǔn)備好I/O(永遠(yuǎn)等下去)
（2）timeout指向timeval結(jié)構(gòu)體且時(shí)間設(shè)置不為0時(shí)，當(dāng)前進(jìn)程掛起，如果到了設(shè)定的時(shí)間（timeout）還沒有任何事件發(fā)生就返回0，進(jìn)程繼續(xù)執(zhí)行后面的代碼（等待一段固定時(shí)間）
（3）timeout指向timeval結(jié)構(gòu)體且時(shí)間設(shè)置為0時(shí)，不會等待，立即返回（根本不等待）
struct timeval{
long tv_sec; //seconds
long tv_usec; //microseconds
};
server_select.c
#include
#include
#include
#include
#include
#include
#include
#include
#include
#define BLOCK 6
int fds[64];
void usage(char * proc)
{
printf("%s [ip] [port]\n",proc);
}
int create_sock(char *port,const char * inaddr)
{
//1.
int listenfd=socket(AF_INET,SOCK_STREAM,0);
if(listenfd<-1){
perror("listenfd");
exit(1);
}
//2.
struct sockaddr_in local;
local.sin_family=AF_INET;
int _port=atoi(port);
local.sin_port=htons(_port);
local.sin_addr.s_addr=inet_addr(inaddr);
struct linger lig;
int iLen;
lig.l_onoff=1;
lig.l_linger=0;
iLen=sizeof(struct linger);
setsockopt(listenfd,SOL_SOCKET,SO_LINGER,(char *)&lig,iLen);
//3.
if(bind(listenfd,(struct sockaddr*)&local,sizeof(local))<0){
perror("bind");
exit(2);
}
//4.
if(listen(listenfd,BLOCK)<0){
perror("listen");
exit(3);
}
return listenfd;
}
int main(int argc,char* argv[])
{
if(argc!=3){
usage(argv[0]);
exit(1);
}
//create listenfd
int listen_fd=create_sock(argv[2],argv[1]);
struct sockaddr_in client;
socklen_t len=sizeof(client);
int max_fd=listen_fd;
char buf[1024];
//initialize fds[]
int fds_num=sizeof(fds)/sizeof(fds[0]);
int i=0;
for(i=0;i0){
FD_SET(fds[i],&readset);
FD_SET(fds[i],&writeset);
if(fds[i]>max_fd)
max_fd=fds[i];
}
else
break;
}
switch(select(max_fd+1,&readset,&writeset,NULL,&timeout)){
//switch(select(max_fd+1,&readset,NULL,NULL,&timeout)){
case -1:
perror("select");
break;
case 0:
printf("timeout...\n");
break;
default:
for(i=0;i0 && FD_ISSET(fds[i],&readset)){
ssize_t _size=read(fds[i],buf,sizeof(buf)-1);
if(_size<0){
perror("read");
}else if(_size==0){//client closed
printf("client shutdown...\n");
close(fds[i]);
fds[i]=-1;
continue;
}else{
buf[_size]='\0';
printf("client# %s",buf);
if(FD_ISSET(fds[i],&writeset)){
if(write(fds[i],buf,sizeof(buf)-1)<0){
perror("write");
}
}
}
}
else{
}
}
break;
}
}
return 0;
}
client_select.c
#include
#include
#include
#include
#include
#include
#include
#include
#include
void usage(char *proc)
{
printf("%s [ip] [port]\n",proc);
}
int creat_socket()
{
int fd=socket(AF_INET,SOCK_STREAM,0);
if(fd<0){
perror("socket");
exit(1);
}
return fd;
}
int main(int argc,char* argv[])
{
if(argc!=3){
usage(argv[0]);
exit(1);
}
int fd=creat_socket();
int _port=atoi(argv[2]);
struct sockaddr_in addr;
addr.sin_family=AF_INET;
addr.sin_port=htons(_port);
inet_aton(argv[1],&addr.sin_addr);
socklen_t addrlen=sizeof(addr);
if(connect(fd,(struct sockaddr*)&addr,addrlen)<0){
perror("connect");
exit(2);
}
char buf[1024];
while(1){
memset(buf,'\0',sizeof(buf));
printf("Please Enter:");
fgets(buf,sizeof(buf)-1,stdin);
if(send(fd,buf,sizeof(buf)-1,0)<0){
perror("send");
continue;
}
//回顯
ssize_t _size=recv(fd,buf,sizeof(buf)-1,0);
if(_size>0){
buf[_size]='\0';
printf("echo->%s\n",buf);
}
}
return 0;
}
運(yùn)行結(jié)果：（可把服務(wù)器端和客戶端結(jié)果對比起來看）
服務(wù)器端
客戶端
select模型的缺點(diǎn)：
1.我的機(jī)器測試
printf("fd_set=%d\n",sizeof(fd_set)); 值為128，說明能監(jiān)視的描述符的大值為128*8=1024個(gè)2.每次都要把所關(guān)心的描述符重新添加一次，即從用戶態(tài)拷貝到內(nèi)核態(tài)（因?yàn)閟elect返回時(shí)沒有發(fā)生事件的描述符將被清空），如果描述符較多的時(shí)候，開銷是很大的
3.當(dāng)select返回的時(shí)候，即使只有一個(gè)事件發(fā)生了，也要把整個(gè)集遍歷一次，同樣，如果描述符較多的時(shí)候，開銷也很大
另外有需要云服務(wù)器可以了解下創(chuàng)新互聯(lián)scvps.cn，海內(nèi)外云服務(wù)器15元起步，三天無理由+7*72小時(shí)售后在線，公司持有idc許可證，提供“云服務(wù)器、裸金屬服務(wù)器、高防服務(wù)器、香港服務(wù)器、美國服務(wù)器、虛擬主機(jī)、免備案服務(wù)器”等云主機(jī)租用服務(wù)以及企業(yè)上云的綜合解決方案，具有“安全穩(wěn)定、簡單易用、服務(wù)可用性高、性價(jià)比高”等特點(diǎn)與優(yōu)勢，專為企業(yè)上云打造定制，能夠滿足用戶豐富、多元化的應(yīng)用場景需求。
文章名稱：IO多路復(fù)用之select-創(chuàng)新互聯(lián)
轉(zhuǎn)載來于：
http://weahome.cn/article/cecjoe.html
重慶分公司
重慶分公司
