Linux 網絡編程---->多路復用：select實例！

好吧，我承認找了好久，網上都沒有像樣的完整的實例，然後自己參照書自己寫一個吧！

//!> server端代碼
//!>server.c

#include <stdio.h>
#include <unistd.h>
#include <stdlib.h>
#include <string.h>
#include <errno.h>
#include <netinet/in.h>
#include <sys/select.h>
#include <sys/types.h>
#include <sys/socket.h>

#define BUF_LEN 1024
#define SERV_PORT 6000
#define FD_SIZE 100
#define MAX_BACK 100

int main( int argc, char ** argv )
{
int listenfd,connfd, sockfd, maxfd, maxi, i;
int nready,client[FD_SIZE]; //!> 接收select返回值、保存客戶端套接字
int lens;
ssize_t n; //!> read字節數
fd_set rset,allset; //!> 不要理解成就只能保存一個，其實fd_set有點像封裝的數組
char buf[BUF_LEN];
socklen_t clilen;
structsockaddr_in servaddr, chiaddr;

if( (listenfd = socket( AF_INET, SOCK_STREAM, 0 ) ) == -1 )
{
printf("Create socket Error : %d\n", errno );
exit(EXIT_FAILURE );
}

//!>
//!> 下面是接口信息
bzero(&servaddr, sizeof( servaddr ) );
servaddr.sin_family = AF_INET;
servaddr.sin_addr.s_addr =htonl( INADDR_ANY);
servaddr.sin_port = htons( SERV_PORT );

//!>
//!> 綁定
if( bind(listenfd, ( struct sockaddr * )&servaddr, sizeof(servaddr ) ) == -1 )
{
printf("BindError : %d\n", errno);
exit(EXIT_FAILURE );
}

//!>
//!> 監聽
if( listen(listenfd, MAX_BACK ) == -1 )
{
printf("Listen Error : %d\n", errno );
exit(EXIT_FAILURE );
}

//!> 當前最大的感興趣的套接字fd
maxfd =listenfd; //!> 當前可通知的最大的fd
maxi =-1; //!> 僅僅是為了client數組的好處理

for( i = 0;i < FD_SIZE; i++) //!> 首先置為全-1
{
client[i] =-1; //!> 首先client的等待隊列中是沒有的，所以全部置為-1
}

FD_ZERO(&allset); //!> 先將其置為0
FD_SET(listenfd, &allset );
//!> 說明當前我對此套接字有興趣，下次select的時候通知我！

while( 1)
{
rset =allset;//!> 由於allset可能每次一個循環之後都有變化，所以每次都賦值一次
if( (nready= select( maxfd + 1, &rset, NULL, NULL, NULL )) ==-1)
{ //!> if 存在關注
printf("Select Erorr : %d\n", errno );
exit(EXIT_FAILURE );
}

if( nready<= 0) //!> if 所有的感興趣的沒有就接著回去select
{
continue;
}



if(FD_ISSET( listenfd, &rset )) //!> if 是監聽接口上的“來電”
{ //!>
//!> printf("server listen ...\n");
clilen =sizeof( chiaddr );

printf("Start doing... \n");

if( (connfd = accept( listenfd, (struct sockaddr*)&chiaddr, &clilen ) ) == -1)
{ //!> accept 返回的還是套接字
printf("Accept Error : %d\n", errno );
continue;
}


for( i = 0;i < FD_SIZE; i++) //!> 注意此處必須是循環，剛開始我認
//!> 為可以直接設置一個end_i來直接處
//!> 理,實質是不可以的！因為每個套接
{ //!> 字的退出時間是不一樣的，後面的
if(client[i] < 0) //!> 可能先退出，那麼就亂了，所以只
{ //!> 有這樣了！
client[i] =connfd; //!> 將client的請求連接保存
break;
}
}

if( i ==FD_SIZE ) //!> The last one
{
printf( "Tomany ... " );
close(connfd ); //!> if 滿了那麼就不連接你了，關閉吧
continue; //!> 返回
}
//!> listen的作用就是向數組中加入套接字！
FD_SET(connfd, &allset); //!> 說明現在對於這個連接也是感興趣的！
//!> 所以加入allset的陣容
if( connfd> maxfd) //!> 這個還是為了解決亂七八糟的數組模型
//!> 的處理
{
maxfd =connfd;
}

if( i> maxi) //!> 同上
{
maxi =i;
}
}

//!> 下面就是處理數據函數( 其實說本質的select還是串行 )
for( i = 0;i <= maxi; i++) //!> 對所有的連接請求的處理
{
if( ( sockfd= client[i] ) > 0) //!> 還是為了不規整的數組
{ //!> 也就說client數組不是連續的全正數或者-1，可能是鋸齒狀的
if(FD_ISSET( sockfd, &rset )) //!> if 當前這個數據套接字有要讀的
{
memset( buf,0, sizeof( buf )); //!> 此步重要，不要有時候出錯

n = read(sockfd, buf, BUF_LEN);
if( n< 0 )
{
printf("Error!\n");
close(sockfd ); //!> 說明在這個請求端口上出錯了！
FD_CLR(sockfd, &allset );
client[i] =-1;
continue;
}
if( n == 0)
{
printf("nodata\n");
close(sockfd ); //!> 說明在這個請求端口上讀完了！
FD_CLR(sockfd, &allset );
client[i] =-1;
continue;
}

printf("Server Recv: %s\n", buf);

if( strcmp(buf, "q" ) == 0) //!> 客戶端輸入“q”退出標志
{
close(sockfd );
FD_CLR(sockfd, &allset );
client[i] =-1;
continue;
}

printf("Server send : %s\n", buf);
write(sockfd, buf, n); //!> 讀出來的寫進去
}
}
}

}

return0;
}