Linux网络编程——TCP并行服务器

embedded/2025/3/10 20:04:11/

        在 Linux 网络编程中，通过不同的技术来实现一个 TCP 并行服务器，能够有效地处理多个客户端连接。我们可以使用 多线程、多进程进程池 和 I/O 多路复用（如 select、poll 或 epoll）来提高服务器的性能。以下是分步实现的代码示例：

1. 使用多线程实现 TCP 并行服务器

多线程服务器：

        多线程服务器会为每个客户端请求创建一个新线程来处理它们。这样可以让服务器同时处理多个客户端，但线程过多会增加上下文切换的开销。

#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include <unistd.h> 
#include <pthread.h> 
#include <sys/types.h> 
#include <sys/socket.h> 
#include <arpa/inet.h> 
#include <netinet/in.h>#define LISMAXNUM    1024int init_udp_ser(const char *ip, unsigned short port)
{struct sockaddr_in seraddr;seraddr.sin_family = AF_INET;seraddr.sin_port = htons(port);seraddr.sin_addr.s_addr = inet_addr(ip);int sockfd = socket(AF_INET, SOCK_STREAM, 0);if (sockfd < 0){perror("fail socket");return -1;}int ret = bind(sockfd, (struct sockaddr *)&seraddr, sizeof(seraddr));if (ret < 0){perror("fail bind");return -1;}ret = listen(sockfd, LISMAXNUM);if (ret < 0){perror("fail listen");return -1;}return sockfd;
}void handler(int signo)
{wait(NULL);
}void *thread(void *arg)
{int connfd = *(int *)arg;char buff[512] = {0};while (1){memset(buff, 0, sizeof(buff));ssize_t size = recv(connfd, buff, sizeof(buff), 0);if (size < 0){close(connfd);return NULL;}if (size == 0){close(connfd);return NULL;}printf("%s\n", buff);size = send(connfd, buff, strlen(buff), 0);if (size < 0){close(connfd);return NULL;}}
}int main(int argc, const char *argv[])
{struct sockaddr_in cli;socklen_t clilen = sizeof(cli); signal(SIGCHLD, handler);int sockfd = init_udp_ser("192.168.1.178", 50000);if (sockfd < 0){return -1;}while (1){int connfd = accept(sockfd, (struct sockaddr *)&cli, &clilen);if (connfd < 0){perror("fail accept");return -1;}pthread_t tid;pthread_create(&tid, NULL, thread, &connfd);pthread_detach(tid);}close(sockfd);return 0;
}
主要流程：
  1. 创建套接字：服务器通过 socket() 创建 TCP 套接字。
  2. 绑定与监听：通过 bind() 和 listen() 绑定端口并等待客户端连接。
  3. 创建线程：每当有一个客户端连接时，通过 pthread_create() 创建一个新线程来处理客户端请求。
  4. 回显客户端消息：线程处理客户端的消息接收与发送。

2. 使用多进程进程池实现 TCP 并行服务器

多进程服务器：

多进程服务器通过 fork() 创建多个子进程，每个子进程处理一个客户端连接。

#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include <unistd.h> 
#include <sys/types.h> 
#include <sys/socket.h> 
#include <arpa/inet.h> 
#include <netinet/in.h> 
#include <sys/wait.h>#define LISMAXNUM    1024int init_udp_ser(const char *ip, unsigned short port)
{struct sockaddr_in seraddr;seraddr.sin_family = AF_INET;seraddr.sin_port = htons(port);seraddr.sin_addr.s_addr = inet_addr(ip);int sockfd = socket(AF_INET, SOCK_STREAM, 0);if (sockfd < 0){perror("fail socket");return -1;}int ret = bind(sockfd, (struct sockaddr *)&seraddr, sizeof(seraddr));if (ret < 0){perror("fail bind");return -1;}ret = listen(sockfd, LISMAXNUM);if (ret < 0){perror("fail listen");return -1;}return sockfd;
}void handler(int signo)
{wait(NULL);
}int main(int argc, const char *argv[])
{struct sockaddr_in cli;socklen_t clilen = sizeof(cli); signal(SIGCHLD, handler);int sockfd = init_udp_ser("192.168.1.178", 50000);if (sockfd < 0){return -1;}while (1){int connfd = accept(sockfd, (struct sockaddr *)&cli, &clilen);if (connfd < 0){perror("fail accept");return -1;}pid_t pid = fork();if (pid < 0){perror("fail fork");return -1;}if (0 == pid){char buff[512] = {0};while (1){memset(buff, 0, sizeof(buff));ssize_t size = recv(connfd, buff, sizeof(buff), 0);if (size < 0){close(connfd);exit(1);}if (size == 0){close(connfd);exit(1);}printf("%s\n", buff);size = send(connfd, buff, strlen(buff), 0);if (size < 0){close(connfd);exit(1);}}}else if (pid > 0){}}close(sockfd);return 0;
}
主要流程：
  1. 创建套接字：通过 socket() 创建 TCP 套接字。
  2. 绑定与监听：使用 bind() 和 listen() 绑定地址并开始监听。
  3. fork() 创建子进程：每当有客户端连接时，父进程通过 fork() 创建一个新的子进程来处理该客户端。
  4. 处理客户端：子进程使用 recv() 和 send() 与客户端进行交互，并回显客户端的消息。

3. 线程池

        提前预创建大量线程，避免任务执行过程中创建线程的耗时。

3. 使用 I/O 多路复用（select）实现 TCP 并行服务器

   select 是一种 I/O 多路复用技术，允许一个进程或线程监视多个文件描述符的状态变化。使用 select 使得服务器能够同时处理多个客户端的请求。

select 实现服务器代码：
#include <stdio.h> 
#include <stdlib.h> 
#include <string.h> 
#include <unistd.h> 
#include <sys/types.h> 
#include <sys/socket.h> 
#include <arpa/inet.h> 
#include <netinet/in.h> 
#include <sys/select.h>#define LISMAXNUM    1024int init_udp_ser(const char *ip, unsigned short port)
{struct sockaddr_in seraddr;seraddr.sin_family = AF_INET;seraddr.sin_port = htons(port);seraddr.sin_addr.s_addr = inet_addr(ip);int sockfd = socket(AF_INET, SOCK_STREAM, 0);if (sockfd < 0){perror("fail socket");return -1;}int ret = bind(sockfd, (struct sockaddr *)&seraddr, sizeof(seraddr));if (ret < 0){perror("fail bind");return -1;}ret = listen(sockfd, LISMAXNUM);if (ret < 0){perror("fail listen");return -1;}return sockfd;
}int main(int argc, const char *argv[])
{char buff[512] = {0};struct sockaddr_in cli;socklen_t clilen = sizeof(cli); int sockfd = init_udp_ser("192.168.1.164", 50000);if (sockfd < 0){return -1;}int maxfd = -1;fd_set rdfds;fd_set tmpfds;FD_ZERO(&rdfds);FD_SET(sockfd, &rdfds);maxfd = maxfd > sockfd ? maxfd : sockfd;while (1){tmpfds = rdfds;int cnt = select(maxfd+1, &tmpfds, NULL, NULL, NULL);if (cnt < 0){perror("fail select");return -1;}for (int i = 0; i < maxfd+1; i++){if (FD_ISSET(i, &tmpfds)){if (i == sockfd){int connfd = accept(sockfd, (struct sockaddr *)&cli, &clilen);if (connfd < 0){perror("fail accept");continue;}FD_SET(connfd, &rdfds);maxfd = maxfd > connfd ? maxfd : connfd;}else{memset(buff, 0, sizeof(buff));ssize_t size = recv(i, buff, sizeof(buff), 0);if (size < 0){perror("fail recv");FD_CLR(i, &rdfds);close(i);continue;}if (size == 0){FD_CLR(i, &rdfds);close(i);continue;}printf("%s\n", buff);strcat(buff, "------>OK");size = send(i, buff, strlen(buff), 0);if (size < 0){perror("fail send");FD_CLR(i, &rdfds);close(i);continue;}}}}}close(sockfd);return 0;
}
主要流程：
  1. 创建套接字：通过 socket() 创建 TCP 套接字。
  2. 绑定与监听：使用 bind() 和 listen() 绑定地址并开始监听。
  3. select：监听多个套接字的状态变化，通过非阻塞方式检测哪些客户端有数据可以处理
    1. 创建文件描述符集合
    2. 将关注的文件描述符加入到集合
    3.  等待IO事件到达
    4.  根据不同的IO事件处理不同的任务

总结

  • 多线程实现：每当有客户端连接时，服务器创建一个线程来处理该连接。适合连接数适中的情况，但线程数过多时可能会带来性能问题

  • 多进程实现：通过 fork() 创建子进程来处理每个客户端。

  • I/O 多路复用（select）实现：服务器通过 select 等待多个客户端的事件，适用于大量客户端连接，且无需为每个连接创建线程或进程。

    • select使用位图管理文件描述符，最多允许同时监测1024个文件描述符（有上限）；

    •  文件描述符集合在应用层创建，需要实现应用层和内核层的反复拷贝；

    •  需要应用层对集合表进行遍历，寻找到达的事件；

    •  只能工作在水平触发模式（低速模式），不能工作在边沿触发模式（高速模式） 。


http://www.ppmy.cn/embedded/171565.html

相关文章

TP-LINK图像处理工程师（深圳）内推

TP-LINK图像处理工程师（深圳）内推

1. 计算机、模式识别、信号处理、应用数学类专业。 2.熟悉色域空间转换&#xff0c;亮度、噪声&#xff0c;对比度等基础图像处理知识。 3.有图像处理相关项目开发经验者优先&#xff08;如降噪、AE、AWB等&#xff09;&#xff1b;熟悉3DNR、编码相关知识者优先。 【专属内推码…
阅读更多...
CarPlanner：用于自动驾驶大规模强化学习的一致性自回归轨迹规划

CarPlanner：用于自动驾驶大规模强化学习的一致性自回归轨迹规划

25年2月来自浙大和菜鸟网络的论文“CarPlanner: Consistent Auto-regressive Trajectory Planning for Large-scale Reinforcement Learning in Autonomous Driving”。 轨迹规划对于自动驾驶至关重要&#xff0c;可确保在复杂环境中安全高效地导航。虽然最近基于学习的方法&a…
阅读更多...
【LangChain】理论及应用实战（1）

【LangChain】理论及应用实战（1）

文章目录 背景知识一、模型 I/O二、prompt模板2.1 字符串模版&#xff1a;PromptTemplate2.2 对话模版&#xff1a;ChatPromptTemplate2.3 自定义模板2.4 组合模板2.5 序列化模板 三、示例选择器四、langchain核心组件&#xff1a;LLMs & Chat Models4.1 LLMs4.2 Chat Mode…
阅读更多...
TCP三次握手，四次挥手；多进程、多线程实现并发服务器

TCP三次握手，四次挥手；多进程、多线程实现并发服务器

三次握手&#xff0c;四次挥手 三次握手示意图&#xff1a; SYN、ACK是TCP协议头里面的标志位 同步 SYN&#xff1a;仅在三次握手建立 TCP 连接时有效。当 SYN 1 而 ACK 0 时&#xff0c;表明这是一个连接请求报文段&#xff0c;对方若同意建立连接&#xff0c;则应在相应的…
阅读更多...
利用MQ自动取消未支付超时订单最佳实践

利用MQ自动取消未支付超时订单最佳实践

一、利用MQ自动取消未支付超时订单最佳实践 1、基于 RocketMQ 延迟消息 1.1&#xff1a;延迟消息 当消息写入到 Broker 后&#xff0c;不会立刻被消费者消费&#xff0c;需要等待指定的时长后才可被消费处理的消息&#xff0c;称为延时消息。 1.2&#xff1a;实现流程 &am…
阅读更多...
揭开AI-OPS 的神秘面纱 第五讲 AI 模型服务层（开源方向）

揭开AI-OPS 的神秘面纱 第五讲 AI 模型服务层（开源方向）

之前的分析确实侧重于通用的模型服务框架和平台，而忽略了对开源模型本身的讨论，以及模型加速和基于开源模型的微调与部署等关键问题。 下面将针对 – 对 AI 模型服务层的分析 开源模型方向 进行讨论。 其实 在AI - OPS 中 模型不是都以最终自己的数据训练成垂直领域的模型为…
阅读更多...
【玩转正则表达式】正则表达式常用语法汇总

【玩转正则表达式】正则表达式常用语法汇总

1. 基本字符 普通字符&#xff1a;匹配自身。例如&#xff0c;正则表达式hello匹配字符串中的“hello”。\d&#xff1a;匹配任何数字字符&#xff0c;相当于[0-9]。例如&#xff0c;\d\d\d匹配三个连续的数字。 示例&#xff1a;123、456 \w&#xff1a;匹配任何字母数字字符…
阅读更多...
安装remixd，在VScode创建hardhat

安装remixd，在VScode创建hardhat

在终端&#xff0c;以管理员身份&#xff0c;cmd 需要科学上网 npm install -g remix-project/remixd 在vscode插件中&#xff0c;安装solidity插件&#xff0c;是暗灰色那款 1.将nodeJs的版本升级至18以上 2.在vscode打开一个新的文件&#xff0c;在终端输入 npx hardhat 3.…
阅读更多...
最新文章

Copyright @ 2022~2023