Liunx 套接字编程(2)TCP接口通信程序

news2025/1/8 12:14:06

1.TCP通信程序的编写

面向连接、可靠传输、提供字节流传输服务

客户端向服务器发送一个连接建立的请求流程,上图中服务端第三步详细流程

2.TCP接口

socket--创建套接字

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

bind---绑定

intbind(int sockfd,  struct sockaddr*addr, socklen_len);

sockfd : socket返回的套接字描述符

addr: 要绑定的地址信息(不同地址域类型,有不同的地址结构)

listen--监听

int listen(int sockfd, int backlog);

注意:listen第二个参数限制的是,同一时刻最大并发连接数,而不是总体能建立的连接数量,因为随着accept取出一个已完成连接,就又可以建立一个新的连接放在队列中。

connect--向服务端发送连接请求,这个接口只有客户端用到

int connect(int sockfd, struct sockaddr *adddr, socklen_t len);

sockfd:套接字描述符

addr: 服务端的地址信息

addrlen:地址长度

accept--获取新建连接

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

从内核sockfd指定的监听套接字对应的已完成连接队列中,取出一个socket,并返回这个socket的描述符

通过addr参数返回具体连接请求来源于哪个客户端

addr: accept内部进行填充客户端地址,是一个输出参数

addrlen: 地址信息长度,输入输出参数,用于指定想要获取的地址长度,以及返回实际的地址长度

返回值: 成功则返回新建连接的套接字描述符; 出错返回-1

send/recv--收发数据

ssize_t send(int sockfd, void *data, size_t len, int flag);

相较于sendto不用在指定对端地址了返回值: 成功则返回实际发送的数据长度; 出错则返回-1

ssize_t recv(int sockfd, void *buf, size_t len, int flag);

相较于recvfrom,不用获取对端地址了返回值: 成功则返回实际发送的字节长度; 出错则返回-1; 连接断开则返回0

tcp是面向连接的,一旦连接断开 (对方可能关闭了连接,或者网络出问题了......)将无法继续通信

recv函数返回0,没有读到数据是一回事,最主要的是要告诉使用者连接断开了

close--关闭套接字

int close(int fd);

3.封装一个TCPSocket类

主要是对socket操作进行封装,简化使用难度,下面为主要过程,具体代码见xshell

问题的探讨:

tcp服务器,涉及到对多个socket进行操作 (有多少客户端连接上来,就有多少socket)每一个socket都需要 accept, recv, send,但是这三个操作都是阻塞操作,

accept,如果没有新连接到来就会阻塞

recv,如果客户端没有发送数据就会阻塞

因此一旦获取了一个新连接,但是这个新连接,一直不发送数据,就会卡在recv处,没办法去调用accept获取下一个连接了而一旦一个连接通信完毕,程序流程运行到accept,但是这时没有新连接,就会卡在这里,就算上一个连接发送数据,也无法处理

tcp服务器觉得别扭的本质原因: 在一个执行流中进行的操作太多,并且这些操作都是阻塞操作。

解决方案:既然一个执行流中不能进行多个阻塞操作,干脆就创建多个执行流(多执行流任务处理)

主执行流只干一件事: 针对监听套接字获取新建连接,获取了一个新连接,就为这个新连接的操作创建一个执行流

其他执行流干的事情: 每个执行流都只负责与一个客户端通信

这样做有个好处,任意一个线程阻塞,都不会影响其他线程,也就是不会影响与其他客户端的通信

具体的实现过程分为两种: 多进程,多线程

多进程: 稳定,健壮

多线程:灵活,消耗小。

多进程方案实现

多进程方案实现: accept之后,创建子进程;但是需要注意僵尸进程的处理

相较于多进程版本,流程上没有大的差别,也是获取一个新建连接之后,创建一个线程出来

注意事项:

线程间是共用同一个文件描述符表,因此对这个通信套接字描述符的操作,只能由负责这个描述符操作的线程进行关闭,其他的线程不能关闭。

局部变量的使用,线程创建的时候,千万要注意传参,不能因为传递局部变量地址,而导致线程内访问的时候出现内存访问错误

4.tcp通信程序编写与运行中遇到的一些特殊情况

连接断开: tcp是面向连接的通信,一旦连接断开就无法通信

问题:如何在代码中知道连接断开了? 连接断开后,在代码中的体现是什么?

当recv函数接收数据的时候,返回0,代表的不仅仅是没有接收到数据,更多是为了表示连接断开了!!!

当send函数发送数据的时候,程序直接异常 (SIGPIPE) 退出,

因此如果网络通信中,不想让程序因为连接断开而导致发送数据的时候程序异常退出,就对SIGPIPE信号进行处理

问题: 有时候网络程序关闭后,无法立即启动,会bind绑定地址报错,绑定失败,地址已经被使用

网络通信程序,如果程序是主动关闭的一方,程序会无法立即启动

因为一个程序主动关闭了连接,这个连接并不会立即被释放(对应的地址和端口依然被占用),而是要等待一段时间。

netstat-anptu命令

这是查看主机上所有网络连接状态的命令

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

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

相关文章

自动化测试工具 —— selenium介绍及基本使用方法

Selenium是一个开源、免费、简单、灵活,对Web浏览器支持良好的自动化测试工具,在UI自动化、爬虫等场景下是十分实用的,能够熟练掌握并使用Selenium工具可以大大的提高效率。 Selenium简介 Selenium支持多平台、多浏览器、多语言去实现自动化…

声音合成——Foley Sound——DECASE项目——多模态智能感知与应用——项目复现

文章目录 概述项目复现配置环境下载并配置文件运行代码第一阶段,训练提取DTFR特征的模型资料搜集 train_vqvae.py 第二阶段,使用训练好的模型提取声音的DTFR特征torch.cuda.OutOfMemoryError: CUDA out of memory. 第三阶段,基于特征训练合成…

【软件测试】支付模块测试攻略,这些测试方法和注意事项你掌握了么?

对于大部分人而言,支付模块或许是日常生活中最为关注和使用的功能之一,因此,对于支付模块的质量控制也显得尤为重要。 但考虑到支付涉及到金钱流转等敏感信息,一旦出现问题可能带来非常严重后果。因此,在支付模块测试…

FastAPI 的路由介绍及使用

上一篇文章中,我介绍了 FastAPI 框架的安装和 HelloWorld 项目搭建方式。本文将介绍如何使用 Router 路由处理 FastAPI 中的请求。 什么是路由 路由 Router 就像是一个流水线上的线长,协调生产,下达命令给不同的组长进行分工,然…

Springboot——事物管理

文章目录 事务管理一、 Spring事务管理1.1 事务回顾1.2 案例: 解散部门(未开启事务)1.3 事务管理注解Transactional1.4 事务管理日志开关1.5 rollbackFor 异常回滚属性1.6 propagation 事务传播行为1.7 解散部门并记录操作日志1.7.1 创建数据…

Java 8 腰斩!Java 17 暴涨 430%!!(文末福利)

New Relic 最新发布了一份 “2023 年 Java 生态系统状况报告”,旨在提供有关当今 Java 生态系统状态的背景和见解。该报告基于从数百万个提供性能数据的应用程序中收集的数据,对生产中使用最多的版本、最受欢迎的 JDK 供应商、容器的兴起等多方面进行了调…

AIGC+实时云渲染:开启3D内容生态的黄金时代

AIGC技术革命下,我们的3D内容生态将会迎来怎样的变化格局? 实时云渲染 / Cloud XR技术将在AIGC大潮中扮演什么样的角色? 作为云基础设施厂商,我们有哪些机会可以抓住? 这些问题已在XR产业、3D内容行业以及软件行业内…

人工智能基础部分18-条件随机场CRF模型的应用

大家好,我是微学AI,今天给大家介绍一下人工智能基础部分18-条件随机场CRF模型的应用,本文将详细介绍条件随机场(CRF)模型,包括其原理、应用场景及实际代码实现。我将通过一个生活中的简单数据样例来演示如何输入数据、运行模型以及…

prometheus监控redis集群并显示到granfana面板

prometheus监控redis集群 监控redis1,在redis机器上安装redis_exporter2,配置prometheus配置文件3,设置redis maxmemory4,导入redis监控模板736 监控redis 1,在redis机器上安装redis_exporter 下载,安装r…

什么是边缘服务器?边缘计算的未来如何?

边缘服务器是指驻留在网络逻辑边缘上的任何类型的服务器,通常位于专用网络和互联网之间。边缘服务器的计算能力正在迅速塑造现代工业格局,动态应用程序和现代业务基础设施的出现使得数据的快速处理和共享成为必然。公司现在正在用边缘服务器技术取代传统…

什么是Pinia?以及它的使用方式?以及和Vuex的区别是什么?

文章目录 概要什么是Pinia?Pinia和Vuex的区别?Pinia相比于Vuex的优势?为什么要使用Pinia?Pinia的简单使用安装(仅限于Vue3)使用 概要 提示:下边是Pinia的简单介绍(详解请点击查看官方…

深度解析接口自动化框架封装项目:封装层级,关联调用,极限改进

目录 前言: 一、接口封装与封装层级 二、接口关联和数据准备 三、接口封装极限改进 四、代码示例 五、总结 前言: 接口自动化是软件测试领域中的一个重要环节,它可以自动化执行接口测试用例,快速发现和定位接口问题&#xf…

JAVA的基本数据类型及扩大缩小转换

JAVA的8种基本类型 分为四大类:整形、浮点型、字符型、布尔型 数据类型类别大小(位)范围byte整型8-128 到 127short整型16-32768 到 32767int整型32-2147483648 到 2147483647long整型64-9223372036854775808 到 9223372036854775807float浮点型32约3.40282347e38…

房屋装修选择自装,如何寻找砌墙工人,比价并施工(砌墙阶段)

环境: 地点:杭州 装修类型:自装 面积:建面135平方 进度:砌墙阶段 问题描述: 房屋装修选择自装,如何寻找砌墙工人,比价并施工 解决方案: 一、了解砌墙相关知识 砌…

docker 安装 prometheus,grafana,node-exporter 监控工具

:https://download.csdn.net/download/qq_42208305/87792827 加载离线镜像 : 监控端安装: docker load -i prometheus.tar docker load -i grafana.tar 被监控端安装: docker load -i node-expo…

类加载器与模块化系统

1 类加载器 “类加载器”是实现应用程序自己决定如何去获取所需的类这个动作的代码。 1.1 类与类加载器 比较两个类是否“相等”,只有在这两个类是由同一个类加载器加载的前提下才有意义。否则,即使这两个类来源同一个Class文件,被同一个J…

智慧型档案馆十防一体化安全管控平台所需要的主要产品

档案八防十防常用的十款设备 序号 名称 1 温湿度传感器 2 空气质量云测仪 3 恒湿净化一体机 4 健康防护一体机 5 综合智能触摸一体化区域控制器 6 空调红外学习控制模块 7 漏水检测控制器及感应线 8 数字烟雾传感器 9 红外防盗传感器 10 系统软件平台 附…

无脑006——mmrotate框架下复现RTMDet-R

必须用mmrotate才有hrsc的程序 1 安装环境: Linux RTX 3090 nvcc --version cuda 11.3 pytorch 1.11.0 conda install pytorch1.11.0 torchvision0.12.0 torchaudio0.11.0 cudatoolkit11.3 -c pytorch测试pytorch是否安装成功: >>> torch.…

深入浅出PyTorch数据读取机制

熟悉深度学习的小伙伴一定都知道:深度学习模型训练主要由数据、模型、损失函数、优化器以及迭代训练五个模块组成。如下图所示,Pytorch数据读取机制则是数据模块中的主要分支。 Pytorch数据读取是通过​​Dataset​​​​​Dataloader​​的方式完成。其…

SOME/IP中间件通信流程

本文根据文章《CAPL如何实现SOME/IP协议通信:SomeIP_IL.dll函数篇(超两万字详解)》内容,抽取总结出SOME/IP通信流程,正不正确的另说,目的是为了加深对SOME/IP中间件的理解。 首先,不管是消费方consumer,还是提供方provider,都有自己的someip中间件。本质上,它是一个…