mediasoup源码分析(七)transport传输

本文主要是介绍mediasoup源码分析(七)transport传输，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

transport传输

- 一、Tansport 转发到Producer
- 二、RtpStreamRecv 处理收到的包
- 三、数据传输到Router，再分发到Consumer
- tips

一、Tansport 转发到Producer

Transport收到数据packet后，会解析出packet中所带的ssrc字段，然后基于ssrc找到该数据的Producer。

Transport::ReceiveRtpPacket
{// Get the associated Producer.RTC::Producer* producer = this->rtpListener.GetProducer(packet);//基于包中的ssrc选出Producer
}

Produer也是基于ssrc找到RtpStreamRecv

//生产者接收到rtp包，数据发送者类
Producer::ReceiveRtpPacketResult Producer::ReceiveRtpPacket(RTC::RtpPacket* packet)
{// Count number of RTP streams.  基于ssrc获取与该包相关的流管理类RTC::RtpStreamRecvauto numRtpStreamsBefore = this->mapSsrcRtpStream.size();auto* rtpStream = GetRtpStream(packet);// Media packet. 判断接收包和与之关联的流的SSRC是否相等，即得保证该包属于该流if (packet->GetSsrc() == rtpStream->GetSsrc()){result = ReceiveRtpPacketResult::MEDIA;// Process the packet.if (!rtpStream->ReceivePacket(packet)){}}this->listener->OnProducerRtpPacketReceived(this, packet);
}

二、RtpStreamRecv 处理收到的包

//流处理接收到的包  这块的逻辑是核心也非常重要，先列出来，后面会单独讲解
bool RtpStreamRecv::ReceivePacket(RTC::RtpPacket* packet)
{//nack 处理   //jitter更新//重传包更新//新包更新
}

三、数据传输到Router，再分发到Consumer

//RtpStreamRecv处理完手机后，数据包又回传到Transport
//此处的listener是Router
inline void Transport::OnProducerRtpPacketReceived()
{this->listener->OnTransportProducerRtpPacketReceived(this, producer, packet);
}
//数据传输到Router
inline void Router::OnTransportProducerRtpPacketReceived(RTC::Transport* /*transport*/, RTC::Producer* producer, RTC::RtpPacket* packet)
{//路由中维护生成者和所有消费者的map关联关系auto& consumers = this->mapProducerConsumers.at(producer);//把数据发给每一个消费者for (auto* consumer : consumers){// Update MID RTP extension value.const auto& mid = consumer->GetRtpParameters().mid;if (!mid.empty())packet->UpdateMid(mid);consumer->SendRtpPacket(packet);}
}