Linux网络编程:TCP并发服务器实现

目录

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 8142while(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 <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <signal.h>
#include <sys/wait.h>#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<addr><port>\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 8142while(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 8142int 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 <stdio.h>
#include <sys/socket.h>
#include <sys/types.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <unistd.h>
#include <string.h>
#include <pthread.h>#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<addr><port>\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 8142int 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并发服务器。

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

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

相关文章

一文了解美国洛杉矶私有云的亮点优势

美国洛杉矶作为全球科技与经济的重要中心&#xff0c;其私有云服务的亮点优势备受瞩目。以下是对洛杉矶私有云优势的科普介绍。 首先&#xff0c;洛杉矶私有云的核心优势在于其安全性。在私有云环境中&#xff0c;数据被存储在专有的、隔离的服务器上&#xff0c;这意味着只有授…

同创优配正规炒股A股三大指数集体收涨 创指重回1900点关口

查查配5月9日电 周四,A股三大指数震荡上扬。截至收盘,上证指数涨0.83%,报3154.32点;深证成指涨1.55%,报9788.07点;创业板指涨1.87%,报1900.01点。总体上个股涨多跌少,全市场超4200只个股上涨。沪深两市今日成交额9011亿元,较上个交易日放量367亿元。 同创优配是AAA 级诚信经营…

【win10 文件夹数量和看到不一致查看隐藏文件已经打开,Thumb文件作妖】

目录 任务介绍&#xff1a;重命名规则修改前修改后 实现思路VB代码实现BUG犯罪现场&#xff08;眼见不一定为实&#xff09;破案1&#xff1a;抓顶风作案的反贼&#xff01;&#xff01;&#xff01;破案2&#xff1a;破隐身抓刺客&#xff01;&#xff01;&#xff01;杀器&am…

机器人系统ros2-开发实践08-了解如何使用 tf2 来访问坐标帧转换(Python)

tf2 库允许你在 ROS 节点中查询两个帧之间的转换。这个查询可以是阻塞的&#xff0c;也可以是非阻塞的&#xff0c;取决于你的需求。下面是一个基本的 Python 示例&#xff0c;展示如何在 ROS 节点中使用 tf2 查询帧转换。 本教程假设您已完成tf2 静态广播器教程 (Python)和tf…

今日早报 每日精选15条新闻简报 每天一分钟 知晓天下事 5月10日,星期五

每天一分钟&#xff0c;知晓天下事&#xff01; 2024年5月10日 星期五 农历四月初三 1、 商务部&#xff1a;汽车以旧换新补贴可与新能源汽车购置税减免等叠加享受。 2、 教育部&#xff1a;京津优质中小学基础教育资源同雄安共享。 3、 医保局&#xff1a;发挥零售药店等不同…

HarmonyOS NEXT星河版之美团外卖点餐功能实战(上)

文章目录 一、目标二、开撸2.1 目录结构2.2 页面模块拆分2.3 主体拆分布局2.4 底部购物车布局2.5 顶部布局2.6 点菜布局---左2.7 菜品Item封装2.7 点菜布局---右2.8 主页面整体布局 三、小结 一、目标 二、开撸 2.1 目录结构 2.2 页面模块拆分 将页面主体拆为三部分&#xff…

Middle for Mac:简洁高效的文本编辑软件

追求简洁与高效&#xff1f;Middle for Mac将是您文本编辑的最佳选择。这款Mac平台上的文本编辑器&#xff0c;以其独特的魅力和实用的功能&#xff0c;赢得了众多用户的喜爱。 Middle注重用户体验&#xff0c;采用简洁直观的界面设计&#xff0c;让您能够迅速上手并享受高效的…

【设计模式】JAVA Design Patterns——Abstract-document

&#x1f50d; 目的 使用动态属性&#xff0c;并在保持类型安全的同时实现非类型化语言的灵活性。 &#x1f50d; 解释 抽象文档模式使您能够处理其他非静态属性。 此模式使用特征的概念来实现类型安全&#xff0c;并将不同类的属性分离为一组接口 真实世界例子 考虑由多个部…

docker学习笔记(五):harbor仓库搭建与简单应用

harbor私有仓库 简介 Docker容器应用的开发和运行离不开可靠的镜像管理&#xff0c;虽然Docker官方也提供了公共的镜像仓库&#xff0c;但是从安全和效率等方面考虑&#xff0c;部署私有环境内的Registry也是非常必要的。Harbor是由VMware公司开源的企业级的Docker Registry管…

组件目录存放问题

目录 一、思考引入 二、组件分类 三、组件分类的目的 一、思考引入 .vue文件本质无区别&#xff0c;而路由相关的组件&#xff0c;为什么要放在views目录呢&#xff1f; 二、组件分类 .vue文件分2类&#xff1a;页面组件和复用组件。注意&#xff1a;都是.vue文件&#xff…

漫画对话 ai翻译

復讐の教科書ーー81 81-1 いい加減吐け&#xff01;&#xff01;冴木&#xff01;&#xff01; 快说吧&#xff01;&#xff01;冴木&#xff01;&#xff01; お前が一連の事件の犯人なんだろ&#xff01;&#xff1f; 你就是连续事件的犯人吧&#xff01;&#xff1f; だか…

游戏工作室如何利用惯性动作捕捉技术制作动画?

随着动捕设备不断进步和游戏行业的发展&#xff0c;惯性动作捕捉技术在游戏开发领域逐渐普及。惯性动作捕捉技术&#xff0c;可以精准捕捉现实世界中的真人动作&#xff0c;并将其精准应用于虚拟角色上&#xff0c;使游戏中的角色动作可以呈现出更写实、逼真和沉浸感&#xff0…

##10 卷积神经网络(CNN):深度学习的视觉之眼

文章目录 前言1. CNN的诞生与发展2. CNN的核心概念3. 在PyTorch中构建CNN4. CNN的训练过程5. 应用:使用CNN进行图像分类5. 应用:使用CNN进行时序数据预测代码实例7. 总结与展望前言 在深度学习的领域中,卷积神经网络(CNN)已经成为视觉识别任务的核心技术。自从AlexNet在2…

光伏设备制造5G智能工厂数字孪生可视化平台,推进行业数字化转型

光伏设备制造5G智能工厂数字孪生可视化平台&#xff0c;推进行业数字化转型。光伏设备制造5G智能工厂数字孪生可视化平台是光伏行业数字化转型的重要一环。通过数字孪生平台&#xff0c;光伏设备制造企业可以实现对生产过程的全面监控和智能管理&#xff0c;提高生产效率&#…

基于51单片机的智能导盲手杖—超声波测距

基于51单片机的智能导盲手杖 &#xff08;仿真&#xff0b;程序原理图&#xff0b;PCB设计报告&#xff09; 功能介绍 具体功能&#xff1a; 1.显示前方障碍物距离。 2.实时测量距离&#xff0c;并通过蜂鸣器提醒距离过短&#xff0c;蜂鸣器蜂鸣发出预警。 3.可以通过按键调…

吴恩达机器学习笔记:第 9 周-17大规模机器学习(Large Scale Machine Learning)17.1-17.2

目录 第 9 周 17、 大规模机器学习(Large Scale Machine Learning)17.1 大型数据集的学习17.2 随机梯度下降法 第 9 周 17、 大规模机器学习(Large Scale Machine Learning) 17.1 大型数据集的学习 如果我们有一个低方差的模型&#xff0c;增加数据集的规模可以帮助你获得更好…

【代码随想录】回溯问题之组合

前言 更详细的在大佬的代码随想录 (programmercarl.com) 本系列仅是简洁版笔记&#xff0c;为了之后方便观看 解决的类型问题 组合无序&#xff0c;排列有序 组合切割子集排列&#xff08;强调元素的顺序&#xff09;棋牌问题&#xff08;n皇后&#xff0c;数独&#xff0…

jsbsim 调 pid 记录

1.先调俯仰角 pitch 俯仰角不能超过 xml 文件里定义的爬升角 高度不对&#xff0c;调 pitch 角的 pid&#xff0c;俯仰角 理论上调pid&#xff1a; 响应快了&#xff0c;P调小&#xff1b;响应慢了&#xff0c;P调大 I消除稳态误差&#xff0c;I调大 D防止震荡&#xff0c;震…

AWS Lambda 第一个例子Hello (JAVA)

什么是Serverless&#xff08;无服务器计算&#xff09; 行业通常所说的Serverless&#xff0c;主要是指“无服务器计算&#xff08;Serverless Computing&#xff09;”。无服务器计算&#xff0c;并不是真的不需要服务器&#xff0c;而是说&#xff0c;对于用户&#xff0c;…

Hadoop3:HDFS的Shell操作(常用命令汇总)

一、简介 什么是HDFS的Shell操作&#xff1f; 很简单&#xff0c;就是在Linux的终端&#xff0c;通过命令来操作HDFS。 如果&#xff0c;你们学习过git、docker、k8s&#xff0c;应该会发现&#xff0c;这些命令的特点和shell命令非常相似 二、常用命令 1、准备工作相关命令…