no message

zhangxiaowen
1 parent 2639f986
Showing 3 changed files with 166 additions and 0 deletions
CNLivePlayer/Classes/Header/CNLivePlayerTypeDef.h
CNLivePlayer/Classes/Player/CNLivePlayer.h
CNLivePlayer/Classes/Player/CNLivePlayer.m
@@ -184,4 +184,18 @@ typedef enum : NSUInteger {
  
 } CNLiveClarityLevel;
  
+/**
+ *  主播直播状态
+ */
+typedef NS_ENUM(NSUInteger, CNLiveAnchorStatus) {
+    ///主播直播中
+    CNLiveAnchorStatusLiving = 0,
+    ///主播已离开
+    CNLiveAnchorStatusLeaving,
+    ///直播已结束
+    CNLiveAnchorStatusEnd,
+    ///直播错误
+    CNLiveAnchorStatusError
+};
+
 #endif /* CNLivePlayerTypeDef_h */
@@ -22,6 +22,7 @@ NS_ASSUME_NONNULL_BEGIN
  
 typedef void (^SuccessBlock) (void);
 typedef void (^FailureBlock) (NSError *error);
+typedef void (^AnchorStatus)(CNLiveAnchorStatus status);
  
 @interface CNLivePlayer : NSObject
  
@@ -59,6 +60,24 @@ typedef void (^FailureBlock) (NSError *error);
 - (instancetype)initLivePlayWithActivityId:(NSString *)activityId channelId:(NSString *)channelId success:(SuccessBlock _Nullable)success failure:(FailureBlock _Nullable)failure;
 // 推荐使用
 - (instancetype)initLivePlayWithActivityId:(NSString *)activityId channelId:(NSString *)channelId;
+- (instancetype)initLivePlayWithActivityId:(NSString *)activityId channelId:(NSString *)channelId
+                                   success:(SuccessBlock _Nullable)success failure:(FailureBlock _Nullable)failure isAgree:(BOOL)isAgree anchorStatus:(AnchorStatus)anchorStatus;
+/*
+ 主播直播状态(只读)
+ 
+ @since v0.0.1
+ */
+
+@property (nonatomic, assign, readonly) CNLiveAnchorStatus anchorStatus;
+
+/*
+ 重新获取主播直播状态
+
+ @param result 重新获取主播直播状态
+
+ @since v0.0.1
+ */
+- (void)retryToGetAnchorStatusResult:(AnchorStatus)result;
  
 #pragma mark - 切换视频
 /**
@@ -14,6 +14,7 @@
 #import "CNLivePlayerRequest.h"
 #import "CommonCrypto/CommonDigest.h"
 #import "CNLivePlayerUrl.h"
+#import <CNLiveMsgTools/CNLiveMsgManager.h>
  
 #define PlayerStringToKey(a, b) [NSString stringWithFormat:@"%@:%@",a,b]
  
@@ -30,6 +31,10 @@
     NSString *_rate;
     BOOL _switchRate;
     CMTime _switchRateTime;
+    
+    //聊天室ID
+    NSString *_roomId;
+
 }
 @property (nonatomic, strong) PLPlayerOption *option;
 @property (nonatomic, strong) PLPlayer *switchPlayer;
@@ -38,6 +43,11 @@
 @end
  
 @implementation CNLivePlayer
+//收到消息通知
+NSString * const MsgToolsPlayerReceiveNotification = @"CNLiveMsgToolsPlayerReceiveNotification";
+//获取主播状态通知
+NSString * const CNLiveAnchorStatusChangedNotification = @"CNLiveAnchorStatusChangedNotification";
+
 - (instancetype)initWithUrl:(NSString *)url{
     self = [super init];
        if (self) {
@@ -107,6 +117,24 @@
 - (instancetype)initLivePlayWithActivityId:(NSString *)activityId channelId:(NSString *)channelId{
     return [self initLivePlayWithActivityId:activityId channelId:channelId success:nil failure:nil];
 }
+- (instancetype)initLivePlayWithActivityId:(NSString *)activityId channelId:(NSString *)channelId
+                                   success:(SuccessBlock _Nullable)success failure:(FailureBlock _Nullable)failure isAgree:(BOOL)isAgree anchorStatus:(AnchorStatus)anchorStatus {
+    self = [super init];
+    if (self) {
+        _switchRate = NO;
+        _activityId = activityId;
+        _channelId = channelId;
+        _videoId = @"";
+        _type = @"live";
+        _rate = @"2";
+        [self getCacheURLSuccess:success failure:failure];
+        if (isAgree) {
+            [self initRCloudWithAppId:Player_AppID appKey:Player_AppKey connectResult:anchorStatus];
+        }
+    }
+    return self;
+    
+}
 /**
 初始化播放器
  
@@ -141,6 +169,7 @@
 }
  
 - (void)dealloc {
+    [self removeRCloudNotificationObservers];
     NSLog(@"CNLivePlayer --> dealloc");
 }
  
@@ -886,6 +915,110 @@ CVPixelBufferGetPixelFormatType 获取 YUV 的类型。
         [self.delegate player:self seekToCompleted:isCompleted];
     }
 }
+#pragma mark - 直播获取主播状态
+#pragma mark - 初始化RM
+- (void)initRCloudWithAppId:(NSString *)appId appKey:(NSString *)appKey connectResult:(AnchorStatus)anchorStatus {
+    [[CNLiveMsgManager sharedCNLiveMsgManager] initCNLiveMsgToolsWithAppKey:appKey appId:appId];
+    //连接RM服务器
+    [[CNLiveMsgManager sharedCNLiveMsgManager] justOnLineSuccess:^(NSString *toolsId) {
+        //加入聊天室
+        [self joinRoomResult:anchorStatus];
+        
+    } error:^(NSInteger errors) {
+        if (anchorStatus) {
+            anchorStatus(NO);
+        }
+    }];
+    
+}
+
+//加入聊天室
+- (void)joinRoomResult:(AnchorStatus)anchorStatus {
+    [self addRCloudNotificationObservers];
+    
+    NSString *contentId = _activityId ? _activityId : _channelId;
+    if (![_channelId containsString:@"_"]) {
+        NSString *spId = [[Player_AppID componentsSeparatedByString:@"_"] firstObject];
+        contentId = [NSString stringWithFormat:@"%@_%@", spId, _channelId];
+    }
+    
+    _roomId = [NSString stringWithFormat:@"CNLiveAnchorStatus_%@",contentId];
+    
+    //加入聊天室
+    [[CNLiveMsgManager sharedCNLiveMsgManager] gatherIfNullCreate:_roomId messageCount:1 success:^(NSString *targetId) {
+        if (anchorStatus) {
+            anchorStatus(YES);
+        }
+                                              
+    } error:^(NSInteger errors, NSString *targetId) {
+        if (anchorStatus) {
+            anchorStatus(CNLiveAnchorStatusError);
+        }
+                                  
+    }];
+    
+}
+
+//重新获取主播状态（离开/已结束）
+- (void)retryToGetAnchorStatusResult:(AnchorStatus)anchorStatus {
+    [self initRCloudWithAppId:Player_AppID appKey:Player_AppKey connectResult:anchorStatus];
+    
+}
+
+#pragma mark - 通知
+- (void)addRCloudNotificationObservers {
+    [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(receiveMessage:) name:MsgToolsPlayerReceiveNotification object:nil];
+
+}
+
+- (void)removeRCloudNotificationObservers {
+    [[NSNotificationCenter defaultCenter] removeObserver:self name:MsgToolsPlayerReceiveNotification object:nil];
+
+    if (!_roomId || [_roomId isEqualToString:@""] || ![_roomId isKindOfClass:[NSString class]] || _roomId.length == 0) {
+        return;
+    }
+    
+    [[CNLiveMsgManager sharedCNLiveMsgManager] disperse:_roomId success:^(NSString *targetId) {
+        
+    } error:^(NSInteger errors, NSString *targetId) {
+        
+    }];
+    
+}
+
+#pragma mark - 聊天室
+- (void)receiveMessage:(NSNotification *)noti {
+    
+    if (!noti.userInfo[@"message"]) return;
+    
+    int newValue = [noti.userInfo[@"message"] intValue];
+    
+    if (_anchorStatus == newValue) return;    //如果新收到的状态与上一次状态一样不作处理
+    _anchorStatus = newValue;
+
+    if (newValue == 1) {
+        _anchorStatus = CNLiveAnchorStatusLiving;
+        [_player play];
+        
+    } else if (newValue == 2) {
+        _anchorStatus = CNLiveAnchorStatusEnd;
+        [_player stop];
+        
+    } else {
+        _anchorStatus = CNLiveAnchorStatusLeaving;
+        [_player pause];
+        
+    }
  
+    if (Player_TestEnvironment) {
+        NSLog(@"CNLiveMoviePlayerController-->主播直播状态%lu",(unsigned long)_anchorStatus);
+    }
+    
+    //发送通知
+    dispatch_async(dispatch_get_main_queue(), ^{
+        [[NSNotificationCenter defaultCenter] postNotificationName:CNLiveAnchorStatusChangedNotification object:nil userInfo:nil];
+    });
+    
+}
  
 @end