当前位置: 首页 > news >正文

Linux网络编程 TCP---并发服务器:多进程架构与端口复用技术实战指南

知识点1【并发服务器—多进程版】

并发服务器:服务器可以同时服务多个客户端

首先复习一下服务器的创建过程(如下图)

1、监听套接字(套接字→绑定→监听(连接队列))

2、利用accept从连接队列的已连接区(完成三次握手)将客户端提取出来,此时产生 已连接套接字

现在我们结合多进程,完成的功能是父进程负责监听,而每个子进程都只负责管理一个客户端

因此,子父进程中 不能有已连接套接字,而子进程中不能有监听套接字。让我们先实现以下这个代码!

这里说一下,并发服务器就是这样的流程,如果暂时理解不了,请先背下来

代码演示

#include <stdio.h>
#include <arpa/inet.h>
#include <netinet/in.h>
#include <stdio.h>
#include <sys/socket.h>
#include <string.h>
#include <sys/types.h> //listen
#include <errno.h>
#include <signal.h> //signal
#include <sys/wait.h> //waitpid
#include <unistd.h>
#include <stdlib.h> //atoi//主进程释放子进程空间函数声明
void my_waitpid(int signal);//子进程中函数体的声明
void fun_subprocess(int fd_sock_accept);int main(int argc, char const *argv[])
{//指令参数个数判断if(argc != 2){printf("demo:./a.out num_of_port");return 0;}//创建(监听)套接字,非法判断int fd_sock_listen = socket(AF_INET,SOCK_STREAM,0);if(fd_sock_listen < 0){printf("socket");_exit(-1);}//绑定并非法判断:先创建地址结构体,然后绑定套接字,这里我们设置端口号为8000.struct sockaddr_in addr_bind;addr_bind.sin_family = AF_INET;addr_bind.sin_port = htons(atoi(argv[1]));addr_bind.sin_addr.s_addr = htonl(INADDR_ANY);int ret_bind = bind(fd_sock_listen,(struct sockaddr *)&addr_bind,sizeof(addr_bind));if(ret_bind != 0){perror("bind");_exit(-1);}//监听,将套接字设为监听套接字,并连接队列 的大小设置为10int ret_listen = listen(fd_sock_listen,10);if(ret_listen != 0){perror("listen");_exit(-1);}//循环中 先accept,在创建子进程:先accpet可以让每个子进程都可以得到一个已连接套接字//又因为accept是带阻塞的,不必担心,子进程的多创建问题while(1){//accept 从 已连接队列中提取已连接套接字:监听套接字//这里的地址结构体,是用来存储 客户端的地址信息struct sockaddr_in addr_accept;bzero(&addr_accept,sizeof(addr_accept));int len_accept = sizeof(addr_accept);int fd_sock_accpet = accept(fd_sock_listen,(struct sockaddr *)&addr_accept,&len_accept);if(fd_sock_accpet < 0){if((errno == ECONNABORTED) || (errno == EINTR)){continue;}else{perror("accept");close(fd_sock_listen);_exit(-1);}}//这里客户端与服务器连接成功,遍历一条消息说明是 客户端的IP和端口号unsigned short port = ntohs(addr_accept.sin_port);char buf_IP[16] = "";inet_ntop(AF_INET,&addr_accept.sin_addr.s_addr,buf_IP,sizeof(buf_IP));//创建子进程,每个子进程中需要关闭int pid = fork();if(pid == 0)//子进程,关闭监听套接字-->执行任务体-->关闭已连接套接字-->退出子进程{//遍历处 客户端连接的子进程printf("客户端IP:%s,端口号:%hu已连接,为其分配的进程ID是:%d\\n",buf_IP,port,getpid());//执行监听套接字close(fd_sock_listen);//执行任务体,要实现1、数据的接收,并遍历在服务器的终端,2、将收到的数据返回客户端fun_subprocess(fd_sock_accpet);//关闭已连接套接字close(fd_sock_accpet);//退出子进程_exit(0);}else//父进程,关闭已连接套接字{close(fd_sock_accpet);//父进程,负责处理回收进程空间,这里回收空间我们采用 等待信号SIGCHLD的方式signal(SIGCHLD,my_waitpid);}}close(fd_sock_listen);return 0;
}//主进程释放子进程空间函数实现
void my_waitpid(int signal)
{while(1){int ret = waitpid(-1,NULL,WNOHANG);if(ret == 0 || ret == -1){//子进程空间被释放退出break;}else if(ret > 0){printf("子进程%d已经退出\\n",ret);}//注意这里一定不要等待全部进程退出,即只判断返回值是-1的情况,会循环堵塞的,应该是检测到一个释放就退出一次//因为这里我们是信号检测,一旦有子进程退出的信号就会进入这个函数一次//这是调试过程中发现的问题}return;
}//子进程中函数体的实现,实现1、数据的接收,并遍历在服务器的终端,2、将收到的数据返回客户端
void fun_subprocess(int fd_sock_accept)
{while(1){//1500最安全,因为以太网的最大传输单元(MTU)是1500Bytechar buf_recv[1500] = "";int len = recv(fd_sock_accept,buf_recv,sizeof(buf_recv),0);printf("%s\\n",buf_recv);//TCP(传输控制协议),是当收到内容长度为0的时候,先输出内容,然后服务器会退出if(len == 0){break;}send(fd_sock_accept,buf_recv,sizeof(buf_recv),0);}
}

代码运行结果

我们这个客户端设计的功能流畅度 是很完善的,并发服务器就是这样,套模板就可以,希望大家在理解的基础上记忆,备注很详细,如果仍有疑问可以私信或者评论留言,我看到了会回复讨论。

知识点2【端口复用】

这里我们演示一个现象,服务器主动断开后,会有一段时间服务器无法使用,是为什么呢?因为 端口仍与 上一个服务器的套接字 之间有联系(客户端的TIME_WAIT状态)。

此时的端口只能绑定一个套接字

1、问题现象演示

为了解决服务器重启后,地址被占用,导致客户端需要等待的问题,我们就要引入端口复用

2、端口复用的概述

端口复用:允许在一个应用程序 可以把n个套接字绑定在一个端口上而不出错

方法:利用setsockopt 函数SO_REUSEADDR 实现

这个函数在UDP的多播和广播中也有使用,后面我会对UDP的内容进行补充。

注意:置端口复用函数要在绑定之前调用,而且只要绑定在同一个端口所有套接字都得设置复用

目的:能够保证服务器重启后,能够立马运行,其他客户端无需等待。

3、端口复用的实现

端口复用的模式是固定的,主要记忆,端口复用的实现方法,与端口复用的位置

实现方法:

    //端口复用的实现int opt = 1;setsockopt(fd_sock_listen,SOL_SOCKET,SO_REUSEADDR,&opt,sizeof(opt));

位置:

在创建套接字之后,绑定套接字之前

代码演示

代码运行结果

可见服务器重启,无需等待。

建议

只要是服务器的创建都加上端口复用的功能

结束

代码重在练习!

代码重在练习!

代码重在练习!

今天的分享就到此结束了,希望对你有所帮助,如果你喜欢我的分享,请点赞收藏夹关注,谢谢大家!!!

相关文章:

  • GO语言入门:常用数学函数2
  • TCVectorDB 向量数据库简介
  • K8s-Pod详解
  • 操作系统是如何运行的?
  • 2014-2021年 区域经济高质量发展-高质量需求指标数据
  • 【Hot100】 240. 搜索二维矩阵 II
  • 微信小程序中使用h5页面预览图片、视频、pdf文件
  • 软考复习——知识点软件开发
  • 深入理解Java包装类:自动装箱拆箱与缓存池机制
  • Linux操作系统--进程的创建和终止
  • 缓存 --- Redis的三种高可用模式
  • 重构之去除多余的if-else
  • Kubernetes相关的名词解释Dashboard界面(6)
  • 年化26.9%的稳健策略|polars重构因子计算引擎(python策略下载)
  • 03【变量观】`let`, `mut` 与 Shadowing:理解 Rust 的变量绑定哲学
  • c++STL——list的使用和模拟实现
  • go环境安装mac
  • 02【初体验】安装、配置与 Hello Cargo:踏出 Rust 开发第一步
  • Three.js + React 实战系列-3D 个人主页 :完成 Navbar 导航栏组件
  • Mac-VScode-C++环境配置
  • 成都市政府秘书长王忠诚调任遂宁市委副书记
  • 第1现场|俄乌互指对方违反复活节临时停火提议
  • 揭晓!人形机器人半马完赛奖+专项奖发布
  • 为博眼球竟编造一女孩被活埋,公安机关公布10起谣言案件
  • 商务部新闻发言人就美对我海事、物流和造船等领域宣布最终措施答记者问
  • 张巍|另眼看古典学⑩:再创作让古希腊神话重获生机——重述厄勒克特拉