iOS - 融云RTC功能梳理

2023-12-22 18:38
文章标签 功能 ios rtc 梳理 融云

本文主要是介绍iOS - 融云RTC功能梳理，希望对大家解决编程问题提供一定的参考价值，需要的开发者们随着小编来一起学习吧！

一. 功能介绍

功能需求

  1. 一个文字聊天室(如图下半部分)
  2. 一个语音聊天室(语音房)(上半部分)
  3. 五个麦位
  4. 可上麦下麦

二. 业务梳理

融云流程图

  1. 业务层面的语音聊天室  在用户创建聊天室时请求业务(自己)服务器，业务服务器创建聊天室，并返回给创者者当前聊天室的 id，同时其他用户可通过获取聊天室列表接口获取到此聊天室的 id。用户调根据此聊天室 id 加入 IM 聊天室和音频 RTC房间。当前用户属于哪个聊天室，当前聊天室内有哪些用户是基于此聊天室。
    备注: 在创建一个房间时, 后台依次会调用融云server API 创建一个语音通话, 文字聊天都包含的一个房间(ROOM).

  2. IM 即时通讯层面的语音聊天室  加入 IM 聊天室后，用户可以发送文本消息聊天。另外维护聊天室各种状态的信令消息也通过 IM 服务来收发。(理论上 文字聊天(IM), 语音房(RTC) 使用一个目标Id即可)

3, RTC 音频层面的语音聊天室   加入 RTC 聊天室后，用户可以获得到当前语音聊天室内所有发布音频流的用户，并选择订阅音频流来收听目标用户的声音，也可以自己发布音频流让其他人听到自己的声音。

三. 前端(App端) 梳理

屏幕快照 2019-10-26 下午5.00.05.png

  • A 可见 B、C、D 的音频、视频

  • B 可按需选择只听 A、D 的音频，只看 A、C 的视频

  • C 可按需选择只听 A、B、D 的音频，但不看其他人视频

  • D 可按需选择只看 A、B、C 的视频，但不听其他人的音频

四. iOS 端伪代码, 以下全是伪代码

  1. RTC(语音视频室基于IM)所以第一步 需要连接IM
[[KKIMMgr shareInstance] checkAndConnectRCSuccess:^{/// 连接成功, 再去创建一个上述功能的房间} error:^(RCConnectErrorCode status) {[CC_Notice show:@"聊天室未连接"];}];
  1. 创建房间成功后呢, 后台会返回一个目标Id, 或者叫做房间Id (roomId), 通过这个Id去连接 RTC Room
///  KKRtcService 是对融云RTC "<RongRTCLib/RongRTCLib.h>"进行了一层封装
[[KKRtcService shareInstance] joinRoom:channelId success:^(RongRTCRoom * _Nonnull room) {dispatch_async(dispatch_get_main_queue(), ^{/// 证明连接成功RTC///  跳转进入房间});});} error:^(RongRTCCode code) {dispatch_main_async_safe(^{[CC_Notice show:@"进入房间失败！"];});}];
  1. 做一个上麦, 下麦的管理

没有伪代码

  1. 对于再麦位上的用户, 扩散动画处理, 也是一段伪代码.
- (void)didReportStatForm:(RongRTCStatisticalForm *)form {//1.发送for(RongRTCStreamStat *streamStat in form.sendStats){//只处理音频//处理发送的音频 动画if ([streamStat.mediaType isEqualToString:RongRTCMediaTypeAudio]) {[self updateMicPositionSpeaking:streamStat.trackId audioLevel:streamStat.audioLevel];}}//2.接收for(RongRTCStreamStat *streamStat in form.recvStats){//只处理音频//处理接收的音频 动画if ([streamStat.mediaType isEqualToString:RongRTCMediaTypeAudio]) {[self updateMicPositionSpeaking:streamStat.trackId audioLevel:streamStat.audioLevel];}}
}- (void)updateMicPositionSpeaking:(NSString *)userId audioLevel:(NSInteger)audioLevel {dispatch_async(dispatch_get_main_queue(), ^{/// 这里是处理了 CollectionViewCell里面的动画逻辑/// 关键在与userId的判断和audioLevel音量的双重条件, 来控制动画for (KKPlayerCardCollectionCell *cell in self.playerListView.visibleCells) {if (cell.dataModel.userId.length > 0 && [userId containsString:cell.dataModel.userId]) {CCLOG(@"cell.dataModel.userId === %@", cell.dataModel.userId);if (self.isMicOpen == YES) {cell.isSpeaking = audioLevel > 0;}else {if ([userId containsString:[KKUserInfoMgr shareInstance].userId]) {cell.isSpeaking = NO;}}}}});
}
  1. 解释

5.1 简单理解上麦需要发布音频流
5.2 下麦取消发布音频流
5.3 想听到谁的声音/视频 你就去订阅谁
5.4 不想听谁的声音关闭扬声器就好了

五. RTCServiceMgr 以下代码通用

@interface RTCServiceMgr : NSObject#pragma mark - life circle
+ (instancetype)shareInstance;
- (void)remove;#pragma mark - rtc
/** 当前加入的 rtc房间 (当加入房间成功之后，才会是有效值 */
@property (nonatomic, strong, readonly) RongRTCRoom *rtcRoom;/** 关闭所有声音 */
@property (nonatomic, assign) BOOL muteAllVoice;/** 设置 直播间代理 */
- (void)setRTCRoomDelegate:(id<RongRTCRoomDelegate>)delegate;/** 设置 直播间引擎代理 */
- (void)setRTCEngineDelegate:(id<RongRTCActivityMonitorDelegate>)delegate;#pragma mark 加入/退出
/** 加入直播间 */
- (void)joinRoom:(NSString *)roomId success:(void (^)( RongRTCRoom *room))success error:(void (^)(RongRTCCode code))error;/** 退出直播间 */
- (void)leaveRoom:(NSString*)roomId success:(void (^)(void))success error:(void (^)(RongRTCCode code))error;#pragma mark  音频流
/** 发布 音视频流 */
- (void)pulishCurrentUserAudioStream;/** 取消发布 音视频流 */
- (void)unpublishCurrentUserAudioStream;/** 订阅 远端音频stream */
- (void)subscribeRemoteUserAudioStream:(NSString *)userId;/** 取消订阅 远端音频stream */
- (void)unsubscribeRemoteUserAudioStream:(NSString *)userId;#pragma mark 麦克风/扬声器
/** 设置麦克风 是否可用 */
- (void)setMicrophoneDisable:(BOOL)disable;/** 设置扬声器 是否可用 */
- (void)useSpeaker:(BOOL)useSpeaker;@end

@interface RTCServiceMgr () 
@property (nonatomic, strong) RongRTCRoom *rtcRoom;
@property (nonatomic, strong) RongRTCVideoCaptureParam *captureParam;
@property (nonatomic, strong) RongRTCAVCapturer *capturer;
@end@implementation RTCServiceMgrstatic RTCServiceMgr *rongRtcMgr = nil;
static dispatch_once_t onceToken;#pragma mark - getter/setter
#pragma mark getter
- (RongRTCAVCapturer *)capturer {if(!_capturer) {_capturer = [RongRTCAVCapturer sharedInstance];}return _capturer;
}
- (RongRTCVideoCaptureParam *)captureParam {if(!_captureParam) {_captureParam = [[RongRTCVideoCaptureParam alloc] init];_captureParam.turnOnCamera = NO;}return _captureParam;}#pragma mark setter
- (void)setMuteAllVoice:(BOOL)mute {_muteAllVoice = mute;for(RongRTCRemoteUser *remoteUser in self.rtcRoom.remoteUsers) {for(RongRTCAVInputStream *stream in remoteUser.remoteAVStreams) {if(stream.streamType == RTCMediaTypeAudio) {stream.disable = mute;}}}
}#pragma mark - life circle
+ (instancetype)shareInstance {dispatch_once(&onceToken, ^{rongRtcMgr = [[KKRtcService alloc] init];});return rongRtcMgr;
}- (instancetype)init {self = [super init];if (self) {}return self;
}/** 清空 */
- (void)remove{//1.删除userDefault中的用户信息//2.释放selfrongRtcMgr = nil;onceToken = 0;
}#pragma mark - rtc
- (void)setRTCRoomDelegate:(id<RongRTCRoomDelegate>)delegate {if(!self.rtcRoom) {//[CC_Notice show:@"尚未加入招募厅，无法设置代理"];return;}self.rtcRoom.delegate = delegate;
}-(void)setRTCEngineDelegate:(id<RongRTCActivityMonitorDelegate>)delegate {[RongRTCEngine sharedEngine].monitorDelegate = delegate;
}#pragma mark 加入/退出 rtc 房间
- (void)joinRoom:(NSString *)roomId success:(void (^)( RongRTCRoom  * _Nullable room))success error:(void (^)(RongRTCCode code))error {[[RongRTCEngine sharedEngine] joinRoom:roomId completion:^(RongRTCRoom * _Nullable room, RongRTCCode code) {dispatch_async(dispatch_get_main_queue(), ^{if(RongRTCCodeSuccess == code) {self.rtcRoom = room;if(success) {success(room);}}else if(RongRTCCodeJoinRepeatedRoom == code || RongRTCCodeJoinToSameRoom == code) {//当 RTC 出现此类错误时，RTC 不会再下发 room 对象，只能用上次的 roomif(success) {success(self.rtcRoom);}}else {if(error) {error(code);}}});}];
}- (void)leaveRoom:(NSString*)roomId success:(void (^)(void))success error:(void (^)(RongRTCCode code))error {[[RongRTCEngine sharedEngine] leaveRoom:roomId completion:^(BOOL isSuccess, RongRTCCode code) {dispatch_async(dispatch_get_main_queue(), ^{BBLOG(@"离开 RTCRoom ，code = %ld",(long)code);//成功 或 不再房间中 或 没有匹配的RTC roomif(isSuccess || RongRTCCodeSuccess == code ||RongRTCCodeNotInRoom == code ||RongRTCCodeNoMatchedRoom == code) {self.rtcRoom = nil;if(success) {success();}}else {if(error) {error(code);}}});}];
}#pragma mark 音频流
/** 发布 音视频流 */
- (void)pulishCurrentUserAudioStream {if(!self.rtcRoom) {//房间没生成return;}//1.采集self.captureParam.turnOnCamera = NO;[self.capturer setCaptureParam:self.captureParam];[self.capturer startCapture];//2.发布[self.rtcRoom publishDefaultAVStream:^(BOOL isSuccess, RongRTCCode desc) {BBLOG(@"当前用户发布音频流 %@",@(desc));}];
}/** 取消发布 音视频流 */
- (void)unpublishCurrentUserAudioStream {if(!self.rtcRoom) {//房间没生成return;}//1.关闭采集[self.capturer stopCapture];//2.取消发布[self.rtcRoom unpublishDefaultAVStream:^(BOOL isSuccess, RongRTCCode desc) {BBLOG(@"当前用户取消发送音视频流 %@",@(desc));}];}/** 订阅 远端音频stream */
- (void)subscribeRemoteUserAudioStream:(NSString *)userId {if(!self.rtcRoom) {//房间没生成return;}if(userId.length < 1){return;}RongRTCRemoteUser *remoteUser = [self getRTCRemoteUser:userId];if(remoteUser.remoteAVStreams.count <= 0) {[CC_Notice show:@"远端资源不存在，不能订阅音频"];//BBLOG(@"subscribe --- user:%@ streams:%@",remoteUser.userId,remoteUser.remoteAVStreams);return;}[self.rtcRoom subscribeAVStream:remoteUser.remoteAVStreams tinyStreams:nil completion:^(BOOL isSuccess, RongRTCCode desc) {BOOL mute = [KKRtcService shareInstance].muteAllVoice;for(RongRTCAVInputStream *stream in remoteUser.remoteAVStreams) {if(stream.streamType == RTCMediaTypeAudio) {stream.disable = mute;}}BBLOG(@"subscribe --- 订阅流 %@ success:%@ code:%@",remoteUser.userId,@(isSuccess),@(desc));}];
}/** 取消订阅 远端音频stream */
- (void)unsubscribeRemoteUserAudioStream:(NSString *)userId {if(!self.rtcRoom) {//房间没生成return;}RongRTCRemoteUser *remoteUser = [self getRTCRemoteUser:userId];if(remoteUser.remoteAVStreams.count <= 0) {//[CC_Notice show:@"远端资源不存在，不能取消订阅音频"];BBLOG(@"unsubscribe --- user:%@ streams:%@",remoteUser.userId,remoteUser.remoteAVStreams);return;}[self.rtcRoom unsubscribeAVStream:remoteUser.remoteAVStreams completion:^(BOOL isSuccess, RongRTCCode desc) {BBLOG(@"取消订阅流 %@ success:%@ code:%@",remoteUser.userId,@(isSuccess),@(desc));}];
}#pragma mark - tool
#pragma mark capturer
- (void)setMicrophoneDisable:(BOOL)disable {[self.capturer setMicrophoneDisable:disable];
}- (void)useSpeaker:(BOOL)useSpeaker {[self.capturer useSpeaker:useSpeaker];
}#pragma mark RemoteUser
/** 获取 rtcRemoteUser */
- (RongRTCRemoteUser *)getRTCRemoteUser:(NSString *)userId{for (RongRTCRemoteUser *user in self.rtcRoom.remoteUsers) {if ([userId isEqualToString:user.userId]) {return user;}}return nil;
}

六 总结

  1. 创建房间(具备RTC功能的房间) 重要!
  2. 加入房间
  3. 麦位管理
  4. 动画处理
  5. 麦克风和扬声器的管理

完
文/夏天然后

这篇关于iOS - 融云RTC功能梳理的文章就介绍到这儿，希望我们推荐的文章对编程师们有所帮助！


http://www.chinasem.cn/article/525036。

相关文章

Java实现文件图片的预览和下载功能

Java实现文件图片的预览和下载功能

《Java实现文件图片的预览和下载功能》这篇文章主要为大家详细介绍了如何使用Java实现文件图片的预览和下载功能,文中的示例代码讲解详细,感兴趣的小伙伴可以跟随小编一起学习一下... Java实现文件（图片）的预览和下载 @ApiOperation("访问文件") @GetMapping("
阅读更多...
SpringKafka消息发布之KafkaTemplate与事务支持功能

SpringKafka消息发布之KafkaTemplate与事务支持功能

《SpringKafka消息发布之KafkaTemplate与事务支持功能》通过本文介绍的基本用法、序列化选项、事务支持、错误处理和性能优化技术,开发者可以构建高效可靠的Kafka消息发布系统,事务支... 目录引言一、KafkaTemplate基础二、消息序列化三、事务支持机制四、错误处理与重试五、性能优
阅读更多...
SpringIntegration消息路由之Router的条件路由与过滤功能

SpringIntegration消息路由之Router的条件路由与过滤功能

《SpringIntegration消息路由之Router的条件路由与过滤功能》本文详细介绍了Router的基础概念、条件路由实现、基于消息头的路由、动态路由与路由表、消息过滤与选择性路由以及错误处理... 目录引言一、Router基础概念二、条件路由实现三、基于消息头的路由四、动态路由与路由表五、消息过滤
阅读更多...
Spring Boot 3.4.3 基于 Spring WebFlux 实现 SSE 功能(代码示例)

Spring Boot 3.4.3 基于 Spring WebFlux 实现 SSE 功能(代码示例)

《SpringBoot3.4.3基于SpringWebFlux实现SSE功能(代码示例)》SpringBoot3.4.3结合SpringWebFlux实现SSE功能,为实时数据推送提供... 目录1. SSE 简介1.1 什么是 SSE？1.2 SSE 的优点1.3 适用场景2. Spring WebFlu
阅读更多...
基于SpringBoot实现文件秒传功能

基于SpringBoot实现文件秒传功能

《基于SpringBoot实现文件秒传功能》在开发Web应用时,文件上传是一个常见需求,然而,当用户需要上传大文件或相同文件多次时,会造成带宽浪费和服务器存储冗余,此时可以使用文件秒传技术通过识别重复... 目录前言文件秒传原理代码实现1. 创建项目基础结构2. 创建上传存储代码3. 创建Result类4.
阅读更多...
Python+PyQt5实现多屏幕协同播放功能

Python+PyQt5实现多屏幕协同播放功能

《Python+PyQt5实现多屏幕协同播放功能》在现代会议展示、数字广告、展览展示等场景中,多屏幕协同播放已成为刚需,下面我们就来看看如何利用Python和PyQt5开发一套功能强大的跨屏播控系统吧... 目录一、项目概述：突破传统播放限制二、核心技术解析2.1 多屏管理机制2.2 播放引擎设计2.3 专
阅读更多...
一文详解SpringBoot响应压缩功能的配置与优化

一文详解SpringBoot响应压缩功能的配置与优化

《一文详解SpringBoot响应压缩功能的配置与优化》SpringBoot的响应压缩功能基于智能协商机制,需同时满足很多条件,本文主要为大家详细介绍了SpringBoot响应压缩功能的配置与优化,需... 目录一、核心工作机制1.1 自动协商触发条件1.2 压缩处理流程二、配置方案详解2.1 基础YAML
阅读更多...
使用PyTorch实现手写数字识别功能

使用PyTorch实现手写数字识别功能

《使用PyTorch实现手写数字识别功能》在人工智能的世界里,计算机视觉是最具魅力的领域之一,通过PyTorch这一强大的深度学习框架,我们将在经典的MNIST数据集上,见证一个神经网络从零开始学会识... 目录当计算机学会“看”数字搭建开发环境MNIST数据集解析1. 认识手写数字数据库2. 数据预处理的
阅读更多...
Python实战之屏幕录制功能的实现

Python实战之屏幕录制功能的实现

《Python实战之屏幕录制功能的实现》屏幕录制,即屏幕捕获,是指将计算机屏幕上的活动记录下来,生成视频文件,本文主要为大家介绍了如何使用Python实现这一功能,希望对大家有所帮助... 目录屏幕录制原理图像捕获音频捕获编码压缩输出保存完整的屏幕录制工具高级功能实时预览增加水印多平台支持屏幕录制原理屏幕
阅读更多...
Python实现自动化表单填写功能

Python实现自动化表单填写功能

《Python实现自动化表单填写功能》在Python中,自动化表单填写可以通过多种库和工具实现,本文将详细介绍常用的自动化表单处理工具,并对它们进行横向比较,可根据需求选择合适的工具,感兴趣的小伙伴跟... 目录1. Selenium简介适用场景示例代码优点缺点2. Playwright简介适用场景示例代码
阅读更多...

Copyright China编程 23002807@qq.com

沪ICP备2023033072号-2