计算机网络编程 | 并发服务器代码实现（多进程/多线程）

news2025/1/31 11:03:16

在这里插入图片描述

欢迎关注博主 Mindtechnist 或加入【Linux C/C++/Python社区】一起学习和分享Linux、C、C++、Python、Matlab，机器人运动控制、多机器人协作，智能优化算法，滤波估计、多传感器信息融合，机器学习，人工智能等相关领域的知识和技术。

多进程多线程并发服务器

  • 什么是并发服务器
  • 多进程并发服务器代码实现
  • 多线程并发服务器代码实现
  • 618图书推荐

专栏：《网络编程》

什么是并发服务器

当涉及到构建高性能的服务器应用程序时，我们通常会考虑使用并发服务器来处理多个客户端请求。在并发服务器中，多进程和多线程是两种常见的并发模型，它们都有各自的优点和适用场景。本文将介绍多进程和多线程并发服务器的基础知识。

多进程并发服务器
多进程并发服务器通过创建多个子进程来处理客户端请求。每个子进程是操作系统中独立运行的单位，拥有自己的内存空间和资源。当有新的客户端连接请求到达时，服务器创建一个新的子进程来处理该请求。子进程负责与客户端通信并提供所需的服务。
多进程并发服务器的优点是稳定性高。由于每个子进程都是相互独立的，一个子进程的崩溃或错误不会影响其他子进程的执行。这种独立性使得多进程并发服务器能够有效地隔离错误，提高服务器的可靠性。
然而，多进程并发服务器也有一些缺点。创建和管理多个进程需要消耗更多的系统资源，包括内存和CPU时间。进程间的通信也需要特殊的机制，例如管道或共享内存，以便在不同进程之间传递数据。此外，由于每个进程都有自己的内存空间，进程间的数据共享和同步可能会变得复杂。

多线程并发服务器
多线程并发服务器通过创建多个线程来处理客户端请求。线程是在进程内部运行的独立执行流，共享同一个进程的内存空间和资源。与多进程不同，多线程服务器不需要创建新的进程来处理请求，而是在同一个进程中创建多个线程。
多线程并发服务器的优点是资源消耗较少。与进程相比，线程的创建和切换开销更小，因为它们共享进程的资源。这使得多线程并发服务器更加轻量级，能够更高效地利用系统资源。
然而，多线程并发服务器也存在一些问题。首先，线程共享进程的内存空间，因此在多线程环境中访问共享数据需要特殊的同步机制，以避免竞态条件和数据不一致。其次，由于线程共享相同的地址空间，一个线程的错误可能会影响整个进程，导致服务器崩溃或不稳定。

选择适合的并发模型
在选择多进程还是多线程并发服务器时，需要根据具体的应用需求和性能要求进行权衡。以下是一些建议：

  • 如果稳定性和容错性是首要考虑因素，多进程并发服务器可能是更好的选择。每个子进程的独立性可以有效地隔离错误，提高服务器的可靠性。
  • 如果服务器需要处理大量的并发连接并需要更高的性能和资源利用率，多线程并发服务器可能更适合。线程的创建和切换开销相对较小，可以更高效地处理并发请求。
  • 如果同时需要稳定性和性能，可以考虑使用混合模型，即在每个进程中创建多个线程，以实现更好的负载平衡和资源利用率。

无论选择多进程还是多线程并发服务器，都需要注意正确处理并发访问共享数据的问题，使用适当的同步机制（如锁、信号量）来保证数据的一致性和正确性。

总结起来，多进程和多线程并发服务器是实现高性能服务器的常见方式。它们各有优劣，选择合适的并发模型需要考虑应用需求和性能要求，并注意处理并发访问共享数据的问题。

多进程并发服务器代码实现

使用多进程并发服务器时要考虑以下几点：

  • 父进程最大文件描述个数(父进程中需要close关闭accept返回的新文件描述符)；
  • 系统内创建进程个数(与内存大小相关)；
  • 进程创建过多是否降低整体服务性能(进程调度)；

server

/* server.c */
#include <stdio.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <signal.h>
#include <sys/wait.h>
#include <sys/types.h>
#include "wrap.h"

#define MAXLINE 80
#define SERV_PORT 800

void do_sigchild(int num)
{
	while (waitpid(0, NULL, WNOHANG) > 0)
		;
}
int main(void)
{
	struct sockaddr_in servaddr, cliaddr;
	socklen_t cliaddr_len;
	int listenfd, connfd;
	char buf[MAXLINE];
	char str[INET_ADDRSTRLEN];
	int i, n;
	pid_t pid;

	struct sigaction newact;
	newact.sa_handler = do_sigchild;
	sigemptyset(&newact.sa_mask);
	newact.sa_flags = 0;
	sigaction(SIGCHLD, &newact, NULL);

	listenfd = Socket(AF_INET, SOCK_STREAM, 0);

	bzero(&servaddr, sizeof(servaddr));
	servaddr.sin_family = AF_INET;
	servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
	servaddr.sin_port = htons(SERV_PORT);

	Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));

	Listen(listenfd, 20);

	printf("Accepting connections ...\n");
	while (1) {
		cliaddr_len = sizeof(cliaddr);
		connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len);

		pid = fork();
		if (pid == 0) {
			Close(listenfd);
			while (1) {
				n = Read(connfd, buf, MAXLINE);
				if (n == 0) {
					printf("the other side has been closed.\n");
					break;
				}
				printf("received from %s at PORT %d\n",
						inet_ntop(AF_INET, &cliaddr.sin_addr, str, sizeof(str)),
						ntohs(cliaddr.sin_port));
				for (i = 0; i < n; i++)
					buf[i] = toupper(buf[i]);
				Write(connfd, buf, n);
			}
			Close(connfd);
			return 0;
		} else if (pid > 0) {
			Close(connfd);
		} else
			perr_exit("fork");
	}
	Close(listenfd);
	return 0;
}

client

/* client.c */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include "wrap.h"

#define MAXLINE 80
#define SERV_PORT 6666

int main(int argc, char *argv[])
{
	struct sockaddr_in servaddr;
	char buf[MAXLINE];
	int sockfd, n;

	sockfd = Socket(AF_INET, SOCK_STREAM, 0);

	bzero(&servaddr, sizeof(servaddr));
	servaddr.sin_family = AF_INET;
	inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr);
	servaddr.sin_port = htons(SERV_PORT);

	Connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));

	while (fgets(buf, MAXLINE, stdin) != NULL) {
		Write(sockfd, buf, strlen(buf));
		n = Read(sockfd, buf, MAXLINE);
		if (n == 0) {
			printf("the other side has been closed.\n");
			break;
		} else
			Write(STDOUT_FILENO, buf, n);
	}
	Close(sockfd);
	return 0;
}

多线程并发服务器代码实现

在使用线程模型开发服务器时需考虑以下问题：

  • 调整进程内最大文件描述符上限；
  • 线程如有共享数据，考虑线程同步；
  • 服务于客户端线程退出时，退出处理（退出值，分离态）；
  • 系统负载，随着链接客户端增加，导致其它线程不能及时得到CPU；

server

/* server.c */
#include <stdio.h>
#include <string.h>
#include <netinet/in.h>
#include <arpa/inet.h>
#include <pthread.h>

#include "wrap.h"
#define MAXLINE 80
#define SERV_PORT 6666

struct s_info {
	struct sockaddr_in cliaddr;
	int connfd;
};
void *do_work(void *arg)
{
	int n,i;
	struct s_info *ts = (struct s_info*)arg;
	char buf[MAXLINE];
	char str[INET_ADDRSTRLEN];
	/* 可以在创建线程前设置线程创建属性,设为分离态,哪种效率高内？ */
	pthread_detach(pthread_self());
	while (1) {
		n = Read(ts->connfd, buf, MAXLINE);
		if (n == 0) {
			printf("the other side has been closed.\n");
			break;
		}
		printf("received from %s at PORT %d\n",
				inet_ntop(AF_INET, &(*ts).cliaddr.sin_addr, str, sizeof(str)),
				ntohs((*ts).cliaddr.sin_port));
		for (i = 0; i < n; i++)
			buf[i] = toupper(buf[i]);
		Write(ts->connfd, buf, n);
	}
	Close(ts->connfd);
}

int main(void)
{
	struct sockaddr_in servaddr, cliaddr;
	socklen_t cliaddr_len;
	int listenfd, connfd;
	int i = 0;
	pthread_t tid;
	struct s_info ts[256];

	listenfd = Socket(AF_INET, SOCK_STREAM, 0);

	bzero(&servaddr, sizeof(servaddr));
	servaddr.sin_family = AF_INET;
	servaddr.sin_addr.s_addr = htonl(INADDR_ANY);
	servaddr.sin_port = htons(SERV_PORT);

	Bind(listenfd, (struct sockaddr *)&servaddr, sizeof(servaddr));
	Listen(listenfd, 20);

	printf("Accepting connections ...\n");
	while (1) {
		cliaddr_len = sizeof(cliaddr);
		connfd = Accept(listenfd, (struct sockaddr *)&cliaddr, &cliaddr_len);
		ts[i].cliaddr = cliaddr;
		ts[i].connfd = connfd;
		/* 达到线程最大数时，pthread_create出错处理, 增加服务器稳定性 */
		pthread_create(&tid, NULL, do_work, (void*)&ts[i]);
		i++;
	}
	return 0;
}

client

/* client.c */
#include <stdio.h>
#include <string.h>
#include <unistd.h>
#include <netinet/in.h>
#include "wrap.h"
#define MAXLINE 80
#define SERV_PORT 6666
int main(int argc, char *argv[])
{
	struct sockaddr_in servaddr;
	char buf[MAXLINE];
	int sockfd, n;

	sockfd = Socket(AF_INET, SOCK_STREAM, 0);

	bzero(&servaddr, sizeof(servaddr));
	servaddr.sin_family = AF_INET;
	inet_pton(AF_INET, "127.0.0.1", &servaddr.sin_addr);
	servaddr.sin_port = htons(SERV_PORT);

	Connect(sockfd, (struct sockaddr *)&servaddr, sizeof(servaddr));

	while (fgets(buf, MAXLINE, stdin) != NULL) {
		Write(sockfd, buf, strlen(buf));
		n = Read(sockfd, buf, MAXLINE);
		if (n == 0)
			printf("the other side has been closed.\n");
		else
			Write(STDOUT_FILENO, buf, n);
	}
	Close(sockfd);
	return 0;
}

618图书推荐

书籍是知识的海洋，计算机好书推荐
在这里插入图片描述
🔥🔥🔥618，清华社 IT BOOK 多得图书活动开始啦！活动时间为2023 年6 月7 日至6 月18 日，清华社为您精选多款高分好书，涵盖了 C++、Java、Python、前端、后端、数据库、算法与机器学习等多个IT 开发领域，适合不同层次的读者。全场5 折，扫码领券更有优惠哦！快来京东点击链接 IT BOOK多得查看详情吧！

在这里插入图片描述
在这里插入图片描述

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

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

相关文章

基于 Quivr 搭建个人知识库

基于 Quivr 搭建个人知识库

目录 Quivr介绍 Quivr特性 Quivr演示 Demo with GPT3.5: Demo of the new version&#xff1a; Quivr实战 Quiv 使用的主要技术 Quiv 实践依赖 创建Supabase项目 部署Quiv项目 第一步&#xff1a;现在源码 第二步&#xff1a;设置环境变量 第三步&#xff1a;执行sql 第…
阅读更多...
http1.0，http1.1，http2.0，http3.0 区别有哪些

http1.0，http1.1，http2.0，http3.0 区别有哪些

20 世纪 60 年代&#xff0c;美国国防部高等研究计划署&#xff08;ARPA&#xff09;建立了 ARPA 网&#xff0c;这被认为是互联网的起源。70 年代&#xff0c;研究人员基于对 ARPA 网的实践和思考&#xff0c;发明出了著名的 TCP/IP 协议。该协议具有良好的分层结构和稳定的性…
阅读更多...
Docker部署开源项目Django-CMS企业内容管理系统

Docker部署开源项目Django-CMS企业内容管理系统

Docker部署开源项目Django-CMS企业内容管理系统 一、Django-CMS介绍1.1 Django-CMS简介1.2 Django-CMS特点 二、本地环境介绍2.1 本地环境规划2.2 本次实践介绍 三、本地环境检查3.1 检查Docker服务状态3.2 检查Docker版本3.3 检查docker compose 版本 四、下载django-cms-quic…
阅读更多...
JS 之 事件Event对象详解（属性、方法、自定义事件）

JS 之 事件Event对象详解（属性、方法、自定义事件）

一、Event对象 1、简介 ​ 事件event对象是指在浏览器中触发事件时&#xff0c;浏览器会自动创建一个event对象&#xff0c;其中存储了本次事件相关的信息&#xff0c;包括事件类型、事件目标、触发元素等等。浏览器创建完event对象之后&#xff0c;会自动将该对象作为参数传…
阅读更多...
NLP——WordNet；Word Similarity； Word Sense Disambiguition

NLP——WordNet；Word Similarity； Word Sense Disambiguition

WordNet WordNet是一个广泛使用的英语词汇数据库和语义网络。它由普林斯顿大学认知科学实验室开发&#xff0c;旨在帮助人们理解单词之间的关系和意义。WordNet的主要目标是将英语词汇组织成一种层次结构&#xff0c;其中每个词都与其他相关词联系起来。WordNet中的单词按照它们…
阅读更多...
[6]PCB设计实验｜认识常用元器件｜电阻器｜18:30~19:00

[6]PCB设计实验｜认识常用元器件｜电阻器｜18:30~19:00

目录 一、电阻器主要用途 1. 稳定和调节电路中的电流和电压 2. 作为分流、分压和负载使用 二、常见电阻器 1. 贴片电阻 2. 热敏电阻 3. 限流电阻 4. 可调电阻 5. 排阻(网络电阻) 三、几种常用电阻器的结构特点 四、电阻的参数 1. 额定功率 电阻器功率的表示 ​2…
阅读更多...
自学黑客/网络安全工具软件大全100套

自学黑客/网络安全工具软件大全100套

黑客工具软件大全100套 1 Nessus&#xff1a;最好的UNIX漏洞扫描工具 Nessus 是最好的免费网络漏洞扫描器&#xff0c;它可以运行于几乎所有的UNIX平台之上。它不止永久升级&#xff0c;还免费提供多达11000种插件&#xff08;但需要注册并接受EULA-acceptance–终端用户授权…
阅读更多...
【六一儿童节】回忆一下“童年的记忆”

【六一儿童节】回忆一下“童年的记忆”

文章目录 [TOC](文章目录) 前言一、EasyX带我们步入了童话的世界1.1绘画哆啦A梦2.2绘画出来喜羊羊 二、我的六一故事总结 前言 我们都有过童年&#xff0c;并且从现在看来&#xff0c;童年是我们最希望可以回去的那段时光&#xff0c;那时候的我们傻傻的&#xff0c;并且很天真…
阅读更多...
电子元器件解析02之电容(一)——定义与性能参数

电子元器件解析02之电容(一)——定义与性能参数

下篇文章&#xff1a;电子元器件解析02之电容(二)——电容分类与应用场景&#xff1a;https://blog.csdn.net/weixin_42837669/article/details/131142767 摘要 电容是最基本的电子元器件之一&#xff0c;本文介绍了电容的定义&#xff0c;并总结了电容的各个性能参数&#xff…
阅读更多...
leetcode143. 重排链表(java)

leetcode143. 重排链表(java)

重排链表 leetcode143. 重排链表题目要描述 解题思路代码链表专题 leetcode143. 重排链表 来源&#xff1a;力扣&#xff08;LeetCode&#xff09; 链接&#xff1a;https://leetcode.cn/problems/reorder-list 题目要描述 给定一个单链表 L 的头节点 head &#xff0c;单链表 …
阅读更多...
根据字节、华为、阿里、腾讯等大厂整理的2023最新面试热点问题，还不行我也救不了你了~

根据字节、华为、阿里、腾讯等大厂整理的2023最新面试热点问题，还不行我也救不了你了~

大厂面试热点问题 1、测试人员需要何时参加需求分析&#xff1f; 如果条件循序 原则上来说 是越早介入需求分析越好 因为测试人员对需求理解越深刻 对测试工作的开展越有利 可以尽早的确定测试思路 减少与开发人员的交互 减少对需求理解上的偏差 2、软件测试与调试的关系 测…
阅读更多...
MM32F3273G8P火龙果开发板MindSDK开发教程11 -获取msa311加速器的xyz轴数据

MM32F3273G8P火龙果开发板MindSDK开发教程11 -获取msa311加速器的xyz轴数据

MM32F3273G8P火龙果开发板MindSDK开发教程11 -获取msa311加速器的xyz轴数据 1、msa311简介 使用i2c总线 可以读取xyz轴的加速度 可以监测单击双击事件 可以监测运动与静止状态 可以监测自由落体事件&#xff0c;可用来监测摔倒或跌落。 可以监测旋转事件&#xff0c;类似手机…
阅读更多...
工作中自我或者团队管理的几个有用工具

工作中自我或者团队管理的几个有用工具

个人或者团队管理过程中&#xff0c;采用一些有效的管理工具或者方法&#xff0c;可以提升工作效率和结果。它们包括SMART原则、PDCA循环、SWOT分析、5W2H分析、鱼骨图分析、七个凡是。这几个工具或者方法之间有互通性&#xff0c;比如&#xff0c;PDCA循环中&#xff0c;在P这…
阅读更多...
数学建模预备知识（1）全网最全的数学建模竞赛汇总，别再被坑了！

数学建模预备知识（1）全网最全的数学建模竞赛汇总，别再被坑了！

&#x1f305;*&#x1f539;** φ(゜▽゜*)♪ **&#x1f539;*&#x1f305; 欢迎来到馒头侠的博客&#xff0c;该类目主要讲数学建模的知识&#xff0c;大家一起学习&#xff0c;Qq及各类联系方式在图片上&#xff01; 喜欢的朋友可以关注下&#xff0c;下次更新不迷路&…
阅读更多...
【MySQL】为什么MySQL选择B+Tree来做索引？

【MySQL】为什么MySQL选择B+Tree来做索引？

B树和B树的区别? B树 B树 B*树 B树和B树的区别 &#xff08;1&#xff09;存储量大&#xff1a;B树叶子及非叶子节点存索引数据&#xff0c;B树叶子非叶子节点存索引&#xff0c;叶子节点存数据&#xff1b; &#xff08;2&#xff09;查找速度&#xff1a; 查单个值&…
阅读更多...
细说websocket - php篇

细说websocket - php篇

下面我画了一个图演示 client 和 server 之间建立 websocket 连接时握手部分&#xff0c;这个部分在 node 中可以十分轻松的完成&#xff0c;因为 node 提供的 net 模块已经对 socket 套接字做了封装处理&#xff0c;开发者使用的时候只需要考虑数据的交互而不用处理连接的建立…
阅读更多...
运营-22.内容分发

运营-22.内容分发

内容分发 内容分发本质要解决的问题包含两点&#xff1a; 1. 高效的连接人与信息&#xff1b; 2. 过滤出有价值的信息&#xff0c;让合适的人看到合适的信息 。 常见的内容分发方式&#xff1a; 1. 编辑分发&#xff1b; 2. 订阅分发&#xff1b; 3. 社交分发&#xff1b; 4. 算…
阅读更多...
Oracle中使用【Interval】对【日期】进行【相加减】，报错 ORA-01839:指定月份的日期无效（Interval的坑）

Oracle中使用【Interval】对【日期】进行【相加减】，报错 ORA-01839:指定月份的日期无效（Interval的坑）

文章目录 1. 前言2. 先说结论3. 案例演示 1. 前言 最近在对某些表进行旧数据的删除&#xff0c;必然是通过【时间】删除之前较为久远的数据&#xff0c;比如1年前&#xff0c;6个月前&#xff0c;7天前的数据等等情况&#xff0c;这个时候的SQL&#xff0c;必然会出现条件&…
阅读更多...
pandas---数据结构（Series、DataFrame 和 MultiIndex）创建方式、属性

pandas---数据结构（Series、DataFrame 和 MultiIndex）创建方式、属性

1. 数据结构 Pandas中一共有三种数据结构&#xff0c;分别为&#xff1a;Series、DataFrame 和MultiIndex。 其中Series是一维数据结构&#xff0c;DataFrame是二维表格型数据结构&#xff0c;MultiIndex是三维数据结构。 1.1 Series Series是一个类似于一维数组的数据结构…
阅读更多...
【LeetCode】每日一题 -- 1170. 比较字符串最小字母出现频次 -- Java Version

【LeetCode】每日一题 -- 1170. 比较字符串最小字母出现频次 -- Java Version

题目链接&#xff1a;https://leetcode.cn/problems/compare-strings-by-frequency-of-the-smallest-character/ 1. 题解&#xff08;1170. 比较字符串最小字母出现频次&#xff09; 昨天的每日一题 2699. 修改图中的边权 有点难&#xff0c;研究了一会儿&#xff0c;学习了一…
阅读更多...
推荐文章
最新文章

Copyright @ 2022~2023