iOS Team / CNLivePlayerStreamerSDKDemo · Files

//
//  LiveViewController.m
//  CNLiveLiveDemo
//
//  Created by Android on 16/8/10.
//  Copyright © 2016年 Android. All rights reserved.
//

#import "StreamerDetailViewController.h"
#import <CNLivePlayerSDK/CNLiveGPUStreamerKit.h>
#import <CNLivePlayerSDK/CNLiveWebcastManager.h>
#import "FilterFunctionView.h"

#define Width [UIScreen mainScreen].bounds.size.width
#define Height [UIScreen mainScreen].bounds.size.height

#define KAppId @"60_irn9edco29"
#define KAppKey @"69fe70bda67e059286ad509d9f5377f815955645b52f94"
#define KBundleId @"com.cnlive.video"

@interface StreamerDetailViewController ()<UIGestureRecognizerDelegate>
{
    UIButton *_startLiveBtn;
    CGFloat _currentPinchZoomFactor;//当前触摸缩放因子
}

@property (nonatomic,strong) UIView *captureView;
@property (nonatomic,strong) UILabel *stateLab;
@property (nonatomic,strong) NSURL *hostURL;
@property (nonatomic,strong) FilterFunctionView *filterView;
@property (nonatomic,strong) CNLiveGPUStreamerKit *kitCN;        //直播推流

@end

@implementation StreamerDetailViewController

- (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];
    }
    
    [UIView animateWithDuration:0.2 animations:^{
        _captureView.frame = self.view.bounds;
        _stateLab.frame = CGRectMake(0, Height-100, Width, 100);
    }];
}

- (void)viewDidLoad {
    [super viewDidLoad];
    
    [self.view addSubview:self.captureView];
    [self.view addSubview:self.filterView];
    [self.view addSubview:self.stateLab];
    
    if (_isAuthLive) {
        
        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];
        
    }else{
        
        _kitCN = [[CNLiveGPUStreamerKit alloc] initWithDefaultConfig];
        _hostURL = _url;
        
        [self setStreamerCfg];
        [self addObservers];
        
    }
    
    _startLiveBtn = [self addButton:@"开始直播" frame:CGRectMake(100, 40, 80, 40) action:@selector(startCapture:)];
    [_startLiveBtn setTitle:@"开始直播" forState:UIControlStateNormal];
    [_startLiveBtn setTitle:@"停止直播" forState:UIControlStateSelected];
    
    [self addButton:@"关闭预览" frame:CGRectMake(10, 40, 80, 40) action:@selector(startPreview:)];
    [self addButton:@"退出" frame:CGRectMake(190, 40, 80, 40) action:@selector(quit)];
    [self addButton:@"美颜" frame:CGRectMake(10, 100, 80, 40) action:@selector(openFilter:)];
    [self addButton:@"摄像头" frame:CGRectMake(100, 100, 80, 40) action:@selector(changeCamera:)];
    [self addButton:@"闪光灯" frame:CGRectMake(190, 100, 80, 40) action:@selector(openFlash)];
    
    
    UITapGestureRecognizer * singleRecognizer = [[UITapGestureRecognizer alloc] initWithTarget:self action:@selector(onTap:)];
    singleRecognizer.delegate = self;
    [self.captureView addGestureRecognizer:singleRecognizer];
    
    UIPinchGestureRecognizer *pinch = [[UIPinchGestureRecognizer alloc]initWithTarget:self action:@selector(pinchDetected:)];
    [self.view addGestureRecognizer:pinch];
    
}

- (UIButton *)addButton:(NSString*)title
                  frame:(CGRect)frame
                 action:(SEL)action {
    UIButton * button;
    button = [UIButton buttonWithType:UIButtonTypeCustom];
    button.frame = frame;
    [button setTitle: title forState: UIControlStateNormal];
    [button addTarget:self action:action forControlEvents:UIControlEventTouchUpInside];
    button.titleLabel.font = [UIFont systemFontOfSize:15];
    [button setTitleColor:[UIColor colorWithRed:23/255.0 green:110/255.0 blue:254/255.0 alpha:1] forState:UIControlStateNormal];
    button.layer.cornerRadius = 10;
    button.layer.masksToBounds = YES;
    button.layer.borderColor = [UIColor blackColor].CGColor;
    button.layer.borderWidth = 1;
    [self.captureView addSubview:button];
    return button;
    
}

#pragma mark - initialization
- (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)startPreview:(UIButton *)button
{
    button.selected = !button.selected;
    if (button.selected) {
        _startLiveBtn.enabled = NO;
        [button setTitle:@"开启预览" forState:UIControlStateNormal];
        if (_kitCN.streamState == CNLiveStreamStateConnected) {
            [_kitCN stopStream];
            _startLiveBtn.selected = NO;
        }
        [_kitCN stopPreview];
    }else{
        [_kitCN startPreview:self.captureView];
        [button setTitle:@"关闭预览" forState:UIControlStateNormal];
        _startLiveBtn.enabled = YES;
    }
}

- (void)startCapture:(UIButton *)button
{
    button.selected = !button.selected;
    
    if (button.selected) {
        if (_isAuthLive) {
            
            [_kitCN startStream:^{
                NSLog(@"开启推流成功 ------- success");
            } failure:^(NSDictionary *errorDic) {
                [self toast:errorDic[@"errorMessage"]];
                _startLiveBtn.selected = NO;
            }];
            
        }else{
            [_kitCN startStream:_hostURL];
        }
    }else{
        _stateLab.text = nil;
        [_kitCN stopStream];
    }
}

- (void)openFilter:(UIButton *)button
{
    button.selected = !button.selected;
    
    if (button.selected) {
        
        _filterView.hidden = NO;
        
        __weak StreamerDetailViewController *weakself = self;
        
        _filterView.filterViewBlock = ^(float grindRatio , float whitenRatio, float intensity){
            
            [weakself.kitCN.beautifyFaceFilter filterAdjustingParameterWithGrindRatio:grindRatio
                                                                          whitenRatio:whitenRatio
                                                                            intensity:intensity];
        };
        
        _filterView.currentTypeBlock = ^(NSInteger currentType){
            [weakself.kitCN.beautifyFaceFilter  setBeautyType:currentType];
        };
        
        _filterView.currentIdxBlock = ^(NSInteger currentIdx){
            weakself.kitCN.beautifyFaceFilter.curEffectIdx = currentIdx;
        };
        
    } else {
        
        _filterView.hidden = YES;
        
    }
}

- (void)changeCamera:(UIButton *)button
{
    //    button.selected = !button.selected;
    //    if (button.selected) {
    //        _kitCN.cameraPosition = AVCaptureDevicePositionBack;
    //    }else{
    //        _kitCN.cameraPosition = AVCaptureDevicePositionFront;
    //    }
    [_kitCN switchCamera];
    
}

- (void)openFlash
{
    [_kitCN toggleTorch];
    //    [_kitCN setTorchMode:AVCaptureTorchModeOn];
}

- (void)quit
{
    if (_kitCN.streamState == CNLiveStreamStateConnected) {
        [_kitCN stopStream];
    }
    if (_kitCN.captureState == CNLiveCaptureStateCapturing) {
        [_kitCN stopPreview];
    }
    
    [self dismissViewControllerAnimated:YES completion:NULL];
}

- (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];
}

#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, _stateLab.text);
    
    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];
        
        if (_isAuthLive) {
            
            [_kitCN startStream:^{
                NSLog(@"开启推流成功 ------- success");
                _startLiveBtn.selected = YES;
                
            } failure:^(NSDictionary *errorDic) {
                [self toast:errorDic[@"errorMessage"]];
                _startLiveBtn.selected = NO;
            }];
            
        }else{
            [_kitCN startStream:_hostURL];
        }
        
        
    });
}

//对焦与曝光
- (void)onTap:(UIGestureRecognizer *)sender
{
    CGPoint current = [sender locationInView:self.view];
    CGPoint point = [self convertToPointOfInterestFromViewCoordinates:current];
    [_kitCN exposureAtPoint:point];
    [_kitCN focusAtPoint:point];
}

//缩放
- (void)pinchDetected:(UIPinchGestureRecognizer *)recognizer{
    if (recognizer.state == UIGestureRecognizerStateBegan) {
        _currentPinchZoomFactor = _kitCN.pinchZoomFactor;
    }
    CGFloat zoomFactor = _currentPinchZoomFactor * recognizer.scale;//当前触摸缩放因子*坐标比例
    [_kitCN setPinchZoomFactor:zoomFactor];
}

/**
 @abstract 将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)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 - GetMethod

- (UIView *)captureView
{
    if (!_captureView) {
        _captureView = [[UIView alloc] initWithFrame:CGRectMake(0, 0, self.view.bounds.size.width, self.view.bounds.size.height)];
        _captureView.backgroundColor = [UIColor blackColor];
    }
    return _captureView;
}

- (UILabel *)stateLab
{
    if (!_stateLab) {
        _stateLab = [[UILabel alloc] initWithFrame:CGRectMake(0, Height-100, Width, 100)];
        _stateLab.backgroundColor = [UIColor clearColor];
        _stateLab.numberOfLines = 0;
        _stateLab.textColor = [UIColor redColor];
    }
    return _stateLab;
}

- (FilterFunctionView *)filterView
{
    if (!_filterView) {
        _filterView = [[FilterFunctionView alloc] initWithFrame:CGRectMake(0, 170, Width, 200)];
        _filterView.hidden = YES;
    }
    return _filterView;
}
- (void)dealloc
{
    [[NSNotificationCenter defaultCenter] removeObserver:self];
    
    [[NSNotificationCenter defaultCenter] removeObserver:self name:CNLiveCaptureStateDidChangeNotification object:nil];
    
    self.kitCN = nil;
}

- (void)didReceiveMemoryWarning {
    [super didReceiveMemoryWarning];
    // Dispose of any resources that can be recreated.
}

/*
 #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.
 }
 */

@end