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

news2024/11/6 3:02:22

目录

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命令查看进程信息，可以看到子进程退出后，没有僵死进程。

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

如若内容造成侵权/违法违规/事实不符，请联系多彩编程网进行投诉反馈，一经查实，立即删除！

相关文章

vue 在什么情况下在数据发生改变的时候不会触发视图更新

vue 在什么情况下在数据发生改变的时候不会触发视图更新

在 Vue 中&#xff0c;通常数据发生变化时&#xff0c;视图会自动更新。但是&#xff0c;有几种情况可能导致数据变化不会触发视图更新&#xff1a; 1.对象属性的添加或删除&#xff1a; Vue 无法检测到对象属性的添加或删除。因为 Vue 在初始化实例时对属性执行了 getter/se…
阅读更多...
【教学类-34-09】20240310华文彩云学号拼图（3*3格子浅灰底图 深灰拼图块）（AI对话大师）

【教学类-34-09】20240310华文彩云学号拼图（3*3格子浅灰底图 深灰拼图块）（AI对话大师）

作品展示 背景需求&#xff1a; 制作了两位数的学号3*3格子&#xff0c; 【教学类-34-05】20230523拼图&#xff08;数字学号0X-长方块拼图-双色深灰浅灰&#xff09;3*3格子&#xff08;中班主题《个别化拼图》偏艺术-美术&#xff09;_灰底白色方块数字怎么制作-CSDN博客文…
阅读更多...
PhantomCrawler：一款功能强大的多代理IP网站请求生成工具

PhantomCrawler：一款功能强大的多代理IP网站请求生成工具

关于PhantomCrawler PhantomCrawler是一款功能强大的多代理IP网站请求生成工具&#xff0c;该工具允许广大研究人员通过不同的代理IP地址来模拟与目标Web站点的交互行为。 PhantomCrawler基于Python、requests和BeautifulSoup实现其功能&#xff0c;并提供了一种简单且高效的方…
阅读更多...
【Linux】gcc与make、makefile

【Linux】gcc与make、makefile

文章目录 1 gcc/g1.1 预处理1.2 编译1.3 汇编1.4 链接1.4.1 静态链接1.4.2 动态链接 2 make和makefile2.1 依赖关系2.2 依赖方法2.3 伪目标 3 总结 1 gcc/g 当我们创建一个文件&#xff0c;并向里面写入代码&#xff0c;此时&#xff0c;我们该如何使我们的代码能够运行起来呢&…
阅读更多...
Delphi 的Read 与Readln 的区别

Delphi 的Read 与Readln 的区别

结合运行窗口&#xff0c;你输入1 2 3 4 这是一行ReadLn在读入时把这四个数当成一行&#xff0c;read(a,b)只读入了前两个数&#xff1a;1 2&#xff0c;就准备读下一行了&#xff0c;下一行输入3&#xff0c;再下一行输入2&#xff0c;所以输出1232&#xff1b; Read是逐个读…
阅读更多...
【MySQL 系列】MySQL 语句篇_DQL 语句

【MySQL 系列】MySQL 语句篇_DQL 语句

DQL&#xff08;Data Query Language&#xff09;&#xff0c;即数据查询语言&#xff0c;用来查询数据记录。DQL 基本结构由 SELECT FROM、WHERE、JOIN 等子句构成。 DQL 语句并不会改变数据库&#xff0c;而是让数据库将查询结果发送结果集给客户端&#xff0c;返回的结果是一…
阅读更多...
IDEA打开项目文件目录不见了

IDEA打开项目文件目录不见了

偶尔发生新拉下来的代码&#xff0c;或者旧代码修改了包名&#xff0c;项目名称等&#xff0c;idea左侧project一栏不显示代码的文件目录。例如下面此时不要慌张&#xff0c;不用删除项目重新拉取&#xff0c;通过以下方式解决&#xff1a; 本人尝试能够解决&#xff0c;如果无…
阅读更多...
Learn OpenGL 05 变换

Learn OpenGL 05 变换

万向节死锁 万向节死锁&#xff08;Gimbal Lock&#xff09;是用欧拉角定义旋转时&#xff0c;产生的在某一情况下旋转轴重合导致的系统丢失自由度的情况&#xff0c;一种最简单的解决方式是调整三维软件中的旋转轴顺序来避免该情况发生。 也就是说当中间轴旋转至90的时候就会…
阅读更多...
Vue+ElementUI启动vue卡死的问题

Vue+ElementUI启动vue卡死的问题

0 引言 今天&#xff0c;博主在学习vueelementui的时候遇到一个问题&#xff0c;卡了博主很久。 1 问题复现 在vue页面的<template>标签中写入两个<div>标签&#xff0c; <template><div><h1>第一个div标签</h1><el-table></…
阅读更多...
vue学习笔记21-组件传递数据_Props

vue学习笔记21-组件传递数据_Props

组件与组件之间不是完全独立的&#xff0c;而是有交集的&#xff0c;那就是组件与组件之间是可以传递数据的 传递数据的解决方案就是props 父级&#xff1a; 在父级中引入子集 <template><h3>Parent</h3><Child/> </template><script> i…
阅读更多...
适配器模式已经在SpringMVC中的源码实现

适配器模式已经在SpringMVC中的源码实现

介绍&#xff1a; 1、适配器模式将某个类的接口转换成客户端期望的另一种接口表示 2、目的&#xff1a;兼容性&#xff0c;让原本因接口不匹配不能一起工作的两个类可以协同工作。其别名为&#xff1a;包装器。 3、属于&#xff1a;结构型模式 4、分3类&#xff1a;1&#xff0…
阅读更多...
方程式工具包远程溢出漏洞图形界面版V0.3（内置永恒之蓝、永恒冠军、永恒浪漫等）

方程式工具包远程溢出漏洞图形界面版V0.3（内置永恒之蓝、永恒冠军、永恒浪漫等）

Part1 前言 大家好&#xff0c;我是ABC_123。我从年前到现在&#xff0c;一直在整理曾经写过的红队工具&#xff0c;逐步把自己认为比较好用的原创工具发出来给大家用一用&#xff0c;方便大家在日常的攻防比赛、红队评估项目中解放双手&#xff0c;节省时间精力和体力。本期给…
阅读更多...
MySQL中常用的操作语句已汇总

MySQL中常用的操作语句已汇总

目录 一、库语句 1.查询现有数据库 2.创建数据库 3.选中数据库 ​编辑 4.删除数据库 二、初阶表操作 1.查看数据库现有表 2.查看表结构 3.创建表 4.删除表 5.全列查询 6.删除表2 7.修改操作 三、插入操作 1.全列插入 2.指定列插入 3.一次插入多组数据 4.插入…
阅读更多...
SpringBoot集成netty实现websocket通信

SpringBoot集成netty实现websocket通信

实现推送消息给指定的用户 一、依赖 <?xml version"1.0" encoding"UTF-8"?> <project xmlns"http://maven.apache.org/POM/4.0.0"xmlns:xsi"http://www.w3.org/2001/XMLSchema-instance"xsi:schemaLocation"http://m…
阅读更多...
redis-集群 原生部署和工具自动部署

redis-集群 原生部署和工具自动部署

什么redis集群&#xff1f; redis集群是一个提供在多个redis节点之间共享数据的程序集。它并不像redis主从复制模式那样仅提供一个master节点来提供写服务&#xff0c;而是会提供多个master节点来提供写服务&#xff0c;每个master节点中存储的数据都不一样&#xff0c;这些数据…
阅读更多...
HarmonyOS系统开发基础环境搭建

HarmonyOS系统开发基础环境搭建

目录 一 鸿蒙介绍&#xff1a; 1.1 HarmonyOS系统 1.2 HarmonyOS软件编程语言 二 HarmonyOS编程环境搭建 1.1 官网下载地址 1.2搭建开发流程 1.3 创建安装目录 1.4 下载DevEco Studio​编辑 1.5 下载后点击安装 1.6 自动添加桌面快捷和bin路径 ​编辑1.7 安装好运行 …
阅读更多...
[Angular 基础] - 表单：模板驱动表单

[Angular 基础] - 表单：模板驱动表单

[Angular 基础] - 表单&#xff1a;模板驱动表单 之前的笔记&#xff1a; [Angular 基础] - routing 路由(上) [Angular 基础] - routing 路由(下) [Angular 基础] - Observable Angular 内置两种表单的支持&#xff0c;这篇写的就是第一种&#xff0c;即模板驱动表单 (Tem…
阅读更多...
wps由于找不到krpt.dll,无法继续执行代码的解决方法

wps由于找不到krpt.dll,无法继续执行代码的解决方法

遇到由于找不到krpt.dll,无法继续执行代码的问题时&#xff0c;理解如何修复这个问题变得至关重要。本文会教大家krpt.dll的恢复流程&#xff0c;并介绍该DLL文件的相关属性。我们将一步步指导你如何处理缺失文件的情况&#xff0c;让你能够解决阻碍代码正常运行的障碍&#xf…
阅读更多...
C语言初学10：typedef

C语言初学10：typedef

一、作用 为用户定义的数据类型取一个新名字 二、对结构体使用typedef定义新的数据类型名字 #include <stdio.h> #include <string.h>typedef struct Books //使用 typedef 来定义一个新的数据类型名字 {char title[50];} book;int main( ) {//book是typedef定…
阅读更多...
背包问题算法

背包问题算法

背包问题算法 0-1背包问题二维数组一维数组 完全背包问题二维数组一维数组 多重背包问题一维数组 0-1背包问题 问题&#xff1a;背包的容量为9&#xff0c;有重量分别为[2, 4, 6, 9]的四个物品&#xff0c;价值分别为[3, 4, 5, 6]&#xff0c;求背包能装的物品的最大价值是多少…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023