Linux网络编程:TCP并发服务器实现
创始人
2025-01-18 07:03:55
0

目录

1、前言

2、多进程代码实现

2.1 创建新的进程

2.2 客户端接收响应函数

2.3 僵尸进程处理

2.4 完整代码

2.5 代码测试  

3、多线程代码实现

3.1 创建新的线程 

3.2 线程函数定义

3.3 完整代码

3.4 代码测试

4、总结


1、前言

前面实现了基本的TCP编程,Linux网络编程:TCP编程实现-CSDN博客,但是存在多个客户端去连接同一个服务器的情况,这时之前编写的基础TCP服务器连接一个客户端后就无法再与其他客户端建立连接,这是就需要考虑并发设计。

2、多进程代码实现

2.1 创建新的进程

若返回的pid小于0,则创建失败退出;

若返回的pid等于0,则为子进程,关闭服务器绑定socket文件描述符;

若返回的pid大于0,则为父进程,关闭客户端绑定socket文件描述符。

if((pid = fork())<0) {     perror("accept");     exit(0); } else if(pid == 0) {     close(fd);     ClientHandle(newfd);     exit(0); } else if(pid > 0) {     close(newfd); }

2.2 客户端接收响应函数

每次创建子进程后进行客户端接收,读取客户端绑定socket文件描述符的buffer,随后进行关闭客户端绑定socket文件描述符。

void ClientHandle(int newfd) { 	int ret; 	char buf[BUFSIZ] = {};//BUFSIZ 8142 	while(1) 	{ 		memset(buf,0,BUFSIZ); 		ret = read(newfd,buf,BUFSIZ); 		if(ret < 0 ) 		{ 			perror("read"); 			exit(0); 		} 		else if(ret == 0) 			break; 		printf("buf = %s\n",buf); 	} 	close(newfd); }

2.3 僵尸进程处理

 当客户端与服务器连接后,终止客户端进程后,服务器的子进程会变成僵尸进程,所以要进行僵尸进程的回收。

子进程终止时会向父进程发送SIGCHLD信号,告知父进程回收自己,但该信号的默认处理动作为忽略,因此父进程仍然不会去回收子进程,需要捕捉处理实现子进程的回收;

进行信号机制的绑定,进行子进程终止信号的接收

signal(SIGCHLD,SigHandle);

实现僵尸进程接收函数

void SigHandle(int sig) { 	if(sig == SIGCHLD) 	{ 		printf("Client exited\n"); 		wait(NULL); 	} }

2.4 完整代码

#include  #include  #include  #include  #include  #include  #include  #include  #include   #define BACKLOG 5 void SigHandle(int sig) { 	if(sig == SIGCHLD) 	{ 		printf("Client exited\n"); 		wait(NULL); 	} } void ClientHandle(int newfd); int main(int argc,char *argv[]) { 	int fd,newfd; 	struct sockaddr_in addr,client_addr; 	socklen_t addrlen = sizeof(client_addr);  	signal(SIGCHLD,SigHandle); 	pid_t pid;  	if(argc < 3) 	{ 		printf("%s\n",argv[0]); 		exit(0); 	}  	/*创建套接字*/ 	fd = socket(AF_INET,SOCK_STREAM,0); 	if(fd < 0) 	{ 		perror("socket"); 		exit(0); 	} 	addr.sin_family = AF_INET; 	addr.sin_port = htons(atoi(argv[2])); 	if(inet_aton(argv[1],&addr.sin_addr)==0) 	{ 		fprintf(stderr,"Invalid address\n"); 		exit(0); 	} 	/*地址快速重用*/ 	int flag = 1,len = sizeof(int); 	if(setsockopt(fd,SOL_SOCKET,SO_REUSEADDR,&flag,len)==-1) 	{ 		perror("setsockopt"); 		exit(1); 	} 	/*绑定通信结构体*/ 	if(bind(fd,(struct sockaddr *)&addr,sizeof(addr)) == -1) 	{ 		perror("bind"); 		exit(0); 	} 	/*设置套接字为侦听模式*/ 	if(listen(fd,BACKLOG) == -1) 	{ 		perror("listen"); 		exit(0); 	}  	while(1) 	{ 		/*接受客户端的连接请求,生成新的用于和客户端通信的套接字*/ 		newfd = accept(fd,(struct sockaddr *)&client_addr,&addrlen); 		if(newfd < 0) 		{ 			perror("accept"); 			exit(0); 		} 		printf("addr:%s port:%d\n",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port)); 		if((pid = fork())<0) 		{ 			perror("accept"); 			exit(0); 		} 		else if(pid == 0) 		{ 			close(fd); 			ClientHandle(newfd); 			exit(0); 		} 		else if(pid > 0) 		{ 			close(newfd); 		} 	} 	close(fd); 	return 0; } void ClientHandle(int newfd) { 	int ret; 	char buf[BUFSIZ] = {};//BUFSIZ 8142 	while(1) 	{ 		memset(buf,0,BUFSIZ); 		ret = read(newfd,buf,BUFSIZ); 		if(ret < 0 ) 		{ 			perror("read"); 			exit(0); 		} 		else if(ret == 0) 			break; 		printf("buf = %s\n",buf); 	} 	close(newfd); } 

2.5 代码测试  

3、多线程代码实现

3.1 创建新的线程 

进行线程创建后进行线程分离 

pthread_create(&tid,NULL,ClientHandle,&newfd); pthread_detach(tid);

3.2 线程函数定义

每次创建子进程后进行客户端接收,读取客户端绑定socket文件描述符的buffer,随后进行关闭客户端绑定socket文件描述符。 

void *ClientHandle(void *arg) { 	int ret; 	char buf[BUFSIZ] = {};//BUFSIZ 8142 	int newfd = *(int *)arg; 	while(1) 	{ 		memset(buf,0,BUFSIZ); 		ret = read(newfd,buf,BUFSIZ); 		if(ret < 0 ) 		{ 			perror("read"); 			exit(0); 		} 		else if(ret == 0) 			break; 		printf("buf = %s\n",buf); 	} 	printf("client exit\n"); 	close(newfd); 	return NULL; } 

3.3 完整代码

#include  #include  #include  #include  #include  #include  #include  #include   #define BACKLOG 5 void *ClientHandle(void *arg); int main(int argc,char *argv[]) { 	int fd,newfd; 	struct sockaddr_in addr,client_addr; 	pthread_t tid; 	socklen_t addrlen = sizeof(client_addr);  	if(argc < 3) 	{ 		printf("%s\n",argv[0]); 		exit(0); 	}  	/*创建套接字*/ 	fd = socket(AF_INET,SOCK_STREAM,0); 	if(fd < 0) 	{ 		perror("socket"); 		exit(0); 	} 	addr.sin_family = AF_INET; 	addr.sin_port = htons(atoi(argv[2])); 	if(inet_aton(argv[1],&addr.sin_addr)==0) 	{ 		fprintf(stderr,"Invalid address\n"); 		exit(0); 	} 	/*地址快速重用*/ 	int flag = 1,len = sizeof(int); 	if(setsockopt(fd,SOL_SOCKET,SO_REUSEADDR,&flag,len)==-1) 	{ 		perror("setsockopt"); 		exit(1); 	} 	/*绑定通信结构体*/ 	if(bind(fd,(struct sockaddr *)&addr,sizeof(addr)) == -1) 	{ 		perror("bind"); 		exit(0); 	} 	/*设置套接字为侦听模式*/ 	if(listen(fd,BACKLOG) == -1) 	{ 		perror("listen"); 		exit(0); 	}  	while(1) 	{ 		/*接受客户端的连接请求,生成新的用于和客户端通信的套接字*/ 		newfd = accept(fd,(struct sockaddr *)&client_addr,&addrlen); 		if(newfd < 0) 		{ 			perror("accept"); 			exit(0); 		} 		printf("addr:%s port:%d\n",inet_ntoa(client_addr.sin_addr),ntohs(client_addr.sin_port)); 		pthread_create(&tid,NULL,ClientHandle,&newfd); 		pthread_detach(tid); 	} 	close(fd); 	return 0; } void *ClientHandle(void *arg) { 	int ret; 	char buf[BUFSIZ] = {};//BUFSIZ 8142 	int newfd = *(int *)arg; 	while(1) 	{ 		memset(buf,0,BUFSIZ); 		ret = read(newfd,buf,BUFSIZ); 		if(ret < 0 ) 		{ 			perror("read"); 			exit(0); 		} 		else if(ret == 0) 			break; 		printf("buf = %s\n",buf); 	} 	printf("client exit\n"); 	close(newfd); 	return NULL; } 

3.4 代码测试

4、总结

本文通过多进程和多线程技术进行的TCP并发服务器的实现,在多进程方式下,解决了僵尸进程的问题。 最后通过完成代码的编写并测试,成功实现了TCP并发服务器。

相关内容

热门资讯

透视神器!德普之星透视辅助, ... 透视神器!德普之星透视辅助, (德普)总是是真的有挂(透视)辅助软件(有挂脚本)1、打开软件启动之后...
透视线上!哈糖大菠萝有挂吗,拱... 透视线上!哈糖大菠萝有挂吗,拱趴大菠萝挂怎么安装,透明挂教程(有挂辅助)1、下载好拱趴大菠萝挂怎么安...
透视辅助!wpk透视是真的吗,... 透视辅助!wpk透视是真的吗,(WPK)总是真的有挂(透视)辅助购买(有挂攻略);1、每一步都需要思...
透视透视脚本!wepoker底... 透视透视脚本!wepoker底牌透视脚本,(WePoKer)都是有挂(透视)辅助器下载(有挂辅助)1...
透视工具!德普之星透视辅助软件... 透视工具!德普之星透视辅助软件是真的吗, (德扑之心)一直有挂(透视)的辅助工具介绍(有挂细节)1、...
透视线上!佛手大菠萝有挂吗,哈... 透视线上!佛手大菠萝有挂吗,哈糖大菠萝有没有挂,解密教程(有挂介绍)所有人都在同一条线上,像星星一样...
透视底牌透视!淘宝买wepok... 透视底牌透视!淘宝买wepoker透视有用吗,(WEPOKER)本来是真的有挂(透视)免费脚本咨询(...
透视辅助!wpk私人局辅助是真... 透视辅助!wpk私人局辅助是真的吗,(Wpk)其实是有挂(透视)作弊(有挂教程)1、让任何用户在无需...
透视实锤!德普之星辅助器, (... 透视实锤!德普之星辅助器, (德普之星)总是有挂(透视)透视挂(有挂解密)1)德普之星辅助器辅助挂:...
透视攻略!德州圈脚本,哈糖大菠... 透视攻略!德州圈脚本,哈糖大菠萝有没有挂,攻略方法(有挂介绍)1、用户打开应用后不用登录就可以直接使...