标签：syn 其他 data last art out recvfrom 连接 types.h
select()，确定一个或多个套接口的状态，本函数用于确定一个或多个套接口的状态，对每一个套接口，调用者可查询它的可读性、可写性及错误状态信息，用fd_set结构来表示一组等待检查的套接口，在调用返回时，这个结构存有满足一定条件的套接口组的子集，并且select()返回满足条件的套接口的数目。有一组宏可用于对fd_set的操作，这些宏与Berkeley Unix软件中的兼容，但内部的表达是完全不同的。
|
1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
148
149
150
151
152
153
154
155
156
157
158
159
160
161
162
163
164
165
166
167
168
169
170
171
172
173
174
175
176
177
178
179
180
|
//下面是示例代码：//代码是服务器TCP模型，采用多路复用的select函数实现了循环的监听并接受客户端的功能，其中也包含了上传下载的功能*/#include<stdio.h>#include<stdlib.h>#include<unistd.h>#include<sys/socket.h>#include<string.h>#include<netinet/in.h>#include<sys/ioctl.h>#include<sys/stat.h>#include<fcntl.h>#include<sys/types.h>#include<dirent.h>int main(){ struct sockaddr_in seraddr,cliaddr; int listenfd,connfd,fd1,fd2,n,m,l,port; char user[20],buf[4096]; fd_set readfds,tmpfds;//岗哨监控集合 socklen_t addrlen; DIR *dr; struct dirent *file; printf("请输入需要设定的服务器名称:"); scanf("%s",user); printf("请输入需要设定的服务器端口:"); scanf("%d",&port); getchar(); if((listenfd=socket(AF_INET,SOCK_STREAM,0))<0) { perror("创建失败"); exit(-1); } /*开始设定服务器的参数地址类型,IP,PORT*/ memset(&seraddr,0,sizeof(seraddr));//将服务器的初值空间清空，防止转化过程有影响 seraddr.sin_family=AF_INET; seraddr.sin_port=htons(port);//将得到的本地端口转换为网络字节序 seraddr.sin_addr.s_addr=htonl(INADDR_ANY);//将得到的ip地址字符串转换为网络字节序的ip地址数值 if((bind(listenfd,(struct sockaddr*)&seraddr,sizeof(seraddr))<0)) { perror("绑定失败"); exit(-1); } printf("绑定创建\n"); if((connfd=listen(listenfd,50))<0) { perror("监听失败"); exit(-1); } printf("开始监听\n"); FD_ZERO(&readfds);//初始化文件集 FD_SET(listenfd,&readfds);//将需要监视的listenfd放入readfds集中 while(1)//循环监听 { int nread,n; tmpfds=readfds;//将监视集传递给临时的监视集中，防止后续的操作修改了监视集 if(select(FD_SETSIZE,&tmpfds,NULL,NULL,NULL)<0)//设置监视，监视tmpfds内的子fd变化,发生变化的将会被保留在tmpfds中 { perror("监视未成功"); exit(-1); } for(fd1=0;fd1<FD_SETSIZE;fd1++)//循环找在最大范围内的fd1 { if(FD_ISSET(fd1,&tmpfds))//查找是否fd在tmpfds里面 { if(fd1==listenfd)//判定fd等于监听fd，即监听fd在监视过程中出现变化被发现 { addrlen=sizeof(cliaddr); connfd=accept(listenfd,(struct sockaddr*)&cliaddr,&addrlen);//开始接收客户 FD_SET(connfd,&readfds);//将connfd加入监视集，监视接入的变化 printf("接入新的连接\n"); } else { ioctl(fd1,FIONREAD,&nread);//测试在fd中还有nread个字符需要读取 if(nread==0)//如果需要读取的数据为0,则关闭检测出来的fd1，并且从监视中移除 { close(fd1); FD_CLR(fd1,&readfds); printf("移除\n"); } else//如果可读数据不为0，则读出来 { int i; char *p=NULL,*q=NULL; n=read(fd1,buf,nread); buf[n]=0; p=buf; if((strncmp(p,"-get",4)==0)) { q=p+5; printf("客户下载文件>%s",q); if((fd2=open(q,O_RDONLY))<0) perror("打开文件错误"); while((m=read(fd2,buf,4096))>0) { write(connfd,buf,m); } bzero(buf,sizeof(buf)); close(fd1); close(fd2); FD_CLR(fd1,&readfds); } if((strncmp(p,"-up",3)==0)) { q=p+4; printf("客户上传文件%s\n",buf+4); if((fd2=open(q,O_CREAT | O_WRONLY | O_APPEND ,0666))<0) { perror("打开文件写入失败"); } while((m=read(connfd,buf,128))>0) { printf("%s",buf); write(fd2,buf,m); } bzero(buf,sizeof(buf)); close(fd1); close(fd2); FD_CLR(fd1,&readfds); } if((strncmp(p,"-ls",3)==0)) { q=p+4; printf("客户查看文件……"); if((dr=opendir(q))==NULL) perror("打开目录失败"); while((file=readdir(dr))!=NULL) { printf("%s ",file->d_name); write(connfd,file->d_name,sizeof(file->d_name)); } close(fd1); close(connfd); closedir(dr); FD_CLR(fd1,&readfds); } printf("从客户收取的信息:%s\n",buf); } } }//end if 0 }//end for 0 }//end while0 exit(0);}//end main |
标签：syn 其他 data last art out recvfrom 连接 types.h
原文地址：http://www.cnblogs.com/cyyljw/p/6889697.html
