|
语音房开发， 这里使用的是声网和网易云信
声网提供连麦的功能，
网易云信处理消息的同步
1, 待验证
1.1 加入房间
注册好网易云信，再去注册声网的服务
let request = NIMChatroomEnterRequest()
? ? ? ? //
? ? ? ? NIMSDK.shared().chatroomManager.enterChatroom(request) { error, chatRoomModel, member in
? ? ? ? ? ? self.configAgoraRtc()
? ? ? ? }
public func configAgoraRtc(){
? ? ? ? let config = AgoraRtcEngineConfig()
//
? ? ? ? agorat = AgoraRtcEngineKit.sharedEngine(with: config, delegate: self)
? ? ? ? agorat.enableAudioVolumeIndication(400, smooth: 3, report_vad:true)
? ? ? ? agorat.adjustPlaybackSignalVolume(2)
? ? ? ? agorat.setChannelProfile(.liveBroadcasting)
? ? ? ? agorat.enableDeepLearningDenoise(true)
? ? ? ? agorat.setClientRole(.audience)
?}
调整为
let request = NIMChatroomEnterRequest()
? ? ? ? //
? ? ? ? NIMSDK.shared().chatroomManager.enterChatroom(request) { error, chatRoomModel, member in
? ? ? ? }
self.configAgoraRtc()
因为，如果没网，就一起 gg 了
出现了意外，一个 OK, 另一个 gg,
可再去，关闭已经开启的服务
1.2 消息同步， 性能优化，耗电方向的角度
语音房，按职能（ 权限 ）的角度，一般可分为，游客和管理员
也可以分得特别细
思路为，天王，左右使者，4 大护法 …
语音房，1 / 3 左右的功能，不对游客开发
例如，游客不能看见房间的成员信息
所以， 房间的成员信息变更的时候，不用通知游客
游客的手机，减少了很多网络 socket 传输，减少耗电
1.2.1 网易云信的消息，一般用 P2P，和 Chatroom，
这里可使用 Team ， 群组功能
成为管理员，就加入了房间对应的群组，接收关联的消息
1.3， 刚开始开发，按照一切非常顺利
例如: 网络请求，等于调异步方法，暂不考虑失败
公司发现啥问题，马上补
KPI 非，用户授予
可能性，那么多。进度，能不赶
1.4 常见的优化 （ 请求加速 ）手段，略
加流程大法，好
弱网环境下，点击上麦，
用户头像，马上上去了，
调用声网修改角色的方法，gg
加流程， 用户头像旁边，多了一把叉
找 UI ，要效果图
2, 功能
发消息的常见流程:
有一个基于时间的考量
用户点击，发消息，UI 上，秒发出
UI, 就是障眼法
200 ms 后，这个网络请求 pending
消息的旁边出现一个进度条
后来，请求超时了，
列表的该消息，旁边出现，
一个重试按钮，和提示语 ( 请检查网络 )
2.1 公屏消息
可以移动端，直接发消息
let session = NIMSession(chatK, type: NIMSessionType.chatroom)
? ? ? ? let message = NIMMessage()
? ? ? ? ? ? let object = NIMCustomObject()
? ? ? ? ? ? object.attachment = HelloMessage()
? ? ? ? ? ? // 构造出具体消息并注入附件
? ? ? ? ? ? message.messageObject = object
do {
? ? ? ? ? ? try NIMSDK.shared().chatManager.send(message, to: session)
? ? ? ? } catch let err {
? ? ? ? ? ? print(err)
? ? ? ? }
消息编码
class HelloMessage: NSObject, NIMCustomAttachment{
? ? var txt = ""
? ? func encode() -> String {
? ? ? ? let dict: [String: Any] = ["txt": txt,
? ? ? ? ? ? ? ? ? ? ? ? ? ? ? ? "type": 6]
? ? ? ? var content = ""
? ? ? ? do {
? ? ? ? ? ? let data = try JSONSerialization.data(withJSONObject: dict, options: [])
? ? ? ? ? ? if let val = String(data: data, encoding: .utf8){
? ? ? ? ? ? ? ? content = val
? ? ? ? ? ? }
? ? ? ? } catch {
? ? ? ? ? ? print(error)
? ? ? ? }
? ? ? ? return content
? ? }
注册解码
NIMCustomObject.registerCustomDecoder(TheDecoder())
解码器
class TheDecoder: NSObject, NIMCustomAttachmentCoding {
? ? /// 消息解码 处理
? ? func decodeAttachment(_ content: String?) -> NIMCustomAttachment? {
? ? ? ? var attachment: NIMCustomAttachment?
? ? ? ? guard let contentData = content?.data(using: .utf8),
? ? ? ? let dic = try? JSONSerialization.jsonObject(with: contentData, options: .mutableContainers) as? [String:Any]
? ? ? ? else{ return nil }
? ? ? ? guard let type = dic["type"] as? Int
? ? ? ? else {
? ? ? ? ? ? return nil
? ? ? ? }
? ? ? ? ? ? switch type{
? ? ? ? ? ? case 6:
// 见后面的 3.1
? ? ? ? ? ? ? ? if let model = RoomTxtModel.deserialize(from: dic){
? ? ? ? ? ? ? ? ? ? attachment = HelloMessage.instance(model)
? ? ? ? ? ? ? ? }
? ? ? ? ? ? default:
? ? ? ? ? ? ? ? ()
? ? ? ? ? ? }
return attachment
? ? ? ? }
}
收到消息的 NIMSDK 的回调方法
func onRecvMessages(_ messages: [NIMMessage]) {
? ? ? ? if let object = message.messageObject as? NIMCustomObject{
? ? ? ? ? ? if let tmpModel = object.attachment as? HelloMessage{
? ? ? ? ? ? ? ? var item = tmpModel.item
? ? ? ? ? ? ? ? item.id = message.messageId
// 见 3.2
? ? ? ? ? ? ? ? subject.onNext([item])
? ? ? ? ? ? }
? ? ? ? }
}
测了几次，发现，发消息的人，收不到该消息
2.1.1 公屏消息, 的另一种实现
用户发消息，调用后端 API.
后端调用网易云信的接口，
然后房间内所有的用户收到消息，同步公屏的内容
此时，发消息的人，等了一个服务端的网络请求，和一个网易云信的消息下发
发消息的人，才更新自己的 UI
慢了些
2.2， 上麦
本地判断成功， 秒上
麦位空闲，没有上锁，
房间没有设置，上麦需要申请
用户自己的手机上， 他的头像覆盖麦位，
开声网的角色
同时，调用 API ，上传自己的麦位信息，
等待服务端云信，下方的消息，
是否有异常，需要在该麦位旁边，来一把叉
3, 三方库
3.1, HandyJSON
Swift 项目中，数据 ( 模型 ) 一般使用结构体，
NIMSDK 的附件 attachment， id 类型， 一般继承自 NSObject
需要来一个转换
class HelloMessage: NSObject, NIMCustomAttachment, JSONy{
? ? required override init() { }
?? class func instance(_ model: RoomTxtModel) -> HelloMessage{
? ? ? ? if let tmp = model.toJSON(), let data = HelloMessage.deserialize(from: tmp){
? ? ? ? ? ? return data
? ? ? ? }
? ? ? ? else{
? ? ? ? ? ? return RoomTxtModel()
? ? ? ? }
? ? }
?? ?
? ? var item: RoomTxtModel{
? ? ? ? if let tmp = toJSON(), let data = RoomTxtModel.deserialize(from: tmp){
? ? ? ? ? ? return data
? ? ? ? }
? ? ? ? else{
? ? ? ? ? ? return RoomTxtModel()
? ? ? ? }
? ? }
?? ?
}
3.2 RxDataSources
var subject = PublishSubject<[RoomTxtModel]>()
公屏就是一个 tableView,
RoomTxtModel 对应 cell，
每一个 RoomTxtModel 的 id, 就是云信消息的 id
( 区别开，拿来就用 )
|