webrtc源码阅读之NACK

**WebRTC源码阅读之NACK**

在WebRTC中，NACK（Negative Acknowledgment）是用于处理媒体流传输过程中的错误或丢包的机制。它允许发送端检测到接收端未正确接收到的数据包，并重新发送这些数据包，以保证媒体流的完整性和可靠性。在本文中，我们将深入探讨WebRTC源码中的NACK机制，包括其工作原理、关键实现细节以及相关代码示例。

**1. NACK的基本概念**

在WebRTC中，NACK是用于处理媒体流传输过程中的错误或丢包的机制。它允许发送端检测到接收端未正确接收到的数据包，并重新发送这些数据包，以保证媒体流的完整性和可靠性。

**2. NACK的工作原理**

NACK的工作原理如下：

* 当接收端接收到一个数据包时，它会将该数据包的序列号（Sequence Number）存储在缓冲区中。
* 如果接收端检测到某个数据包丢失或错误，或者缓冲区已满，它会向发送端发送NACK消息，包含未正确接收到的数据包的序列号。
* 当发送端接收到NACK消息时，它会重新发送这些未正确接收到的数据包。

**3. NACK的实现细节**

在WebRTC源码中，NACK是由`RTCPeerConnection`类中的`handleRtcpNack()`函数来处理的。这个函数负责解析NACK消息，确定哪些数据包需要重新发送，并将这些数据包重新发送给接收端。

cppvoid RTCPeerConnection::handleRtcpNack(const RtpPacket& packet) {
 // 解析NACK消息中的序列号 uint32_t sequenceNumber = packet.getSequenceNumber();

 // 确定哪些数据包需要重新发送 std::vector packetsToResend;
 for (const auto& stream : m_streams) {
 if (stream->isStreamActive()) {
 packetsToResend.push_back(stream->getPacket(sequenceNumber));
 }
 }

 // 将这些数据包重新发送给接收端 for (uint32_t packetId : packetsToResend) {
 RtpPacket newPacket = m_rtpSender.createRtpPacket(packetId);
 m_rtpSender.sendRtpPacket(newPacket);
 }
}

cpp// 接收端接收到数据包后，将其序列号存储在缓冲区中void Receiver::onRtpPacketReceived(const RtpPacket& packet) {
 m_buffer.push_back(packet.getSequenceNumber());
}

// 接收端检测到某个数据包丢失或错误，或者缓冲区已满时向发送端发送NACK消息void Receiver::sendNack() {
 std::vector missingPackets;
 for (uint32_t sequenceNumber : m_buffer) {
 if (!m_receivedPackets.contains(sequenceNumber)) {
 missingPackets.push_back(sequenceNumber);
 }
 }

 RtpPacket nackPacket = m_rtpSender.createRtpNack(missingPackets);
 m_rtpSender.sendRtpPacket(nackPacket);
}

// 发送端接收到NACK消息后重新发送这些未正确接收到的数据包void Sender::onRtcpNack(const RtpPacket& packet) {
 std::vector packetsToResend;
 for (const auto& stream : m_streams) {
 if (stream->isStreamActive()) {
 packetsToResend.push_back(stream->getPacket(packet.getSequenceNumber()));
 }
 }

 for (uint32_t packetId : packetsToResend) {
 RtpPacket newPacket = m_rtpSender.createRtpPacket(packetId);
 m_rtpSender.sendRtpPacket(newPacket);
 }
}