IT评测·应用市场-qidao123.com
标题:
盘算机网络编程 | 并发服务器代码实现（多进程/多线程）
[打印本页]
作者:
络腮胡菲菲
时间:
2024-6-15 00:54
标题:
盘算机网络编程 | 并发服务器代码实现（多进程/多线程）
接待关注博主 Mindtechnist 或到场【Linux C/C++/Python社区】一起学习和分享Linux、C、C++、Python、Matlab，呆板人运动控制、多呆板人协作，智能优化算法，滤波估计、多传感器信息融合，呆板学习，人工智能等相关领域的知识和技术。
专栏：《网络编程》
什么是并发服务器
当涉及到构建高性能的服务器应用步伐时，我们通常会考虑利用并发服务器来处置惩罚多个客户端哀求。在并发服务器中，多进程和多线程是两种常见的并发模型，它们都有各自的优点和实用场景。本文将介绍多进程和多线程并发服务器的基础知识。
多进程并发服务器
多进程并发服务器通过创建多个子进程来处置惩罚客户端哀求。每个子进程是操纵系统中独立运行的单位，拥有自己的内存空间和资源。当有新的客户端连接哀求到达时，服务器创建一个新的子进程来处置惩罚该哀求。子进程负责与客户端通讯并提供所需的服务。
多进程并发服务器的优点是稳定性高。由于每个子进程都是相互独立的，一个子进程的瓦解或错误不会影响其他子进程的实验。这种独立性使得多进程并发服务器能够有效地隔离错误，提高服务器的可靠性。
然而，多进程并发服务器也有一些缺点。创建和管理多个进程必要消耗更多的系统资源，包罗内存和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图书保举
书籍是知识的海洋，盘算机好书保举
欢迎光临 IT评测·应用市场-qidao123.com (https://dis.qidao123.com/)
Powered by Discuz! X3.4
