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

目录

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.mzph.cn/news/742063.shtml

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

相关文章

计算机模式识别的基本步骤与详解

计算机模式识别的基本步骤与详解

在数字化时代的浪潮中，计算机模式识别技术以其卓越的能力，在图像识别、语音识别、自然语言处理等领域展现出了广泛的应用前景。那么，计算机究竟是如何进行模式识别的呢？本文将详细解析计算机进行模式识别的基本步骤，并深入探讨每个步骤的核心要点。 一、模式识别的基本步…
阅读更多...
unity中实现场景跳转

unity中实现场景跳转

1&#xff0c;第一步创建2个场景&#xff08;右键资源窗口&#xff0c;名字这里我取的1111和2222&#xff09; 2.添加跳转按钮&#xff08;双击其中一个场景并添加按钮&#xff09; 3.编辑按钮的文字&#xff08;将原本的按钮打开点击里面的text&#xff0c;就可以在右边编辑文…
阅读更多...
【JSON】JSON解析 fastJson框架

【JSON】JSON解析 fastJson框架

一、JSON &#xff08;一&#xff09;、简介 JSON(JavaScript Object Notation, JS 对象简谱) 是一种轻量级的数据交换格式。 ​ 简洁和清晰的层次结构使得 JSON 成为理想的数据交换语言。 ​ 易于人阅读和编写&#xff0c;同时也易于机器解析和生成&#xff0c;并有效地提…
阅读更多...
MySQL8.0安装教程+使用Navicat远程连接

MySQL8.0安装教程+使用Navicat远程连接

MySQL8.0安装教程使用Navicat远程连接 版本&#xff1a;MySQL8.0.28 环境&#xff1a;Windows11 1.MySQL下载 进入官网https://www.mysql.com/进行下载&#xff1a; 2.安装MySQL 下载好后&#xff0c;点击运行程序开始安装&#xff0c;安装步骤如下&#xff1a; 以下步骤验…
阅读更多...
学习Java的第九天

学习Java的第九天

本章将学习什么是类的无参、带参方法又是什么 一、什么是类的无参方法 类是由一组具有相同属性和共同行为的实体抽象而来。对象执行的操作是通过编写类的方法实现的。显而易见&#xff0c;类的方法是一个功能模块&#xff0c;其作用是“做一件事情”。 1、类的方法必须包括以…
阅读更多...
【海贼王的数据航海】排序——概念|直接插入排序|希尔排序

【海贼王的数据航海】排序——概念|直接插入排序|希尔排序

目录 1 -> 排序的概念及其运用 1.1 -> 排序的概念 1.2 -> 常见的排序算法 2 -> 插入排序 2.1 -> 基本思想 2.2 -> 直接插入排序 2.2.1 -> 代码实现 2.3 -> 希尔排序(缩小增量排序) 2.3.1 -> 代码实现 1 -> 排序的概念及其运用 1.1 -&g…
阅读更多...
React改变数据【案例】

React改变数据【案例】

State传统方式 <!DOCTYPE html> <html lang"en"> <head><meta charset"UTF-8"><meta name"viewport" content"widthdevice-width, initial-scale1.0"><title>React Demo</title> <!--…
阅读更多...
linuxOPS基础_vmware虚拟机安装及介绍

linuxOPS基础_vmware虚拟机安装及介绍

虚拟机概念 什么是虚拟机&#xff1f; 虚拟机&#xff0c;有些时候想模拟出一个真实的电脑环境&#xff0c;碍于使用真机安装代价太大&#xff0c;因此而诞生的一款可以模拟操作系统运行的软件。 虚拟机目前有2 个比较有名的产品&#xff1a;vmware 出品的vmware workstatio…
阅读更多...
Jmeter(五) - 从入门到精通 - 创建网络计划实战和创建高级Web测试计划（详解教程）

Jmeter(五) - 从入门到精通 - 创建网络计划实战和创建高级Web测试计划（详解教程）

1.简介 上一篇中已经将其的理论知识介绍了一下&#xff0c;这一篇就带着大家一步一步的把上一篇介绍的理论知识实践一下&#xff0c;然后再说一下如何创建高级web测试计划。 2.网络计划实战 通过上一篇的学习&#xff0c;将其分类为&#xff1a; &#xff08;1&#xff09;不需…
阅读更多...
蓝桥杯真题讲解：三国游戏（贪心）

蓝桥杯真题讲解：三国游戏（贪心）

蓝桥杯真题讲解&#xff1a;三国游戏&#xff08;贪心&#xff09; 一、视频讲解二、正解代码 一、视频讲解 蓝桥杯真题讲解&#xff1a;三国游戏&#xff08;贪心&#xff09; 二、正解代码 //三国游戏&#xff1a;贪心 #include<bits/stdc.h> #define int long lon…
阅读更多...
Springboot applicaton.yml logging output

Springboot applicaton.yml logging output

debug model will show the SQL running process
阅读更多...
1688中国站获得实力档案信息 API 返回值说明

1688中国站获得实力档案信息 API 返回值说明

公共参数 名称类型必须描述keyString是申请免费调用key&#xff08;必须以GET方式拼接在URL中&#xff09;secretString是调用密钥api_nameString是API接口名称&#xff08;包括在请求地址中&#xff09;[item_search,item_get,item_search_shop等]cacheString否[yes,no]默认y…
阅读更多...
物体检测-系列教程27：YOLOV5 源码解析17（训练脚本解读：训练函数4）

物体检测-系列教程27：YOLOV5 源码解析17（训练脚本解读：训练函数4）

&#x1f60e;&#x1f60e;&#x1f60e;物体检测-系列教程 总目录 有任何问题欢迎在下面留言 本篇文章的代码运行界面均在Pycharm中进行 本篇文章配套的代码资源已经上传 点我下载源码 24、epoch循环训练------更新、评估、保存 这部分是训练过程的每个epoch结束之前执行的一…
阅读更多...
同城即配年度观察：顺丰同城率先全年盈利，行业破局迎参考

同城即配年度观察：顺丰同城率先全年盈利，行业破局迎参考

即时消费趋势增强&#xff0c;“万物到家即时可得”成为了消费新常态。这创造出不可忽视的场景潜力&#xff0c;也在无形中让龙头企业的发展质量走到突破点。 3月11日晚&#xff0c;“第三方即时配送第一股”顺丰同城发布公告称&#xff0c;预期实现2023年全年盈利&#xff0c…
阅读更多...
Python的os模块，必学干货!

Python的os模块，必学干货!

1.os模块作用 主要是用来完成对文件或者文件夹的操作 2.导入os模块 import os 3.listdir() 查看指定目录下面所有的文件或者文件夹 print(os.listdir(r"D:\PycharmProjects\pythonProject")) # [.idea, 01_语法, 02_函数, 03_类型转换, 04_运算符, 05_分支结…
阅读更多...
深入解析C++树形关联式容器：map、set及其衍生容器的使用与原理

深入解析C++树形关联式容器：map、set及其衍生容器的使用与原理

文章目录 一、引言二、关联式容器的中的 paira.pair 的创建及使用b.pair 间的比较 三、 map 与 set 详解1. map 的基本操作2. set 的基本操作3.关联式容器的迭代器 四、 multimap 与 multiset 的特性五、关联式容器的使用技巧与注意事项1. 键值类型的选择与设计2. 自定义比较函…
阅读更多...
Python基础学习(4)散列类型(无序序列)

Python基础学习(4)散列类型(无序序列)

文章目录 一,认识集合1.定义2.运算 二.集合方法1.删2.增 三.认识字典1.字典(dict)2.特性3.字典方法①查②改③增④删 四.声明空变量 Python基础学习(1)基本知识 Python基础学习(2)序列类型方法与数据类型转换 Python基础学习(3)进阶字符串(格式化输出) Python基础学习(4)散列类…
阅读更多...
专题1 - 双指针 - leetcode 15. 三数之和 - 中等难度

专题1 - 双指针 - leetcode 15. 三数之和 - 中等难度

leetcode 15. 三数之和 - 点击直达 leetcode 15. 三数之和 中等难度 双指针1. 题目详情1. 原题链接2. 基础框架 2. 解题思路1. 题目分析2. 算法原理3. 时间复杂度 3. 代码实现4. 知识与收获 leetcode 15. 三数之和 中等难度 双指针 1. 题目详情 给你一个整数数组 nums &#…
阅读更多...
通过xlsx库解析读取excel表格内容

通过xlsx库解析读取excel表格内容

一、使用 有时项目中有需要前端自己将本地的excel文件导入并获取内部数据&#xff0c;最终处理数据&#xff08;批量导入等场景&#xff09; 这时我们就可以用到一个库&#xff08;xlsx&#xff09;来读取excel中的内容&#xff0c;然后通过其API能力将数据转换成json格式 具…
阅读更多...
Pytorch实战01——CIAR10数据集

Pytorch实战01——CIAR10数据集

目录 1、model.py文件 &#xff08;预训练的模型&#xff09; 2、train.py文件&#xff08;会产生训练好的.th文件&#xff09; 3、predict.py文件&#xff08;预测文件&#xff09; 4、结果展示&#xff1a; 1、model.py文件 &#xff08;预训练的模型&#xff09; impor…
阅读更多...
最新文章

Copyright @ 2022~2023