多线程多进程处理服务器并发（多进程处理如何解决僵死进程）

目录

1.可循环发送数据的代码

2.改成循环之后每次发现只能处理一个客户端 

3.服务器端处理并发问题

3.1 思路

3.2 利用多线程实现并发

​编辑

3.3 利用多进程实现并发

3.3.1 多进程并发产生的僵死进程问题

​3.3.2 解决僵死进程问题

1.可循环发送数据的代码

服务器代码：

#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
int main()
{
	int sockfd=socket(AF_INET,SOCK_STREAM,0);//监听套接字
	assert(sockfd!=-1);

	struct sockaddr_in saddr,caddr;
	memset(&saddr,0,sizeof(saddr));
	saddr.sin_family=AF_INET;
	saddr.sin_port=htons(6000);//主机，网络大小端转换
	saddr.sin_addr.s_addr=inet_addr("127.0.0.1");//IP地址转换
	
	int res=bind(sockfd,(struct sockaddr*)&saddr,sizeof(saddr));
	assert(res!=-1);

	res=listen(sockfd,5);
	assert(res!=-1);
	
	while(1)
	{
		int len=sizeof(saddr);
		printf("accept wait...\n");
		int c=accept(sockfd,(struct sockaddr*)&caddr,&len);//链接套接字
		if(c<0)
		{
			continue;
		}
		printf("accept c=%d\n",c);
	    printf("accept client ip:%s ,port=%d\n",inet_ntoa(caddr.sin_addr),ntohs(caddr.sin_port));
		while(1)
		{	
			char buff[128]={0};
			int n=recv(c,buff,127,0);//返回值为0说明断开连接
			if(n<=0)
			{
				break;
			}
			printf("buff=%s\n",buff);

			send(c,"ok",2,0);
		}
		close(c);
	}
	close(sockfd);
	exit(0);
}

 客户端代码：

#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
int main()
{
	int sockfd=socket(AF_INET,SOCK_STREAM,0);//监听套接字
	assert(sockfd!=-1);

	struct sockaddr_in saddr;
	memset(&saddr,0,sizeof(saddr));
	saddr.sin_family=AF_INET;
	saddr.sin_port=htons(6000);
	saddr.sin_addr.s_addr=inet_addr("127.0.0.1");

	int res=connect(sockfd,(struct sockaddr*)&saddr,sizeof(saddr));
	assert(res!=-1);
	
	while(1)
	{
		printf("input:\n");
		char buff[128]={0};
		fgets(buff,127,stdin);

		if(strncmp(buff,"end",3)==0)
		{
			break;
		}
		send(sockfd,buff,strlen(buff),0);
		memset(buff,0,128);
		recv(sockfd,buff,127,0);
		printf("read:%s\n",buff);
	}
	close(sockfd);
	exit(0);
}

运行结果：

2.改成循环之后每次发现只能处理一个客户端 

将代码从单词发送数据改为while(1)循环发送数据后，我们发现每次只能处理一个客户端，其它客户端消息无法发送给服务器。

原因： 

3.服务器端处理并发问题

3.1 思路

这个问题可以通过引入多线程和多进程来解决。

服务端接收一个客户端的连接后（accept之后），创建一个线程或者进程，然后在新创建的线程或进程中循环处理数据。

主线程(父进程)只负责监听客户端的连接，并使用 accept()接受连接,不进行数据的处理。如下图所示: 

3.2 利用多线程实现并发

客户端代码不变，服务器端代码做如下更改：

#include <stdio.h>
#include <stdlib.h>
#include <assert.h>
#include <unistd.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <string.h>
#include <pthread.h>
void* work_pthread(void*arg)
{	
	int c=*(int*)arg;
	while(1)
	{
		char buff[128]={0};
		int n=recv(c,buff,127,0);//返回值为0说明断开连接
		if(n<=0)
		{
			break;
		}
		printf("recv(%d)=%s\n",c,buff);

		send(c,"ok",2,0);
	}
	printf("one clinet over!\n");
	close(c);
}

int main()
{
	int sockfd=socket(AF_INET,SOCK_STREAM,0);//监听套接字
	assert(sockfd!=-1);

	struct sockaddr_in saddr,caddr;
	memset(&saddr,0,sizeof(saddr));
	saddr.sin_family=AF_INET;
	saddr.sin_port=htons(6000);//主机，网络大小端转换
	saddr.sin_addr.s_addr=inet_addr("127.0.0.1");//IP地址转换
	
	int res=bind(sockfd,(struct sockaddr*)&saddr,sizeof(saddr));
	assert(res!=-1);

	res=listen(sockfd,5);
	assert(res!=-1);
    
	while(1)
	{
		int len=sizeof(saddr);
		printf("accept wait...\n");
		int c=accept(sockfd,(struct sockaddr*)&caddr,&len);//链接套接字
		if(c<0)
		{
			continue;
		}
		printf("accept c=%d\n",c);
	    printf("accept client ip:%s ,port=%d\n",inet_ntoa(caddr.sin_addr),ntohs(caddr.sin_port));
		
		pthread_t id;
		pthread_create(&id,NULL,work_pthread,(void*)&c);

	}
	close(sockfd);
	exit(0);
}

netstat -natp连接成功之后发现有两个./ser

3.3 利用多进程实现并发

客户端代码不变，服务器代码如下：

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <assert.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>

void DealClientLink(int c,struct sockaddr_in caddr)
{
	while(1)
	{
		char buff[128]={0};
		int n=recv(c,buff,127,0);//返回值为0说明断开连接
		if(n<=0)
		{
			break;
		}
		printf("%s:%d:buff=%s\n",inet_ntoa(caddr.sin_addr),ntohs(caddr.sin_port),buff);

		send(c,"ok",2,0);
	}
	printf("one clinet unlike!\n");
	close(c);
}

int main()
{
	int sockfd=socket(AF_INET,SOCK_STREAM,0);//监听套接字
	assert(sockfd!=-1);

	struct sockaddr_in saddr,caddr;
	memset(&saddr,0,sizeof(saddr));
	saddr.sin_family=AF_INET;
	saddr.sin_port=htons(6000);//主机，网络大小端转换
	saddr.sin_addr.s_addr=inet_addr("127.0.0.1");//IP地址转换

	int res=bind(sockfd,(struct sockaddr*)&saddr,sizeof(saddr));
	assert(res!=-1);

	res=listen(sockfd,5);
	assert(res!=-1);

	printf("%s:%d link success!\n",inet_ntoa(caddr.sin_addr),ntohs(caddr.sin_port));
	while(1)
	{
		int len=sizeof(saddr);
		int c=accept(sockfd,(struct sockaddr*)&caddr,&len);//链接套接字
		if(c<0)
		{
			continue;
		}
		pid_t pid=fork();
		assert(pid!=-1);

		if(pid==0)
		{
			DealClientLink(c,caddr);
			exit(0);
		}
	}
	close(sockfd);
	exit(0);
}

 运行结果：

3.3.1 多进程并发产生的僵死进程问题

子进程为客户端，父进程为服务器端，子进程先于父进程结束，父进程没有获取到子进程的退出码，子进程就会变成僵死进程，占用内存，影响执行速度。

客户端代码运行前：

关闭客户端（子进程结束）后：

如下图，产生了两个僵死进程。

 3.3.2 解决僵死进程问题

修改一下代码，让父进程调用wait()方法获取子进程的退出码，并结合信号使用，让它不再阻塞。

#include <wait.h>

void fun(int sig)
{
    wait(&sig);
}

signal(SIGCHLD,fun);//在主进程中添加

完整代码：

#include <stdio.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <assert.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <wait.h>

void DealClientLink(int c,struct sockaddr_in caddr)
{
	while(1)
	{
		char buff[128]={0};
		int n=recv(c,buff,127,0);//返回值为0说明断开连接
		if(n<=0)
		{
			break;
		}
		printf("%s:%d:buff=%s\n",inet_ntoa(caddr.sin_addr),ntohs(caddr.sin_port),buff);

		send(c,"ok",2,0);
	}
	printf("one clinet unlike!\n");
	close(c);
}

void fun(int sign)
{
	wait(&sign);
}

int main()
{
	signal(SIGCHLD,fun);
	int sockfd=socket(AF_INET,SOCK_STREAM,0);//监听套接字
	assert(sockfd!=-1);

	struct sockaddr_in saddr,caddr;
	memset(&saddr,0,sizeof(saddr));
	saddr.sin_family=AF_INET;
	saddr.sin_port=htons(6000);//主机，网络大小端转换
	saddr.sin_addr.s_addr=inet_addr("127.0.0.1");//IP地址转换

	int res=bind(sockfd,(struct sockaddr*)&saddr,sizeof(saddr));
	assert(res!=-1);

	res=listen(sockfd,5);
	assert(res!=-1);

	printf("%s:%d link success!\n",inet_ntoa(caddr.sin_addr),ntohs(caddr.sin_port));
	while(1)
	{
		int len=sizeof(saddr);
		int c=accept(sockfd,(struct sockaddr*)&caddr,&len);//链接套接字
		if(c<0)
		{
			continue;
		}
		pid_t pid=fork();
		assert(pid!=-1);

		if(pid==0)
		{
			DealClientLink(c,caddr);
			exit(0);
		}
	}
	close(sockfd);
	exit(0);
}

 使用ps -f命令查看进程信息，可以看到子进程退出后，没有僵死进程。

本文来自互联网用户投稿，该文观点仅代表作者本人，不代表本站立场。本站仅提供信息存储空间服务，不拥有所有权，不承担相关法律责任。如若转载，请注明出处：/a/446263.html

如若内容造成侵权/违法违规/事实不符，请联系我们进行投诉反馈qq邮箱809451989@qq.com，一经查实，立即删除！

相关文章

AI代码加速器即将发布！傅盛：程序员会写某种代码就能找到工作的时代一去不复返了

AI代码加速器即将发布！傅盛：程序员会写某种代码就能找到工作的时代一去不复返了

在产品介绍视频的最后&#xff0c;代码加速器运行了Prompt生成的代码&#xff0c;是一个为傅盛庆生的祝福“彩蛋”。不得不说&#xff0c;猎户星空的程序员就做到了傅盛说的不止写代码&#xff0c;真是有点浪漫小心机在身上的。 3月6日&#xff0c;猎豹移动董事长兼CEO、猎户星…
阅读更多...
木球竞赛抽签计分系统（C# Winform）

木球竞赛抽签计分系统（C# Winform）

前几天做了个小系统&#xff0c;木球竞赛抽签计分系统。种子的设置&#xff0c;和轮空的设置&#xff0c;都是按照运动抽签的规则。目前仅支持8位&#xff0c;16位, 32位&#xff0c;64位报表的生成。 功能模块&#xff1a; 1、比赛管理&#xff1a;名称、承办、时间、地点 2…
阅读更多...
使用Certbot解决https证书自动更新的问题

使用Certbot解决https证书自动更新的问题

除了各个第三方博客平台之外&#xff0c;我还一直保有一个自建的博客网站https://zxs.io/&#xff0c;还有几个其他的域名用做小工具之类的&#xff0c;之前一直使用阿里云免费https证书&#xff0c;一次申请可以用一年&#xff0c;但现在阿里云免费证书缩短到3个月了&#xff…
阅读更多...
云上攻防-云产品篇堡垒机场景JumpServer绿盟SASTeleport麒麟齐治

云上攻防-云产品篇堡垒机场景JumpServer绿盟SASTeleport麒麟齐治

知识点 1、云产品-堡垒机-产品介绍&攻击事件 2、云产品-堡垒机-安全漏洞&影响产品 章节点&#xff1a; 云场景攻防&#xff1a;公有云&#xff0c;私有云&#xff0c;混合云&#xff0c;虚拟化集群&#xff0c;云桌面等 云厂商攻防&#xff1a;阿里云&#xff0c;腾讯…
阅读更多...
【网络工程设计】交换网络技术

【网络工程设计】交换网络技术

&#x1f4dd;本文介绍 本文主要介绍使用GNS3和VMware来构件一个简单的交换网络 &#x1f44b;作者简介&#xff1a;一个正在积极探索的本科生 &#x1f4f1;联系方式&#xff1a;943641266(QQ) &#x1f6aa;Github地址&#xff1a;https://github.com/sankexilianhua &#x…
阅读更多...
【MySQL篇】 MySQL基础学习

【MySQL篇】 MySQL基础学习

文章目录 前言基础数据类型DDL数据库操作查询数据库创建数据库删除数据库使用数据库 DDL表操作创建表查询表修改表删除 DML-增删改添加数据更改数据删除数据 DQL-查询基础查询条件查询聚合函数分组查询排序查询分页查询编写顺序 DML-用户及权限用户管理权限控制 函数字符串函数…
阅读更多...
修复网络适配器不工作的14种方法，总有一种适合你

修复网络适配器不工作的14种方法，总有一种适合你

网络适配器是将设备连接到internet或其他计算机的关键硬件组件。如果设备发生故障，你可能会面临连接速度慢的问题，在最坏的情况下，互联网将完全停止工作。 这可能是由于损坏的驱动程序、冲突的设备、配置错误的设置，甚至是硬件故障！但也有可能出现互联网问题，使你认为网…
阅读更多...
22.网络游戏逆向分析与漏洞攻防-网络通信数据包分析工具-加载配置文件到分析工具界面

22.网络游戏逆向分析与漏洞攻防-网络通信数据包分析工具-加载配置文件到分析工具界面

免责声明&#xff1a;内容仅供学习参考&#xff0c;请合法利用知识&#xff0c;禁止进行违法犯罪活动&#xff01; 如果看不懂、不知道现在做的什么&#xff0c;那就跟着做完看效果 内容参考于&#xff1a;易道云信息技术研究院VIP课 上一个内容&#xff1a;21.配置数据保存…
阅读更多...
【java+vue】前后端项目架构详细流程

【java+vue】前后端项目架构详细流程

前端 1.创建vue项目 需要工具&#xff1a;node、Vscode 1.在磁盘上创建文件&#xff08;web&#xff09;&#xff0c;并移到Vscode的工作区 2.进入该文件的终端 3.检测node和vue是否正常&#xff0c;若不显示版本号&#xff0c;则自行下载 4.生成vue 1.执行命令&#xff1a;…
阅读更多...
JavaScript中的Set和Map：理解与使用

JavaScript中的Set和Map：理解与使用

&#x1f90d; 前端开发工程师、技术日更博主、已过CET6 &#x1f368; 阿珊和她的猫_CSDN博客专家、23年度博客之星前端领域TOP1 &#x1f560; 牛客高级专题作者、打造专栏《前端面试必备》 、《2024面试高频手撕题》 &#x1f35a; 蓝桥云课签约作者、上架课程《Vue.js 和 E…
阅读更多...
2.JavaWebMySql基础

2.JavaWebMySql基础

导语&#xff1a; 一、数据库基本概念 1.什么是数据库 2.关于MySql数据库 二、MySQL的安装与卸载 安装步骤&#xff1a; 卸载步骤&#xff1a; 三、MySQL服务操作 1.服务启动和关闭&#xff1a; 2.登录和退出MySQL&#xff1a; 3.服务自启动&#xff1a; 4.命令行登…
阅读更多...
小程序Taro框架 自定义底部Tabbar，处理自定义Tab栏切换卡顿、闪烁

小程序Taro框架 自定义底部Tabbar，处理自定义Tab栏切换卡顿、闪烁

最终效果 最近在用Taro框架开发一个小程序&#xff0c;有一个自定义底部Tabbar的需求&#xff0c;最终效果如下 起步 这页是我第一次接触自定义小程序底部Tabbar&#xff0c;所有第一选择必然是相看官方文档&#xff1a;微信小程序自定义 Tabbar | Taro 文档 &#xff08;如果…
阅读更多...
ping多个IP的工具

ping多个IP的工具

Ping Tool 项目地址 python开发的IP搜索小工具 ping一个网段所有IP&#xff0c;显示结果查看某个ip地址开放监听的端口配置可保存
阅读更多...
IDEA编译安卓源码TVBox

IDEA编译安卓源码TVBox

因为电视x受限&#xff0c;无法观看电视直播&#xff0c;为了春晚不受影响&#xff0c;于是网络一顿搜索&#xff0c;试过多个APP&#xff0c;偶尔找到这款开源的TVBox&#xff0c;寒假在家&#xff0c;随便拿来练练手&#xff0c;学习安卓APP的编写&#xff0c;此文做以记录&a…
阅读更多...
手拉手RocketMQ基础

手拉手RocketMQ基础

消息中间件的对比 消息中间件 ActiveMQ RabbitMQ RocketMQ kafka 开发语言 java erlang java scala 单击吞吐量 万级 万级 10万级 10万级 时效性 ms us ms ms 可用性 高(主从架构) 高(主从架构) 非常高(主从架构) 非常高(主从架构) 消息中间件: activ…
阅读更多...
分享软件项目实施方案模板

分享软件项目实施方案模板

本项目在实施过程中将遵守做到以下几个方面&#xff1a; 与建设单位共同完成整个系统软件、网络等设计,负责系统的开发、测试、调试、人员培训、系统的试运行和交付&#xff0c;并保证系统质量。负责系统的维护、应用软件的升级和更新。提出对系统硬件设备的相关技术要求。在项…
阅读更多...
JDBC的学习记录

JDBC的学习记录

JDBC就是使用java语言操作关系型数据库的一套API。 JDBC&#xff08;Java Database Connectivity&#xff09;是Java语言中用于连接和操作数据库的一种标准接口。它提供了一组方法和类&#xff0c;使Java程序能够与各种不同类型的关系型数据库进行交互。 JDBC的主要功能包括建…
阅读更多...
PythonWeb

PythonWeb

例题一 from flask import Flask app Flask(__name__) app.route(/index) def index():return f<h1>这是首页&#xff01;</h1> def second():return f<h1>这是第二页&#xff01;</h1> if __name__ __name__:app.run(host"0.0.0.0",port…
阅读更多...
图腾柱PFC工作原理：一张图

图腾柱PFC工作原理：一张图

视屏链接&#xff1a; PFC工作原理
阅读更多...
SpringCloud--Sentinel使用

SpringCloud--Sentinel使用

一、快速开始 Sentinel 的使用可以分为两个部分&#xff1a; 核心库&#xff08;Java 客户端&#xff09;&#xff1a;不依赖任何框架/库&#xff0c;能够运行于 Java 8 及以上的版本的运行时环境&#xff0c;同时对 Dubbo / Spring Cloud 等框架也有较好的支持。控制台&…
阅读更多...
最新文章

Copyright @ 2022~2023