這篇文章主要介紹“Linux下select異步通訊如何實現(xiàn)”的相關知識，小編通過實際案例向大家展示操作過程，操作方法簡單快捷，實用性強，希望這篇“Linux下select異步通訊如何實現(xiàn)”文章能幫助大家解決問題。
創(chuàng)新互聯(lián)公司公司2013年成立，先為蘆溪等服務建站，蘆溪等地企業(yè)，進行企業(yè)商務咨詢服務。為蘆溪企業(yè)網站制作PC+手機+微官網三網同步一站式服務解決您的所有建站問題。
1.服務器端
/*select_server.c 2011.9.2 by yyg*/ #include#include #include #include #include #include #include #include #include #include #include #include #include #define MAXBUF 1024 int main(int argc,char **argv){ int sockfd,new_fd; socklen_t len; struct sockaddr_in my_addr,their_addr; unsigned int myport,lisnum; char buf[MAXBUF+1]; fd_set rfds; struct timeval（argv[1]){ myport = atoi(argv[1]); } else myport = 7838; if(argv[2]){ lisnum = atoi(argv[2]); } else lisnum =2; if((sockfd = socket(PF_INET,SOCK_STREAM,0))== -1){ perror("socket"); exit(1); } bzero(&my_addr,sizeof(my_addr)); my_addr.sin_family = PF_INET; my_addr.sin_port = htons(myport); if(argv[3]) my_addr.sin_addr.s_addr = INADDR_ANY; if(bind(sockfd,(struct sockaddr *)&my_addr,sizeof(struct sockaddr)) == -1){ perror("bind"); exit(1); } if(listen(sockfd, lisnum) == -1){ perror("listen"); exit(1); } while(1){ printf("\n----waiting for new connecting to start new char----\n"); len = sizeof(struct sockaddr); if((new_fd = accept(sockfd,(struct sockaddr *)&their_addr,&len)) == -1){ perror("accept"); exit(errno); } else printf("server:got connection from %s,port %d,socked %d\n",\ inet_ntoa(their_addr.sin_addr),\ ntohs(their_addr.sin_port),new_fd); /*開始處理每個新連接上的數(shù)據(jù)收發(fā)*/ //printf("\n---ready to go.now you can chatting...input enter,then you can chat---\n"); while(1){ /*把集合清空*/ FD_ZERO(&rfds); /*把標準輸入句柄0加入到集合中*/ FD_SET(0,&rfds); maxfd = 0; /*把當前連接句柄new_fd加入到集合中*/ FD_SET(new_fd,&rfds); if(new_fd > maxfd) maxfd = new_fd; /*設置最大等待時間*/ tv.tv_sec = 1; tv.tv_usec = 0; retval = select(maxfd+1,&rfds,NULL,NULL,&tv); if(retval == -1){ printf("select error!%s\n",strerror(errno)); break; } else if(retval == 0){ //printf("no message come,user no press the button,please wait...\n"); continue; } else{ if(FD_ISSET(new_fd,&rfds)){ /*連接的socket 上有消息則接收并顯示*/ bzero(buf,MAXBUF+1); /*接收對方發(fā)過來的消息，最多MAXBUF字節(jié)*/ len = recv(new_fd, buf, MAXBUF, 0); if(len > 0) printf("recv msg success:%s! %d bytes rcv.\n ",buf,len); else{ if(len < 0){ printf("recv msg fail.the errno is:%d,error info is %s.\n",errno,strerror(errno)); } else printf("quit.\n"); break; } }// FD_ISSET = sockfd情況 if(FD_ISSET(0,&rfds)){ /*用戶有輸入了，則讀取其內容并發(fā)送*/ bzero(buf, MAXBUF+1); fgets(buf, MAXBUF, stdin); if(!strncasecmp(buf, "quit", 4)){ printf("self request to quit the chating\n"); break; } /*發(fā)消息給服務器*/ len = send(new_fd, buf, strlen(buf)-1 , 0); if(len < 0){ printf("mgs:%s send fail!errno is:%d,error info is:%s\n", buf, errno, strerror(errno)); break; }else{ printf("msg: %s\t send success, send %d bytes!\n", buf, len); } }//FD_ISSET = 0 }//select 處理結束 }/*內while*/ close(new_fd); /*處理每個新連接上的數(shù)據(jù)收發(fā)結束*/ printf("would you want to chatting with another one?(no->quit)"); fflush(stdout); bzero(buf,MAXBUF+1); fgets(buf,MAXBUF,stdin); if(!strncasecmp(buf,"no",2)){ printf("quit the chatting!\n"); break; } }/*外while*/ close(sockfd); return 0; }
2.客戶端
/*select_client.c 2011.9.2 by yyg*/ #include#include #include #include #include #include #include #include #include #include #include #include #include #define MAXBUF 1024 int main(int argc,char **argv){ int sockfd,len; struct sockaddr_in dest; char buffer[MAXBUF+1]; fd_set rfds; struct timeval（argc != 3){ printf("the param style wrong!\n"); exit(0); } /*創(chuàng)建一個socket用于tcp通信*/ if((sockfd = socket(AF_INET,SOCK_STREAM,0)) < 0){ perror("socket"); exit(errno); } /*初始化服務器端(對方)的地址和端口信息*/ bzero(&dest,sizeof(dest)); dest.sin_family = AF_INET; dest.sin_port = htons(atoi(argv[2])); if(inet_aton(argv[1],(struct in_addr *)&dest.sin_addr.s_addr) == 0){ perror(argv[1]); exit(errno); } /*conect to the server*/ if(connect(sockfd,(struct sockaddr*)&dest,sizeof(dest)) !=0){ perror("connect"); exit(errno); } printf("\n---ready to chatting...---\n"); while(1){ /*把集合清空*/ FD_ZERO(&rfds); /*把標準輸入句柄0加入到集合中*/ FD_SET(0,&rfds); maxfd = 0; /*把當前連接句柄socket 加入到集合中*/ FD_SET(sockfd,&rfds); if(sockfd > maxfd) maxfd = sockfd; /*設置最大等待時間*/ tv.tv_sec = 1; tv.tv_usec = 0; /*開始等待*/ retval = select(maxfd+1,&rfds,NULL,NULL,&tv); if(retval == -1){ printf("select error,quit!\n"); break; }else if(retval == 0){ continue; }else{ if(FD_ISSET(sockfd,&rfds)){ /*連接的socket 上有消息則接收并顯示*/ bzero(buffer,MAXBUF+1); /*接收對方發(fā)過來的消息，最多MAXBUF字節(jié)*/ len = recv(sockfd, buffer, MAXBUF, 0); if(len > 0) printf("recv msg success:%s! %d bytes rcv.\n ",buffer,len); else{ if(len < 0){ printf("recv msg fail.the errno is:%d,error info is %s.\n",errno,strerror(errno)); } else printf("quit.\n"); break; } }// FD_ISSET = sockfd情況 if(FD_ISSET(0,&rfds)){ /*用戶有輸入了，則讀取其內容并發(fā)送*/ bzero(buffer, MAXBUF+1); fgets(buffer, MAXBUF, stdin); if(!strncasecmp(buffer, "quit", 4)){ printf("self request to quit the chating\n"); break; } /*發(fā)消息給服務器*/ len = send(sockfd, buffer, strlen(buffer)-1 , 0); if(len < 0){ printf("mgs:%s send fail!errno is:%d,error info is:%s\n", buffer, errno, strerror(errno)); break; }else{ printf("msg: %s\t send success, send %d bytes!\n", buffer, len); } }//FD_ISSET = 0 }//select 處理結束 }//處理聊天的while 循環(huán) /*關閉連接*/ close(sockfd); return 0; }
運行結果：
終端1：服務器端
[root@localhost net]# ./select_server 7838 ----waiting for new connecting to start new char---- server:got connection from 172.31.100.236,port 59462,socked 4 recv msg success:kfldsjfk! 8 bytes rcv. 456354 msg: 456354 send success, send 6 bytes! recv msg success:453455! 6 bytes rcv.
終端2：客戶端
[root@localhost net]# ./select_client 172.31.100.236 7838 ---ready to chatting...--- kfldsjfk msg: kfldsjfk send success, send 8 bytes! recv msg success:456354! 6 bytes rcv. 453455 msg: 453455 send success, send 6 bytes!
關于“Linux下select異步通訊如何實現(xiàn)”的內容就介紹到這里了，感謝大家的閱讀。如果想了解更多行業(yè)相關的知識，可以關注創(chuàng)新互聯(lián)行業(yè)資訊頻道，小編每天都會為大家更新不同的知識點。
重慶分公司
重慶分公司
