1.使用select函數實現IO多路復用
使用select函數實現IO多路復用的服務器：
#include<stdio.h>
#include<head.h>
#include<netinet/in.h>
#include<sys/select.h>
#include<arpa/inet.h>
#define PROT 1112
#define IP "192.168.125.232"
int main(int argc, const char *argv[])
{//創建流式套接字int sfd=socket(AF_INET,SOCK_STREAM,0);if(sfd<0){ ERR_MSG("socket");return -1; } printf("sfd=%d\n",sfd);//設置允許端口被快速復用int reuse=1;if(setsockopt(sfd,SOL_SOCKET,SO_REUSEADDR,&reuse,sizeof(reuse))<0){ ERR_MSG("setsockopt");return -1; } printf("允許端口快速復用成功\n");//綁定服務器的IP和端口--->必須綁定struct sockaddr_in sin;sin.sin_family = AF_INET;//必須填AF_INETsin.sin_port = htons(PROT);//端口號：1024~49151sin.sin_addr.s_addr = inet_addr(IP);//本機IPif(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))<0){ ERR_MSG("bind");return -1; } printf("綁定成功\n");//將套接字設置為被動監聽狀態if(listen(sfd,128)<0){ ERR_MSG("listen");return -1; } printf("被動監聽狀態設置成功\n");//創建一個讀集合fd_set readfds,tempfds;//fd_set本質是一個結構體，成員是一個long類型的數組//集合目的是為了存儲讓內核監測的文件描述符，不初始化有可能隨機到有效的但不需要監測的文件描述符//需要將集合初始化為無意義的文件描述符FD_ZERO(&readfds);FD_ZERO(&tempfds);//將需要的文件描述符添加到讀集合中FD_SET(0,&readfds);FD_SET(sfd,&readfds);int s_res=-1;int nfd=-1;int maxfd=sfd;char buf[128]="";ssize_t res=0;struct sockaddr_in cin;//存儲客戶端地址信息socklen_t addrlen = sizeof(cin);struct sockaddr_in saveCin[1024];while(1){ tempfds = readfds;//調用io多路復用函數 select()s_res = select(maxfd+1,&tempfds,NULL,NULL,NULL);if(s_res < 0){ERR_MSG("select");return -1; }else if(0 == s_res){printf("timeout...\n");break;}printf("__%d__\n",__LINE__);//能運行到當前位置，代表集合中有文件描述符準備就緒//此時集合中路會只剩下觸發事件的文件描述符//例如：//當0號文件描述符觸發事件，則集合中只剩下0//當sfd文件描述符觸發事件，則集合中只剩下sfd//當0和sfd同時觸發，集合中剩下0和sfd//判斷哪個文件描述符準備就緒，走對應處理函數//判斷集合中剩下哪個文件描述符，代表哪個文件描述符準備就緒//判斷nfd是否在集合中,若不在集合中則走recv函數for(int i=0;i<=maxfd;i++){if(FD_ISSET(i,&tempfds)==0)//判斷i是否在集合中，不在進入下一個循環continue;if(0 == i){printf("觸發鍵盤輸入事件\n");fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1]=0;printf(": %s\n",buf);}else if(sfd == i){printf("觸發客戶端連接事件\n");nfd=accept(sfd,(struct sockaddr*)&cin,&addrlen);if(nfd<0){ERR_MSG("accept");return -1; }printf("[%s:%d]nfd=%d,客戶端連接成功\n",inet_ntoa(cin.sin_addr),ntohs(cin.sin_port),nfd);saveCin[nfd]=cin;//將nfd添加到集合中FD_SET(nfd,&readfds);//更新maxfdmaxfd = maxfd>nfd ? maxfd : nfd; }else{printf("客戶端交互\n");//接收數據bzero(buf,sizeof(buf));res=recv(i,buf,sizeof(buf),0);if(res<0){ERR_MSG("recv");return -1; }else if(0==res){printf("[%s:%d]nfd=%d 客戶端下線\n",inet_ntoa(saveCin[i].sin_addr),ntohs(saveCin[i].sin_port),i);//關閉下線客戶端的文件描述符close(i);//將下線客戶端的文件描述符從集合中刪除FD_CLR(i,&readfds);//更新maxfd//從目前記錄的最大fd開始判斷是否在集合中，存在為最大，//不存在往前開始判斷前一個在不在，直到判斷到在的為最大while(FD_ISSET(maxfd,&readfds)==0&&maxfd-->=0);/* int j=maxfd; for(;j>=0;j--){if(FD_ISSET(maxfd,&readfds))break;maxfd=j;}*/continue;}printf("nfd=%d : %s\n",i,buf);//發送數據strcat(buf,"*_*");if(send(nfd,buf,sizeof(buf),0)<0){ERR_MSG("send");return -1; }printf("發送成功\n");}}} //關閉所有文件描述符close(sfd);return 0;
} 使用select函數實現IO多路復用的客戶端：
#include<stdio.h>
#include<head.h>
#include<netinet/in.h>
#include<arpa/inet.h>
#include<sys/select.h>
#define PROT 1112//服務器綁定的端口
#define IP "192.168.125.232"//服務器綁定的IP端口
int main(int argc, const char *argv[])
{//創建流式套接字int cfd=socket(AF_INET,SOCK_STREAM,0);if(cfd<0){ ERR_MSG("socket");return -1; } printf("cfd=%d\n",cfd);//綁定客戶端的IP和端口--->非必須綁定//連接服務器//先填充服務器的地址信息結構體，真實地址信息結構體根據地址族制定struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PROT);//服務器綁定的端口號sin.sin_addr.s_addr = inet_addr(IP);//服務器綁定的本機IP//連接服務器if(connect(cfd,(struct sockaddr*)&sin,sizeof(sin))<0){ ERR_MSG("connect");return -1; } printf("連接服務器成功\n");char buf[128]="";ssize_t res=0;int s_res=-1;//創建讀集合fd_set readfds,tempfds;FD_ZERO(&readfds);FD_ZERO(&tempfds);FD_SET(0,&readfds);FD_SET(cfd,&readfds);while(1){ tempfds=readfds;s_res=select(cfd+1,&tempfds,NULL,NULL,NULL);if(s_res<0){ERR_MSG("select");return -1; }else if(0==s_res){printf("time out...\n");break;}printf("__%d__\n",__LINE__);//能運行到這代表集合中有文件描述符準備就緒//判斷哪個文件描述符準備就緒，運行對應函數if(FD_ISSET(0,&tempfds)){printf("觸發鍵盤輸入事件\n");bzero(buf,sizeof(buf));fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1]=0;//發送數據if(send(cfd,buf,sizeof(buf),0)<0){ERR_MSG("send");return -1; }printf("發送成功\n");}else if(FD_ISSET(cfd,&tempfds)){printf("觸發服務器交互\n");bzero(buf,sizeof(buf));//接收數據res=recv(cfd,buf,sizeof(buf),0);if(res<0){ ERR_MSG("recv");return -1; }else if(0==res){printf("[%s:%d]cfd=%d 服務器掉線\n",IP,PROT,cfd);break;}printf("[%s:%d]cfd=%d : %s\n",IP,PROT,cfd,buf);}} //關閉所有文件描述符close(cfd);return 0;
}
?使用poll函數實現IO多路復用的客戶端：
#include<stdio.h>
#include<head.h>
#include<poll.h>
#define PROT 1112//服務器綁定的端口
#define IP "192.168.125.232"//服務器綁定的IP端口
int main(int argc, const char *argv[])
{//創建流式套接字int cfd=socket(AF_INET,SOCK_STREAM,0);if(cfd<0){ERR_MSG("socket");return -1;}printf("cfd=%d\n",cfd);//綁定客戶端的IP和端口--->非必須綁定//連接服務器//先填充服務器的地址信息結構體，真實地址信息結構體根據地址族制定struct sockaddr_in sin;sin.sin_family = AF_INET;sin.sin_port = htons(PROT);//服務器綁定的端口號sin.sin_addr.s_addr = inet_addr(IP);//服務器綁定的本機IP//連接服務器if(connect(cfd,(struct sockaddr*)&sin,sizeof(sin))<0){ERR_MSG("connect");return -1;} printf("連接服務器成功\n");char buf[128]="";ssize_t res=0;int p_res=-1;//定義集合struct pollfd fds[2];//將需要監測的文件描述符添加到集合fds[0].fd=0;//制定監測0號文件描述符fds[0].events=POLLIN;fds[1].fd=cfd;fds[1].events=POLLIN;while(1){p_res=poll(fds,2,-1);if(p_res<0){ERR_MSG("poll");return -1;}else if(0==p_res){printf("time out...\n");break;}//能運行到這代表集合中有文件描述符準備就緒//判斷哪個文件描述符準備就緒，運行對應處理函數//判斷集合中的每個文件描述符中是否有pollin//從revents中將代表pollin的那一位單獨提取出來，判斷是1還是0if((fds[0].revents&POLLIN)!=0){printf("觸發鍵盤輸入事件\n");bzero(buf,sizeof(buf));fgets(buf,sizeof(buf),stdin);buf[strlen(buf)-1]=0;//發送數據if(send(cfd,buf,sizeof(buf),0)<0){ERR_MSG("send");return -1;}printf("發送成功\n");}if(fds[1].revents&POLLIN){printf("觸發服務器交互\n");bzero(buf,sizeof(buf));//接收數據res=recv(cfd,buf,sizeof(buf),0);if(res<0){ERR_MSG("recv");return -1;}else if(0==res){printf("[%s:%d]cfd=%d 服務器掉線\n",IP,PROT,cfd);break;}printf("[%s:%d]cfd=%d : %s\n",IP,PROT,cfd,buf);}}//關閉所有文件描述符close(cfd);return 0;
}
)
 】- 智能硬件設備開發)
)
