采集

王军波
1 parent 69c75123
Showing 1 changed file with 323 additions and 13 deletions
LiveVideoCloud/LiveVideoCloud/Classes/Sections/LiveSections/Controller/LVCLiveViewController.m
@@ -7,13 +7,46 @@
 //
 #import "LVCLiveViewController.h"
+#import <CNLivePlayerSDK/CNLiveGPUStreamerKit.h>
+#import <CNLivePlayerSDK/CNLiveWebcastManager.h>
-@interface LVCLiveViewController ()
+#define KAppId @"60_irn9edco29"
+#define KAppKey @"69fe70bda67e059286ad509d9f5377f815955645b52f94"
+
+@interface LVCLiveViewController () {
+    // 开始直播
+    UIButton *_startLiveBtn;
+    // 缩放因子
+    CGFloat _currentPinchZoomFactor;
+}
+
+@property (nonatomic,strong) UIView *captureView;
+
+@property (nonatomic,strong) CNLiveGPUStreamerKit *kitCN;
 @end
 @implementation LVCLiveViewController
+- (BOOL)shouldAutorotateToInterfaceOrientation:(UIInterfaceOrientation)interfaceOrientation
+{
+    if (_kitCN) {
+        return UIInterfaceOrientationMaskAllButUpsideDown;
+    } else {
+        return UIInterfaceOrientationMaskPortrait;
+    }
+}
+
+-(void)didRotateFromInterfaceOrientation:(UIInterfaceOrientation)fromInterfaceOrientation {
+    
+    UIInterfaceOrientation orie = [[UIApplication sharedApplication] statusBarOrientation];
+    [_kitCN rotatePreviewTo:orie];
+    
+    if (_kitCN.streamerBase.isStreaming) {
+        [_kitCN rotateStreamTo:orie];
+    }
+}
+
 - (void)viewDidLoad {
     [super viewDidLoad];
     // Do any additional setup after loading the view.
@@ -23,26 +56,303 @@
     [closeBtn setTitle:@"关闭" forState:UIControlStateNormal];
     [closeBtn addTarget:self action:@selector(closeBtnClivk) forControlEvents:UIControlEventTouchUpInside];
     [self.view addSubview:closeBtn];
+    
+    // 活动Id
+    NSString *activityId = [NSString stringWithFormat:@"%d%d%d%d%d",arc4random()%9,arc4random()%9,arc4random()%9,arc4random()%9,arc4random()%9];
+    // 初始化直播云
+    [[CNLiveWebcastManager manager] initWithAppId:KAppId appKey:KAppKey];
+    // 初始化推流
+    _kitCN = [[CNLiveGPUStreamerKit alloc] initWithDefaultConfigWithActivityId:activityId channelId:@"iOStest" isHorizontalScreen:@"0"];
+    
+    //        _kitCN.activityName = @"iOS test";
+    //        _kitCN.coverImgUrl = @"djfiwooa";
+    
+    [self setStreamerCfg];
+    [self addObservers];
 }
-- (void)closeBtnClivk
-{
+#pragma mark - initialization Streamer
+- (void)setStreamerCfg {
+    //采集配置
+    _kitCN.capPreset = AVCaptureSessionPreset640x480;
+    _kitCN.previewDimension = CGSizeMake(360, 640);
+    _kitCN.streamDimension = CGSizeMake(360, 640);
+    _kitCN.videoFPS = 15;
+    _kitCN.cameraPosition = AVCaptureDevicePositionFront;
+    
+    //推流配置
+    _kitCN.streamerBase.videoCodec = CNLiveVideoCodec_AUTO;
+    _kitCN.streamerBase.videoInitBitrate = 900;
+    _kitCN.streamerBase.videoMaxBitrate = 900;
+    _kitCN.streamerBase.videoMinBitrate = 300;
+    _kitCN.streamerBase.maxKeyInterval = 2;
+    _kitCN.streamerBase.audiokBPS = 48;
+    
+    // 如果有耳机,麦克风
+    if ([CNLiveAudioCapture isHeadsetPluggedIn]) {
+        // 音频采集器  自动播放采集声音
+        [_kitCN.audioCapture setBPlayCapturedAudio:YES];
+    }
+    
+    //设置画面朝向
+    [_kitCN setVideoOrientationBy:[[UIApplication sharedApplication] statusBarOrientation]];
+    
+    // 启动预览
+    [_kitCN startPreview:self.captureView];
+    
+    //水印图片
+    _kitCN.watermark.logoPic = [UIImage imageNamed:@"互动电视180x180"];
+    _kitCN.watermark.logoRect = CGRectMake(0.8, 0.8, 50, 50);
+    _kitCN.watermark.logoAlpha = 0.6;
+    
+    //水印文字
+    _kitCN.watermark.textLabel = [[UILabel alloc] init];
+    _kitCN.watermark.textLabel.text = [NSString stringWithFormat:@"cnlive"];
+    _kitCN.watermark.textLabel.font = [UIFont systemFontOfSize:8];
+    _kitCN.watermark.textRect = CGRectMake(0.78, 0.88, 0.2, 0.04);
+    [_kitCN.watermark updateTextLabel];
+    
+}
+
+#pragma mark - Action !!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!!
+
+- (void)addObservers {
+    
+    [[NSNotificationCenter defaultCenter] addObserver:self selector:@selector(captureStateChange) name:CNLiveCaptureStateDidChangeNotification object:nil];
+    
+    [[NSNotificationCenter defaultCenter] addObserver:self
+                                             selector:@selector(streamStateChange)
+                                                 name:CNLiveStreamStateDidChangeNotification
+                                               object:nil];
+    
+    [[NSNotificationCenter defaultCenter] addObserver:self
+                                             selector:@selector(enterBg)
+                                                 name:UIApplicationDidEnterBackgroundNotification
+                                               object:nil];
+    
+    [[NSNotificationCenter defaultCenter] addObserver:self
+                                             selector:@selector(becameActive)
+                                                 name:UIApplicationDidBecomeActiveNotification
+                                               object:nil];
+}
+
+// 退出
+- (void)closeBtnClivk {
+    
     [self dismissViewControllerAnimated:YES completion:nil];
 }
-- (void)didReceiveMemoryWarning {
-    [super didReceiveMemoryWarning];
-    // Dispose of any resources that can be recreated.
+#pragma mark - notification
+
+- (void)enterBg {
+    
+    [_kitCN appEnterBackground];
+}
+
+- (void)becameActive {
+    
+    [_kitCN appBecomeActive];
+}
+
+- (void)captureStateChange {
+    
+    if ( _kitCN.captureState == CNLiveCaptureStateIdle){
+        //初始化时状态为空闲
+//        _stateLab.text = @"CNLiveCaptureStateIdle";
+        
+        return;
+    }
+    else if (_kitCN.captureState == CNLiveCaptureStateCapturing ) {
+        //设备工作中
+//        _stateLab.text = @"CNLiveCaptureStateCapturing";
+        
+        return;
+    }
+    else if (_kitCN.captureState == CNLiveCaptureStateClosingCapture ) {
+        //关闭采集设备中
+//        _stateLab.text = @"CNLiveCaptureStateClosingCapture";
+        
+        return;
+    }
+    else if (_kitCN.captureState == CNLiveCaptureStateDevAuthDenied ) {
+        //设备授权被拒绝
+        NSLog(@"---------CNLiveCaptureStateDevAuthDenied");
+//        _stateLab.text = @"camera/mic Authorization Denied";
+        
+        return;
+    }
+    else if (_kitCN.captureState == CNLiveCaptureStateParameterError ) {
+        // 参数错误，无法打开
+        NSLog(@"---------CNLiveCaptureStateParameterError");
+//        _stateLab.text = @"capture devices ParameterError";
+        
+        return;
+    }
+    else if (_kitCN.captureState == CNLiveCaptureStateDevBusy ) {
+        //设备正忙，请稍后尝试
+        NSLog(@"---------CNLiveCaptureStateDevBusy");
+//        _stateLab.text = @"device busy, try later";
+        
+    }
+}
+
+- (void)streamStateChange {
+    
+    if (_kitCN.streamState == CNLiveStreamStateIdle) {
+        
+        NSLog(@"---------CNLiveStreamStateIdle");
+//        _stateLab.text = @"CNLiveStreamStateIdle";
+    }
+    
+    if (_kitCN.streamState == CNLiveStreamStateConnected) {
+        
+        NSLog(@"---------CNLiveStreamStateConnected");
+//        _stateLab.text = [NSString stringWithFormat:@"CNLiveStreamStateConnected------%@",_hostURL];
+    }
+    
+    if (_kitCN.streamState == CNLiveStreamStateConnecting) {
+        
+        NSLog(@"---------CNLiveStreamStateConnecting");
+//        _stateLab.text = @"CNLiveStreamStateConnecting";
+    }
+    
+    //推流出错
+    if (_kitCN.streamState == CNLiveStreamStateError) {
+        
+        NSLog(@"---------CNLiveStreamStateError");
+        [self onStreamError];
+    }
+    
+    //断开推流
+    if ( _kitCN.streamState == CNLiveStreamStateDisconnecting) {
+        
+        NSLog(@"---------CNLiveStreamStateDisconnecting");
+//        _stateLab.text = @"CNLiveStreamStateDisconnecting";
+    }
+    
+    //结束推流成功
+    if ( _kitCN.streamState == CNLiveStopStreamSuccess) {
+        
+        NSLog(@"---------CNLiveStopStreamSuccess");
+//        _stateLab.text = @"CNLiveStopStreamSuccess";
+    }
+}
+
+- (void)onStreamError {
+    
+    CNLiveStreamErrorCode err = _kitCN.streamErrorCode;
+    
+    NSLog(@"onErr: %lu ", (unsigned long) err);
+    
+    if ( CNLiveStreamErrorCode_CNLiveAUTHFAILED == err ) {
+//        _stateLab.text = @"SDK auth failed, \npls check ak/sk";
+    }
+    else if ( CNLiveStreamErrorCode_CODEC_OPEN_FAILED == err) {
+//        _stateLab.text = @"Selected Codec not supported \n in this version";
+    }
+    else if ( CNLiveStreamErrorCode_CONNECT_FAILED == err) {
+//        _stateLab.text = @"Connecting error, pls check host url \nor network";
+    }
+    else if ( CNLiveStreamErrorCode_CONNECT_BREAK == err) {
+//        _stateLab.text = @"Connection break";
+    }
+    else if ( CNLiveStreamErrorCode_ABNORMAL == err) {
+//        _stateLab.text = @"CNLiveStreamErrorCode_ABNORMAL";
+        [self toast:@"推流异常中断~~"];
+        _startLiveBtn.selected = NO;
+        
+    } else if (err == CNLiveStreamErrorCode_CODEC_OPEN_FAILED) {
+        NSLog(@"video codec open failed, try software codec");
+        _kitCN.streamerBase.videoCodec = CNLiveVideoCodec_VT264;
+        [self tryReconnect];
+    }
+    else {
+        
+    }
+    
+    // 断网重连
+    if (err == CNLiveStreamErrorCode_CONNECT_BREAK || err == CNLiveStreamErrorCode_AV_SYNC_ERROR) {
+        [self tryReconnect];
+    }
+    
+}
+
+- (void) tryReconnect {
+    
+    dispatch_time_t delay = dispatch_time(DISPATCH_TIME_NOW, (int64_t)(5 * NSEC_PER_SEC));
+    dispatch_after(delay, dispatch_get_main_queue(), ^{
+        
+        NSLog(@"try again");
+        
+        [_kitCN stopStream];
+        
+        [_kitCN startStream:^{
+            NSLog(@"开启推流成功 ------- success");
+            _startLiveBtn.selected = YES;
+            
+        } failure:^(NSDictionary *errorDic) {
+            [self toast:errorDic[@"errorMessage"]];
+            _startLiveBtn.selected = NO;
+        }];
+        
+    });
+}
+
+//
+- (void)toast:(NSString*)message
+{
+    
+    UIAlertView *toast = [[UIAlertView alloc] initWithTitle:nil
+                                                    message:message
+                                                   delegate:nil
+                                          cancelButtonTitle:nil
+                                          otherButtonTitles:nil, nil];
+    [toast show];
+    double duration = 2.5;
+    dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(duration * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
+        [toast dismissWithClickedButtonIndex:0 animated:NO];
+    });
 }
-/*
-#pragma mark - Navigation
-// In a storyboard-based application, you will often want to do a little preparation before navigation
-- (void)prepareForSegue:(UIStoryboardSegue *)segue sender:(id)sender {
-    // Get the new view controller using [segue destinationViewController].
-    // Pass the selected object to the new view controller.
+// 将UI的坐标转换成相机坐标
+- (CGPoint)convertToPointOfInterestFromViewCoordinates:(CGPoint)viewCoordinates
+{
+    CGPoint pointOfInterest = CGPointMake(.5f, .5f);
+    CGSize frameSize = self.view.frame.size;
+    CGSize apertureSize = [_kitCN captureDimension];
+    CGPoint point = viewCoordinates;
+    CGFloat apertureRatio = apertureSize.height / apertureSize.width;
+    CGFloat viewRatio = frameSize.width / frameSize.height;
+    CGFloat xc = .5f;
+    CGFloat yc = .5f;
+    
+    if (viewRatio > apertureRatio) {
+        CGFloat y2 = frameSize.height;
+        CGFloat x2 = frameSize.height * apertureRatio;
+        CGFloat x1 = frameSize.width;
+        CGFloat blackBar = (x1 - x2) / 2;
+        if (point.x >= blackBar && point.x <= blackBar + x2) {
+            xc = point.y / y2;
+            yc = 1.f - ((point.x - blackBar) / x2);
+        }
+    }else {
+        CGFloat y2 = frameSize.width / apertureRatio;
+        CGFloat y1 = frameSize.height;
+        CGFloat x2 = frameSize.width;
+        CGFloat blackBar = (y1 - y2) / 2;
+        if (point.y >= blackBar && point.y <= blackBar + y2) {
+            xc = ((point.y - blackBar) / y2);
+            yc = 1.f - (point.x / x2);
+        }
+    }
+    pointOfInterest = CGPointMake(xc, yc);
+    return pointOfInterest;
+}
+
+- (void)didReceiveMemoryWarning {
+    [super didReceiveMemoryWarning];
+    // Dispose of any resources that can be recreated.
 }
-*/
 @end