• WebRTC QoS方法之Pacer实现


    1 背景介绍

    若仅仅发送音频数据,不需要PACER模块:

    1)一帧音频数据本身不大,不会超过以太网的最大报文长度。一个RTP报文可以搞定,按照打包时长的节奏发送就可以。但视频数据不能按照音频数据的思路发送,一帧视频可能很大,远大于以太网的1500byte,需要分别封装在几个RTP报文中,若这些视频帧RTP报文一起发送到网络上,必然会导致网络瞬间拥塞。产生丢包抖动等异常。

    2)大多数编解码格式下,一帧音频数据长度固定,音频码率持续平稳。码率不会出现忽高忽低现象。但是一帧视频数据长度受内容影响严重。I、P、B帧间的长度相差非常大。直接发送网络波动幅度很大。尤其是WIFI环境下,受限WIFI的调度机制,媒体数据能否平稳发送,对弱网的WiFi环境对通话质量影响很大。

    PACER的目的就是让视频数据按照评估码率均匀的在各个时间片发送出去。如下图所示:

    2 实现原理  

    2.1 设计PACER模块主要解决三个问题

    2.1.1 怎么发

    音频,视频、NACK、FEC,PADDING报文都要统一从PACER模块发送。若不区分报文优先级,势必会对系统延时产生很大的影响。

    所以音视频数据编码和RTP切分打包后,首先将RTP报文存在pace queue队列,并将报文元数据(packet id, size, timestamp, 重传标示)送到pacer queue进行排队等待发送,插入队列的元数据会进行优先级排序。

    pace queue是一个基于优先级排序的多维链表,它并不是一个先进先出的fifo,而是一个按优先级排序的list。报文优先级规则是:

    优先级高的报文排在fifo的前面,低的排在后面。

    首先判断报文的priority等级,等级越小的优先级越高(priority等级根据报文类型进行分类)。

    然后判断重发标示,重发的报文比普通报文的优先级更高

    最后是判断视频帧timestamp,越早的视频帧优先级更高。

    pacer每次触发发送事件时是先从queue的最前面取出优先级最高的报文进行发送,这样做的目的是让视频在传输的过程中延迟尽量小,重传的报文尽快能到达防止等待卡顿。pace queue还可以设置最大延迟,如果超过最大延迟,会计算queue中数据发送所需要的码率,并且会把这个码率替代target bitrate作为budget参考码率来加速发送(最大延时详细处理流程在2.2小节有介绍)

    本文福利, C++音视频学习资料包、技术视频,内容包括(音视频开发,面试题,FFmpeg webRTC rtmp hls rtsp ffplay srs↓↓↓↓↓↓见下面↓↓文章底部点击领取↓↓

    根据报文类型确定数据优先级处理函数如下:

    按照优先级POP数据处理函数如下:

    2.1.2 什么时候发

    PacingController::NextSendTime、PacingController::ProcessPackets是PACER模块两个核心函数,PacingController::ProcessPackets按照PacingController::NextSendTime控制的节奏周期调用。完成PACER平滑发送功能。

    PacingController::NextSendTime在控制发送节奏上,有两种模式kPeriodic、kDynamic。kDynamic还没理解透,这里先记录kPeriodic实现方式。

    kPeriodic模式下,固定每隔5ms调用一次发送报文任务。

    2.1.3 发多少

    PacingController::ProcessPackets被定时触发后,会计算当前时间和上次被调用时间的时间差,然后将时间差参数传入media_budget_,media_budget_算出当前时间片网络可以发送多少数据,然后从pacer queue当中取出报文元数据进行网络发送。

    media_budget_根据评估出来的参考码率计算这次定时事件能发送多少字节的公式如下:

    delta time:上次检查时间点和这次检查时间点的时间差。

    target bitrate:pacer的参考码率,是由estimator根据网络状态评估出来的。

    remain_bytes:每次触发发包时会减去发送报文的长度size,如果remain_bytes > 0,继续从pace queue中取下一个报文进行发送,直到remain_bytes <=0 或者 pace queue没有更多的报文。

    如果pacer queue没有更多待发送的报文,但media_budget_计算出还可以发送更多的数据,这个时候pacer会进行padding报文补充。

    2.2 PACER模块引入延时问题规避方法

    2.2.1 max_pacing_delay

    PACER模块定量计算发送网络报文数据量,相当于cache等待发送,必然会引起延迟。为了保证实时性,PACER模块有个max_pacing_delay全局变量,配置最大缓冲发送延时时间上限,若最大缓冲延时大于该值,就要重新调整PACER模块的目标码率,保证当前数据都能及时发送出去。

    max_pacing_delay生效流程如下:

    配置max_pacing_delay参数

    •    VideoSendStreamImpl::VideoSendStreamImpl配置到transport->SetQueueTimeLimit

    •  PacingController::ProcessPackets

          会实时计算当前处理方式会引入的系统延时,当延时大于设定目标上限值,需要及时调整PACER目标码率,保证PACER模块引入延时时间可控。

    很明显这仅仅是一个迫不得己的规避方法,实际应用中,这种方法会出现码率梯度上升现象。

    2.2.2 编码算法码控模块配合

    PACER模块实现不复杂,但是要想真正做好PACER功能,仅仅靠一个PACER模块是玩不转的,需要与视频编码器的码控模块配合:

    1、首先探测模块配置码率给编码器,编码器一定要保证在可控周期内码率收敛到配置的码率参数值以内,否则会给PACER模块造成的累计延时越来越大压力。

    2、另外IP帧rate也要在合理范围内。若I帧超大,势必导致关键帧传输延时变大,影响端到端系统延时。

    这些参数都要根据自己的实际应用场景进行调优。

    三、备注说明

    上述是按照PacedSender算法对pacer模块进行分析,实际上webrtc有两套pace算法。TaskQueuePacedSender和PacedSender。他们在RtpTransportControllerSend::RtpTransportControllerSend函数中的use_task_queue_pacer_配置

     本文福利, C++音视频学习资料包、技术视频,内容包括(音视频开发,面试题,FFmpeg webRTC rtmp hls rtsp ffplay srs↓↓↓↓↓↓见下面↓↓文章底部点击领取↓↓

  • 相关阅读:
    sarsa算法和qlearning算法有什么不同
    Python实战项目-7发送验证码/短信登录/短信注册接口
    uniapp中使用编辑器editor
    Pytorch索引、切片、连接
    NumPy 中的排序方法(sort, argsort, lexsort, partition, argpartition, searchsorted)
    【软考 系统架构设计师】嵌入式系统⑤ 嵌入式系统开发与设计
    Educational Codeforces Round 41 (Rated for Div. 2) E. Tufurama
    vue3: 1.如何利用 effectScope 自己实现一个青铜版pinia 一 state篇
    MTK刷机工具 SP Flash Tool linux 版本安装失败
    NuttX实时操作系统介绍(最详细)
  • 原文地址:https://blog.csdn.net/m0_60259116/article/details/126287853