多线程|多进程|高并发网络编程

在这里插入图片描述

一.多进程并发服务器

多进程并发服务器是一种经典的服务器架构，它通过创建多个子进程来处理客户端连接，从而实现并发处理多个客户端请求的能力。

概念：

  1. 服务器启动时，创建主进程，并绑定监听端口。
  2. 当有客户端连接请求时，主进程接受连接，并创建一个子进程来处理该客户端连接。
  3. 子进程与客户端进行通信，处理请求和发送响应。
  4. 主进程继续监听新的连接请求。
  5. 子进程完成任务后，可以选择终止或继续处理其他连接，根据需求选择是否重复循环。

优点：

  1. 高并发处理能力：每个子进程都可以独立地处理一个客户端连接，利用多核处理器的优势，实现高并发处理能力，提高服务器的吞吐量。
  2. 稳定性：每个子进程都是独立的，一个进程出现问题不会影响其他进程，提高了服务器的稳定性和容错能力。
  3. 简单直观：采用多进程模型实现并发服务器相对简单，代码可读性高，易于理解和维护。
  4. 跨平台：多进程并发服务器概念适用于各种操作系统，不仅限于Linux平台。

缺点：

  1. 高资源消耗：每个子进程都需要独立的资源，包括内存、文件描述符等，当并发连接数较高时，会消耗大量的系统资源。
  2. 进程间通信：各个子进程之间的通信需要额外的机制，例如管道、共享内存等，增加了复杂性。
  3. 上下文切换开销：进程间切换的开销相对较大，会影响性能。
  4. 调试困难：由于每个子进程独立执行，调试和定位问题可能会变得复杂。

综上所述，多进程并发服务器能够满足高并发处理需求，并具有稳定性和简单性等优点。然而，它也存在资源消耗较高和调试困难等缺点，根据实际需求和应用场景选择合适的服务器架构是很重要的。

案例

利用多进程，在TCP通信的基础上，实现服务器可以同时连接多个客户端。实现大小写转换。

service.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <arpa/inet.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <signal.h>
#include <sys/wait.h>void handler(int sig)
{if (sig == SIGCHLD){while(waitpid(0,NULL,WNOHANG)>0);}
}
int main(int argc, char const *argv[])
{//1.建立socket套接字int socked = socket(AF_INET, SOCK_STREAM, 0);if (socked < 0){perror("socket is err");return -1;}//2.bind绑定服务器ip和端口号struct sockaddr_in saddr, caddr;saddr.sin_family = AF_INET;saddr.sin_port = htons(atoi(argv[1]));saddr.sin_addr.s_addr = inet_addr("0.0.0.0");int len = sizeof(caddr);int rev = bind(socked, (struct sockaddr *)(&saddr), sizeof(saddr));if (rev < 0){perror("bind is err");return 0;}//3.listen设置最大同时链接数量rev = listen(socked, 32);if (rev < 0){perror("rev is err");return 0;}//4.建立子进程负责服务器给客户端发送消息,并且主进程不结束,此进程不结束char buf[1024] = {0};int size=0;while (1){int acceptfd = accept(socked, (struct sockaddr *)(&caddr), &len);if (acceptfd < 0){perror("accept is err");return 0;}pid_t pid = fork();if (pid < 0){perror("pid is err");return 0;}else if (pid == 0){//子进程,每个子进程维护一个客户端//不许要监听,直接关掉close(socked);while (1){int flage = recv(acceptfd, buf, sizeof(buf), 0);if (flage < 0){perror("recv is err");}else if (flage == 0){printf("ip:%s is close\n", inet_ntoa(caddr.sin_addr));close(acceptfd);break;}else{size = strlen(buf);for (int i = 0; i < size; ++i){if (buf[i] >= 'a' && buf[i] <= 'z')buf[i] = buf[i] + ('A' - 'a');elsebuf[i] = buf[i] + ('a' - 'A');}printf("%d %s\n",getpid(),buf);send(acceptfd, buf, sizeof(buf), 0);}}}else{//主进程回收子线程资源close(acceptfd);//异步节约资源signal(SIGCHLD, handler);}}return 0;
}

client.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <arpa/inet.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>int main(int argc, char const *argv[])
{//1.socket建立文件描述符int fd = socket(AF_INET, SOCK_STREAM, 0);if (fd < 0){perror("socket is err");}//2.connect连接服务器struct sockaddr_in saddr;saddr.sin_family = AF_INET;saddr.sin_port = htons(atoi(argv[2]));saddr.sin_addr.s_addr = inet_addr(argv[1]);int flage = connect(fd, (struct sockaddr *)(&saddr), sizeof(saddr));if (flage < 0){perror("connect is err");}//3.服务器端不断发送数据,接受服务器转化后的数据char buf[1024] = {0};while (1){//memset(buf,0,sizeof(buf));fgets(buf, sizeof(buf), stdin);if (strncmp(buf,"quit#",5)==0){break;}if (buf[strlen(buf) - 1] == '\n')buf[strlen(buf) - 1] = '\0';send(fd, buf, sizeof(buf), 0);flage = recv(fd, buf, sizeof(buf), 0);if (flage < 0){perror("recv is err");}else{fprintf(stdout, "%s\n", buf);}}close(fd);return 0;
}

二.多线程并发服务器

多线程并发服务器是一种服务器架构，通过创建多个线程来处理客户端连接，实现并发处理多个客户端请求的能力。下面是多线程并发服务器的概念和一些优点：

概念：

  1. 服务器启动时，创建主线程，并绑定监听端口。
  2. 当有客户端连接请求时，主线程接受连接，并创建一个或多个线程来处理该客户端连接。
  3. 线程与客户端进行通信，处理请求和发送响应。
  4. 主线程继续监听新的连接请求。
  5. 线程完成任务后，选择终止或继续处理其他连接，根据需求选择是否重复循环。

优点：

  1. 资源效率：线程相比进程，创建和销毁的开销较小，占用的资源较少，特别是共享的资源，如文件描述符，可以在多个连接之间共享，提高了资源的利用效率。
  2. 响应速度：线程之间的切换开销较小，内存空间共享，可以快速响应客户端请求，减少了连接等待时间。
  3. 简单直观：与多进程相比，多线程实现并发服务器更简单直观，代码可读性高，易于理解和维护。
  4. 可扩展性：线程可轻松地添加和删除，适应不断变化的连接数需求，提供更好的可扩展性。
  5. 共享数据简便：线程之间共享的数据结构可以直接访问，不需要像进程间通信一样使用额外的机制。

缺点：

  1. 数据同步问题：多线程共享数据可能导致竞态条件和数据一致性问题，需要使用锁或其他同步机制来保证线程安全。
  2. 调试困难：由于线程之间共享同一进程的内存空间，调试和定位问题可能会变得复杂。
  3. 并行性限制：在某些情况下，多线程服务器的并行性可能受限于系统中可用的CPU核心数量。
  4. 需要考虑线程安全：编写线程安全的代码可能需要更多的开发工作和考虑，避免数据竞争和死锁等问题。

综上所述，多线程并发服务器能够满足高并发处理需求，并具有资源效率、响应速度、简单性和可扩展性等优点。然而，它也存在数据同步问题和调试困难等缺点，根据实际需求和应用场景选择合适的服务器架构是很重要的。

案例

利用多线程，在TCP通信的基础上，实现服务器可以同时连接多个客户端。实现大小写转换。

service.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <arpa/inet.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>
#include <signal.h>
#include <sys/wait.h>
#include <pthread.h>struct client
{int acceptfd;struct sockaddr_in caddr;
};void *my_pthread(void *p)
{char buf[1024] = {0};int size = 0;struct client *cl = (struct client *)p;int acceptfd = cl->acceptfd;struct sockaddr_in caddr = cl->caddr;while (1){int flage = recv(acceptfd, buf, sizeof(buf), 0);if (flage < 0){perror("recv is err");}else if (flage == 0){printf("ip:%s is close\n", inet_ntoa(caddr.sin_addr));close(acceptfd);break;}else{size = strlen(buf);for (int i = 0; i < size; ++i){if (buf[i] >= 'a' && buf[i] <= 'z')buf[i] = buf[i] + ('A' - 'a');elsebuf[i] = buf[i] + ('a' - 'A');}send(acceptfd, buf, sizeof(buf), 0);}}close(acceptfd);return 0;
}int main(int argc, char const *argv[])
{//1.建立socket套接字int socked = socket(AF_INET, SOCK_STREAM, 0);if (socked < 0){perror("socket is err");return -1;}//2.bind绑定服务器ip和端口号struct sockaddr_in saddr, caddr;saddr.sin_family = AF_INET;saddr.sin_port = htons(atoi(argv[1]));saddr.sin_addr.s_addr = inet_addr("0.0.0.0");int len = sizeof(caddr);int rev = bind(socked, (struct sockaddr *)(&saddr), sizeof(saddr));if (rev < 0){perror("bind is err");return 0;}//3.listen设置最大同时链接数量rev = listen(socked, 32);if (rev < 0){perror("rev is err");return 0;}//4.建立子进程负责服务器给客户端发送消息,并且主进程不结束,此进程不结束int i = 0;pthread_t tid;struct client ti[1024] = {0};while (1){int acceptfd = accept(socked, (struct sockaddr *)(&caddr), &len);if (acceptfd < 0){perror("accept is err");return 0;}ti[i].acceptfd = acceptfd;ti[i].caddr = caddr;pthread_create(&tid, NULL, my_pthread, (void *)&ti[i]);pthread_detach(tid);++i;}return 0;
}

client.c

#include <stdio.h>
#include <sys/types.h>
#include <sys/socket.h>
#include <netinet/in.h>
#include <netinet/ip.h>
#include <arpa/inet.h>
#include <string.h>
#include <stdlib.h>
#include <unistd.h>int main(int argc, char const *argv[])
{//1.socket建立文件描述符int fd = socket(AF_INET, SOCK_STREAM, 0);if (fd < 0){perror("socket is err");}//2.connect连接服务器struct sockaddr_in saddr;saddr.sin_family = AF_INET;saddr.sin_port = htons(atoi(argv[2]));saddr.sin_addr.s_addr = inet_addr(argv[1]);int flage = connect(fd, (struct sockaddr *)(&saddr), sizeof(saddr));if (flage < 0){perror("connect is err");}//3.服务器端不断发送数据,接受服务器转化后的数据char buf[1024] = {0};while (1){//memset(buf,0,sizeof(buf));fgets(buf, sizeof(buf), stdin);if (strncmp(buf,"quit#",5)==0){break;}if (buf[strlen(buf) - 1] == '\n')buf[strlen(buf) - 1] = '\0';send(fd, buf, sizeof(buf), 0);flage = recv(fd, buf, sizeof(buf), 0);if (flage < 0){perror("recv is err");}else{fprintf(stdout, "%s\n", buf);}}close(fd);return 0;
}

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

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

相关文章

LLM 04-大模型的数据

LLM 04-大模型的数据

LLM 03-大模型的数据 到目前为止&#xff0c;我们已经讨论了大型语言模型的行为&#xff08;能力和损害&#xff09;。现在&#xff0c;我们要剥开洋葱的第一层&#xff0c;开始讨论这些模型是如何构建的。任何机器学习方法的起点都是训练数据&#xff0c;因此这就是我们开始的…
阅读更多...
【深度学习】 Python 和 NumPy 系列教程（十三）：Matplotlib详解：1、2d绘图（上）：折线图、散点图、柱状图、直方图、饼图

【深度学习】 Python 和 NumPy 系列教程（十三）：Matplotlib详解：1、2d绘图（上）：折线图、散点图、柱状图、直方图、饼图

目录 一、前言 二、实验环境 三、Matplotlib详解 0、绘图风格 1、2d绘图类型 0. 设置中文字体 1. 折线图&#xff08;Line Plot&#xff09; 2. 散点图&#xff08;Scatter Plot&#xff09; 3. 柱状图&#xff08;Bar Plot&#xff09; 4. 直方图&#xff08;Histogr…
阅读更多...
【JavaSE笔记】方法

【JavaSE笔记】方法

一、前言 Java中的方法是一种在Java编程中非常常见的概念。 我们可以将方法看作是一种可重复使用的代码块&#xff0c;类似于生活中的工具。就像我们在日常生活中会使用各种各样的工具来完成不同的任务一样&#xff0c;我们在编程中也可以使用方法来完成各种不同的操作。 二…
阅读更多...
Flex布局详解

Flex布局详解

目录 一、Flex 布局是什么&#xff1f; 二、基本概念 三、容器的属性 3.1 flex-direction属性 3.2 flex-wrap属性 3.3 flex-flow 3.4 justify-content属性 3.5 align-items属性 3.6 align-content属性 四、项目的属性 4.1 order属性 4.2 flex-grow属性 4.3 flex-s…
阅读更多...
c++11的一些新特性

c++11的一些新特性

c11 1. {}初始化2. 范围for循环3. final与override4. 右值引用4.1 左值引用和右值引用4.2 左值引用与右值引用比较 5. lambda表达式6. 声明6.1 auto6.2 decltype6.3 nullptr 7. 可变参数模版 1. {}初始化 在C中&#xff0c;使用花括号初始化的方式被称为列表初始化。列表初始化…
阅读更多...
让NPU跑起来迅为RK3588开发板设置交叉编译器

让NPU跑起来迅为RK3588开发板设置交叉编译器

让NPU跑起来迅为RK3588开发板设置交叉编译器 编译器下载地址是网盘资料“iTOP-3588 开发板\02_【iTOP-RK3588 开发板】开发资料 \12_NPU 使用配套资料\03_编译所需工具\Linux”。 拷贝 gcc-arm-10.3-2021.07-x86_64-aarch64-none-linux-gnu.tar.gz 到 Ubuntu 的/opt/tool_ch…
阅读更多...
记录crack某IDE插件过程

记录crack某IDE插件过程

声明&#xff1a;本文仅记录学习过程&#xff0c;已对关键位置脱敏处理&#xff0c;未提供任何工具&#xff0c;请支持正版。 反编译jar包 使用cfr进行对插件核心jar包MyBxxxxxx-obfuss.jar进行反编译&#xff0c;在本地生成a.txt。 java -jar cfr-0.152.jar MyBxxxx-obfuss.…
阅读更多...
外包干了2个月，技术退步明显。。。。。

外包干了2个月，技术退步明显。。。。。

先说一下自己的情况&#xff0c;大专生&#xff0c;18年通过校招进入武汉某软件公司&#xff0c;干了接近4年的功能测试&#xff0c;今年年初&#xff0c;感觉自己不能够在这样下去了&#xff0c;长时间呆在一个舒适的环境会让一个人堕落!而我已经在一个企业干了四年的功能测试…
阅读更多...
MATLAB入门-字符串操作

MATLAB入门-字符串操作

MATLAB入门-字符串操作 注&#xff1a;本篇文章是学习笔记&#xff0c;课程链接是&#xff1a;link MATLAB中的字符串特性&#xff1a; 无论是字符还是字符串&#xff0c;都要使用单引号来‘’表示&#xff1b;在MATLAB中&#xff0c;字符都是在矩阵中存储的&#xff0c;无论…
阅读更多...
【GO语言基础】变量常量

【GO语言基础】变量常量

系列文章目录 【Go语言学习】ide安装与配置 【GO语言基础】前言 【GO语言基础】变量常量 【GO语言基础】数据类型 文章目录 系列文章目录常量和枚举变量声明全局变量声明大小写敏感 总结 常量和枚举 使用const关键字声明常量&#xff0c;并为每个常量提供显式的值。Go语言没有…
阅读更多...
算法训练营day48|动态规划 part09：打家劫舍(LeetCode 198.打家劫舍、213.打家劫舍II、337.打家劫舍 III)

算法训练营day48|动态规划 part09：打家劫舍(LeetCode 198.打家劫舍、213.打家劫舍II、337.打家劫舍 III)

文章目录 198.打家劫舍思路分析代码实现思考总结 213.打家劫舍II思路分析代码实现 337.打家劫舍 III (树形DP)思路分析代码实现思考总结 198.打家劫舍 题目链接&#x1f525;&#x1f525; 你是一个专业的小偷&#xff0c;计划偷窃沿街的房屋。每间房内都藏有一定的现金&#…
阅读更多...
二维码智慧门牌管理系统：数据现势性，满足应用需求的根本保证

二维码智慧门牌管理系统：数据现势性，满足应用需求的根本保证

文章目录 前言一、项目背景二、数据的现势性三、系统的优势四、应用前景 前言 在当今信息化社会&#xff0c;数据的重要性日益凸显&#xff0c;尤其是数据的现势性&#xff0c;它决定着服务的质量和满足应用需求的能力。近日&#xff0c;一个创新的二维码智慧门牌管理系统项目…
阅读更多...
033：跨域，vue端和 Nignx反向代理的配置详细解析

033：跨域，vue端和 Nignx反向代理的配置详细解析

第033个 查看专栏目录: VUE ------ element UI 专栏目标 在vue和element UI联合技术栈的操控下&#xff0c;本专栏提供行之有效的源代码示例和信息点介绍&#xff0c;做到灵活运用。 &#xff08;1&#xff09;提供vue2的一些基本操作&#xff1a;安装、引用&#xff0c;模板使…
阅读更多...
IEC 61850扫盲

IEC 61850扫盲

目录 1 简介 2 主要特点 2.1 信息分层 2.2 信息模型与通信协议独立 2.3 数据自描述 2.4 面向对象数据统一建模 2.5 带确认服务 2.6 不带确认的服务 2.7 VMD&#xff08;虚拟制造设备&#xff09; 2.8 GOOSE&#xff08;Generic Object Oriented Substation Event&…
阅读更多...
Vue.js的服务器端渲染(SSR)：为什么和如何

Vue.js的服务器端渲染(SSR)：为什么和如何

&#x1f337;&#x1f341; 博主猫头虎&#xff08;&#x1f405;&#x1f43e;&#xff09;带您 Go to New World✨&#x1f341; &#x1f984; 博客首页——&#x1f405;&#x1f43e;猫头虎的博客&#x1f390; &#x1f433; 《面试题大全专栏》 &#x1f995; 文章图文…
阅读更多...
【C# Programming】继承、接口

【C# Programming】继承、接口

一、继承 1、派生 继承在相似而又不同的概念之间建立了类层次概念。 更一般的类称为基类&#xff0c;更具体的类称为派生类。派生类继承了基类的所有性质。 定义派生类要在类标识符后面添加一个冒号&#xff0c;接着添加基类名。 public class PdaItem {public string Name {…
阅读更多...
时序预测 | MATLAB实现ARMA自回归移动平均模型时间序列预测

时序预测 | MATLAB实现ARMA自回归移动平均模型时间序列预测

时序预测 | MATLAB实现ARMA自回归移动平均模型时间序列预测 目录 时序预测 | MATLAB实现ARMA自回归移动平均模型时间序列预测预测效果基本介绍程序设计参考资料 预测效果 基本介绍 MATLAB实现ARMA时间序列预测&#xff08;完整源码和数据&#xff09; 本程序基于MATLAB的armax函…
阅读更多...
安全实战 | 怎么用零信任防范弱密码？

安全实战 | 怎么用零信任防范弱密码？

防范弱密码&#xff0c;不仅需要提升安全性&#xff0c;更需要提升用户体验。 比如在登录各类业务系统时&#xff0c;我们希望员工登录不同系统不再频繁切换账号密码&#xff0c;不再需要3-5个月更换一次密码&#xff0c;也不再需要频繁的输入、记录、找回密码。 员工所有的办…
阅读更多...
JDK9特性——模块化REPL工具

JDK9特性——模块化REPL工具

文章目录 前言模块化模块化案例 可交互的REPL工具 前言 谈到Java9大家往往第一个想到的就是Jigsaw项目&#xff08;后改名为Modularity&#xff09;。众所周知&#xff0c;Java已经发展超过20年(95年最初发布)&#xff0c;Java和相关生态在不断丰富的同时也越来越暴露出一些问…
阅读更多...
开源药店商城系统源码比较：哪个适合你的药品电商业务

开源药店商城系统源码比较：哪个适合你的药品电商业务

在构建药品电商业务时&#xff0c;选择适合的药店商城系统源码是至关重要的决策之一。开源药店商城系统源码提供了快速入门的机会&#xff0c;但在选择之前&#xff0c;您需要仔细考虑您的需求、技术要求和可扩展性。本文将比较几个流行的开源药店商城系统源码&#xff0c;以帮…
阅读更多...
最新文章
推荐文章

Copyright @ 2022~2023