基于UDP传输协议的实现分析之流量和拥塞控制

这篇具有很好参考价值的文章主要介绍了基于UDP传输协议的实现分析之流量和拥塞控制。希望对大家有所帮助。如果存在错误或未考虑完全的地方,请大家不吝赐教,您也可以点击"举报违法"按钮提交疑问。

  UDP的概念

  UDP 是User Datagram Protocol的简称, 中文名是用户数据报协议,是OSI(Open System Interconnection,开放式系统互联) 参考模型中一种无连接的传输层协议,提供面向事务的简单不可靠信息传送服务,IETF RFC 768是UDP的正式规范。UDP在IP报文的协议号是17。

  流量控制

  对于一个带宽1Gbps, RTT为100ms的网络来说

  BDP=1,000,000,000*0.1/8=12,500,000字节=12207K=12M

  传统TCP接收窗口大小=65535byte=64K, 显然满足不了

  udt使用包大小1500byte, 默认接口窗口大小为8192, 因此

  接收窗口的大小为=1500*8192=12,288,000字节=12000K=11.7M

  因此, 可以看到udt的默认设置已经足够.

  Congestion Control(拥塞控制)

  1. 两个重要的参数:

  congestion window size and the inter-packet sending interval

  2. 主要的接口

  1) init: when the UDT socket is connected.

  2) close: when the UDT socket is closed.

  3) onACK: when ACK is received.

  4) onLOSS: when NACK is received.

  5) onTimeout: when timeout occurs.

  6) onPktSent: when a data packet is sent.

  7) onPktRecv: when a data packet is received.

  3. udt的拥塞算法:

  On ACK packet received:

  1) If the current status is in the slow start phase, set the

  congestion window size to the product of packet arrival rate and

  (RTT + SYN). Slow Start ends. Stop.

  2) Set the congestion window size (CWND) to: CWND = A * (RTT + SYN) +16.

  3) The number of sent packets to be increased in the next SYN period

  (inc) is calculated as:

  if (B <= C)</p>

  inc = 1/PS;

  else

  inc = max(10^(ceil(log10((B-C)*PS*8))) * Beta/PS, 1/PS);

  where B is the estimated link capacity and C is the current

  sending speed. All are counted as packets per second. PS is the

  fixed size of UDT packet counted in bytes. Beta is a constant

  value of 0.0000015.

  4) The SND period is updated as:

  SND = (SND * SYN) / (SND * inc + SYN).

  Java代码

复制代码
代码如下:
  1.Java代码
  2.*/
  3.publicvoidonACK(longackSeqno){
  4.//increasewindowduringslowstart
  5.if(slowStartPhase){
  6.congestionWindowSize+=ackSeqno-lastAckSeqNumber;
  7.lastAckSeqNumber=ackSeqno;
  8.//butnotbeyondamaximumsize
  9.if(congestionWindowSize>session.getFlowWindowSize()){
  10.slowStartPhase=false;
  11.if(packetArrivalRate>0){
  12.packetSendingPeriod=1000000.0/packetArrivalRate;
  13.}
  14.else{
  15.packetSendingPeriod=(double)congestionWindowSize/(roundTripTime+Util.getSYNTimeD());
  16.}
  17.}
  18.
  19.}else{
  20.//1.ifitisnotinslowstartphase,setthecongestionwindowsize
  21.//totheproductofpacketarrivalrateand(rtt+SYN)
  22.doubleA=packetArrivalRate/1000000.0*(roundTripTime+Util.getSYNTimeD());
  23.congestionWindowSize=(long)A+16;
  24.if(logger.isLoggable(Level.FINER)){
  25.logger.finer("receiverate"+packetArrivalRate+"rtt"+roundTripTime+"settowindowsize:"+(A+16));
  26.}
  27.}
  28.
  29.//norateincreaseduringslowstart
  30.if(slowStartPhase)return;
  31.
  32.//norateincrease"immediately"afteraNAK
  33.if(loss){
  34.loss=false;
  35.return;
  36.}
  37.
  38.//4.computetheincreaseinsentpacketsforthenextSYNperiod
  39.doublenumOfIncreasingPacket=computeNumOfIncreasingPacket();
  40.
  41.//5.updatethesendperiod
  42.doublefactor=Util.getSYNTimeD()/(packetSendingPeriod*numOfIncreasingPacket+Util.getSYNTimeD());
  43.packetSendingPeriod=factor*packetSendingPeriod;
  44.//packetSendingPeriod=0.995*packetSendingPeriod;
  45.
  46.statistics.setSendPeriod(packetSendingPeriod);
  47.}

  On NAK packet received:

  1) If it is in slow start phase, set inter-packet interval to

  1/recvrate. Slow start ends. Stop.

  2) If this NAK starts a new congestion period, increase inter-packet

  interval (snd) to snd = snd * 1.125; Update AvgNAKNum, reset

  NAKCount to 1, and compute DecRandom to a random (average

  distribution) number between 1 and AvgNAKNum. Update LastDecSeq.

  Stop.

  3) If DecCount <= 5, and NAKCount == DecCount * DecRandom:</p>

  a. Update SND period: SND = SND * 1.125;

  b. Increase DecCount by 1;

  c. Record the current largest sent sequence number (LastDecSeq).

  Java代码

复制代码
代码如下:
  1./*(non-Javadoc)
  2.*@seeudt.CongestionControl#onNAK(java.util.List)
  3.*/
  4.publicvoidonLoss(ListlossInfo){
  5.loss=true;
  6.longfirstBiggestlossSeqNo=lossInfo.get(0);
  7.nACKCount++;
  8./*1)Ifitisinslowstartphase,setinter-packetintervalto
  9.1/recvrate.Slowstartends.Stop.*/
  10.if(slowStartPhase){
  11.if(packetArrivalRate>0){
  12.packetSendingPeriod=100000.0/packetArrivalRate;
  13.}
  14.else{
  15.packetSendingPeriod=congestionWindowSize/(roundTripTime+Util.getSYNTime());
  16.}
  17.slowStartPhase=false;
  18.return;
  19.}
  20.
  21.longcurrentMaxSequenceNumber=session.getSocket().getSender().getCurrentSequenceNumber();
  22.//2)IfthisNAKstartsanewcongestionepoch
  23.if(firstBiggestlossSeqNo>lastDecreaseSeqNo){
  24.//-increaseinter-packetinterval
  25.packetSendingPeriod=Math.ceil(packetSendingPeriod*1.125);
  26.//-UpdateAvgNAKNum(theaveragenumberofNAKspercongestion)
  27.averageNACKNum=(int)Math.ceil(averageNACKNum*0.875+nACKCount*0.125);
  28.//-resetNAKCountandDecCountto1,
  29.nACKCount=1;
  30.decCount=1;
  31./*-computeDecRandomtoarandom(averagedistribution)numberbetween1andAvgNAKNum*/
  32.decreaseRandom=(int)Math.ceil((averageNACKNum-1)*Math.random()+1);
  33.//-UpdateLastDecSeq
  34.lastDecreaseSeqNo=currentMaxSequenceNumber;
  35.//-Stop.
  36.}
  37.//*3)IfDecCount<=5,andNAKCount==DecCount*DecRandom:<br>  38.elseif(decCount<=5&&nACKCount==decCount*decreaseRandom){<br>  39.//a.UpdateSNDperiod:SNDSND=SND*1.125;
  40.packetSendingPeriod=Math.ceil(packetSendingPeriod*1.125);
  41.//b.IncreaseDecCountby1;
  42.decCount++;
  43.//c.Recordthecurrentlargestsentsequencenumber(LastDecSeq).
  44.lastDecreaseSeqNo=currentMaxSequenceNumber;
  45.}
  46.
  47.statistics.setSendPeriod(packetSendingPeriod);
  48.return;
  49.}

  以上就是基于UDP传输协议的流量和拥塞控制的代码,希望能帮到大家,谢谢阅读。文章来源地址https://www.toymoban.com/news/detail-466523.html

到了这里,关于基于UDP传输协议的实现分析之流量和拥塞控制的文章就介绍完了。如果您还想了解更多内容,请在右上角搜索TOY模板网以前的文章或继续浏览下面的相关文章,希望大家以后多多支持TOY模板网!

本文来自互联网用户投稿,该文观点仅代表作者本人,不代表本站立场。本站仅提供信息存储空间服务,不拥有所有权,不承担相关法律责任。如若转载,请注明出处: 如若内容造成侵权/违法违规/事实不符,请点击违法举报进行投诉反馈,一经查实,立即删除!

领支付宝红包 赞助服务器费用

相关文章

  • 千兆以太网传输层 UDP 协议原理与 FPGA 实现(UDP接收)

    相关文章: (1)千兆以太网网络层 ARP 协议的原理与 FPGA 实现 (2)千兆以太网硬件设计及链路层 MAC 协议格式 (3)CRC校验原理及实现 (4)RGMII 与 GMII 转换电路设计 (5)千兆以太网网络层 IP 协议介绍与 IP 校 验和算法实现 (6)千兆以太网传输层 UDP 协议原理与 FPGA 实现(

    2024年02月04日
    浏览(128)
  • 哈工大计算机网络课程传输层协议之:拥塞控制原理剖析

    哈工大计算机网络课程传输层协议详解之:可靠数据传输的基本原理 哈工大计算机网络课程传输层协议详解之:流水线机制与滑动窗口协议 哈工大计算机网络课程传输层协议详解之:TCP协议 **拥塞(Congestion)** 非正式定义:“太多发送主机发送了太多数据或者发送速度太快

    2024年02月11日
    浏览(42)
  • Labview实现vi间数据传递的方法汇总 ---子VI、队列、全局变量及UDP/TCP协议传输

    本文汇总一下不同VI之间数据传递的方式,使大家明确数据传递的几种类型并灵活使用。 本文程序均上传至云端,读者可自行下载学习。 基于目前大家所学到的基础知识,在Labview中简单来说数据类型基本包括 数值、字符串、数组、簇、布尔量、引用、路径、枚举量、波形图

    2024年04月10日
    浏览(55)
  • 【网络】传输层协议-UDP协议

    回忆数据发送到网络的过程 之前在学习HTTP等应用层协议时为了方便理解:我们简单的认为HTTP协议是将请求和响应直接发送到了网络当中 实际上: 应用层需要先将数据交给传输层,由传输层对数据做进一步处理后再将数据继续向下进行交付,该过程贯穿整个网络协议栈,最终才能将

    2024年02月03日
    浏览(85)
  • 传输层协议——UDP

    ssh服务器, 使用 22 端口 ftp服务器, 使用 21 端口 telnet服务器,使用 23 端口 http服务器, 使用 80 端口 https服务器, 使用 443 端口 0-1023: 知名端口号, HTTP、FTP、SSH应用层协议,端口号是固定的 1024-65535 : 操作系统动态分配的端口号,客户端程序的端口号,就由操作系统从这

    2024年02月07日
    浏览(36)
  • 传输层协议--UDP

    传输层负责数据能够从发送端传输到接收端。 端口号标识了一个主机上进行通信的一个进程。 两个问题: 1. 一个进程可以绑定多个端口号吗? --可以 2.一个端口号可以绑定多个进程吗?--不可以 我们需要维护的是一个端口号唯一确定一个进程,这关系好比函数(一个x只能唯

    2024年02月09日
    浏览(31)
  • 【计算机网络】传输层协议 -- UDP协议

    传输层是计算机网络中的一个重要层次,位于网络层和应用层之间,它的主要功能是为应用层提供端到端的数据传输服务,负责确保数据可靠传输、流浪控制和拥塞控制等。 传输层的两个主要协议是传输控制协议(TCP)和用户数据报协议(UDP)。它们各自有不同的特点和用途

    2024年02月15日
    浏览(75)
  • 【Linux】UDP协议——传输层

    目录 传输层 再谈端口号 端口号范围划分 认识知名端口号 两个问题 netstat与iostat pidof UDP协议 UDP协议格式 UDP协议的特点 面向数据报 UDP的缓冲区 UDP使用注意事项 基于UDP的应用层协议 在学习HTTP等应用层协议时,为了便于理解,可以简单的认为HTTP协议是将请求和响应直接发送

    2024年02月13日
    浏览(37)
  • 传输层(TCP/UDP)协议

    TCP(Transmission Control Protocol)传输控制协议 IP(Internet Protocol)因特网互联协议 TCP/IP是一个Protocol Stack,包括TCP、IP、UDP、ICMP、RIP、TELNET、FTP、SMTP、ARP等许多协议,叫TCP/IP只是因为其中使用并且最具代表性的是这两个协议。 1.工作在传输层 2.面向连接协议 3.全双工协议 4.半关

    2024年04月15日
    浏览(45)
  • 传输层协议----UDP/TCP

    传输层的作用就是负责数据能够从发送端传输到接收端. 正文开始! 端口号(Port)标识了一个主机上进行通信的不同的应用程序; 在TCP/IP协议中中,用\\\"源IP\\\",“源端口号”,“目的IP”,“目的端口号”,\\\"协议号\\\"这样的一个五元组来标识一个通信(在Linux中可以通过netstat -n查看) 0~1023:知

    2023年04月08日
    浏览(44)

觉得文章有用就打赏一下文章作者

支付宝扫一扫打赏

博客赞助

微信扫一扫打赏

请作者喝杯咖啡吧~博客赞助

支付宝扫一扫领取红包,优惠每天领

二维码1

领取红包

二维码2

领红包