接收来自 SD-RTN™ 的媒体流

 auto service = createAndInitAgoraService(false, true, true);    

// Create local user observer
  auto localUserObserver =
      std::make_shared<SampleLocalUserObserver>(connection->getLocalUser());


  // Register audio frame observer to receive audio stream
  auto pcmFrameObserver = std::make_shared<PcmFrameObserver>(options.audioFile);
  if (connection->getLocalUser()->setPlaybackAudioFrameBeforeMixingParameters(
          options.audio.numOfChannels, options.audio.sampleRate)) {
    AG_LOG(ERROR, "Failed to set audio frame parameters!");
    return -1;
  }
  localUserObserver->setAudioFrameObserver(pcmFrameObserver.get());

  // Register video frame observer to receive video stream
  agora::agora_refptr<agora::rtc::IVideoSinkBase> yuvFrameObserver =
      new agora::RefCountedObject<YuvFrameObserver>(options.videoFile);
  localUserObserver->setVideoFrameObserver(yuvFrameObserver);

4. 接收媒体流

注册音频帧观测器和视频帧观测器后，当 SDK 触发 onPlaybackAudioFrameBeforeMixing或 onFrame回调时，意味着收到了一个音频帧或视频帧。你需要在这两个回调函数中添加接收媒体流的逻辑，比如将音频帧写入音频文件。

// Callback to receive a PCM frame
bool PcmFrameObserver::onPlaybackAudioFrameBeforeMixing(
    unsigned int uid, AudioFrame& audioFrame) {
  // Create new file to save received PCM samples
  if (!pcmFile_) {
    std::string fileName = (++fileCount > 1)
                               ? (outputFilePath_ + to_string(fileCount))
                               : outputFilePath_;
    if (!(pcmFile_ = fopen(fileName.c_str(), "w"))) {
      AG_LOG(ERROR, "Failed to create received audio file %s",
             fileName.c_str());
      return false;
    }
    AG_LOG(INFO, "Created file %s to save received PCM samples",
           fileName.c_str());
  }


  // Write PCM samples
  size_t writeBytes =
      audioFrame.samplesPerChannel * audioFrame.channels * sizeof(int16_t);
  if (fwrite(audioFrame.buffer, 1, writeBytes, pcmFile_) != writeBytes) {
    AG_LOG(ERROR, "Error writing decoded audio data: %s", std::strerror(errno));
    return false;
  }
  fileSize_ += writeBytes;

  // Close the file if size limit is reached
  if (fileSize_ >= DEFAULT_FILE_LIMIT) {
    fclose(pcmFile_);
    pcmFile_ = nullptr;
    fileSize_ = 0;
  }
  return true;
}

// Callback to receive a YUV frame
int YuvFrameObserver::onFrame(
    const agora::media::base::VideoFrame& videoFrame) {
  // Create new file to save received YUV frames
  if (!yuvFile_) {
    std::string fileName = (++fileCount > 1)
                               ? (outputFilePath_ + to_string(fileCount))
                               : outputFilePath_;
    if (!(yuvFile_ = fopen(fileName.c_str(), "w+"))) {
      AG_LOG(ERROR, "Failed to create received video file %s",
             fileName.c_str());
      return -1;
    }
    AG_LOG(INFO, "Created file %s to save received YUV frames",
           fileName.c_str());
  }

  // Write Y planar
  size_t writeBytes = videoFrame.yStride * videoFrame.height;
  if (fwrite(videoFrame.yBuffer, 1, writeBytes, yuvFile_) != writeBytes) {
    AG_LOG(ERROR, "Error writing decoded video data: %s", std::strerror(errno));
    return -1;
  }
  fileSize_ += writeBytes;

  // Write U planar
  writeBytes = videoFrame.uStride * videoFrame.height / 2;
  if (fwrite(videoFrame.uBuffer, 1, writeBytes, yuvFile_) != writeBytes) {
    AG_LOG(ERROR, "Error writing decoded video data: %s", std::strerror(errno));
    return -1;
  }
  fileSize_ += writeBytes;

  // Write V planar
  writeBytes = videoFrame.vStride * videoFrame.height / 2;
  if (fwrite(videoFrame.vBuffer, 1, writeBytes, yuvFile_) != writeBytes) {
    AG_LOG(ERROR, "Error writing decoded video data: %s", std::strerror(errno));
    return -1;
  }
  fileSize_ += writeBytes;

  // Close the file if size limit is reached
  if (fileSize_ >= DEFAULT_FILE_LIMIT) {
    fclose(yuvFile_);
    yuvFile_ = nullptr;
    fileSize_ = 0;
  }
  return 0;
};

5. 断开连接并释放资源

媒体流传输完成后，你可以通过以下步骤退出频道并断开与声网服务器的连接：

1. 注销音视频帧观测器。
2. 调用 disconnect 断开与声网服务器的连接。
3. 释放 IRtcConnection 对象相关的资源。
   你必须严格按照示例代码中的顺序释放相关资源。

// Unregister audio & video frame observers
  localUserObserver->unsetAudioFrameObserver();
  localUserObserver->unsetVideoFrameObserver();


  // Disconnect from声网channel
  if (connection->disconnect()) {
    AG_LOG(ERROR, "Failed to disconnect from声网channel!");
    return -1;
  }
  AG_LOG(INFO, "Disconnected from声网channel successfully");


  // Destroy声网connection and related resources
  localUserObserver.reset();
  pcmFrameObserver.reset();
  yuvFrameObserver = nullptr;
  connection = nullptr;

6. 全局注销

当你的应用程序退出时，可以调用如下逻辑，注销整个 AgoraService。

// Destroy声网 Service
  service->release();
  service = nullptr;

进阶功能

使用 String 型用户 ID

Linux SDK 支持使用 String 型用户 ID 加入频道。使用时，你需要注意以下限制：

• 在调用 createAndInitAgoraService 时，需要将 enableuseStringUid 设为 true。
• String 型用户 ID 能且只能与 String 型用户 ID 互通。如果一个频道内同时存在 String 型用户 ID 和 Int 型用户 ID，会导致未知的错误。
• 和 Int 型用户 ID 不同，在调用 connect 方法时，你必须给 userId 赋值。设置为 null 会收到报错。
• String 型用户 ID 必须是频道内唯一的。

具体代码可参考 sample_stringuid_receive.cpp 示例项目。

接收加密后的媒体流

你可以使用 encryptionMode参数设置加密算法以及加密密钥。具体代码可参考 sample_receive_decrypted_h264.cpp 示例项目。

 // Set the encryption mode
  if (options.encryptionMode == true) {
    agora::rtc::EncryptionConfig Config;
    Config.encryptionMode = agora::rtc::SM4_128_ECB;
    Config.encryptionKey = options.encryptionKey.c_str();
    if (connection->enableEncryption(options.encryptionMode, Config) < 0) {
      AG_LOG(ERROR, "Failed to enable encryption!");
    }
    AG_LOG(INFO, "Enable encryption successfully");
  }

其他注意事项

• 以上所有接口函数，如无特殊说明，都是异步调用，无需担心阻塞用户线程。
• 在声网 SDK 和 Linux SDK 互通的场景中，请确保将 RTC SDK 的频道场景设置为 LIVE_BROADCASTING。
• SDK 发送 AAC 格式的音频数据时，不支持 44.1 Kbps 的采样率。

示例项目

我们在 SDK 中提供了一系列接收媒体流的示例项目，供你参考：