码迷,mamicode.com
首页 > 其他好文 > 详细

网络编程——I/O复用

时间:2018-07-08 18:06:58      阅读:179      评论:0      收藏:0      [点我收藏+]

标签:lse   读取   姓名   exce   定义   tle   网络编程   ==   include   

int select( int nfds, fd_set FAR* readfds, fd_set * writefds, fd_set * exceptfds, const struct timeval * timeout);

  nfds:是一个整数值,是指集合中所有文件描述符的范围,即所有文件描述符的最大值加1。在Windows中这个参数的值无所谓,可以设置不正确。
  readfds:(可选)指针,指向一组等待可读性检查的套接口。
  writefds:(可选)指针,指向一组等待可写性检查的套接口。
  exceptfds:(可选)指针,指向一组等待错误检查的套接口。
  timeout:select()最多等待时间,对阻塞操作则为NULL。
  如果对readfds、writefds或exceptfds中任一个组类不感兴趣,可将它置为空NULL。
在socket.h头文件中共定义了四个宏来操作描述字集。
  FD_ZERO(fd_set *fdset);将指定的文件描述符集清空,在对文件描述符集合进行设置前,必须对其进行初始化,如果不清空,由于在系统分配内存空间后,通常并不作清空处理,所以结果是不可知的。
     FD_SET(fd_set *fdset);用于在文件描述符集合中增加一个新的文件描述符。 
     FD_CLR(fd_set *fdset);用于在文件描述符集合中删除一个文件描述符。 
     FD_ISSET(int fd,fd_set *fdset);用于测试指定的文件描述符是否在该集合中。
 
 
服务端代码:(客户端基本不变)
  1 #include "common.h"
  2 
  3 struct cli_t
  4 {
  5     int cfd;
  6     struct sockaddr_in caddr;
  7     struct cli_t *next;
  8 };
  9 
 10 typedef struct stu//学生结构体
 11 {
 12     int id;
 13     char name[20];
 14     int score;
 15     struct stu *next;
 16 }Stu,*PStu;
 17 
 18 void fun(int sig)//捕捉信号
 19 {
 20     printf("连接中断\n");
 21     return;
 22 }
 23 
 24 unsigned int ListLength(PStu ptr)  //计算链表长度
 25 {
 26     unsigned int l=0;
 27     while(ptr!=NULL)
 28     {
 29         l++;
 30         ptr=ptr->next;
 31     }
 32     return l;
 33 }
 34 
 35 PStu ListSort(PStu ptr) //链表排序
 36 {
 37     PStu sorthead=NULL; 
 38     unsigned int l=ListLength(ptr);
 39     while(l>0)
 40     {      
 41         PStu p1=ptr;
 42         PStu p2=p1;
 43         int max=p1->score;
 44         while(p1!=NULL)
 45         {
 46             if(p1->score>max)
 47             {max=p1->score; p2=p1;}
 48             p1=p1->next;
 49         }
 50         PStu p3=ptr;
 51         if (p3==p2)
 52             ptr=p3->next;  
 53         else
 54         {   while(p3->next!=p2)
 55             p3=p3->next;  
 56 
 57             p3->next=p2->next;  
 58         }
 59 
 60         PStu r;  
 61         p2->next=NULL;
 62         if(sorthead==NULL)
 63             sorthead=p2;
 64         else
 65             r->next=p2;
 66 
 67         r=p2;
 68         l--;
 69     }
 70     return sorthead;
 71 }
 72 
 73 void show(PStu head)//打印链表函数
 74 {
 75     printf("学号\t姓名\t分数\n");
 76     while(head!=NULL)
 77     {
 78         printf("%d\t%s\t%d\n",head->id,head->name,head->score);
 79         head=head->next;
 80     }
 81     return ;
 82 }
 83 
 84 int read_file(int agv)//接受信息(子线程)
 85 {
 86     PStu head=NULL;
 87     Stu *ptr;
 88     PStu r;
 89     int nfd;
 90     int ret;
 91     nfd=(int)agv;//接收传参nfd 
 92 
 93     signal(SIGPIPE,fun);
 94     printf("read...\n");
 95     while(1)
 96     {
 97         ptr=malloc(sizeof(Stu));
 98         ret=read(nfd,ptr,sizeof(Stu));
 99         if(ret<0)
100         {
101             perror("read");return -1;
102         }
103         if(ret==0)
104         {
105             head=ListSort(head);
106             show(head);
107             printf("read over\n");
108             return 0;
109         }
110         if(ret>0);//把链表读出来
111         {
112             ptr->next=NULL;
113             if(head==NULL)
114             {
115                 head=ptr;
116             }
117             else
118             {
119                 r->next=ptr;
120             }
121             r=ptr;
122         }
123     }
124     return 1;
125 }
126 
127 int main()//主线程,一直工作,接收客户端
128 {
129     PStu head=NULL;
130     pthread_t pthid;
131     int ret;
132     int fd,nfd;
133     struct sockaddr_in  saddr,caddr;
134     int addr_len;
135     signal(SIGPIPE,fun);
136     fd = socket(AF_INET,SOCK_STREAM,0);
137     if(fd<0)
138     {
139         perror("socket");
140         return -1;
141     }
142     saddr.sin_family = AF_INET;
143     saddr.sin_port   = htons(9000);
144     inet_pton(AF_INET,"192.168.6.128",&saddr.sin_addr.s_addr);
145     ret = bind(fd,(struct sockaddr*)&saddr,sizeof(saddr));
146     if(ret<0)
147     {
148         perror("bind");
149         goto END;
150     }
151     ret = listen(fd,20);
152     if(ret<0)
153     {
154         perror("listen");
155         goto END;
156     }
157 
158     fd_set set,rset;//创建文件描述符集合
159     int *pfd;
160     struct cli_t *chead=NULL;
161     struct cli_t *pcli;
162     int maxfd;
163 
164     FD_ZERO(&set);//将文件描述符集清空
165     FD_SET(fd,&set);//在文件描述符集合中增加一个新的文件描述符
166     maxfd=fd;
167 
168     while(1)//循环接收多个客户端
169     {
170         rset=set;//把set的文件描述符拷贝给reset,防止set发生改变
171         printf("select...\n");
172         ret=select(maxfd+1,&rset,NULL,NULL,NULL);//对读进行操作等待(无限等待)
173         printf("select over && ret= %d\n",ret);
174 
175         if(ret<0)
176         {
177             perror("select");
178             break;
179         }
180         if(FD_ISSET(fd,&rset))//检查fd是否在文件描述符集中, select将更新这个集合,只保留符合条件的套节字在这个集合里面 
181         {
182             //接收连接
183             addr_len = sizeof(caddr);
184             printf("accept..\n");
185             nfd = accept(fd,(struct sockaddr*)&caddr,&addr_len);
186             if(nfd<0)
187             {
188                 perror("accept");
189             }
190             printf("accept over..\n");
191             //加入集合 
192             FD_SET(nfd,&set);//把nfd加入到set集合中
193             if(nfd>maxfd)
194                 maxfd=nfd;
195 
196             // 加入链表
197             pcli=malloc(sizeof(struct cli_t));
198             pcli->cfd=nfd;
199             pcli->caddr=caddr;
200             pcli->next=chead;
201             chead=pcli;
202         }
203         for(pcli=chead;pcli!=NULL;pcli=pcli->next)//循环遍历,哪个客户端准备好了(写入并传输了数据就读出数据)
204         {
205             int tfd=pcli->cfd;
206             if(!FD_ISSET(tfd,&rset))//防止客户端没写入数据时阻塞在read里面
207                 continue;
208             ret=read_file(tfd);
209             if(ret<=0)
210             {
211                 printf("read ret =0 tcp broken\n");
212                 FD_CLR(tfd,&set);//客户端读取完毕且关闭,清空集合
213             }
214         }printf("asd");
215     }
216 END:
217     close(fd);
218     return 0;
219 }

 

网络编程——I/O复用

标签:lse   读取   姓名   exce   定义   tle   网络编程   ==   include   

原文地址:https://www.cnblogs.com/it8343/p/9280642.html

(0)
(0)
   
举报
评论 一句话评论(0
登录后才能评论!
© 2014 mamicode.com 版权所有  联系我们:gaon5@hotmail.com
迷上了代码!