• 10.1select并发服务器以及客户端

    服务器：

    1. #include
    2.  
    3. //do-while只是为了不让花括号单独存在，并不循环
    4. #define ERR_MSG(msg) do{\
    5. 	fprintf(stderr,"%d:",__LINE__);\
    6. 	perror(msg);\
    7. }while(0);
    8.  
    9. #define PORT 8888//端口号1024-49151
    10. #define IP "192.168.2.54"//本机ＩＰ，终端输入ifconfig可得
    11.  
    12. int main(int argc, const char *argv[])
    13. {
    14. 	//创建流式套接字 socket
    15. 	int sfd = socket(AF_INET,SOCK_STREAM,0);
    16. 	if(sfd<0){
    17. 		//printf("%d:",__LINE__);
    18. 		//perror("socket error");
    19. 		ERR_MSG("socket");
    20. 		return -1;
    21. 	}
    22. 	printf("socket create success sfd=%d\n",sfd);
    23.  
    24. 	//允许端口快速的被复用
    25. 	int reuse = 1;                                                            
    26. 	if(setsockopt(sfd, SOL_SOCKET, SO_REUSEADDR, &reuse, sizeof(reuse)) < 0)
    27. 	{
    28. 		ERR_MSG("setsockopt");
    29. 		return -1;
    30. 	}
    31. 	printf("允许端口快速的被复用成功\n");
    32.  
    33. 	//填充地址信息结构体给bind函数绑定
    34. 	//真是的地址信息结构体根据地址族制定 AF_INET:man 7 ip
    35. 	struct sockaddr_in sin;
    36. 	sin.sin_family 		= AF_INET;//必须填AF_INET
    37. 	sin.sin_port   		= htons(PORT);//端口号的网络字节序
    38. 	sin.sin_addr.s_addr = inet_addr(IP);//本机IP
    39. 	//绑定服务器的地址信息  -->必须绑定    bind
    40. 	if(bind(sfd,(struct sockaddr*)&sin,sizeof(sin))<0){
    41. 		ERR_MSG("bind");
    42. 		return -1;
    43. 	}//指针类型的强转不会有数据丢失
    44. 	printf("bind success\n");
    45.  
    46. 	//将套接字设置为被动监听状态 listen
    47. 	if(listen(sfd,128)<0){
    48. 		ERR_MSG("listen");
    49. 		return -1;
    50. 	}
    51. 	printf("listen success\n");
    52.  
    53. 	//定义文件描述符集合
    54. 	fd_set readfds,tmpfds;
    55.  
    56. 	//将文件描述符集合清空
    57. 	FD_ZERO(&readfds);
    58. 	//将文件描述符放入集合之中
    59. 	FD_SET(sfd,&readfds);
    60. 	FD_SET(0, &readfds);
    61.  
    62. 	int maxfd = sfd;
    63. 	int res;
    64. 	char buf[128] = "";
    65. 	struct sockaddr_in cin;  //存储客户端的地址信息
    66. 	socklen_t addrlen = sizeof(cin);  //真实的地址信息结构体的大小
    67. 	//获取一个已经完成的客户端信息，生成一个新的文件描述符 accept
    68. 	int newfd;
    69. 	struct sockaddr_in saveCin[1024];  //备份连接成功的客户端的地址信息，用下标来对应地址信息 
    70. 	while(1){
    71. 		tmpfds = readfds;
    72.  
    73. 		//调用select函数
    74. 		res = select(maxfd+1,&tmpfds, NULL, NULL, NULL);
    75. 		if(res < 0){
    76. 			ERR_MSG("select error");
    77. 			break;
    78. 		}else if(0 == res){
    79. 			printf("time out\n");
    80. 			break;
    81. 		}else{
    82. 			for(int i=0; i<=maxfd; i++){
    83. 				if(0==FD_ISSET(i, &tmpfds)){
    84. 					continue;
    85. 				}else if(-1==FD_ISSET(i, &tmpfds)){
    86. 					ERR_MSG("FD_ISSET error");
    87. 					break;
    88. 				}
    89.  
    90. 				if(0==i){
    91. 					//终端输入
    92. 					printf("从终端读取成功::");
    93. 					fgets(buf,sizeof(buf),stdin);
    94.  
    95. 					buf[strlen(buf)-1] = 0;
    96.  
    97. 					printf("%s\n",buf);
    98. 				}
    99. 				else if(sfd == i){
    100. 					if((newfd=accept(sfd,(struct sockaddr*)&cin,&addrlen))<0){
    101. 						ERR_MSG("accept");
    102. 						return -1;
    103.  
    104.  
    105. 					}
    106. 					printf("[%s:%d]客户端链接成功 newfd = %d\n",\
    107. 							inet_ntoa(cin.sin_addr),\
    108. 							ntohs(cin.sin_port),newfd);
    109.  
    110. 					saveCin[newfd] = cin;  //将cin另存到下标为文件描述符的位置
    111.  
    112. 					//将newfd添加到集合中
    113. 					FD_SET(newfd, &readfds);
    114.  
    115. 					//更新maxfd
    116. 					maxfd = maxfd>newfd?maxfd:newfd;
    117.  
    118.  
    119. 				}else{
    120. 					if(FD_ISSET(i, &readfds)){
    121. 						//清空字符串
    122. 						bzero(buf,sizeof(buf)); //memset
    123.  
    124. 						//接收
    125. 						res = recv(i, buf, sizeof(buf) ,0);
    126. 						if(res<0){
    127. 							ERR_MSG("recv");
    128. 							return -1;
    129. 						}else if(0==res){
    130. 							printf("[%s:%d]客户端下线　newfd=%d\n",\
    131. 									inet_ntoa(saveCin[i].sin_addr),\
    132. 									ntohs(saveCin[i].sin_port),i);
    133. 							//将文件描述符从集合中踢出
    134. 							FD_CLR(i, &readfds);
    135. 							//由于踢出的文件描述符可能是最大文件描述符,更新maxfd
    136. 							/*		for(; maxfd>=0; maxfd--){
    137. 									if(FD_ISSET(maxfd, &readfds)){
    138. 									break;
    139. 									}
    140. 									}	*/
    141.  
    142. 							while(FD_ISSET(maxfd, &readfds)==0 && maxfd-->=0);
    143.  
    144. 							//关闭文件描述符
    145. 							close(i);
    146. 							continue;
    147. 						}
    148. 						printf("[%s:%d]客户端消息　newfd=%d:%s\n",\
    149. 								inet_ntoa(saveCin[i].sin_addr),\
    150. 								ntohs(saveCin[i].sin_port),i,buf);	
    151.  
    152.  
    153. 						//发送
    154. 						strcat(buf,">_<");
    155. 						if(send(i,buf,strlen(buf),0)<0){
    156. 							ERR_MSG("send");
    157. 							return -1;
    158. 						}
    159. 						printf("send success\n");			
    160. 					}				
    161.  
    162.  
    163. 				}
    164. 			}
    165. /*
    166. 			//如果是终端输入就绪
    167. 			if(FD_ISSET(0,&tmpfds)){
    168. 				printf("从终端读取成功::");
    169. 				fgets(buf,sizeof(buf),stdin);
    171. 				buf[strlen(buf)-1] = 0;
    173. 				printf("%s\n",buf);
    174. 			}
    176. 			//如果是客户端连接就绪
    177. 			if(FD_ISSET(sfd,&tmpfds)){
    178. 				if((newfd=accept(sfd,(struct sockaddr*)&cin,&addrlen))<0){
    179. 					ERR_MSG("accept");
    180. 					return -1;
    183. 				}
    184. 				printf("[%s:%d]客户端链接成功 newfd = %d\n",\
    185. 						inet_ntoa(cin.sin_addr),\
    186. 						ntohs(cin.sin_port),newfd);
    188. 				saveCin[newfd] = cin;  //将cin另存到下标为文件描述符的位置
    190. 				//将newfd添加到集合中
    191. 				FD_SET(newfd, &readfds);
    193. 				//更新maxfd
    194. 				maxfd = maxfd>newfd?maxfd:newfd;
    195. 			}
    196. 			for(int i=4; i<=maxfd; i++){
    197. 				if(FD_ISSET(i, &readfds)){
    198. 					//清空字符串
    199. 					bzero(buf,sizeof(buf)); //memset
    201. 					//接收
    202. 					res = recv(i, buf, sizeof(buf) ,0);
    203. 					if(res<0){
    204. 						ERR_MSG("recv");
    205. 						return -1;
    206. 					}else if(0==res){
    207. 						printf("[%s:%d]客户端下线　newfd=%d\n",\
    208. 								inet_ntoa(saveCin[i].sin_addr),\
    209. 								ntohs(saveCin[i].sin_port),i);
    210. 						//将文件描述符从集合中踢出
    211. 						FD_CLR(i, &readfds);
    212. 						//由于踢出的文件描述符可能是最大文件描述符,更新maxfd
    213. 						for(; maxfd>=0; maxfd--){
    214. 							if(FD_ISSET(maxfd, &readfds)){
    215. 								break;
    216. 							}
    217. 						}	
    219. 						while(FD_ISSET(maxfd, &readfds)==0 && maxfd-->=0);
    221. 						//关闭文件描述符
    222. 						close(i);
    223. 						continue;
    224. 					}
    225. 					printf("[%s:%d]客户端消息　newfd=%d:%s\n",\
    226. 							inet_ntoa(saveCin[i].sin_addr),\
    227. 							ntohs(saveCin[i].sin_port),i,buf);	
    230. 					//发送
    231. 					strcat(buf,">_<");
    232. 					if(send(i,buf,strlen(buf),0)<0){
    233. 						ERR_MSG("send");
    234. 						return -1;
    235. 					}
    236. 					printf("send success\n");			
    237. 				}
    238. 			}*/
    239. 		}
    240. 	}
    241.  
    242.  
    243. 	//关闭文件描述符
    244. 	close(newfd);
    245. 	if(close(sfd)<0){
    246. 		ERR_MSG("close");
    247. 		return -1;
    248. 	}
    249.  
    250.  
    251. 	return 0;
    252. }

    服务器：

    1. #include
    2.  
    3. //do-while只是为了不让花括号单独存在，并不循环
    4. #define ERR_MSG(msg) do{\
    5. 	fprintf(stderr,"%d:",__LINE__);\
    6. 	perror(msg);\
    7. }while(0);
    8.  
    9. #define PORT 8888//端口号1024-49151
    10. #define IP "192.168.2.54"//本机ＩＰ，终端输入ifconfig可得
    11.  
    12. int main(int argc, const char *argv[])
    13. {
    14. 	//创建流式套接字 socket
    15. 	int cfd = socket(AF_INET,SOCK_STREAM,0);
    16. 	if(cfd<0){
    17. 		//printf("%d:",__LINE__);
    18. 		//perror("socket error");
    19. 		ERR_MSG("socket");
    20. 		return -1;
    21. 	}
    22. 	printf("socket create success sfd=%d\n",cfd);
    23.  
    24. 	//填充服务器的地址信息结构体给connect函数连接
    25. 	//相连接哪个服务器就输入哪个服务器的地址信息
    26. 	//真是的地址信息结构体根据地址族制定 AF_INET:man 7 ip
    27. 	struct sockaddr_in sin;
    28. 	sin.sin_family 		= AF_INET;//必须填AF_INET
    29. 	sin.sin_port   		= htons(PORT);//服务器绑定的端口号的网络字节序
    30. 	sin.sin_addr.s_addr = inet_addr(IP);//服务器绑定的IP
    31. 	socklen_t addrlen    = sizeof(sin);
    32. 	//连接指定服务器 connect
    33. 	if(connect(cfd,(struct sockaddr*)&sin,addrlen)<0){
    34. 		ERR_MSG("connect");
    35. 		return -1;
    36. 	}
    37.  
    38. 	char buf[128] = "";
    39. 	ssize_t res = 0;
    40.  
    41. 	//定义文件描述符集合
    42. 	fd_set readfds,tmpfds;
    43. 	//初始化集合
    44. 	FD_ZERO(&readfds);
    45. 	//把cfd加入集合
    46. 	FD_SET(cfd, &readfds);
    47. 	//把标准输入加入集合
    48. 	FD_SET(0, &readfds);
    49. 	int ret = -1;
    50. 	while(1){
    51. 		tmpfds = readfds;
    52. 		ret = select(cfd+1, &tmpfds, NULL, NULL, NULL);
    53.  
    54. 		if(ret<0){
    55. 			ERR_MSG("select error");
    56. 			break;
    57. 		}else if(0 == ret){
    58. 			printf("time out\n");
    59. 			break;
    60. 		}else{
    61. 			if(FD_ISSET(0, &tmpfds)){
    62. 				//说明有来自终端的输入，需要发送
    63. 				//清空字符串
    64. 				bzero(buf,sizeof(buf)); //memset
    65. 				printf("请输入>> ");
    66. 				fgets(buf,sizeof(buf),stdin);
    67. 				buf[strlen(buf)-1] = 0;
    68.  
    69. 				//发送
    70. 				strcat(buf,">_<");
    71. 				if(send(cfd,buf,strlen(buf),0)<0){
    72. 					ERR_MSG("send");
    73. 					return -1;
    74. 				}
    75. 				printf("send success\n");
    76. 			}
    77.  
    78. 			if(FD_ISSET(cfd, &tmpfds)){
    79. 				//套接字文件的接收缓冲区有数据，需要接收
    80. 				//说明有来自终端的输入，需要发送
    81. 				//清空字符串
    82. 				bzero(buf,sizeof(buf)); //memset
    83.  
    84. 				//接收
    85. 				res = recv(cfd, buf, sizeof(buf) ,0);
    86. 				if(res<0){
    87. 					ERR_MSG("recv");
    88. 					return -1;
    89. 				}else if(0==res){
    90. 					printf("[%s:%d]服务器下线　cfd=%d\n",\
    91. 							inet_ntoa(sin.sin_addr),\
    92. 							ntohs(sin.sin_port),cfd);
    93. 					break;
    94. 				}
    95. 				printf("[%s:%d]服务器消息　cfd=%d:%s\n",\
    96. 						inet_ntoa(sin.sin_addr),\
    97. 						ntohs(sin.sin_port),cfd,buf);
    98. 			}
    99.  
    100. 		}
    101.  
    102. 	
    103. 	}
    104.  
    105.  
    106. /*
    107. 	while(1){
    108. 		//清空字符串
    109. 		bzero(buf,sizeof(buf)); //memset
    110. 		printf("请输入>> ");
    111. 		fgets(buf,sizeof(buf),stdin);
    112. 		buf[strlen(buf)-1] = 0;
    114. 		//发送
    115. 		strcat(buf,">_<");
    116. 		if(send(cfd,buf,strlen(buf),0)<0){
    117. 			ERR_MSG("send");
    118. 			return -1;
    119. 		}
    120. 		printf("send success\n");
    122. 		//接收
    123. 		res = recv(cfd, buf, sizeof(buf) ,0);
    124. 		if(res<0){
    125. 			ERR_MSG("recv");
    126. 			return -1;
    127. 		}else if(0==res){
    128. 			printf("[%s:%d]服务器下线　cfd=%d\n",\
    129. 					inet_ntoa(sin.sin_addr),\
    130. 					ntohs(sin.sin_port),cfd);
    131. 			break;
    132. 		}
    133. 		printf("[%s:%d]服务器消息　cfd=%d:%s\n",\
    134. 					inet_ntoa(sin.sin_addr),\
    135. 					ntohs(sin.sin_port),cfd,buf);		
    136. 	}
    137. */
    138. 	//关闭文件描述符
    139. 	//close(newfd);
    140. 	if(close(cfd)<0){
    141. 		ERR_MSG("close");
    142. 		return -1;
    143. 	}
    144.  
    145.  
    146. 	return 0;
    147. }

    效果：

  • 相关阅读:
    ssm手机销售网站
    Spring-boot-starter-actuator的可视化spring-boot-admin
    Java成王之路】EE初阶第二十一篇: 前端三剑客 JavaScript(WebAPI)
    es从线上库导出数据并导入开发环境
    git clone private repo remote: Repository not found. | git新电脑上clone私有库
    【论文笔记】policy-space response oracles (PSRO)
    Python 获取两个数组中各个坐标点对之间最短的欧氏距离
    初刷leetcode题目(3)——数据结构与算法
    计算机服务器中了勒索病毒怎么解决，勒索病毒解密步骤数据恢复
    公司内部传文件怎么安全——「用绿盾透明加密软件」
  • 原文地址：https://blog.csdn.net/sy311SB/article/details/133468988