【高性能服务器】多进程并发模型

 🔥博客主页： 我要成为C++领域大神
🎥系列专栏：【C++核心编程】 【计算机网络】 【Linux编程】 【操作系统】
❤️感谢大家点赞👍收藏⭐评论✍️

本博客致力于知识分享，与更多的人进行学习交流

对于常见的C/S模型，一个服务端通常需要服务多个客户端。如果使用单行的处理模型，当新的客户端请求服务端的服务时，就必须等待比它先到的客户端的请求全部完成。

因此引入多进程并发服务器模型。多进程并发服务器模型的简单流程图如下所示。父进程创建一个套接字，然后与自己的IP地址、端口号进行绑定。之后调用开始监听来自客户端的敲门，当有客户端来敲门时，accept()接收客户端的连接并创建一个新套接字用于与客户端通信。接下来调用fork()函数，当调用fork()函数时，操作系统会复制当前进程的一个副本，包括进程的代码、数据和状态等信息。如果其返回值为负数，表示创建子进程失败。否则他在父子进程中有不同的返回值：如果返回值为0，表示当前代码正在子进程中执行。如果返回值大于0，表示当前代码正在父进程中执行，返回的值是子进程的进程ID。因此可以使用if-else语句来编写子进程的处理代码。

在子进程中，先关闭从父进程中复制下来监听套接字，这个套接字在子进程中没有用了，纯属浪费资源，之后再进行与客户端的通信。而在父进程中，同理关闭accept()创建的新套接字，然后继续监听客户端的连接请求。

多进程

父进程处理连接请求，子进程处理消息收发

缺点：

1、子进程与客户端高度绑定。如果客户端连接断开频繁，服务器会频繁创建销毁子进程，系统开销较大，资源浪费

2、并发数量取决于进程数量，如果系统可创建的进程较少，那表示服务器并发数受进程数量限制

3、进程模型本身有较大内存开销

使用服务器测试业务：

客户端向标准输入发送小写字符串，服务端响应回复对应大写字符，"abcAS"->"ABCAS"

客户端向服务端发送关键字localtime，服务端响应回复系统时间、

服务端：

#include <stdio.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <string.h>
#include <time.h>#define _SERVER_IP "xxx.xxx.xxx.xxx"
#define _PORT 8080
#define _BACKLOG 128
#define _SHUTDOWN 1
#define _TRUE 1
#define _FALSE 0
#define _IPSIZE 16
#define _RECVLEN 1500int main()
{int recvlen;struct sockaddr_in serverAddr,clientAddr;int server_fd;int client_fd;char Result[_RECVLEN];char client_ip[_IPSIZE];pid_t pid;socklen_t Addrlen;serverAddr.sin_family=AF_INET;serverAddr.sin_port=htons(_PORT);serverAddr.sin_addr.s_addr=htonl(INADDR_ANY);server_fd=socket(AF_INET,SOCK_STREAM,0);bind(server_fd,(struct sockaddr*)&serverAddr,sizeof(serverAddr));listen(server_fd,_BACKLOG);printf("Test TCP Server Version 1.1.0 is Running...\n");time_t tp;char time_buf[100];//存放当前系统时间int toupper_flag;while(_SHUTDOWN){Addrlen=sizeof(clientAddr);if((client_fd=accept(server_fd,(struct sockaddr*)&clientAddr,&Addrlen))>0){//Socket通信bzero(Result,sizeof(Result));bzero(client_ip,sizeof(client_ip));inet_ntop(AF_INET,&clientAddr.sin_addr.s_addr,client_ip,_IPSIZE);printf("Connection From :IP[%s],PORT[%d]\n",client_ip,ntohs(clientAddr.sin_port));sprintf(Result,"Hi [%s] Welcome to my TCP test server!service version 1.1.0...",client_ip);send(client_fd,Result,strlen(Result),0);bzero(Result,sizeof(Result));pid=fork();//创建子进程处理通信，父进程只用于处理连接请求if(pid>0){}else if(pid==0){//读取用户数据，如果用户发的是普通小写字符字符串，转换为大写，如果发送的是local关键字，响应时间//持续响应，循环读写while((recvlen=recv(client_fd,Result,sizeof(Result),0))>0){//处理客户端业务printf("Client Say:%s\n",Result);if(strcmp(Result,"localtime")==0){tp=time(NULL);//获取时间种子ctime_r(&tp,time_buf);time_buf[strcspn(time_buf,"\n")]='\0';printf("[%s]Response SysTime Successfully!\n",client_ip);send(client_fd,time_buf,strlen(time_buf)+1,0);}else{toupper_flag=0;while(recvlen>toupper_flag){Result[toupper_flag]=toupper(Result[toupper_flag]);++toupper_flag;}printf("[%s]Response Toupper Successfully!\n",client_ip);send(client_fd,Result,recvlen,0);}}if(recvlen==0)//客户端退出{close(client_fd);printf("[%s] is Exiting,Kill Child\n",client_ip);exit(0);}}else{perror("fork call failed");exit(0);}close(client_fd);}else{perror("accpet failed");close(server_fd);exit(0);}}close(server_fd);return 0;
}

客户端：

#ifndef _MYSOCK_H_
#define _MYSOCK_H_#include <arpa/inet.h>
#include <ctype.h>
#include <errno.h>
#include <netinet/in.h>
#include <stdio.h>
#include <stdlib.h>
#include <string.h>
#include <sys/select.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <time.h>
#include <unistd.h>int SOCKET(int domain, int type, int protocol);
int BIND(int sockfd, struct sockaddr* addr, socklen_t addrlen);
ssize_t RECV(int sockfd, void* buf, size_t len, int flags);
ssize_t SEND(int sockfd, void* buf, size_t len, int flags);
int CONNECT(int sockfd, struct sockaddr* addr, socklen_t addrlen);
int ACCEPT(int sockfd, struct sockaddr* addr, socklen_t* addrlen);
int LISTEN(int sockfd, int backlog);
char* FGETS(char* s, int size, FILE* stream);
int SELECT(int nfds, fd_set* readfds, fd_set* writefds, fd_set* exceptfds,struct timeval* timeout);
int socket_init();
int return_response(int clientfd, const char* clientip);
//void strDeal(int *client_fd);// 全局变量声明
char recv_buf[1024];
char time_buf[64];
int serverFd, clientFd;
struct sockaddr_in clientAddr;
fd_set set, oset;
int client_array[1020];
int maxfd, ready;
socklen_t addrlen;
char clientip[16];
time_t tp;
ssize_t recvlen;
int toupper_flag;
#define SHUTDOWN 1
#endif
#include "MySock.h"//客户端源码编写，连接服务器成功，服务器反馈信息#define _IP "xxx.xxx.xxx.xxx"
#define _PORT 8080
int main()
{struct sockaddr_in ServerAddr;bzero(&ServerAddr,sizeof(ServerAddr));ServerAddr.sin_family=AF_INET;ServerAddr.sin_port=htons(_PORT);inet_pton(AF_INET,_IP,&ServerAddr.sin_addr.s_addr);int Myfd=SOCKET(AF_INET,SOCK_STREAM,0);//看需求决定是否要绑定char Response[1024];//存放服务端反馈信息ssize_t recvlen;bzero(Response,sizeof(Response));char sendbuf[1024];if((CONNECT(Myfd,(struct sockaddr *)&ServerAddr,sizeof(ServerAddr)))==0){while(1){    if((recvlen=RECV(Myfd,Response,sizeof(Response),0))>0){printf("%s\n",Response);}printf("Please Type Some text:");//读取标准输入发送给服务端FGETS(sendbuf,sizeof(sendbuf),stdin);    sendbuf[strcspn(sendbuf,"\n")]='\0';SEND(Myfd,sendbuf,sizeof(sendbuf),0);}}close(Myfd);printf("Client is Over\n");return 0;
}

运行结果：可以同时运行多个客户端

通过命令查看服务端运行的子进程：

当客户端退出后，杀死子进程

缺点：频繁创建子进程开销大，并且对回收考虑欠佳，会产生僵尸进程

多进程+多线程

在父进程下创建两个线程，一个线程负责处理连接请求，另外一个线程处理子进程的回收。

负责回收的线程通过捕捉SIGCHLD信号触发捕捉函数杀死子进程

如果基于信号数量决定回收操作次数，一定会漏回收，所以回收方式应该是产生一次SIGCHLD信号，尽可能将当前可回收的所有僵尸回收完毕。

由于信号处理行为是共享的，如果产生回收信号，主线程也会尝试捕捉并执行捕捉函数，如果调用了捕捉函数，那么会强制中断主线程中的阻塞函数，影响连接。所以主线程需要设置对SIGCHLD屏蔽，屏蔽在线程创建后，继承给普通线程，普通线程完成捕捉设定，而后解除信号屏蔽。

#include <stdio.h>
#include <stdlib.h>
#include <arpa/inet.h>
#include <sys/socket.h>
#include <string.h>
#include <time.h>
#include <pthread.h>
#include <signal.h>#define _SERVER_IP "xxx.xxx.xxx.xxx"
#define _PORT 8080
#define _BACKLOG 128
#define _SHUTDOWN 1
#define _TRUE 1
#define _FALSE 0
#define _IPSIZE 16
#define _RECVLEN 1500void sig_wait(int n)
{pid_t zpid;while((zpid=waitpid(-1,NULL,WNOHANG))>0){printf("wait Thread Tid [0x%x] Wait Successfully,Zombie %d\n",(unsigned int)pthread_self(),zpid);}
}void * thread_wait(void *arg)
{//设定信号捕捉pthread_detach(pthread_self());struct sigaction act,oact;act.sa_handler=sig_wait;act.sa_flags=0;sigemptyset(&act.sa_mask);sigaction(SIGCHLD,&act,&oact);//解除屏蔽sigprocmask(SIG_SETMASK,&act.sa_mask,NULL);printf("wait Thread [0x%x] is Waiting...\n",(unsigned int)pthread_self());while(1)sleep(1);pthread_exit(NULL);
}int main()
{int recvlen;struct sockaddr_in serverAddr,clientAddr;int server_fd;int client_fd;char Result[_RECVLEN];char client_ip[_IPSIZE];pid_t pid;//主线程设置屏蔽sigset_t set,oldset;sigemptyset(&set);sigaddset(&set,SIGCHLD);sigprocmask(SIG_SETMASK,&set,&oldset);pthread_t tid;pthread_create(&tid,NULL,thread_wait,NULL);//创建回收线程socklen_t Addrlen;serverAddr.sin_family=AF_INET;serverAddr.sin_port=htons(_PORT);serverAddr.sin_addr.s_addr=htonl(INADDR_ANY);server_fd=socket(AF_INET,SOCK_STREAM,0);bind(server_fd,(struct sockaddr*)&serverAddr,sizeof(serverAddr));listen(server_fd,_BACKLOG);printf("Test TCP Server Version 1.1.0 is Running...\n");time_t tp;char time_buf[100];//存放当前系统时间int toupper_flag;while(_SHUTDOWN){Addrlen=sizeof(clientAddr);if((client_fd=accept(server_fd,(struct sockaddr*)&clientAddr,&Addrlen))>0){//Socket通信bzero(Result,sizeof(Result));bzero(client_ip,sizeof(client_ip));inet_ntop(AF_INET,&clientAddr.sin_addr.s_addr,client_ip,_IPSIZE);printf("Connection From :IP[%s],PORT[%d]\n",client_ip,ntohs(clientAddr.sin_port));sprintf(Result,"Hi [%s] Welcome to my TCP test server!service version 1.1.0...",client_ip);send(client_fd,Result,strlen(Result),0);bzero(Result,sizeof(Result));pid=fork();//创建子进程处理通信，父进程只用于处理连接请求if(pid>0){}else if(pid==0){//读取用户数据，如果用户发的是普通小写字符字符串，转换为大写，如果发送的是local关键字，响应时间//持续响应，循环读写while((recvlen=recv(client_fd,Result,sizeof(Result),0))>0){//处理客户端业务printf("Client Say:%s\n",Result);if(strcmp(Result,"localtime")==0){tp=time(NULL);//获取时间种子ctime_r(&tp,time_buf);time_buf[strcspn(time_buf,"\n")]='\0';printf("[%s]Response SysTime Successfully!\n",client_ip);send(client_fd,time_buf,strlen(time_buf)+1,0);}else{toupper_flag=0;while(recvlen>toupper_flag){Result[toupper_flag]=toupper(Result[toupper_flag]);++toupper_flag;}printf("[%s]Response Toupper Successfully!\n",client_ip);send(client_fd,Result,recvlen,0);}}if(recvlen==0)//客户端退出{close(client_fd);printf("[%s] is Exiting,Kill Child\n",client_ip);exit(0);}}else{perror("fork call failed");exit(0);}close(client_fd);	}else{perror("accpet failed");close(server_fd);exit(0);}}close(server_fd);return 0;
}

当客户端进程退出后，成功杀死了僵尸进程

服务端下有两个线程，一个负责创建通信进程，一个负责回收僵尸进程

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

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

相关文章

【深度学习】注意力机制的改进：稀疏注意力、局部注意力、低秩/线性注意力

【深度学习】注意力机制的改进：稀疏注意力、局部注意力、低秩/线性注意力

文章目录 稀疏注意力PVT v2中的稀疏注意力公式 代码示例 局部注意力局部注意力Swin Transformer中的基于窗口的注意力公式 代码示例窗口移位操作&#xff08;Shifted Window&#xff09;实现细节公式代码示例 低秩/线性注意力低秩/线性注意力Linformer公式 代码示例代码解释 稀…
阅读更多...
事务的影子拷贝-系统架构师（二十）

事务的影子拷贝-系统架构师（二十）

1、&#xff08;重点&#xff09;企业信息集成按照组织范围分为企业内部的信息集成和外部信息集成。在企业内部信息集成中&#xff0c;&#xff08;&#xff09;实现了不同系统之间的互操作&#xff0c;使的不同系统之间能够实现数据和方法的共享。&#xff08;&#xff09;实现…
阅读更多...
Unity小知识

Unity小知识

1.当我们把摄像机的内容渲染到RenderTexture上而不是屏幕上时,那么相机的Aspect默认会设置成和RenderTexture的分辨率一样.不过最终如果把RenderTexture作为贴图贴到模型上去的时候还是会被UV拉伸和缩小的。 2.要想自定义UnityPackage的内容&#xff0c;只要找到UnityProject/L…
阅读更多...
H5与小程序：两者有何不同？

H5与小程序：两者有何不同？

H5&#xff0c;即HTML5&#xff0c;是构建Web内容的一种语言描述方式&#xff0c;也是互联网的下一代标准&#xff0c;被认为是互联网的核心技术之一。HTML5是在HTML4.01的基础上进行了一定的改进后的规范&#xff0c;用户在使用任何手段进行网页浏览时看到的内容原本都是HTML格…
阅读更多...
GPT对话代码库——HAL库下 USART 的配置及问题（STM32G431CBT6）

GPT对话代码库——HAL库下 USART 的配置及问题（STM32G431CBT6）

目录 1&#xff0c;问&#xff1a; 1&#xff0c;答&#xff1a; 示例代码 正确的HAL库初始化方式 自定义初始化方式&#xff08;不推荐&#xff09; 总结 2&#xff0c;问&#xff1a; 2&#xff0c;答&#xff1a; 代码详细解释 初始部分 主初始化部分 初始化调用…
阅读更多...
QT学习积累——如何提高Qt遍历list的效率

QT学习积累——如何提高Qt遍历list的效率

目录 引出Qt遍历list提高效率显示函数的调用使用&与不使用&除法的一个坑 总结自定义信号和槽1.自定义信号2.自定义槽3.建立连接4.进行触发 自定义信号重载带参数的按钮触发信号触发信号拓展 lambda表达式返回值mutable修饰案例 引出 QT学习积累——如何提高Qt遍历list…
阅读更多...
python 操作网页

python 操作网页

使用selenium库获取网页元素的属性值是一个常见的需求。以下是一个Python代码示例，展示了如何使用selenium来获取一个链接的href属性以及一个输入框的value属性。 首先，请确保您已经安装了selenium库，并且配置了WebDriver（如ChromeDriver）以驱动浏览器。 pythonfrom sele…
阅读更多...
如何避免Java中的内存泄漏？

如何避免Java中的内存泄漏？

如何避免Java中的内存泄漏&#xff1f; 大家好&#xff0c;我是免费搭建查券返利机器人省钱赚佣金就用微赚淘客系统3.0的小编&#xff0c;也是冬天不穿秋裤&#xff0c;天冷也要风度的程序猿&#xff01; 在Java开发中&#xff0c;内存泄漏&#xff08;Memory Leak&#xff0…
阅读更多...
CSF视频文件格式转换WMV格式（2024年可用）

CSF视频文件格式转换WMV格式（2024年可用）

如果大家看过一些高校教学讲解视频的话&#xff0c;很可能见过这样一个难得的格式&#xff0c;".csf "&#xff0c;非常漂亮 。 用暴风影音都可以打开观看&#xff0c;会自动下载解码。 但是一旦我们想要利用或者上传视频的时候就麻烦了&#xff0c;一般网站不认这…
阅读更多...
STM32重定向printf到串口（重写fputc不生效）

STM32重定向printf到串口（重写fputc不生效）

使用STM32开发&#xff0c;想用printf把输出打印到串口&#xff0c;需要重定向printf函数。 网上一搜全都是重写fpuc的&#xff0c;但这只针对使用了MicroLIB的情况&#xff0c;如果你使用STM32CubeMX配置了CMake或者Makefile项目&#xff0c;这种方法是根本不可行的&#xff0…
阅读更多...
为什么PS5运行游戏的效果往往比号称更强大的Xbox Series X更好？

为什么PS5运行游戏的效果往往比号称更强大的Xbox Series X更好？

在第九代游戏机即将进入第四个年头之际&#xff0c;有一个问题仍未得到解答&#xff1a;索尼的 PS5 游戏机的性能如何经常超越纸面性能更强大的微软 Xbox X 系列&#xff1f; 几个明显的例子包括《生化危机 4》、《使命召唤&#xff1a;黑色行动&#xff1a;冷战》和新一代更新…
阅读更多...
【支撑文档】系统安全保证措施（word原件）

【支撑文档】系统安全保证措施（word原件）

软件安全保证措施word 软件所有全套资料获取进主页或者本文末个人名片直接。
阅读更多...
跨平台营销的智能协同：Kompas.ai如何整合多渠道策略

跨平台营销的智能协同：Kompas.ai如何整合多渠道策略

引言 在数字化营销的今天&#xff0c;消费者的注意力分散在多个平台上。品牌要想有效地吸引和保持消费者的关注&#xff0c;就必须采取跨平台营销策略。Kompas.ai&#xff0c;作为一款智能营销工具&#xff0c;能够帮助品牌实现这一目标。 跨平台营销的重要性 跨平台营销能够…
阅读更多...
智慧园区大数据云平台建设方案（Word原件）

智慧园区大数据云平台建设方案（Word原件）

第一章 项目建设背景及现状 第二章 园区创新发展趋势 第三章 工业园区大数据存在的问题 第四章 智慧工业园区大数据建设目的 第五章 智慧园区总体构架 第六章 系统核心组件 第七章 智慧工业园区大数据平台规划设计 获取方式&#xff1a;本文末个人名片直接获取。 软件资料清单…
阅读更多...
【报错】安装clang-14 的时候，报错E: 无法定位软件包 clang-14

【报错】安装clang-14 的时候，报错E: 无法定位软件包 clang-14

1 报错 安装clang-14，命令如下： sudo apt-get install clang-14 报错为E: 无法定位软件包 clang-14 2 解决方法 使用其他的安装方法，命令如下： wget https://apt.llvm.org/llvm.sh # 添加权限chmod +x llvm.shsudo ./llvm.sh 14 all # 卸载第3步安装过程中安装无用的…
阅读更多...
mysql 获取枚举的随机值

mysql 获取枚举的随机值

mysql 获取枚举的随机值 1.需求描述2.使用到的函数elt函数语法示例 RAND() 函数FLOOR()函数 3.解决方案手写生成&#xff1a;少量数据从表中生成&#xff1a;多数据 4.实战 1.需求描述 在MySQL中&#xff0c;您可以使用ENUM类型定义列&#xff0c;并且可以从中选择随机值。但是…
阅读更多...
超融合服务器挂载硬盘--linux系统

超融合服务器挂载硬盘--linux系统

项目中需要增加服务器的硬盘容量&#xff0c;通过超融合挂载了硬盘后&#xff0c;还需要添加到指定的路径下&#xff0c;这里记录一下操作步骤。 一&#xff1a;通过管理界面挂载硬盘 这一步都是界面操作&#xff0c;登录超融合控制云台后&#xff0c;找到对应的服务器&#…
阅读更多...
uniapp中实现跳转到外部链接（也就是a标签的功能）

uniapp中实现跳转到外部链接（也就是a标签的功能）

uniapp中实现跳转到外部链接&#xff08;也就是a标签的功能&#xff09; 项目中需要做到跳转到外部链接&#xff0c;网上找了很多都不是很符合自己的要求&#xff0c;需要编译成app后是跳转到游览器打开链接&#xff0c;编译成web是在新窗口打开链接。实现的代码如下&#xff1…
阅读更多...
矩阵、混剪、大盘，3大功能升级优化！助力企业高效管理！

矩阵、混剪、大盘，3大功能升级优化！助力企业高效管理！

在数字化转型的浪潮中&#xff0c;企业对于工具与技术的需求愈发强烈。 为满足市场需求&#xff0c;本月【云略】为各企业上线了便捷功能&#xff0c;赋能企业经营决策和业务增长。 矩阵管理 √【矩阵号管理】抖音支持设置城市IP 内容管理 √【混剪任务】支持关联智能发布计…
阅读更多...
PDF文档如何统计字数，统计PDF文档字数的方法有哪些?

PDF文档如何统计字数，统计PDF文档字数的方法有哪些?

在平时使用pdf阅读或者是处理文档的时候&#xff0c;常常需要统计文档的字数。pdf在查看文字时其实很简单。 PDF文档是一种常见的电子文档格式&#xff0c;如果需要对PDF文档中的字数进行统计&#xff0c;可以使用以下方法&#xff1a; Adobe Acrobat DC&#xff1a;Adobe Ac…
阅读更多...
最新文章

Copyright @ 2022~2023