linux网络编程-多进程实现TCP并发服务器

news/2024/3/29 23:10:16/文章来源:https://blog.csdn.net/d704791892/article/details/129168681

服务端流程步骤

  • socket函数创建监听套接字lfd

  • bind函数将监听套接字绑定ip和端口

  • listen函数设置服务器为被动监听状态,同时创建一条未完成连接队列(没走完tcp三次握手流程的连接),和一条已完成连接队列(已完成tcp三次握手的连接)

  • accept函数循环的从已完成连接队列中提取连接,并返回一个新的套接字cfd跟客户端进行通信

  • fork函数创建一个子进程,让子进程与客户端进行通信

  • 子进程:read函数循环的从r缓冲区读取客户端发送的数据,write函数将要发送的数据写入w缓冲区

  • close函数关闭套接字

客户端流程步骤

  • socket函数创建套接字

  • connect函数连接服务器

  • write函数将要发送的数据写入w缓冲区,read函数从r缓冲区读取服务器发送给客户端的数据

  • close函数关闭套接字

客户端跟服务器通信流程图

相关函数

  • int socket(int domain, int type, int protocol);

功能:创建一个用于网络通信的套接字文件描述符

参数:domain:协议族(AF_INET:ipv4,AF_INET6:ipv6,等等)

type:套接字类型(SOCK_DGRAM:udp,SOCK_STREAM:tcp,等等)

protocol:用于制定某个协议的特定类型,即type类型中的某个类型,通常不用管它,设置为 0

返回值:成功则返回socket套接字描述符, 失败返回-1,并设置errno

头文件:#include <sys/socket.h>

  • int bind(int sockfd, struct sockaddr *my_addr, socklen_t addrlen);

功能:将sockfd绑定ip和端口

参数:sockfd:套接字

my_addr:存放有协议,ip,端口的结构体信息

addrlen:my_addr结构体大小

返回值:成功返回0,失败返回-1,并设置errno

头文件:#include <sys/types.h>

#include <sys/socket.h>

  • int listen(int s, int backlog);

功能:让服务器处于被动监听状态,同时创建了一条未完成三次握手的连接队列和一条已经完成三次握 手的连接队列

参数:s:套接字

backlog:支持未完成连接和已完成连接之和的最大值,一般设置128

返回值:成功返回0,失败返回-1,并设置errno

头文件:#include <sys/socket.h>

  • int accept(int s, struct sockaddr *addr, socklen_t *addrlen);

功能:从已完成连接队列中提取客户端连接

参数:s:套接字

addr:存放成功连接的客户端的ip,端口等信息结构体

addrlen:存放addr结构体大小的变量地址

返回值:成功则返回一个非负整数标识这个连接套接字,是否返回-1

头文件:#include <sys/types.h>

#include <sys/socket.h>

  • ssize_t read(int fd, void *buf, size_t count);

功能:从文件描述符 fd 中读取 count 字节的数据并放入从 buf 开始的缓冲区中

参数:fd:文件描述符

buf:缓冲区

count:读count字节

返回值:成功时返回读取到的字节数,失败返回-1,并设置errno

头文件:#include <unistd.h>

  • ssize_t write(int fd, const void *buf, size_t count);

功能:向文件描述符fd所引用的文件中写入从buf开始的缓冲区中count字节的数据

参数:fd:文件描述符

buf:缓冲区

count:写count字节

返回值:功时返回所写入的字节数,失败返回-1,并设置errno

头文件:#include <unistd.h>

  • int close(int fd);

功能:关闭 一个文件描述符

参数:fd:要关闭的文件描述符

返回值:成功返回0,失败返回-1,并设置errno

头文件:#include <unistd.h>

  • int connect(int sockfd, const struct sockaddr *addr, socklen_t addrlen);

功能:连接服务器

参数:sockfd:套接字

addr:服务器的ip,端口等结构体信息

addrlen:addr结构体大小

返回值:成功返回0,失败返回-1,并设置errno

头文件:#include <sys/socket.h>

  • pid_t fork(void);

功能:创建一个子进程

参数:无

返回值:父进程返回子进程的进程id,子进程返回0

头文件:#include <unistd.h>

  • int sigprocmask(int how, const sigset_t *set, sigset_t *oldset);

功能:设置信号集屏蔽字

参数:how:SIG_BLOCK (mask |= set),SIG_UNBLOCK (mask &= ~set),SIG_SETMASK (mask = set)

set:信号集

oldset:旧的信号集

返回值:成功返回0,失败返回-1,并设置errno

头文件:#include <signal.h>

  • pid_t waitpid(pid_t pid, int *status, int options);

功能:回收已结束的子进程资源

参数:pid:pid<-1 等待进程组识别码为pid绝对值的任何子进程

pid=-1 等待任何子进程, 相当于wait()

pid=0 等待进程组识别码与目前进程相同的任何子进程

pid>0 等待任何子进程识别码为pid的子进程

status:子进程的结束状态值

options:WNOHANG 如果没有任何已经结束的子进程则马上返回, 不予以等待

WUNTRACED 如果子进程进入暂停执行情况则马上返回, 但结束状态不予以理会

返回值:成功返回子进程pid,失败返回-1

头文件: #include <sys/types.h>

#include <sys/wait.h>

服务端代码

#include <stdio.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <string.h>
#include <unistd.h>
#include <signal.h>
#include <stdlib.h>
#include <sys/types.h>
#include <sys/wait.h>
#include <errno.h>#define BUF_SIZE 256void do_sigchld(int signo, siginfo_t *siginfo, void *p)
{int status;pid_t pid;while((pid = waitpid(0, &status, WNOHANG)) > 0) //0:回收跟调用进程同组的子进程的资源,WNOHANG:不阻塞{if (WIFEXITED(status))printf("pid = %d, parent pid = %d, child pid = %d, exit status %d\n", pid, getpid(), siginfo->si_pid, WEXITSTATUS(status));else if (WEXITSTATUS(status))printf("pid = %d, parent pid = %d, child pid = %d, exit by signal %d\n ", pid, getpid(), siginfo->si_pid, WIFSIGNALED(status));}
}void sys_err(const char *str, int err)
{perror(str);exit(err);
}int main(int argc, char *argv[])
{if (argc < 2){printf("%s port\n", argv[0]);exit(1);}//创建流式套接字int lfd = socket(AF_INET, SOCK_STREAM, 0);if (lfd < 0)sys_err("socket", 1);//绑定ip端口    struct sockaddr_in server_addr;server_addr.sin_family = AF_INET;server_addr.sin_port = htons((unsigned short)atoi(argv[1]));server_addr.sin_addr.s_addr = 0; //0表示将本机所有ip都绑定上int ret = bind(lfd, (struct sockaddr *)&server_addr, sizeof(server_addr));if (ret < 0)sys_err("bind", 1);//监听ret = listen(lfd, 128);if (ret < 0)sys_err("listen", 1);//阻塞SIGCHLD信号sigset_t set;sigemptyset(&set);sigaddset(&set, SIGCHLD);sigprocmask(SIG_BLOCK, &set, NULL);int block = 1;//循环提取int cfd;pid_t pid;struct sockaddr_in client_addr; socklen_t len = sizeof(client_addr);char buf[BUF_SIZE];ssize_t size;char ip[INET_ADDRSTRLEN] = "";while(1){cfd = accept(lfd, (struct sockaddr *)&client_addr, &len);if (cfd < 0){if (errno == EINTR)continue;sys_err("accept", 1);}printf("client ip = %s, port = %d connect success\n", inet_ntop(AF_INET, &client_addr.sin_addr.s_addr, ip, sizeof(ip)), ntohs(client_addr.sin_port));pid = fork();if (pid == 0){//in childclose(lfd); //关闭不用了的监听套接字//解除阻塞SIGCHLD信号sigprocmask(SIG_UNBLOCK, &set, NULL);block = 0;while(1){memset(buf, 0, sizeof(buf));size = read(cfd, buf, sizeof(buf));if (size == 0) //客户端断开连接{printf("client close\n");break;}printf("%s\n", buf);write(cfd, buf, size);}break;}else if (pid > 0){//in parentclose(cfd); //关闭不用了的跟客户端通讯的套接字if (1 == block){//先捕捉struct sigaction sa;sa.sa_sigaction = do_sigchld;sigemptyset(&sa.sa_mask);sa.sa_flags = SA_SIGINFO;sigaction(SIGCHLD, &sa, NULL);//后解除阻塞sigprocmask(SIG_UNBLOCK, &set, NULL);block = 0;}}elsesys_err("fork", 1);}//关闭套接字if (pid == 0)close(cfd);else if (pid > 0)close(lfd);return 0;
}

客户端代码

#include <stdio.h>
#include <unistd.h>
#include <sys/socket.h>
#include <arpa/inet.h>
#include <stdlib.h>
#include <string.h>int main(int argc, char *argv[])
{if (argc < 3){printf("%s sever_ip server_port\n", argv[0]);exit(1);}//创建流式套接字int fd = socket(AF_INET, SOCK_STREAM, 0);if (fd < 0){perror("socket");exit(1);}//连接服务器struct sockaddr_in addr;addr.sin_family = AF_INET;addr.sin_port = htons((unsigned short)atoi(argv[2]));addr.sin_addr.s_addr = inet_addr(argv[1]);int ret = connect(fd, (struct sockaddr *)&addr, sizeof(addr));printf("connect ret = %d\n", ret);if (ret < 0){perror("connect");exit(1);}//读写数据char buf_w[128] = "";char buf_r[128] = "";ssize_t size_r = 0;while(1){fgets(buf_w, sizeof(buf_w), stdin);buf_w[strlen(buf_w) - 1] = 0;write(fd, buf_w, strlen(buf_w));size_r = read(fd, buf_r, sizeof(buf_r));if (size_r == 0) //服务器断开break;elseprintf("%s\n", buf_r);memset(buf_w, 0, sizeof(buf_w));memset(buf_r, 0, sizeof(buf_r));}//关闭套接字close(fd);return 0;
}

结果

  • 3个客户端连接服务器时

服务端

客户端

ps aux 可以看到有4个服务器进程(其中一个是主进程,用于监听处理新的连接,其他3个子进程用于跟客户端进行通信)

  • 回射服务信息截图

客户端1:

客户端2:

客户端3:

服务器收到进行打印:

3个客户端都退出时

服务端收到客户端退出,并回收跟客户端进行通信的3个子进程的资源

ps aux 查看可以看到只剩主进程,用于监听处理新的连接,其他3个子进程都已结束

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

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

相关文章

HTML Flex 布局

基本概念 采用 Flex 布局的元素&#xff0c;称为 Flex 容器&#xff08;flex container&#xff09;&#xff0c;简称“容器”。它的所有子元素自动成为容器成员&#xff0c;称为 Flex 项目&#xff08;flex item&#xff09;&#xff0c;简称“项目”。容器默认存在两根轴&am…

JavaSE之常用关键字学习

文章目录Java常用关键字学习1、static关键字学习1.1 用法一&#xff1a;修饰成员变量1.2 用法二&#xff1a;修饰成员方法1.3 用法三&#xff1a;修饰代码块1.4 用法四&#xff1a;修饰内部类类1.5 单例设计模式2、extends关键字学习2.1 继承的特点2.2 方法重写3、this、super关…

基于Comsol的花瓣形穿孔微穿孔板的吸声理论仿真

研究背景&#xff1a; 为了抑制噪声污染&#xff0c;已经开发了许多吸声材料和结构。传统的吸声材料&#xff0c;如开孔泡沫和纤维棉&#xff0c;随着时间的推移会劣化&#xff0c;因为小颗粒常常从这些多孔材料的骨架中脱落。此外&#xff0c;脱落的小颗粒可能污染建筑物内的…

立项近7年,索尼产品经理分享PS VR2开发背后的故事

备受期待的索尼PS VR2终于正式发售&#xff0c;VR爱好者们终于有机会体验到《地平线&#xff1a;山之呼唤》等PS VR2独占的VR大作。近期&#xff0c;为了解PS VR2头显诞生背后的故事&#xff0c;外媒AV Watch采访到PS VR2的开发负责人Yasuo Takahashi&#xff0c;在本次采访中&…

面试题-----JDBC单例模式(懒汉式和饿汉式)

1.单例概念 作为一种常见的设计模式&#xff0c;单例模式的设计概念是"两个私有,一个公有",即私有属性/成员变量和私有构造,以及公有方法,常用于在整个程序中仅调用一次的代码。 2.具体操作 从单例模式的描述来看,单例模式并不能用于多次频繁调用的设计中,而更适用…

剑指 Offer 55 - I. 二叉树的深度

摘要 剑指 Offer 55 - I. 二叉树的深度 一、深度优先搜索 如果我们知道了左子树和右子树的最大深度l和r&#xff0c;那么该二叉树的最大深度即为&#xff1a;max(l,r)1。 而左子树和右子树的最大深度又可以以同样的方式进行计算。因此我们可以用「深度优先搜索」的方法来计…

校园学生翻墙打架识别检测系统 yolov7

校园学生翻墙打架识别检测系统通过yolov7网络模型深度学习分析技术&#xff0c;校园学生翻墙打架识别检测算法可以对&#xff1a;打架行为、倒地行为识别、人员拥挤行为、攀高翻墙违规行为等违规行为进行实时分析检测。YOLOv7 的发展方向与当前主流的实时目标检测器不同&#x…

动手学深度学习v2—01数据操作+数据预处理

[TOC]此次用到的虚拟环境&#xff1a;pytorchmwy项目名称&#xff1a;limuAI所需框架和工具&#xff1a;pytorch&#xff0c;pandas一、创建CSV文件所需工具&#xff1a;pandas在与项目同等目录下创建一个文件夹名为data&#xff0c;其中文件名称为house_tiny.csv。代码如下&am…

随想录二刷 (双指针法) leetcode 27 26 283 844

双指针法的原理 双指针法相对于暴力解法的优点有以下几点 暴力遍历的时间复杂度会比较高双指针法利用两个指针进行遍历完成双层循环所做的事情 双指针一般有两种方法 同向指针&#xff0c;双向指针 第一题 leetcode 27 移除元素 题目描述 题目分析 采用暴力遍历可以得出结…

高效制作知识库的软件工具,这6个都很不错哦!

任何工作流程都离不开文档管理&#xff0c;因此文档管理也是企业数字化转型中的重要环节。面对复杂的业务流程、频繁的文档编辑任务和跨区域的文件共享需求&#xff0c;优秀的文档管理体系能够帮助企业实现安全的文档存储&#xff0c;高效的文档搜索&#xff0c;便捷的文档协作…

(一)Spring-Cloud源码分析之核心流程关系及springcloud与springboot包区别(新)

文章目录1. 前言2. springcloud简介3. Springcloud包简介4. Springcloud和Springboot流程关系5. Springcloud启动流程新增的功能和接口5.1 新增接口5.2 新增功能类5.2.1 spring-cloud-context包5.2.2 spring-cloud-commons包6. Springcloud实现机制带来的问题7. Springcloud和S…

深入浅出C++ ——手撕红黑树

文章目录一、红黑树的概念二、红黑树的性质三、红黑树节点的定义四、红黑树的插入操作五、红黑树的验证五、红黑树的删除六、红黑树与AVL树的比较七、红黑树的应用八、红黑树模拟实现一、红黑树的概念 红黑树&#xff0c;是一种二叉搜索树&#xff0c;但在每个结点上增加一个存…

Typecho COS插件实现网站静态资源存储到COS,降低本地存储负载

Typecho 简介Typecho 是一个简单、强大的轻量级开源博客平台&#xff0c;用于建立个人独立博客。它具有高效的性能&#xff0c;支持多种文件格式&#xff0c;并具有对设备的响应式适配功能。Typecho 相对于其他 CMS 还有一些特殊优势&#xff1a;包括可扩展性、不同数据库之间的…

(二十五)、实现评论功能(5)【uniapp+uinicloud多用户社区博客实战项目(完整开发文档-从零到完整项目)】

1&#xff0c;实现二级回复的入库操作 1.1 两个子组件&#xff08;comment-item和comment-frame&#xff09;与父组件reply之间的属性传值 comment-item&#xff1a; props: {item: {type: Object,default () {return {}}}},comment-frame&#xff1a; props: {commentObj: {…

儿童饰品发夹发卡出口美国办理什么认证?

亚马逊美国站上传新产品&#xff0c;很多时候都是需要类目审核的&#xff0c;后台给出要求提供认证&#xff0c;产品类目不同&#xff0c;所需要提供的认证证书是不一样&#xff0c;儿童产品需要提交的是CPC认证&#xff0c;玩具&#xff0c;母婴用品&#xff0c;儿童书包&…

PDF文件怎么转图片格式?转换有技巧

PDF文件有时为了更美观或者更直观的展现出效果&#xff0c;我们会把它转成图片格式&#xff0c;这样不论是归档总结还是存储起来都会更为高效。有没有合适的转换方法呢&#xff1f;这就来给你们罗列几种我个人用过体验还算不错的方式&#xff0c;大家可以拿来参考一下哈。1.用电…

Apifox = Postman + Swagger + Mock + JMeter

目录 可视化API设计 高效 & 零学习成本 可复用的“数据模型” 遵循 OpenAPI(Swagger) 规范 可导入 Swagger 等 20 数据格式 具体使用尝鲜 多项目管理 支持多环境切换 支持IDEA、浏览器、桌面应用 Idea插件 公共API hub库 如题&#xff1a;一款非常好用的API管理测…

Wi-Fi 7技术揭秘

引言 2022年4月7日&#xff0c;紫光股份旗下新华三集团全球首发企业级智原生Wi-Fi 7 AP新品 WA7638和WA7338。仅在同年的6月15日&#xff0c;在东京举行的第29届日本网络通信展览会&#xff08;Interop Tokyo 2022&#xff0c;简称Interop展&#xff09;中&#xff0c;WA7638就…

D1s RDC2022纪念版开发板开箱评测及点屏教程

作者new_bee 本文转自&#xff1a;https://bbs.aw-ol.com/topic/3005/ 目录 芯片介绍开发板介绍RT-Smart用户态系统编译使用感想引用 1. 芯片介绍 RISC-V架构由于其精简和开源的特性&#xff0c;得到业界的认可&#xff0c;近几年可谓相当热门。操作系统方面有RT-Thread&am…

Firebase常用功能和官方Demo简介

一、Firebase简介Firebase刚开始是一家实时后端数据库创业公司&#xff0c;它能帮助开发者很快的写出Web端和移动端的应用。自2014年10月Google收购Firebase以来&#xff0c;用户可以在更方便地使用Firebase的同时&#xff0c;结合Google的云服务。现在的Firebase算是谷歌旗下的…