网络编程(12): TCP重传、滑动窗口、流量控制、拥塞控制
1、TCP重传机制
通过序列号和确认号确保可靠传输,当发送端发送数据给接收到,接收端会返回一个确认号,表示收到消息了
- 超时重传:没有在指定时间内收到
ACK
报文- 超时重传的两种可能:数据包丢失、确认包丢失
- 超时重传时间
RTO
:RTO
较大:重发就变慢了,丢包之后需要半天才能重发,效率低RTO
较小:可能没有丢包,还在等待ACK过程中,就重发了,会导致网络拥塞,进而导致更多的超时重发- 所以
RTO
需要略大于报文往返的时间RTT
(数据发送到接收到ACK的时间差)
- 由于网络波动问题,
RTT
可能不是固定的,所以RTO
对应也不是固定的 - 一般超时重传一次,下一次超时重传的间隔会加倍,避免网络环境差的频繁发送
- 快速重传:
超时重传的问题
:重传周期可能很长(时间会加倍),快速重传可以解决这个问题,以数据为驱动作为重传- 发送了数据包
seq1
~seq5
,- 发送端发送
seq1
,接收端回复ack=2
,表示接收到包1 seq2
丢失- 发送端连续发送
seq3
~seq5
,接收端会重复返回ack=2
- 连续三次
ack=2
,触发快速重传
,重复seq2
- 由于接收到了
seq3
~seq5
,发送端会返回ack=6
- 发送端发送
- 快速重传只解决了超时问题,但是还有一个问题:重传的时候重传一个还是所有数据包
- 因为如果只重传一个,当有两个数据包丢失的时候,需要判断两次返回的ack(三次重复),来进行单包重传,效率低
- 如果重传所有,就会有多余的包被重新发送,无用功
- SACK:选择性确认,可以知道哪些数据丢失了
- 需要
TCP
头部选项
字段中,添加一个SACK
,可以将已接收到的数据的信息发送给发送方,发送方就知道了哪些数据丢失了,从而只发送丢失的数据 - 在快速重传的基础上,发送方收到三次相同的ack报文,触发快速重传机制,通过
SACK
信息可以知道哪段数据丢失了,只对丢失的数据重传
- 需要
D-SACK
:通过SACK
告诉发送端哪些数据被重复接收了- 可以让发送端知道是包丢失,还是ACK包丢失了
- 可以知道发送的数据包是不是被网络延迟了
- 可以知道网络中是不是把发送端的数据包给复制了
- 小结:
- 如果数据包丢失或者ACK包丢失,超过一定时间会触发超时重传,超时时间
RTO
略大于RTT
时间(发送数据到接收ACK包的时间间隔) - 为了解决超时等待的时间,提高效率,就有了快速重传,当有一个包丢失的时候,可以通过判断重复的ack进行快速重传,通过在TCP头部的选项字段里面添加SACK,就可以知道哪些包是丢失的,从而只重传丢失的包
- 如果在
ACK
包丢失,导致的超时重传,发送端接收到接收端SACK
从而知道收到了重复数据,这个SACK
就是D-SACK
,如果一个包由于网络问题导致的快速重传,也可以通过D-SACK
来进行判断
- 如果数据包丢失或者ACK包丢失,超过一定时间会触发超时重传,超时时间
2、TCP滑动窗口
TCP每次发送数据都要进行确认应答,当上一个包收到应答了再发下一个
- 如果是一问一答的形式,则数据包往返的时间周期越长,通信效率就越低
- 为了解决上面的问题,就有窗口概念,
- 可以指定窗口大小,窗口大小是不需要等待确认应答,可以继续发送数据的最大值
- 窗口是内核里面开辟的缓存区,需要保留发送的数据,只有收到应答才会从缓冲区中删除
- 在
TCP头部
可以指定窗口大小,发送端会根据ACK
返回的窗口大小,来发送数据,从而保证对端可以正常接收数据,所以窗口大小是由接收端决定的
- 发送端的窗口:
- 有两个绝对指针:一个指向没有收到ack的第一个字节的序列号, 一个指向窗口中可用空间的第一个字节的序列号
- 会根据ACK报文中的窗口大小进行调整,因为应用层不一定及时收数据
- 此外,如果发送端窗口满了,没有及时收到
ACK
,就不能在应用层进行发送数据,如果序列号较前的收到ack,窗口会向右移动,存在可发空间,应用层可以继续拷贝发送数据
- 接收端的窗口:可以接收发送端发送的数据量,一次能处理的数据量
- 只有一个绝对指针,指向期望对端发送来的下一个字节的序列号
- 窗口里面是还没进行确认的数据,也就是还没收到的数据,但是可以接收的数据大小
- 发送端窗口约等于接收端窗口,因为传输存在延迟,不一定及时调整窗口大小,所以是约等于
- 小结:
- 三次握手确定窗口大小,接收端能接收多少数据,发送端根据接收端数据进行调整,去发送数据,在发送端窗口大小内,发送端可以一直发,并等待接收端返回ack确认号来发送窗口移动,每次ack报文都会携带窗口大小,可能会改变;
3、TCP流量控制
利用滑动窗口实现流量控制,发送端不能一股脑的发过去,如果对方处理不过来就会触发重传机制
- 流量控制:发送方 根据 接收方的实际接收能力发送数据,也就是接收端滑动窗口的大小
- TCP内核缓冲区和滑动窗口的关系:缓冲区大小会影响窗口大小
- 应用层不及时收取数据,会导致窗口变小:
- TCP滑动窗口(指针实现)是处于TCP缓冲区中间的,如果接收端接收到数据并返回ACK,但是应用层没有及时收取,当缓冲区内存不够,可能会导致滑动窗口变小,当窗口大小变成0,就发生了窗口关闭
- 系统资源减少,会导致缓冲区变小:
- 如果用户空间没有及时读取缓冲区数据,并且接收缓冲区由于系统资源突然变小,发送端来不及调整,会导致数据丢包现象,这是因为先减少缓冲区再收缩窗口
- 所以不允许同时减少缓冲又收缩窗口,而先收缩窗口后一段时间再减少缓冲,从而避免丢包
- 应用层不及时收取数据,会导致窗口变小:
- 窗口关闭:
- 窗口大小为0的情况,就会阻止发送端发送数据,直到大小变成非0
- 如果接收端窗口变成非0,会通过发送携带窗口大小的ACK报文,如果ACK报文丢失,发送端会一直等待,造成死锁问题
- 如何避免死锁问题:当窗口关闭,就会启动一个持续计时器,如果超时就会发送一个
窗口探测报文
,接收端收到这个报文,就会返回一个携带当前窗口大小的ACK报文,如果窗口依旧为0,就会重启持续计时器
- 糊涂窗口综合症
- 接收端太忙,会导致发送端的窗口越来越小,到最后只有接收端腾出字节空间,发送端就会马上发送,但是TCP/IP包头就有40字节,有数据就传输的话,开销太大了
- 导致的原因是:
- 接收端告知小窗口大小
- 发送端发送小数据
- 如何避免:
- 接收方不告知小窗口,窗口小于某个值就发送窗口为0的ACK,阻止对端发送数据
- 发送发避免发送小数据,开启Nagle算法,避免小包发送
- Nagle算法思想,延时处理,满足下面一个条件即可:
- 窗口大小>=MSS并且数据大小>=MSS
- 收到前一个数据的ack报文
- 一般需要搭配 不通知小窗口给发送方+开启Nagle算法才能避免糊涂窗口综合症
4、TCP拥塞控制
-
流量控制:是为了避免,发送端 数据填满 接收端的缓存,但是流量控制并不知道网络中发送的情况
-
网络拥塞:网络发生拥堵的时候,继续发送大量数据包,就可能导致数据包延时、丢失等情况,TCP就会重传数据,一旦重传就会导致网络更加拥堵,从而不断恶性循环
-
拥塞控制:避免发送方的数据填满整个网络,并且为了调节发送数据的量,定义了一个
拥塞窗口(cwnd)
的概念 -
拥塞窗口(cwnd):是发送方维护的一个状态变量,会根据网络的拥塞程度进行变化,滑动的发送窗口=min(滑动的接收窗口,拥塞窗口),当网络没有出现拥塞,
cwnd
窗口就会越大,当网络出现拥塞,cwnd
就会越小 -
如何判断网络拥塞:发送方没有在指定时间接收到ACK应答报文,也就是发送超时重传,就会认为网络出现拥塞了
-
拥塞控制主要是四算法:
- 慢启动:(指数增长)
- TCP建立连接后,一点点点提高数据包发送的数量,发送端没收到一个ACK,拥塞窗口
cwnd
的大小就会+1; - 存在一个慢启动门限
ssthresh
,如果cwnd
<ssthresh
使用的就是慢启动算法,如果cwnd
>=ssthresh
,就使用拥塞避免算法;ssthresh
一般大小为65535字节
- TCP建立连接后,一点点点提高数据包发送的数量,发送端没收到一个ACK,拥塞窗口
- 拥塞避免:
- 没收到一个ACK,
cwnd
增加1/cwnd
,是为了确保cwnd
的线性增长 - 如果一直保持增长,网络就会慢慢进入拥塞状态,从而出现了丢包现象
- 如果触发了重传机制,就会进入拥塞发生算法
- 没收到一个ACK,
- 拥塞发送:
- 发生重传(超时、快速)的时候就会进入拥塞发生算法
- 超时重传的拥塞发生:
ssthresh
会设置为cwnd/2
,并且cwnd
会回复为初始值,linux的初始值是10(10个MSS);- 设置完
ssthresh
和cwnd
之后,会重新开始慢启动; - 这种方式下来的拥塞发生太激进了,容易造成网络卡顿
- 快速重传的拥塞发生:
- 设置
cwnd
为cwnd/2
,再设置ssthresh
为cwnd
- 设置完之后,会进入
快速回复算法
- 设置
- 快速回复:
- 当发生快速重传的时候,表示网络不是太糟糕,一般快速回复和快速重传同时使用
- 进入快速回复前,
cwnd
和ssthresh
都全部设置完了 快速回复
:cwnd
=ssthresh+3
,3表示接收到了三个数据包- 重传丢失的数据包;
- 如果再收到重复的
ACK
,cwnd
就+1 - 如果收到的是新的ACK,表示网络没问题了,则将cwnd设置为ssthresh,进入拥塞避免状态;
- 慢启动:(指数增长)
-
拥塞控制算法过程:
- 从TCP三次握手建立连接开始,发送端开始慢启动,没收到一个包的ACK,拥塞窗口就会+1,如果达到阈值,就会进入拥塞避免算法,每收到一个包的ACK,拥塞窗口就会增加窗口的倒数,从而保证拥塞窗口的线性增加
- 当遇到丢包的情况,就判断为网络拥塞,从而重复重传机制,进入拥塞发送算法,根据重传机制的不同,拥塞发送算法也会不同
- 超时重传,sthresh=cwnd/2,并且cwnd=初始值,重新重慢启动开始
- 快速重传,cwnd=cwnd/2,ssthresh=cwnd,开启快速回复
- 快速回复:先是设置cwnd=ssthresh+3,并重传丢失数据包,如果依旧重复收到相同的ACK,就会重复触发快速重传和快速回复,如果收到的是新的数据包,则进入拥塞避免状态。
参考文章:小林coding
相关文章:

网络编程(12): TCP重传、滑动窗口、流量控制、拥塞控制
1、TCP重传机制 通过序列号和确认号确保可靠传输,当发送端发送数据给接收到,接收端会返回一个确认号,表示收到消息了 超时重传:没有在指定时间内收到ACK报文 超时重传的两种可能:数据包丢失、确认包丢失超时重传时间RT…...

Docker安装RabbitMQ服务端
使用docker安装RabbitMQ服务端 1、搜索镜像 docker search rabbitmq2、拉取镜像 默认拉取最后一个版本,可以在后面加版本号拉取指定版本 docker pull rabbitmq 3、运行镜像 docker run -d --hostname my-rabbit --name rabbit -p 15672:15672 rabbitmq4、查看…...

vueuse常用方法
useDateFormat 时间格式化 <script setup lang"ts">import { useNow, useDateFormat } from vueuse/coreconst formatted useDateFormat(useNow(), YYYY-MM-DD HH:mm:ss)</script><template><div>{{ formatted }}</div> </templa…...

选择大型语言模型自定义技术
推荐:使用 NSDT场景编辑器 助你快速搭建可二次编辑器的3D应用场景 企业需要自定义模型来根据其特定用例和领域知识定制语言处理功能。自定义LLM使企业能够在特定的行业或组织环境中更高效,更准确地生成和理解文本。 自定义模型使企业能够创建符合其品牌…...

算法概述-Java常用算法
算法概述-Java常用算法 1、算法概念2、算法相关概念3、算法的性能评价4、算法应用归纳 1、算法概念 广泛算法定义:算法是模型分析的一组可行性的、确定的和有穷的规则。 经典算法特征:有穷性、确切性、输入、输出和可行性。 常用的算法包括递推、递归、穷…...

CCLINK转MODBUS-TCP网关cclink通讯接线图 终端电阻
大家好,今天我们要聊的是生产管理系统中的CCLINK和MODBUS-TCP协议,它们的不同使得数据互通比较困难,但捷米JM-CCLK-TCP网关的出现改变了这一切。 1捷米JM-CCLK-TCP是一款自主研发的CCLINK从站功能的通讯网关,它的主要功能是将各种…...

香蕉派 BPI-P2 Pro采用RK3308芯片,512M内存,8G存储,支持PoE供电
Banana Pi BPI-P2 pro(Armsom pro)是一款基于瑞芯瑞(Rockchip) RK3308B-S芯片的开发板。采用高性能4核ARM Cortex-A35处理器,512M RAM内存。和8G eMMC板载存储,支持PoE网线供电功能。芯片具有丰富的接口,如I2S、PCM、TDM、I2C、UART、SPDIF、…...

「隐语小课」拆分学习之“水平拆分学习”
一、引言 拆分学习是 2018 年由 MIT 最先提出的分布式算法。本文结合该领域的相关英文文献,介绍水平拆分学习的基本方法,同时还将对比拆分模型与中心化模型、联邦模型在不同条件下模型效率和准确性。拆分学习作为主流的隐私计算学习范式之一,…...

WPF--关于Action事件小结
WPF--关于Action事件小结 1.需要类实例去调用事件建立订阅关系 public event Action<int, object> MaintainEvent; new GP1().MaintainEvent NormalCmdAction; 2.static用处--在不便实例的时候,可以直接由类调用 public static event Action<int, objec…...

创建一个 React+Typescript 项目
接下来 我们来一起探索一下用TypeScript 来编写react 这也是一个非常好的趋势,目前也非常多人使用 那么 我们就先从创建项目开始 首先 我们先找一个 或者 之前创建一个目录 用来放我们的项目 然后 在这个目录下直接输入 例如 这里 我想创建一个叫 tsReApp 的项目…...

Java课题笔记~ 数据提交的方式
前四种数据注入的方式,会自动进行类型转换。但无法自动转换日期类型。 (1)单个数据(基本数据类型)注入 在方法中声明一个和表单提交的参数名称相同的参数,由框架按照名称直接注入。 (2&#x…...

VUE3给页面添加按钮事件
在Vue 3中,可以通过使用setup函数来添加事件和自定义逻辑。下面是一个示例代码,演示了如何添加页面上的altb事件 <template><div><p>Press Alt B to trigger the event!</p></div> </template><script setup&g…...

基于centos7.9通过nginx实现负载均衡以及反向代理
摘要:负载均衡: 负载均衡是一种技术,用于在多个服务器之间分发传入的网络流量,以平衡服务器的负载,提高系统的可用性和性能。当您有多台服务器时,您可以使用负载均衡将请求分发到这些服务器上,从…...

前端原生写自定义旋转变换轮播图
html部分: <div class"banner_box"><div class"swiperWrapper" v-show"bannerList.length>0"><div class"swiper-item" :id"swiperSlide${index}" :class"{active:index0,next:index1,pr…...

linux tomcat server.xml 项目访问路径变更不生效
如果想改成默认的127.0.0.1:8080 访问项目 先确定更改的作用文件 server.xml 的 host:appBase 标签 默认找到appBase webapps 下的war包,并解压,解压后的appname为访问路径 也就变成了 127.0.0.1:8080/appname host:Context:path 标签 appBase的 优先…...

介绍原型模式:快速构建和复制对象的设计模式
经过瀑布模式之后,我们不禁想要用模型解决更多的问题,最重要的就是不再单向行径。 由此,介绍 原型模式, 所谓原型,就是我们有一个框架或者初始角色。我们可以根据项目的不同,对它进行不同的修改࿰…...

Unity的TimeScale的影响范围分析
大家好,我是阿赵。 这期来说一下Unity的TimeScale。 一、前言 Unity提供了Time这个类,来控制时间。其实我自己倒是很少使用这个Time,因为做网络同步的游戏,一般是需要同步服务器时间,所以我比较多是在使用System.Date…...

爬虫逆向实战(五)--猿人学第三题
一、数据接口分析 主页地址:猿人学第三题 1、抓包 通过抓包可以发现数据接口是api/match/3 2、判断是否有加密参数 请求参数是否加密? 无请求头是否加密? 无响应是否加密? 无cookie是否加密? 无 二、发送请求 …...

[虚幻引擎] UE使用虚拟纹理在模型上显示挖空效果
此教程是记录如在UE中使用虚拟纹理,实现模型挖洞的效果。 1. 新建项目,开启项目支持虚拟纹理并并重启。 2. 新建一个基础关卡 3. 拖动“运行时虚拟纹理体积” 进入场景,并把体积修改变大,以可以完全包括到地板。 4. 创建一个虚拟纹…...

vue3中reactive和ref的比较
1.reactive和ref函数的共同作用是什么? 用函数调用的方式生成响应式数据 2. reactive vs ref? 1.reactive不能处理简单类型的数据 2.ref参数类型支持更好但是必须通过.value访问修改 3.ref函数的内部实现依赖于reactive函数 3. 在实际工作中推荐使用哪个? …...

Beats:使用 Filebeat 将 golang 应用程序记录到 Elasticsearch - 8.x
毫无疑问,日志记录是任何应用程序最重要的方面之一。 当事情出错时(而且确实会出错),我们需要知道发生了什么。 为了实现这一目标,我们可以设置 Filebeat 从我们的 golang 应用程序收集日志,然后将它们发送…...

【STM32+ESP8266上云连载①】给ESP8266烧录AT固件
文章目录 一、给NodeMCU烧录固件1.1硬件准备1.2软件准备1.3AT固件下载1.4配置设置1.5开始烧录 二、给ESP8266-01S烧录固件2.1硬件准备2.2AT固件下载2.3连线2.4烧录配置 三、给ESP-12E/F/S单片烧录固件四、指令测试4.1HTTP测试4.2MQTT测试 我在使用ESP8266的时候遇到了一些问题&…...

深入解析Spring基本概念和核心思想
文章目录 基本概念IoCIoc容器IoC理解IoC的步骤Spring中使用ioc的步骤 AopAop的理解Aop的步骤 控制反转谁控制谁? 控制什么?为何叫反转(对应于正向)?哪些方面反转了?为何需要反转? 依赖什么是依赖(按名称理解、按动词理解)? 谁依赖于谁? 为什么需要依赖? 依赖什么东西?…...

Redis数据结构——快速列表quicklist、快表
定义 Redis中的数据结构,链表和压缩列表这两种数据结构是列表对象的底层实现方式。 当时考虑到链表的附加空间太大,节点的内存都是单独分配的,还会导致内存碎片化问题严重。 因此从Redis3.2开始,对列表的底层数据结构进行了改造&…...

excel统计函数篇3之rank系列
下面这三个函数都是返回指定数据在指定范围中的数据中的名次 1、RANK(number,ref,[order]):返回一列数字的数字排位(数字排位是相对于列表中其他值的大小) rank(数字,数字序列,升序/降序) – 数字在数字序列中的名次 2、RANK.AV…...

Flink 火焰图
方式一 使用 Flink Web UI 的 Flame Graph Flink 自己也支持了 Task 粒度的 Flame Graphs 功能,并且可以细化到 subtask 粒度。 第一步:配置启用功能 Flink 作业动态参数里增加配置:“rest.flamegraph.enabled”: “true” 并重启作业。当前…...

kubectl get 中英文对照
wlzx059node01:~$ kubectl get --help Display one or many resources. (显示一个或多个资源。)Prints a table of the most important information about the specified resources. You can filter the list using a label selector and the --selector flag. If the desired …...

R语言APSIM模型进阶应用与参数优化、批量模拟实践技术
随着数字农业和智慧农业的发展,基于过程的农业生产系统模型在模拟作物对气候变化的响应与适应、农田管理优化、作物品种和株型筛选、农田固碳和温室气体排放等领域扮演着越来越重要的作用。APSIM (Agricultural Production Systems sIMulator)模型是世界知名的作物生…...

无涯教程-Perl - times函数
描述 此函数返回一个四元素列表,为当前进程及其子进程提供用户,系统,子进程和子系统时间。 语法 以下是此函数的简单语法- times返回值 此函数返回ARRAY,($usertime,$systemtime,$childsystem,$childuser) 例 以下是显示其基本用法的示例代码- #!/usr/bin/perl -w($use…...

《计算机网络:自顶向下方法》第五章--网络层:控制平面
控制平面作为一种网络范围的逻辑,不仅控制沿着从源主机到目的主机的端到端路径间的路由器如何转发数据报,而且控制网络层组件和服务如何配置和管理 传统上,控制平面功能与数据平面的转发功能在一起实现,在路由器中作为统一的整体…...