系統(tǒng)提供select函數(shù)來實現(xiàn)多路復(fù)用輸入/輸出模型。

讓客戶滿意是我們工作的目標(biāo)，不斷超越客戶的期望值來自于我們對這個行業(yè)的熱愛。我們立志把好的技術(shù)通過有效、簡單的方式提供給客戶，將通過不懈努力成為客戶在信息化領(lǐng)域值得信任、有價值的長期合作伙伴，公司提供的服務(wù)項目有：域名注冊、網(wǎng)站空間、營銷軟件、網(wǎng)站建設(shè)、銅川網(wǎng)站維護、網(wǎng)站推廣。

select函數(shù)讓我們的程序監(jiān)視多個文件描述符的狀態(tài)變化。程序會停在select這里等待，直到被監(jiān)視的文件描述符中有一個或多個發(fā)生了狀態(tài)變化

函數(shù)原型如下：

返回值：  成功返回就緒描述符的個數(shù)，超過timeout時間且沒有任何事件發(fā)生返回0，失敗返回-1

參數(shù)解釋：

nfds：    被監(jiān)視的文件描述符中值最大描述符值加1（描述符是從0開始的，描述符0、1、2...nfds-1均將被測試）

下面三個參數(shù)readset、writeset和exceptset指定我們要讓內(nèi)核測試讀、寫和異常條件的描述符。如果對某一個的條件不感興趣，就可以把它設(shè)為空指針。

readfds: 讀描述符集（所有關(guān)心讀事件的描述符被用戶添加進來），這個參數(shù)是個輸入輸出型參數(shù)

writefds: 寫描述符集

exceptfds: 異常描述符集

struct fd_set可以理解為一個集合，這個集合中存放的是文件描述符，可通過以下四個宏進行設(shè)置：

 void FD_CLR(int fd, fd_set *fdset);   //把給定的文件描述符從指定集合刪除

 int FD_ISSET(int fd, fd_set *fdset);  //判斷指定描述符時候被加入了指定集合中（是否可讀/可寫） 

 void FD_SET(int fd, fd_set *fdset);   //把一個給定的文件描述符加入集合之中

 void FD_ZERO(fd_set *fdset);           //清空集合

timeout:  設(shè)置一段時間

        （1）timeout=NULL時，當(dāng)前進程一直等待，直到有一個描述符準(zhǔn)備好I/O(永遠等下去)

        （2）timeout指向timeval結(jié)構(gòu)體且時間設(shè)置不為0時，當(dāng)前進程掛起，如果到了設(shè)定的時間（timeout）還沒有任何事件發(fā)生就返回0，進程繼續(xù)執(zhí)行后面的代碼（等待一段固定時間）

        （3）timeout指向timeval結(jié)構(gòu)體且時間設(shè)置為0時，不會等待，立即返回（根本不等待）

                      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;
}

運行結(jié)果：（可把服務(wù)器端和客戶端結(jié)果對比起來看）

服務(wù)器端

客戶端

select模型的缺點：

1.我的機器測試

printf("fd_set=%d\n",sizeof(fd_set));  值為128，說明能監(jiān)視的描述符的最大值為128*8=1024個

2.每次都要把所關(guān)心的描述符重新添加一次，即從用戶態(tài)拷貝到內(nèi)核態(tài)（因為select返回時沒有發(fā)生事件的描述符將被清空），如果描述符較多的時候，開銷是很大的

3.當(dāng)select返回的時候，即使只有一個事件發(fā)生了，也要把整個集遍歷一次，同樣，如果描述符較多的時候，開銷也很大