linuxsocket怎么實現(xiàn)多個客戶端連接服務器端
這篇“l(fā)inux socket怎么實現(xiàn)多個客戶端連接服務器端”文章的知識點大部分人都不太理解，所以小編給大家總結(jié)了以下內(nèi)容，內(nèi)容詳細，步驟清晰，具有一定的借鑒價值，希望大家閱讀完這篇文章能有所收獲，下面我們一起來看看這篇“l(fā)inux socket怎么實現(xiàn)多個客戶端連接服務器端”文章吧。
創(chuàng)新互聯(lián)企業(yè)建站,10余年網(wǎng)站建設經(jīng)驗，專注于網(wǎng)站建設技術(shù)，精于網(wǎng)頁設計，有多年建站和網(wǎng)站代運營經(jīng)驗，設計師為客戶打造網(wǎng)絡企業(yè)風格，提供周到的建站售前咨詢和貼心的售后服務。對于網(wǎng)站設計制作、網(wǎng)站設計中不同領(lǐng)域進行深入了解和探索，創(chuàng)新互聯(lián)在網(wǎng)站建設中充分了解客戶行業(yè)的需求，以靈動的思維在網(wǎng)頁中充分展現(xiàn)，通過對客戶行業(yè)精準市場調(diào)研，為客戶提供的解決方案。
一、引言
在實際情況中，人們往往遇到多個客戶端連接服務器端的情況。由于之前介紹的函數(shù)如connect,recv,send等都是阻塞性函數(shù)，若資源沒有充分準備好，則調(diào)用該函數(shù)的進程將進入睡眠狀態(tài)，這樣就無法處理I/O多路復用的情況了。
本文給出兩種I/O多路復用的方法：fcntl(),select()。可以看到，由于Linux中把socket當作一種特殊的文件描述符，這給用戶的處理帶來很大方便。
二、fcntl
fcntl()函數(shù)有如下特性：
1）非阻塞I/O： 可將cmd 設為F_SETFL,將lock設為O_NONBLOCK
2)信號驅(qū)動I/O：可將cmd設為F_SETFL,將lock設為O_ASYNC.
例程：
#include#include #include #include #include #include #include #include #include #include #include #include #include #include #define SERVPORT 3333 #define BACKLOG 10 #define MAX_CONNECTED_NO 10 #define MAXDATASIZE 100 int main() { struct sockaddr_in server_sockaddr,client_sockaddr; int sin_size,recvbytes,flags; int sockfd,client_fd; char buf[MAXDATASIZE]; /*創(chuàng)建socket*/ if((sockfd = socket(AF_INET,SOCK_STREAM,0))==-1){ perror("socket"); exit(1); } printf("socket success!,sockfd=%d\n",sockfd); /*設置sockaddr結(jié)構(gòu)*/ server_sockaddr.sin_family=AF_INET; server_sockaddr.sin_port=htons(SERVPORT); server_sockaddr.sin_addr.s_addr=INADDR_ANY; bzero(&(server_sockaddr.sin_zero),8); /*將本地ip地址綁定端口號*/ if(bind(sockfd,(struct sockaddr *)&server_sockaddr,sizeof(struct sockaddr))==-1){ perror("bind"); exit(1); } printf("bind success!\n"); /*監(jiān)聽*/ if(listen(sockfd,BACKLOG)==-1){ perror("listen"); exit(1); } printf("listening....\n"); /*fcntl()函數(shù)，處理多路復用I/O*/ if((flags=fcntl( sockfd, F_SETFL, 0))<0) perror("fcntl F_SETFL"); flags |= O_NONBLOCK; if(fcntl( sockfd, F_SETFL,flags)<0) perror("fcntl"); while(1){ sin_size=sizeof(struct sockaddr_in); if((client_fd=accept(sockfd,(struct sockaddr*)&client_sockaddr,&sin_size))==-1){ //服務器接受客戶端的請求，返回一個新的文件描述符 perror("accept"); exit(1); } if((recvbytes=recv(client_fd,buf,MAXDATASIZE,0))==-1){ perror("recv"); exit(1); } if(read(client_fd,buf,MAXDATASIZE)<0){ perror("read"); exit(1); } printf("received a connection :%s",buf); /*關(guān)閉連接*/ close(client_fd); exit(1); }/*while*/ }
運行該程序：
[root@localhost net]# ./fcntl socket success!,sockfd=3 bind success! listening.... accept: Resource temporarily unavailable
可以看到，當accept的資源不可用時，程序會自動返回。
若將紅色加粗代碼替換為：
if((flags=fcntl( sockfd, F_SETFL, 0))<0)
perror("fcntl F_SETFL");
flags |= O_ASYNC;
if(fcntl( sockfd, F_SETFL,flags)<0)
perror("fcntl");運行結(jié)果如下：
[root@localhost net]# ./fcntl1 socket success!,sockfd = 3 bind success! listening...
可以看到，進程一直處于等待中，直到另一相關(guān)信號驅(qū)動它為止。
三、select
#include#include #include #include #include #include #include #include #include #include #include #include #define SERVPORT 3333 #define BACKLOG 10 #define MAX_CONNECTED_NO 10 #define MAXDATASIZE 100 int main() { struct sockaddr_in server_sockaddr,client_sockaddr; int sin_size,recvbytes; fd_set readfd; fd_set writefd; int sockfd,client_fd; char buf[MAXDATASIZE]; /*創(chuàng)建socket*/ if((sockfd = socket(AF_INET,SOCK_STREAM,0))==-1){ perror("socket"); exit(1); } printf("socket success!,sockfd=%d\n",sockfd); /*設置sockaddr結(jié)構(gòu)*/ server_sockaddr.sin_family=AF_INET; server_sockaddr.sin_port=htons(SERVPORT); server_sockaddr.sin_addr.s_addr=INADDR_ANY; bzero(&(server_sockaddr.sin_zero),8); /*將本地ip地址綁定端口號*/ if(bind(sockfd,(struct sockaddr *)&server_sockaddr,sizeof(struct sockaddr))==-1){ perror("bind"); exit(1); } printf("bind success!\n"); /*監(jiān)聽*/ if(listen(sockfd,BACKLOG)==-1){ perror("listen"); exit(1); } printf("listening....\n"); /*select*/ FD_ZERO(&readfd); // 將readfd 清空 FD_SET(sockfd,&readfd); //將sockfd加入到readfd集合中 while(1){ sin_size=sizeof(struct sockaddr_in); if(select(MAX_CONNECTED_NO,&readfd,NULL,NULL,(struct timeval（FD_ISSET(sockfd,&readfd)>0){ // FD_ISSET 這個宏判斷 sockfd 是否屬于可讀的文件描述符。從 sockfd 中讀入, 輸出到標準輸出上去. if((client_fd=accept(sockfd,(struct sockaddr *)&client_sockaddr,&sin_size))==-1){ //client_sockaddr：客戶端地址 perror("accept"); exit(1); } if((recvbytes=recv(client_fd,buf,MAXDATASIZE,0))==-1){ perror("recv"); exit(1); } if(read(client_fd,buf,MAXDATASIZE)<0){ perror("read"); exit(1); } printf("received a connection :%s",buf); }/*if*/ close(client_fd); }/*select*/ }/*while*/ } 運行結(jié)果如下： [root@localhost net]# gcc select1.c -o select1 [root@localhost net]# ./select1 socket create success! bind success! listening...
以上就是關(guān)于“l(fā)inux socket怎么實現(xiàn)多個客戶端連接服務器端”這篇文章的內(nèi)容，相信大家都有了一定的了解，希望小編分享的內(nèi)容對大家有幫助，若想了解更多相關(guān)的知識內(nèi)容，請關(guān)注創(chuàng)新互聯(lián)行業(yè)資訊頻道。
本文標題：linuxsocket怎么實現(xiàn)多個客戶端連接服務器端
文章出自：http://m.jiaotiyi.com/article/pcpcid.html