快速实现 CDN 推流

更新时间： 2024/07/24 13:38:57

网易云信音视频通话 SDK（简称 NERTC SDK）融合了 CDN 推流能力，您只要集成一个 SDK，即可实现单人直播、PK 直播和连麦功能。应用可以在三个场景间无缝切换，大大提升 PK 直播的用户体验。本文介绍如何在 iOS 工程中，通过 Cocoapods 引入 NERTC SDK，并实现 CDN 推流能力。

进行本文操作前，请确保您已经完成了前置准备工作：


  flowchart LR

    A("创建应用并获取 App Key") --> B(开通音视频通话 2.0<br>和直播服务)-->  E("获取推拉流地址")--> C("集成 RTC SDK") --> D(实现 CDN 推流)
    click A "https://doc.yunxin.163.com/console/concept/TIzMDE4NTA?platform=console"
    click B "https://doc.yunxin.163.com/live-streaming/quick-start/jExNTcyODc?platform=iOS"
    click C "https://doc.yunxin.163.com/live-streaming/quick-start/jExNTcyODc?platform=iOS"
    click E "https://doc.yunxin.163.com/live-streaming/quick-start/jExNTcyODc?platform=iOS#%E6%AD%A5%E9%AA%A43%20%E8%8E%B7%E5%8F%96%E6%8E%A8%E6%8B%89%E6%B5%81%E5%9C%B0%E5%9D%80"
    style D fill:#337EFF,stroke:#337EFF,stroke-width:0px,color:#FFFFFF;
    style A fill:#9DC3E6,stroke:#9DC3E6,stroke-width:0px,color:#FFFFFF;
    style B fill:#9DC3E6,stroke:#9DC3E6,stroke-width:0px,color:#FFFFFF;
    style C fill:#9DC3E6,stroke:#9DC3E6,stroke-width:0px,color:#FFFFFF;
    style E fill:#9DC3E6,stroke:#9DC3E6,stroke-width:0px,color:#FFFFFF;

功能介绍

CDN（Content Delivery Network，内容分发网络）推流，是指利用 CDN 技术将音视频直播或实时数据流从直播编码器、监控摄像头等源头传输到互联网用户的过程。关键流程如下：

  flowchart LR
  A("采集与编码") --> B("推流")-->  E("CDN 分发")
  E--> H("单人直播")
  E--> F("PK 直播")
  E--> G("直播中连麦")
    style A fill:#337EFF,stroke:#337EFF,stroke-width:0px,color:#FFFFFF;
    style B fill:#337EFF,stroke:#337EFF,stroke-width:0px,color:#FFFFFF;
    style E fill:#337EFF,stroke:#337EFF,stroke-width:0px,color:#FFFFFF;
    style F fill:#337EFF,stroke:#337EFF,stroke-width:0px,color:#FFFFFF;
    style G fill:#337EFF,stroke:#337EFF,stroke-width:0px,color:#FFFFFF;
    style H fill:#337EFF,stroke:#337EFF,stroke-width:0px,color:#FFFFFF;

采集与编码：通过摄像机、虚拟设备等采集端，采集音视频内容，并对其进行编码压缩，转换成适合网络传输的数字流格式。
推流：通过RTMP（Real-Time Messaging Protocol，实时消息传输协议）、HLS（HTTP Live Streaming）、FLV（Flash Video）等协议，将编码后的音视频流上传至 CDN 的入口节点。
CDN 分发：通过网易云信全球分布的边缘节点网络，将推流数据迅速、高效地缓存并分发到距离观众最近的 CDN 节点。
拉流与播放：观众通过播放器或 App，从 CDN 边缘节点拉取音视频流，实时观看低延迟和高质量的直播视频，并进行直播互动。
- 在单人直播时，NERTC SDK 将主播的音视频直接推流到 CDN 分发，观众无需加入房间即可通过播放器拉流观看。
- 在 PK 直播时，通过跨频道转发，无须切换 NERTC SDK，也不需要退出或重新进入房间，直接将媒体流转发到主播房间和挑战者房间，实现主播跨房间与其他主播实时互动。直播间内的观众可以同时观看两个主播 PK 互动，场景无缝切换。
- 直播中连麦成功后，观众在房间里与主播进行实时音视频通话，增加直播互动。

单人直播

单人直播的架构原理如下图所示。

单人直播模式下，主播 A 和主播 B 分别加入房间 A 和 B，NERTC SDK 将主播音视频直接推流到 CDN 分发，观众端使用 RTMP/HLS/FLV 协议进行拉流观看。

PK 直播

PK 直播的架构原理如下图所示。

PK 直播的业务流程说明如下：

主播 A 发出 PK 邀请，主播 B 同意。
通过跨频道转发，主播 A 和主播 B 不需要退出原房间，直接将媒体流转发到房间 A 和房间 B 中，实现主播跨房间与其他主播实时互动。
互动直播服务器将主播 A 和主播 B 的音视频进行混屏转码后，推到 CDN 分发。
观众端使用 RTMP/HLS/FLV 协议进行拉流观看。

连麦

连麦的架构原理如下图所示。

连麦的业务流程说明如下：

观众申请上麦，主播同意上麦申请后，观众加入 RTC 房间。
互动直播服务器将主播和观众的音视频进行混屏转码后，推到 CDN 分发。
观众端使用 RTMP/HLS/FLV 协议进行拉流观看。

应用场景

CDN 推流适用于直播间 PK、游戏、在线教育等场景：

秀场直播：PK 连麦是视频互动直播的主流玩法，多个主播间通过主动邀请、随机匹配等方式互相配对，连麦成功后通过斗歌等方式进行 PK 竞技，并在一定时限内决出胜负，获胜一方可获得奖励，例如粉丝礼物、打赏、积分等。
游戏场景：用户可以选择与其他玩家进行 PK，通过 PK 功能实现双方的音视频流同步播放，提高游戏体验。
电商直播：可通过引入 PK 连麦模式，实现价格比拼等直播形式，激起用户的购买欲望，摆脱传统电商直播缺少互动的单调形式。
在线教育：老师和学生可以通过 PK 功能进行互动课堂，实现音视频流的同步播放，提高学习效果。

下载示例代码

网易云信为您提供 实现 CDN 推流 的示例代码作为参考，您可以单击下载 CDN 推流最佳实践代码.zip，直接拷贝用于运行测试。

集成 NERTC SDK

只有 5.6.10 及以后版本的 NERTC SDK 支持 CDN 推流功能，请参考如下方法集成对应版本的 NERTC SDK。详细的集成 SDK 的步骤请参考集成 SDK。

下载 NERTC SDK

使用 CocoaPods 集成 5.6.10 版本 SDK 的示例代码如下：
```
CocoaPodspod 'NERtcSDK', '5.6.10'
```
如需手动集成，请到 SDK 下载中心的 直播推流区域 下载对应的 SDK。

为了保障您的直播业务用户体验，接入之前，请　提交工单联系网易云信技术支持工程师，根据您的场景为您提供专属的 1 对 1 服务。

导入 NERtcSDK 类

在项目中导入 NERtcSDK 类：

Objective-C#import <NERtcSDK/NERtcSDK.h>

注意事项

拉流时，只支持网易云信播放器 NELivePlayer 进行拉流，其他播放器暂不兼容。
旁路推流时，请使用客户端推流接口（addLiveStreamTask）。不要使用服务端的旁路推流接口，因为客户端推流接口针对本场景做了适配处理。

实现单人直播

API 时序图

sequenceDiagram
    title: 实现单人直播的 API 时序图
    actor 主播 A
    participant NERtcSDK as 网易云信 RTC SDK

    主播 A->>NERtcSDK: setupEngineWithContext 初始化引擎
    主播 A->>NERtcSDK: setChannelProfile 设置场景属性为直播
    主播 A->>NERtcSDK: setLocalVideoConfig 设置视频属性
    主播 A->>NERtcSDK: enableLocalVideo(YES) 开启视频的采集和发送
    主播 A->>NERtcSDK: enableLocalAudio(YES) 开启音频的采集和发送
    rect rgb(191, 223, 255)
    主播 A->>NERtcSDK: startPushStreaming 开始推流
    NERtcSDK-->>主播 A: onNERtcEngineStartPushStreaming

    主播 A->>NERtcSDK: stopPushStreaming 停止推流
    NERtcSDK-->>主播 A: onNERtcEngineStopPushStreaming
    end

实现方法

调用 setupEngineWithContext 方法初始化引擎。

您还需要在初始化时 注册相关必要回调，请在初始化方法中传入原型为 NERtcEngineDelegate / NERtcEngineDelegateEx 的回调，直播推流相关回调请参考常用的回调。
```
Objective-C NERtcEngineContext *context = [[NERtcEngineContext alloc] init];
 context.appKey = AppKey;
 context.engineDelegate = self;

 [[NERtcEngine sharedEngine] setupEngineWithContext:context];
```

设置直播场景

Objective-C[[NERtcEngine sharedEngine] setChannelProfile:kNERtcChannelProfileLiveBroadcasting];

设置视频参数

Objective-C//设置本地视频主流编码参数，建议 960*540*15 帧，对于清晰度有较高要求的可以选择 1280*720*15 帧
NERtcEngine *coreEngine = [NERtcEngine sharedEngine];
NERtcVideoEncodeConfiguration *config = [[NERtcVideoEncodeConfiguration alloc] init];
config.width = 1280;// 设置分辨率宽
config.height = 720;// 设置分辨率高
config.frameRate = kNERtcVideoFrameRateFps15; //视频帧率

[coreEngine setLocalVideoConfig:config streamType:kNERtcStreamChannelTypeMainStream];

设置音频参数

Objective-C//audioprofile 设置为 kNERtcAudioProfileHighQuality 和 kNERtcAudioScenarioMusic, 保证直播音频效果
[[NERtcEngine sharedEngine] setAudioProfile:kNERtcAudioProfileHighQuality
                                   scenario:kNERtcAudioScenarioMusic];

设置本地视频画布。

初始化成功后，可以设置本地视图，来预览本地图像。您可以根据业务需要实现加入房间之前预览或加入房间后预览。
```
Objective-CUIView *localUserView = [[UIView alloc] initWithFrame:CGRectMake(0, 0, 200, 200)];
NERtcVideoCanvas *canvas = [[NERtcVideoCanvas alloc] init];
canvas.container = localUserView;
[[NERtcEngine sharedEngine] setupLocalVideoCanvas:canvas];
```
- 若您想调整摄像头的相关参数，请参考视频设备管理进行设置。
- 实现加入房间前预览。
  1. 调用 setupLocalVideoCanvas 方法设置本地视图，可以通过 renderMode 和 mirrorMode 参数设置视频的渲染模式和镜像模式。再调用 startPreview(streamType) 方法预览本地图像。
```
Objective-C//设置本地视频画布，以适应区域模式、开启镜像为例
UIView *localUserView = [[UIView alloc] initWithFrame:CGRectMake(0, 0, 200, 200)];
NERtcVideoCanvas *canvas = [[NERtcVideoCanvas alloc] init];
canvas.container = localUserView;
[[NERtcEngine sharedEngine] setupLocalVideoCanvas:canvas];

//以开启本地视频主流预览为例
[[NERtcEngine sharedEngine] startPreview:kNERtcStreamChannelTypeMainStream];
```
  2. 若要结束预览调用 stopPreview(streamType) 方法停止预览。
    
    stopPreview(streamType) 的 streamType 参数请与 startPreview(streamType) 的保持一致，即同为主流或辅流的开启和停止预览。

调用 enableLocalVideo 和 enableLocalAudio 方法进行视频和音频的采集发送。

Objective-C[[NERtcEngine sharedEngine] enableLocalVideo:YES];
[[NERtcEngine sharedEngine] enableLocalAudio:YES];

主播调用 startPushStreaming 接口，将房间中的音视频流推流到 CDN 上，NERtcPushStreamingConfig 相关参数说明如下表所示。

Objective-C//设置推流参数 onfig.streamingRoomInfo = roomInfo;
NERtcPushStreamingConfig *pushConfig = [[NERtcPushStreamingConfig alloc] init];
NERtcStreamingRoomInfo *roomInfo = [[NERtcStreamingRoomInfo alloc] init];
roomInfo.channelName = cname;
roomInfo.uId = uid;
roomInfo.token = token; //用于加入房间的 toke
pushConfig.streamingUrl = streamingUrl;
pushConfig.streamingRoomInfo = roomInfo;

//开启推流
[[NERtcEngine sharedEngine] startPushStreaming:config];

参数	描述
streamingUrl	指定该音视频流的 CDN 推流地址。推流地址的获取方法请参考获取推拉流地址。
NERtcStreamingRoomInfo	推流的房间信息。
token	安全认证签名（NERTC Token）。调试模式下：可设置为 null。产品默认为安全模式，您可以在网易云信控制台将鉴权模式修改为调试模式，具体请参考 Token 鉴权。调试模式的安全性不高，请在产品正式上线前修改为安全模式。产品正式上线后：请设置为已获取的 NERTC Token。安全模式下必须设置为获取到的 Token。若未传入正确的 Token 将无法进入房间。推荐使用安全模式。
channel_name	房间名称。长度为 1 ~ 64 字节。支持以下字符类型：英文大小写数字空格特殊字符 `!#$%&()+-:;≤.,>? @[]^_{\|}~"` 开始直播时，若房间名称不存在，则网易云信服务器内部将自动创建一个名为 {channel_name} 的通话房间。
uid	用户的唯一标识 ID，为数字串，房间内每个用户的 uid 必须是唯一的。此 uid 为用户在您应用中的 ID，请在您的业务服务器上自行管理并维护。

推流成功后，房间内的用户会收到 onNERtcEngineStartPushStreamingWithResult:channelId: 的回调。
直播结束后，调用 stopPushStreaming 接口停止推流。
停止推流后，房间内的用户会收到 onNERtcEngineStopPushStreaming 回调。

实现 PK 直播

通过跨房间媒体流转发，主播无须退出/加入原房间，即可将媒体流同时转发到多个房间中，实现 PK 直播。

下文介绍在单人直播的过程中，主播 A 邀请主播 B 进行 PK 直播的实现流程。

API 时序图

sequenceDiagram
    title: 实现 PK 直播的 API 时序图
    actor 主播 A
    participant 业务服务器
    actor 主播 B
    participant NERtcSDK as 网易云信 RTC SDK
    %% 开始 PK

    主播 A->>业务服务器: 邀请 PK
    Note right of 主播 A: 邀请主播 B 进行 PK<br>（带上自己的 uid、cname、<br>Token 等信息）
    Note left of 主播 B: 请自行实现麦位<br>管理相关业务逻辑
    业务服务器->>主播 B: 邀请 PK（带上主播 A 的 <br>uid、cname、<br>Token 等信息）

    主播 B-->>业务服务器: 同意 PK
    业务服务器-->>主播 A: 对端同意 PK（带上主播<br> B 的 uid、cname、Token 等信息）

    rect rgb(191, 223, 255)
    主播 A ->> NERtcSDK: startChannelMediaRelay   开启媒体转发
    主播 A ->> NERtcSDK: addLiveStream 开始旁路推流
    NERtcSDK -->> 主播 A: onNERTCEngineLiveStreamState 监听旁路推流状态

    主播 A ->> NERtcSDK: stopPushStreaming   旁路推流成功后，停止单人直播推流

    Note right of 主播 A: 当主播 B 开始 MediaRelay <br>后，更新旁路推流，具体请<br>根据实际业务进行调整
    主播 A ->> NERtcSDK: updateLiveStreamTask 更新旁路推流
    Note right of 主播 A: 根据回调确认 mediaRelay <br>是否成功，如果失败，则进行失败回退，<br>例如调用 stopChannelMediaRelay 和<br> removeLiveStreamTask 方法结束 PK
    NERtcSDK -->> 主播 A: onNERtcEngineChannelMediaRelayStateDidChange:channelName: <br>和 onNERtcEngineDidReceiveChannelMediaRelayEvent: channelName: error:

    end
    NERtcSDK -->> 主播 A: 监听房间中人员进入和音视频打开的回调
    NERtcSDK -->> 主播 B: 监听房间中人员进入<br>和音视频打开的回调

    主播 A ->> 业务服务器: 结束 PK
    业务服务器 ->> 主播 B: 结束 PK
    主播 A ->> NERtcSDK: startPushStreaming 重新开始单人直播推流

    NERtcSDK -->> 主播 A: onNERtcEngineStartPushStreaming
    主播 A ->> NERtcSDK: stopChannelMediaRelay 停止媒体转发
    主播 A ->> NERtcSDK: removeLiveStreamTask 移除旁路推流任务
    主播 B ->> NERtcSDK: stopChannelMediaRelay
    主播 B ->> NERtcSDK: removeLiveStreamTask <br>移除旁路推流任务

前提条件

实现 PK 直播前，请确保您已经实现了单人直播。

开始 PK

开始 mediaRelay。

主播 A 调用 startChannelMediaRelay 方法开启媒体转发功能，将主播 A 的视频流推送到主播 B 房间。

Objective-CNERtcChannelMediaRelayConfiguration *mediaRelayConfig = [[NERtcChannelMediaRelayConfiguration alloc]init];
NERtcChannelMediaRelayInfo *info = [[NERtcChannelMediaRelayInfo alloc]init];
info.channelName = channelName; //PK 目标房间的房间号
info.token = token;//用于加入 PK 目标房间的 token, 与加入房间获取的 token 方式一致，注意 Token 需要及时使用，防止过期导致异常。
info.uid = uid;//本人在 PK 目标房间的 uid
[mediaRelayConfig setDestinationInfo:info forChannelName:info.channelName];

[[NERtcEngine sharedEngine] startChannelMediaRelay:mediaRelayConfig]

开启旁路推流任务。

主播 A 调用 addLiveStreamTask 方法添加旁路推流任务，将主播 A 和主播 B 房间的音视频流推送到 CDN 上进行合流。

Objective-C//设置旁路推流参数
NERtcLiveStreamTaskInfo *info = [[NERtcLiveStreamTaskInfo alloc] init];
NERtcLiveConfig *config = [[NERtcLiveConfig alloc] init];

info.streamURL = self.pushStreamingUrl;
info.taskID = PKTaskId;
info.lsMode = kNERtcLsModeVideo;

config.channels = 2;
config.sampleRate = kNERtcLiveStreamAudioSampleRate44100;
config.audioBitrate = 128;
config.audioCodecProfile = kNERtcLiveStreamAudioCodecProfileLCAAC;

//如果需要服务器录制
info.serverRecordEnabled = YES;
info.config = config;

//设置整体布局
NERtcLiveStreamLayout *layout = [[NERtcLiveStreamLayout alloc] init];
layout.width = 720;//整体布局宽度 建议与单推一致
layout.height = 1280;//整体布局高度 建议与单推一致
info.layout = layout;

//自己
NERtcLiveStreamUserTranscoding *user1 = [[NERtcLiveStreamUserTranscoding alloc]init];
user1.uid = myUid;
user1.audioPush = YES; // 推流是否发布 user1 的音频
user1.videoPush = YES; // 推流是否发布 user1 的视频
user1.x = 0; // user1 的视频布局 x 偏移，相对整体布局的左上角
user1.y = 320; // user1 的视频布局 y 偏移，相对整体布局的左上角
user1.width = 360; // user1 的视频布局宽度
user1.height = 640; //user1 的视频布局高度
user1.adaption = kNERtcLsModeVideoScaleCropFill; //会填满画面，超出部分会被裁减

//如果此时知道对方 Uid 可以在这里预先填上，如果不知道，可以先不设置 User2，然后参考第 6 步 update
NERtcLiveStreamUserTranscoding *user2 = [[NERtcLiveStreamUserTranscoding alloc]init];
user2.uid = pkUid;
user2.audioPush = YES; // 推流是否发布 user2 的音频
user2.videoPush = YES; // 推流是否发布 user2 的视频
user2.x = 360; // user2 的视频布局 x 偏移，相对整体布局的左上角
user2.y = 320; // user2 的视频布局 y 偏移，相对整体布局的左上角
user2.width = 360; // user2 的视频布局宽度
user2.height = 640; //user2 的视频布局高度
user2.adaption = kNERtcLsModeVideoScaleCropFill; //

NSMutableArray* layoutUsers = [NSMutableArray array];
[layoutUsers addObject:user1];
[layoutUsers addObject:user2];
info.layout.users = layoutUsers;

//结束之前的旁路推流，防止异常
[[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
}];

//开启旁路推流
[[NERtcEngine sharedEngine] addLiveStreamTask:info compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    if (0 != errorCode) {
        //表示开启开启 PK 失败，此时仍然处于单人直播状态，此时业务可以根据自身定制。如果想要继续 PK 需要重新按照实现 PK 直播逻辑继续开始 PK。
    }
}]

等待旁路推流结果。

通过 onNERTCEngineLiveStreamState 回调监听旁路推流状态，如果状态为 kNERtcLsStatePushing，表示旁路推流成功。

Objective-C//旁路直播状态回调
- (void)onNERTCEngineLiveStreamState:(NERtcLiveStreamStateCode)state
                            taskID:(NSString *)taskID
                                url:(NSString *)url {
    //表示 PK 成功
    if (state == kNERtcLsStatePushing) {
    //停止单人直播
    [NERtcEngine sharedEngine] stopPushStreaming];
    }else{
        //此时需要按照以下操作回退到单推
        [[NERtcEngine sharedEngine] stopChannelMediaRelay];
        [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
        }];

        [[NERtcEngine sharedEngine] startPushStreaming:config];
    }
}

如果旁路推流失败，则根据业务实际情况进行失败回退，例如调用 stopChannelMediaRelay 方法停止媒体转发功能。

停止单人直播推流。

主播 A 调用 stopPushStreaming 方法停止单人直播推流。

Objective-C//在第 4 步骤收到 onNERTCEngineLiveStreamState 回调 kNERtcLsStatePushing 后
//调用 stopPushStreaming 停止单人直播
[NERtcEngine sharedEngine] stopPushStreaming];

等待主播 B 加入房间后更新旁路推流任务。

主播 A 调用 updateLiveStreamTask 如果无法预先知道 PK 对方的 Uid，或者需要保证主播房间和挑战者房间的音视频流能够同步播放明，可以参考这一步。

Objective-C//对方加入房间回调
- (void)onNERtcEngineUserDidJoinWithUserID:(uint64_t)userID userName:(NSString *)userName {
    //参考第 4 步的旁路推流设置
    //调用 update 接口更新
    [[NERtcEngine sharedEngine] updateLiveStreamTask:info compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    }]
}

确认 mediaRelay 是否成功。

通过 onNERtcEngineChannelMediaRelayStateDidChange 和 onNERtcEngineDidReceiveChannelMediaRelayEvent: channelName: error: 回调监听媒体转发状态，确认媒体转发是否成功。

如果媒体转发失败，则根据业务实际情况进行失败回退，例如调用 stopChannelMediaRelay 和 removeLiveStreamTask 方法结束 PK。

Objective-C- (void)onNERtcEngineDidReceiveChannelMediaRelayEvent:(NERtcChannelMediaRelayEvent)event channelName:(NSString *)channelName error:(NERtcError)error {
    //表示失败
    if (event == NERtcChannelMediaRelayEventFailure) {
        //此时需要按照以下操作回退到单推
        [[NERtcEngine sharedEngine] stopChannelMediaRelay];
        [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
        }];

        [[NERtcEngine sharedEngine] startPushStreaming:config];
    }
    //表示成功
    if（event == NERtcChannelMediaRelayEventConnected）{
        //此时表示 PK 建立成功
    }
}

结束 PK

开始单人直播推流。

主播 A 调用 startPushStreaming 方法开始单人直播推流。

Objective-C//设置推流参数，此时 streamingRoomInfo 可以不传
NERtcPushStreamingConfig *pushConfig = [[NERtcPushStreamingConfig alloc] init];
pushConfig.streamingUrl = streamingUrl;

//开启推流
[[NERtcEngine sharedEngine] startPushStreaming:config];

等待单人直播推流结果。

主播 A 通过 onNERtcEngineStartPushStreamingWithResult:channelId: 回调监听单人直播推流状态，如果推流成功，则执行下一步操作。

Objective-C- (void)onNERtcEngineStartPushStreamingWithResult:(NERtcError)result channelId:(uint64_t)channelId {
    if (kNERtcNoError != result && && kNERtcErrInvalidState != result) {
        //开始 cdn 推流失败，此时仍然处于 PK 直播中，可以根据业务情况进行相关处理，如需要继续结束需要参照第一步，再次调用开启推流
        return;
    }

    //停止 MediaRelay
    [[NERtcEngine sharedEngine] stopChannelMediaRelay];
    //停止旁路推流
    [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    }];
}

停止 mediaRelay。

主播 A 和主播 B 分别调用 stopChannelMediaRelay 方法停止媒体转发功能。

根据第 2 步, 在 onNERtcEngineStartPushStreamingWithResult 回调方法停止 MediaRelay。
移除旁路推流任务。

主播 A 和主播 B 分别调用 removeLiveStreamTask 方法移除旁路推流任务。

根据第 2 步, 在 onNERtcEngineStartPushStreamingWithResult 回调方法停止旁路推流。

注意事项

removeLiveStreamTask 的调用

当 PK 业务直接退出房间时候，需要调用 removeLiveStreamTask 停止旁路推流，防止流没有停止，观众还能拉到流，出现业务异常，可参考以下场景。

Objective-C//主动 leaveChannel，退出房间 （不是切为单人直播）
- (void)leavePK{
    [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    }];
    [[NERtcEngine sharedEngine] leavechannel];
}

//SDK disconnect 断开
- (void)onNERtcEngineDidDisconnectWithReason:(NERtcError)reason{
    [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    }];
}

推荐每次开始 PK addLiveStreamTask 前，可以先调用 removeLiveStreamTask 停止之前的旁路推流任务，防止一些异常情况，出现 addLiveStreamTask 失败，导致业务异常，流程见开始 PK 第 2 步。

Objective-C[[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
}];
[[NERtcEngine sharedEngine] addLiveStreamTask:[self mockLiveStreamInfoForPk] compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    if (0 != errorCode) {
        //表示开启开启 PK 失败，此时仍然处于单人直播状态，此时业务可以根据自身定制。如果想要继续 PK 需要重新按照实现 PK 直播逻辑继续开始 PK。
    }
}

异常情况的回调处理

旁路推流回调失败处理，回退至单推处理逻辑。

Objective-C//开启旁路推流失败回调
[[NERtcEngine sharedEngine] addLiveStreamTask:info compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
        if (0 != errorCode) {
            //停止 MediaRelay
            [[NERtcEngine sharedEngine] stopChannelMediaRelay];
            //停止旁路推流
            [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
            }];
        }
}]

//旁路推流状态回调
- (void)onNERTCEngineLiveStreamState:(NERtcLiveStreamStateCode)state
                            taskID:(NSString *)taskID
                                url:(NSString *)url {
    //表示 PK 成功
    if (state == kNERtcLsStatePushing) {
    //参考开始 PK 第 3 步停止单人直播
    } else if (state == kNERtcLsStatePushFail){
        //此时需要按照以下操作回退到单推
        [[NERtcEngine sharedEngine] stopChannelMediaRelay];
        [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
        }];

        [[NERtcEngine sharedEngine] startPushStreaming:config];
    }
}

MediaRelay 失败，回退至单推处理逻辑。

Objective-C- (void)onNERtcEngineDidReceiveChannelMediaRelayEvent:(NERtcChannelMediaRelayEvent)event channelName:(NSString *)channelName error:(NERtcError)error {
    //表示失败
    if (event == NERtcChannelMediaRelayEventFailure) {
        //此时需要按照以下操作回退到单推
        [[NERtcEngine sharedEngine] stopChannelMediaRelay];
        [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
        }];

        [[NERtcEngine sharedEngine] startPushStreaming:config];
    }
    //表示成功
    else if (event == NERtcChannelMediaRelayEventConnected){
        //此时表示 PK 建立成功
    }
}

以上回退时业务需要告知 PK 对方，同时回退。

实现直播中连麦

下文介绍在单人直播的过程中，观众连麦场景下，NERTC 的实现流程。

API 时序图

sequenceDiagram
    title: 实现直播中连麦的 API 时序图
    actor 主播 A
    participant 业务服务器
    participant NERtcSDK as 网易云信 RTC SDK
    actor 连麦者

    Note over 主播 A, 连麦者:开始连麦

    连麦者->>业务服务器: 申请上麦
    Note right of 主播 A: 请自行实现相关业务逻辑
    业务服务器->>主播 A: 申请上麦

    主播 A-->>业务服务器: 同意上麦
    业务服务器-->>连麦者: 主播同意上麦

    连麦者 ->> NERtcSDK: joinChannel

    rect rgb(191, 223, 255)
    主播 A ->> NERtcSDK: addLiveStreamTask 开始旁路推流
    NERtcSDK -->> 主播 A: onNERTCEngineLiveStreamState

    主播 A ->> NERtcSDK: stopPushStreaming   旁路推流成功后，停止推流

    Note over 主播 A, 连麦者:连麦状态下新增连麦
    主播 A ->> NERtcSDK: updateLiveStreamTask 更新旁路推流

    Note over 主播 A, 连麦者:结束连麦
    连麦者 ->> 业务服务器: 下麦
    业务服务器 ->> 主播 A: 下麦

    主播 A ->> NERtcSDK: startPushStreaming 重新开始推流
    NERtcSDK -->> 主播 A: onNERtcEngineStartPushStreamingWithResult:channelId:

    主播 A ->> NERtcSDK: removeLiveStreamTask 移除推流任务
    end

    连麦者 ->> NERtcSDK: leaveChannel

前提条件

实现在单人直播的过程中，观众连麦前，请确保您已经实现了单人直播。

开始连麦

开启旁路推流任务。

主播 A 调用 addLiveStreamTask 方法添加旁路推流任务，将主播房间和连麦者的音视频流推送到 CDN 上进行合流。

Objective-C//设置旁路推流参数
NERtcLiveStreamTaskInfo *info = [[NERtcLiveStreamTaskInfo alloc] init];
NERtcLiveConfig *config = [[NERtcLiveConfig alloc] init];

info.streamURL = self.pushStreamingUrl;
info.taskID = PKTaskId;
info.lsMode = kNERtcLsModeVideo;

config.channels = 2;
config.sampleRate = kNERtcLiveStreamAudioSampleRate44100;
config.audioBitrate = 128;
config.audioCodecProfile = kNERtcLiveStreamAudioCodecProfileLCAAC;

//如果需要服务器录制
info.serverRecordEnabled = YES;
info.config = config;

//设置整体布局
NERtcLiveStreamLayout *layout = [[NERtcLiveStreamLayout alloc] init];
layout.width = 720;//整体布局宽度
layout.height = 1280;//整体布局高度
info.layout = layout;

//自己
NERtcLiveStreamUserTranscoding *user1 = [[NERtcLiveStreamUserTranscoding alloc]init];
user1.uid = myUid;
user1.audioPush = YES; // 推流是否发布 user1 的音频
user1.videoPush = YES; // 推流是否发布 user1 的视频
user1.x = 0; // user1 的视频布局 x 偏移，相对整体布局的左上角
user1.y = 320; // user1 的视频布局 y 偏移，相对整体布局的左上角
user1.width = 360; // user1 的视频布局宽度
user1.height = 640; //user1 的视频布局高度
user1.adaption = kNERtcLsModeVideoScaleCropFill;

//如果此时知道对方 Uid 可以在这里预先填上，如果不知道，可以先不设置 User2，然后参考第 6 步 update
NERtcLiveStreamUserTranscoding *user2 = [[NERtcLiveStreamUserTranscoding alloc]init];
user2.uid = pkUid;
user2.audioPush = YES; // 推流是否发布 user2 的音频
user2.videoPush = YES; // 推流是否发布 user2 的视频
user2.x = 360; // user2 的视频布局 x 偏移，相对整体布局的左上角
user2.y = 320; // user2 的视频布局 y 偏移，相对整体布局的左上角
user2.width = 360; // user2 的视频布局宽度
user2.height = 640; //user2 的视频布局高度
user2.adaption = kNERtcLsModeVideoScaleCropFill;

NSMutableArray* layoutUsers = [NSMutableArray array];
[layoutUsers addObject:user1];
[layoutUsers addObject:user2];
info.layout.users = layoutUsers;

//结束之前的推流，推荐调用，防止异常
[[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
}];
//开启旁路推流
[[NERtcEngine sharedEngine] addLiveStreamTask:info compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    if (0 != errorCode) {
        //表示开启开启连麦失败，此时仍然处于单人直播状态，此时业务可以根据自身定制。如果想要继续连麦需要重新按照实现连麦直播逻辑继续开始连麦。
    }
}]

等待旁路推流结果。

通过 onNERTCEngineLiveStreamState 回调监听旁路推流状态，如果状态为 kNERtcLsStatePushing，表示旁路推流成功。如果旁路推流失败，则调用 removeLiveStreamTask 方法移除推流任务。

Objective-C    //旁路直播状态回调
- (void)onNERTCEngineLiveStreamState:(NERtcLiveStreamStateCode)state
                            taskID:(NSString *)taskID
                                url:(NSString *)url {
    //表示 连麦 成功
    if (state == kNERtcLsStatePushing) {
    //停止单人直播
    [NERtcEngine sharedEngine] stopPushStreaming];
    }else{
        //此时需要按照以下操作回退到单推
        [[NERtcEngine sharedEngine] stopChannelMediaRelay];
        [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
        }];

        [[NERtcEngine sharedEngine] startPushStreaming:config];
    }
}

旁路推流成功后，停止单人直播推流。

主播 A 调用 stopPushStreaming 方法停止单人直播推流。

Objective-C
//在第 3 步骤收到 onNERTCEngineLiveStreamState 回调 kNERtcLsStatePushing 后
//调用 stopPushStreaming 停止单人直播
[NERtcEngine sharedEngine] stopPushStreaming];

结束连麦

开始单人直播推流。

主播 A 调用 startPushStreaming 方法开始单人直播推流。

Objective-C//设置推流参数，此时 streamingRoomInfo 可以不传
NERtcPushStreamingConfig *pushConfig = [[NERtcPushStreamingConfig alloc] init];
pushConfig.streamingUrl = streamingUrl;

//开启推流
[[NERtcEngine sharedEngine] startPushStreaming:config];

等待单人直播推流结果。

主播 A 通过 onNERtcEngineStartPushStreamingWithResult:channelId: 回调监听单人直播推流状态，如果推流成功，则执行下一步操作。

Objective-C- (void)onNERtcEngineStartPushStreamingWithResult:(NERtcError)result channelId:(uint64_t)channelId {
    if (kNERtcNoError != result) {
        //开始 cdn 推流失败，此时仍然处于 PK 直播中，可以根据业务情况进行相关处理，如需要继续结束需要参照第一步，再次调用开启推流
        return;
    }
    //停止旁路推流
    [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    }];
}

移除旁路推流任务。

主播 A 和主播 B 分别调用 removeLiveStreamTask 方法移除旁路推流任务。

根据第 2 步, 在 onNERtcEngineStartPushStreamingWithResult 回调方法停止旁路推流

注意事项

removeLiveStreamTask 的调用

当 PK 业务直接退出房间时候，需要调用 removeLiveStreamTask 停止旁路推流，防止流没有停止，观众还能拉到流，出现业务异常，可参考以下场景。

Objective-C//主动 leaveChannel，退出房间 （不是切为单人直播）
- (void)leavePK{
    [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    }];
    [[NERtcEngine sharedEngine] leavechannel];
}

//SDK disconnect 断开
- (void)onNERtcEngineDidDisconnectWithReason:(NERtcError)reason{
    [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    }];
}

推荐每次开始 PK addLiveStreamTask 前，可以先调用 removeLiveStreamTask 停止之前的旁路推流任务，防止一些异常情况，出现 addLiveStreamTask 失败，导致业务异常，流程见开始 PK 第 2 步.

Objective-C    [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
    }];
    [[NERtcEngine sharedEngine] addLiveStreamTask:[self mockLiveStreamInfoForPk] compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
        if (0 != errorCode) {
            //表示开启开启 PK 失败，此时仍然处于单人直播状态，此时业务可以根据自身定制。如果想要继续 PK 需要重新按照实现 PK 直播逻辑继续开始 PK。
        }
    }

异常情况的回调处理

旁路推流回调失败处理，回退至单推处理逻辑：

Objective-C//开启旁路推流失败回调
 [[NERtcEngine sharedEngine] addLiveStreamTask:info compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
        if (0 != errorCode) {
             //停止 MediaRelay
            [[NERtcEngine sharedEngine] stopChannelMediaRelay];
            //停止旁路推流
            [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
            }];
        }
   }]

//旁路推流状态回调
- (void)onNERTCEngineLiveStreamState:(NERtcLiveStreamStateCode)state
                              taskID:(NSString *)taskID
                                 url:(NSString *)url {
    //表示 PK 成功
    if (state == kNERtcLsStatePushing) {
       //参考开始 PK 第 3 步停止单人直播
    } else if (state == kNERtcLsStatePushFail){
        //此时需要按照以下操作回退到单推
        [[NERtcEngine sharedEngine] stopChannelMediaRelay];
        [[NERtcEngine sharedEngine] removeLiveStreamTask:PKTaskId compeltion:^(NSString * _Nonnull taskId, kNERtcLiveStreamError errorCode) {
        }];

        [[NERtcEngine sharedEngine] startPushStreaming:config];
    }
}

以上回退时业务需要告知连麦对方，主播已经回退，连麦结束。

常用的回调

请在初始化时注册推流相关的回调，以下列举推流需要关注的主要回调：

单人直播场景需要关注的主要回调：

Objective-C    //开始推流 startPushStreaming 结果回调
    - (void)onNERtcEngineStartPushStreamingWithResult:(NERtcError)result channelId:(uint64_t)channelId{
        if (kNERtcNoError != result) {
            //kNERtcErrInvalidState 表示当前正在推流，不需要处理
            if (kNERtcErrInvalidState == result) {
                return;
            }
            //推流失败，业务按需处理，如果需要继续推流，需要再次调用 startPushStreaming 接口
        }else{
            //推流成功，业务按需处理。
        }
    }

    //停止推流 stopPushStreaming 结果回调
    -(void)onNERtcEngineStopPushStreaming:(NERtcError)result{
        //不需要额外处理，表示本身不在推流中
    }

    //推流过程中断开，变为重连状态回调
    - (void)onNERtcEnginePushStreamingChangeToReconnectingWithReason:(NERtcError)reason{
        //此时表示推流无法连上服务器，正在重连，业务按需处理，可以提示主播
    }

    //推流过程中重连成功回调
    - (void)onNERtcEnginePushStreamingReconnectedSuccess{
        //此时表示重连成功，推流恢复正常
    }

    //SDK 客户端和服务器断开连接
    - (void)onNERtcEngineReconnectingStart{
        //此时表示客户端 SDK 无法连上服务器，正在重连，业务按需处理，可以提示主播
    }

    //SDK 客户端重连状态结果回调
    - (void)onNERtcEngineRejoinChannel:(NERtcError)result{
        //此时表示重连成功，SDK 连上了服务器
    }

    //推流过程重连失败，最终断开回调
    - (void)onNERtcEngineDidDisconnectWithReason:(NERtcError)reason{
        //此时表示推流失败了，业务按需处理，如果需要继续推流，需要再次调用 startPushStreaming 接口
    }

PK 场景需要关注的主要回调：

Objective-C//开始推流 startPushStreaming 结果回调
- (void)onNERtcEngineStartPushStreamingWithResult:(NERtcError)result channelId:(uint64_t)channelId{
    if (kNERtcNoError != result) {
        //kNERtcErrInvalidState 不需要关注
        if(kNERtcErrInvalidState != result){
            return;
         }
        //推流失败，业务按需处理，参考结束 PK 的第 2 步。
    }else{
        //推流成功，业务按需处理，参考结束 PK 的第 2 步。
    }
}

//停止推流 stopPushStreaming 结果回调
-(void)onNERtcEngineStopPushStreaming:(NERtcError)result{
    //可以不需要关注
}

//SDK 客户端和服务器断开连接
- (void)onNERtcEngineReconnectingStart{
    //此时表示客户端 SDK 无法连上服务器，正在重连，业务按需处理，可以提示主播
}

//SDK 客户端重连状态结果回调
- (void)onNERtcEngineRejoinChannel:(NERtcError)result{
    //此时表示重连成功，SDK 连上了服务器
}

//推流过程重连失败，最终断开回调
- (void)onNERtcEngineDidDisconnectWithReason:(NERtcError)reason{
    //此时表示推流失败了，业务按需处理，如果需要继续推流，需要再次调用 startPushStreaming 接口
}

//MediaRelay 事件回调
- (void)onNERtcEngineDidReceiveChannelMediaRelayEvent:(NERtcChannelMediaRelayEvent)event channelName:(NSString *)channelName error:(NERtcError)error {
    //表示失败
    if (event == NERtcChannelMediaRelayEventFailure) {
        //参照开始 PK 第 6 步
    }
    //表示成功
    if（event == NERtcChannelMediaRelayEventConnected）{
        //参照开始 PK 第 6 步
    }
}

//旁路直播状态回调
- (void)onNERTCEngineLiveStreamState:(NERtcLiveStreamStateCode)state
                            taskID:(NSString *)taskID
                                url:(NSString *)url {
    //表示 PK 成功
    if (state == kNERtcLsStatePushing) {
    //参考开始 PK 第 3 步停止单人直播
    }else{
    //参考开始 PK 第 3 步操作回退到单推
    }
}

连麦场景需要关注的主要回调：

Objective-C//开始推流 startPushStreaming 结果回调
- (void)onNERtcEngineStartPushStreamingWithResult:(NERtcError)result channelId:(uint64_t)channelId{
if (kNERtcNoError != result) {
    //kNERtcErrInvalidState 不需要关注
    if(kNERtcErrInvalidState != result){
        return;
    }
        //推流失败，业务按需处理，参考结束连麦的第 2 步。
    }else{
        //推流成功，业务按需处理，参考结束连麦的第 2 步。
    }
}

//停止推流 stopPushStreaming 结果回调
-(void)onNERtcEngineStopPushStreaming:(NERtcError)result{
    //可以不关注
}

//SDK 客户端和服务器断开连接
- (void)onNERtcEngineReconnectingStart{
    //此时表示客户端 SDK 无法连上服务器，正在重连，业务按需处理，可以提示主播
}

//SDK 客户端重连状态结果回调
- (void)onNERtcEngineRejoinChannel:(NERtcError)result{
    //此时表示重连成功，SDK 连上了服务器
}

//推流过程重连失败，最终断开回调
- (void)onNERtcEngineDidDisconnectWithReason:(NERtcError)reason{
    //此时表示 SDK 重连失败了，业务按需处理，如果需要继续推流，需要再次调用 startPushStreaming 接口
}

//旁路直播状态回调
- (void)onNERTCEngineLiveStreamState:(NERtcLiveStreamStateCode)state
                            taskID:(NSString *)taskID
                                url:(NSString *)url {
    //表示 连麦 成功
    if (state == kNERtcLsStatePushing) {
    //参考开始连麦第 2 步停止单人直播
    }else{
    //参考开始连麦第 2 步操作回退到单推
    }
}

观众端播放器拉流

请使用网易云信播放器进行拉流播放，播放器的实现方法请参考实现播放功能。

为了避免在播放音视频媒体流时，因网络连接不稳定或者其他问题导致播放失败，请设置自动重试参数，以提高播放成功率和用户体验。

在线咨询

微信咨询

电话咨询

此文档是否对你有帮助？

有帮助

去反馈

功能介绍
单人直播
PK 直播
连麦
应用场景
下载示例代码
集成 NERTC SDK
下载 NERTC SDK
导入 NERtcSDK 类
注意事项
实现单人直播
API 时序图
实现方法
实现 PK 直播
API 时序图
前提条件
开始 PK
结束 PK
注意事项
实现直播中连麦
API 时序图
前提条件
开始连麦
结束连麦
注意事项
常用的回调
观众端播放器拉流