devbox
小丑西瓜9
这个屌丝很懒，什么也没留下！
关注作者
热门标签
热门文章
当前位置:   article > 正文

2021-07-21_- (void)sendvideobuffertohostapp:(cmsamplebufferre

作者：小丑西瓜9 | 2024-03-18 05:38:41

赞

踩

- (void)sendvideobuffertohostapp:(cmsamplebufferref)samplebuffer

replaykit2处理(引)

  • 特点
  1. replaykit2在replaykit的基础上增加了能录制桌面，退到后台打开其他应用同样能录制当前屏幕显示的内容，
  2. 使用socket完成进程间的通信，
  3. 负责录制的屏幕数据的进程占用内存最大只能50M，大于则会被系统杀掉
  • 系统版本下的区别
    ios12新出了一个api用于在app内能直接调起录屏功能的UI
RPSystemBroadcastPickerView

    具体实现
    申明

    @property (nonatomic,strong)RPSystemBroadcastPickerView API_AVAILABLE(ios(12.0))     *broadPickerView;

      初始化

      - (RPSystemBroadcastPickerView *)broadPickerView API_AVAILABLE(ios(12.0)){
  if(!_broadPickerView){
    _broadPickerView = [[RPSystemBroadcastPickerView alloc] initWithFrame:CGRectMake(0, 0, 1, 1)];
    //是否显示音频按钮
    _broadPickerView.showsMicrophoneButton = NO;
    这个是决定调起某一个特定的extensionUpload，这里就写自己创建的upload的bundleID
    _broadPickerView.preferredExtension = @"extensionbundleID";
  }
  return _broadPickerView;
}
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9

      app内调用录制按钮的方法

      if (@available(iOS 12.0, *)) {
	//首先判断是否在录制中
      if (![UIScreen mainScreen].isCaptured) {
        dispatch_async(dispatch_get_main_queue(), ^{
          [[UIApplication sharedApplication].keyWindow addSubview:self.broadPickerView];
          
          for (UIView *view in self.broadPickerView.subviews)
          {
            if ([view isKindOfClass:[UIButton class]])
            {
	          // UIControlEventAllTouchEvents这个属性需要特别注意，网上很多说使用的是别的类型，在ios13下都会不起作用，ios13以后必须使用UIControlEventAllTouchEvents，调用事件才有效，所以直接使用UIControlEventAllTouchEvents，在ios9以上都支持
              [(UIButton*)view sendActionsForControlEvents:UIControlEventAllTouchEvents];
            }
          }
          
        });
      }
    }
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17

      看了上面的特定api，先看下创建ExtensionUpload的方式
      选中工程的 Targets —> editor —>addTarget —>Broadcast Upload Extension—>Next
      在这里插入图片描述
      next 如下

      1. 输入名称
      2. 选择语言
      3. Include UI Extension 可选可不选，后期也用不到
        在这里插入图片描述

      确定后会在工程中多几个文件
      1.SampleHandler
      2. BroadcastSetupViewController

      在这里插入图片描述
      其中SampleHandler就是我们获取录屏数据处理的类，这个类相当于一个单独的应用，想要调制需要运行extension的才能打印或者断点调试

      //这个代码是我们获取数据并处理的方法
- (void)processSampleBuffer:(CMSampleBufferRef)sampleBuffer withType:(RPSampleBufferType)sampleBufferType {
    
    switch (sampleBufferType) {
        case RPSampleBufferTypeVideo:
            // Handle video sample buffer
            break;
        case RPSampleBufferTypeAudioApp:
            // Handle audio sample buffer for app audio
            break;
        case RPSampleBufferTypeAudioMic:
            // Handle audio sample buffer for mic audio
            break;
            
        default:
            break;
    }
}
这里面的难点在于，如果你有单独的类来处理视频数据的上传，直接上传就可以了，如果你需要把数据传回住app在处理，就需要用到进程间的通信了，进程间的通信有很多种，不再叙述，感兴趣可以网上查查，这里只讲使使用socket进行进程间的通信

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19

      这里还涉及到一个进程间的通知的问题，用于状态标记的回传

      socket 使用GCDAsysocket

      处理数据视频数据使用一个第三方的对视频进行裁剪封装为nsdata数据，socket使用nsadata类型的数据
      下面的代码其实可以是一个固定写法，就这样写，变动也是在个别参数的调试

      //
//  SampleHandler.m
//  ClairEye
//
//  Created by AmpleSky on 2020/3/31.
//  Copyright © 2020年 Facebook. All rights reserved.
//

#import "SampleHandler.h"
#import "NTESYUVConverter.h"
#import "NTESI420Frame.h"
#import "GCDAsyncSocket.h"
#import "NTESSocketPacket.h"
#import "NTESTPCircularBuffer.h"

@interface SampleHandler ()<GCDAsyncSocketDelegate>

@property (nonatomic, assign) CGFloat cropRate;
@property (nonatomic, assign) CGSize  targetSize;
@property (nonatomic, assign) NTESVideoPackOrientation orientation;

@property (nonatomic, copy) NSString *ip;
@property (nonatomic, copy) NSString *clientPort;
@property (nonatomic, copy) NSString *serverPort;
@property (nonatomic, strong) dispatch_queue_t videoQueue;
@property (nonatomic, assign) NSUInteger frameCount;
@property (nonatomic, assign) BOOL connected;
@property (nonatomic, strong) dispatch_source_t timer;

@property (nonatomic, strong) GCDAsyncSocket *socket;
@property (nonatomic, strong) dispatch_queue_t queue;
@property (nonatomic, assign) NTESTPCircularBuffer *recvBuffer;

@end

@implementation SampleHandler
BOOL _enterBack = false;
static void Callback(CFNotificationCenterRef center,
                     void *observer,
                     CFStringRef name,
                     const void *object,
                     CFDictionaryRef userInfo)
{
  _enterBack = true;
  dispatch_after(dispatch_time(DISPATCH_TIME_NOW, (int64_t)(3 * NSEC_PER_SEC)), dispatch_get_main_queue(), ^{
  _enterBack = false;
  });
 
}
BOOL _finish = false;
static void FinishCallback(CFNotificationCenterRef center,
                           void *observer,
                           CFStringRef name,
                           const void *object,
                           CFDictionaryRef userInfo)
{
  _finish = true;
  
}


- (void)dealloc {
  _connected = NO;
  
  if (_socket) {
    [_socket disconnect];
    _socket = nil;
    NTESTPCircularBufferCleanup(_recvBuffer);
  }
  
  if(_timer) {
    _timer = nil;
  }
}

- (instancetype)init {
  if(self = [super init]) {
    
    _targetSize = CGSizeMake(540, 960);
    _cropRate = 15;
    _orientation = NTESVideoPackOrientationPortrait;
    
    _ip = @"127.0.0.1";
    _serverPort = @"8999";
    _clientPort = [NSString stringWithFormat:@"%d", arc4random()%9999];
    _videoQueue = dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0);
    CFStringRef name = CFSTR("customName");
    CFNotificationCenterRef center = CFNotificationCenterGetDarwinNotifyCenter();
    CFNotificationCenterAddObserver(center,
                                    (const void *)self,
                                    Callback,
                                    name,
                                    NULL,
                                    kCFNotificationDeliverImmediately);
    CFStringRef finishName = CFSTR("StopScreen");
    CFNotificationCenterRef finishCenter = CFNotificationCenterGetDarwinNotifyCenter();
  
    CFNotificationCenterAddObserver(finishCenter,
                                    (const void *)self,
                                    FinishCallback,
                                    finishName,
                                    NULL,
                                    kCFNotificationDeliverImmediately);
    

  }
  return self;
}


- (void)broadcastStartedWithSetupInfo:(NSDictionary<NSString *,NSObject *> *)setupInfo {
  if (!self.connected) {
    [self.socket disconnect];
  }
  if (!self.socket.isConnected) {
    [self setupSocket];
  }
  
}

- (void)broadcastPaused {
//  if (self.connected) {
//    NSString * str =@"Paused";
//    NSData *data =[str dataUsingEncoding:NSUTF8StringEncoding];
//    [self.socket writeData:data withTimeout:5 tag:0];
//  }
}

- (void)broadcastResumed {
//  if (self.connected) {
//    NSString * str =@"Resumed";
//    NSData *data =[str dataUsingEncoding:NSUTF8StringEncoding];
//    [self.socket writeData:data withTimeout:5 tag:0];
//  }
}

- (void)broadcastFinished {
  if (self.connected) {
    NSString * str =@"Finish";
    NSData *data =[str dataUsingEncoding:NSUTF8StringEncoding];
    [self.socket writeData:data withTimeout:-1 tag:0];
  }
//  [self.socket disconnect];
}

- (void)processSampleBuffer:(CMSampleBufferRef)sampleBuffer withType:(RPSampleBufferType)sampleBufferType {
  switch (sampleBufferType) {
    case RPSampleBufferTypeVideo:
    {
      if (!self.connected)
      {
        return;
      }
//      if(self.connected){
      
      if(_finish){
        NSError *error;
        if([UIDevice currentDevice].systemVersion.doubleValue >= 12 && [UIDevice currentDevice].systemVersion.doubleValue < 13){
          error = [NSError errorWithDomain:@"您停止了屏幕共享" code:-001 userInfo:@{}];
        }else{
          error = nil;
        }
        [self finishBroadcastWithError:error];
      }
      
      
      if( CMSampleBufferDataIsReady(sampleBuffer)){
        [self sendVideoBufferToHostApp:sampleBuffer];
      }

    }
      break;
    case RPSampleBufferTypeAudioApp:
      // Handle audio sample buffer for app audio
      break;
    case RPSampleBufferTypeAudioMic:
      // Handle audio sample buffer for mic audio
      break;
      
    default:
      break;
  }
}
#pragma mark - 处理分辨率切换等
- (void)onRecvData:(NSData *)data head:(NTESPacketHead *)head
{
  if (!data)
  {
    return;
  }
  
  switch (head->command_id)
  {
    case 1:
    {
      NSString *qualityStr = [NSString stringWithUTF8String:[data bytes]];
      int qualit = [qualityStr intValue];
      switch (qualit) {
        case 0:
          self.targetSize = CGSizeMake(480, 640);
          break;
        case 1:
          self.targetSize = CGSizeMake(144, 177);
          break;
        case 2:
          self.targetSize = CGSizeMake(288, 352);
          break;
        case 3:
          self.targetSize = CGSizeMake(320, 480);
          break;
        case 4:
          self.targetSize = CGSizeMake(375, 667);
          break;
        case 5:
          self.targetSize = CGSizeMake(414, 812);
          break;
        case 6:
          self.targetSize = CGSizeMake(414, 812);
          break;
        default:
          break;
      }
      NSLog(@"change target size %@", @(self.targetSize));
    }
      break;
    case 2:
      break;
    case 3:
    {
      NSString *orientationStr = [NSString stringWithUTF8String:[data bytes]];
      int orient = [orientationStr intValue];
      switch (orient) {
        case 0:
          self.orientation = NTESVideoPackOrientationPortrait;
          break;
        case 1:
          self.orientation = NTESVideoPackOrientationLandscapeLeft;
          break;
        case 2:
          self.orientation = NTESVideoPackOrientationPortraitUpsideDown;
          break;
        case 3:
          self.orientation = NTESVideoPackOrientationLandscapeRight;
          break;
        default:
          break;
      };
      NSLog(@"change orientation %@", @(self.orientation));
      
    }
      break;
    default:
      break;
  }
}



#pragma mark - Process
- (void)sendVideoBufferToHostApp:(CMSampleBufferRef)sampleBuffer {
  if (!self.socket)
  {
    return;
  }
  CFRetain(sampleBuffer);
  
  dispatch_async(self.videoQueue, ^{ // queue optimal
    @autoreleasepool {
      if (self.frameCount > 1000)
      {
        CFRelease(sampleBuffer);
        return;
      }
      self.frameCount ++ ;
      CVPixelBufferRef pixelBuffer = CMSampleBufferGetImageBuffer(sampleBuffer);
      
      CFStringRef RPVideoSampleOrientationKeyRef = (__bridge CFStringRef)RPVideoSampleOrientationKey;
      NSNumber *orientation = (NSNumber *)CMGetAttachment(sampleBuffer, RPVideoSampleOrientationKeyRef,NULL);
      
       switch ([orientation integerValue]) {
         case 1:
           self.orientation = NTESVideoPackOrientationPortrait;
            break;
         case 6:
           self.orientation = NTESVideoPackOrientationLandscapeRight;
           break;
           
         case 8:
           self.orientation = NTESVideoPackOrientationLandscapeLeft;
           break;
         default:
           break;
       }
      // To data
      NTESI420Frame *videoFrame = nil;
      videoFrame = [NTESYUVConverter pixelBufferToI420:pixelBuffer
                                              withCrop:self.cropRate
                                            targetSize:self.targetSize
                                        andOrientation:self.orientation];
      CFRelease(sampleBuffer);
      // To Host App
      if (videoFrame){
          NSData *raw = [videoFrame bytes];
          //NSData *data = [NTESSocketPacket packetWithBuffer:raw];
          NSData *headerData = [NTESSocketPacket packetWithBuffer:raw];
          if (!_enterBack) {
            if (self.connected) {
              [self.socket writeData:headerData withTimeout:-1 tag:0];
              [self.socket writeData:raw withTimeout:-1 tag:0];
            }
          }
      }
      self.frameCount --;
    };
  });
}

- (NSData *)packetWithBuffer:(NSData *)rawData
{
  NSMutableData *mutableData = [NSMutableData data];
  @autoreleasepool {
    if (rawData.length == 0)
    {
      return NULL;
    }
    
    size_t size = rawData.length;
    void *data = malloc(sizeof(NTESPacketHead));
    NTESPacketHead *head = (NTESPacketHead *)malloc(sizeof(NTESPacketHead));
    head->version = 1;
    head->command_id = 0;
    head->service_id = 0;
    head->serial_id = 0;
    head->data_len = (uint32_t)size;
    
    size_t headSize = sizeof(NTESPacketHead);
    memcpy(data, head, headSize);
    NSData *headData = [NSData dataWithBytes:data length:headSize];
    [mutableData appendData:headData];
    [mutableData appendData:rawData];
    
    free(data);
    free(head);
  }
  return [mutableData copy];
}

- (NSData *)packetWithBuffer:(const void *)buffer
                        size:(size_t)size
                  packetSize:(size_t *)packetSize
{
  if (0 == size)
  {
    return NULL;
  }
  
  void *data = malloc(sizeof(NTESPacketHead) + size);
  NTESPacketHead *head = (NTESPacketHead *)malloc(sizeof(NTESPacketHead));
  head->version = 1;
  head->command_id = 0;
  head->service_id = 0;
  head->serial_id = 0;
  head->data_len = (uint32_t)size;
  
  size_t headSize = sizeof(NTESPacketHead);
  *packetSize = size + headSize;
  memcpy(data, head, headSize);
  memcpy(data + headSize, buffer, size);
  
  
  NSData *result = [NSData dataWithBytes:data length:*packetSize];
  
  free(head);
  free(data);
  return result;
}

#pragma mark - Socket

- (void)setupSocket
{
  _recvBuffer = (NTESTPCircularBuffer *)malloc(sizeof(NTESTPCircularBuffer)); // 需要释放
  NTESTPCircularBufferInit(_recvBuffer, kRecvBufferMaxSize);
  self.queue = dispatch_queue_create("com.netease.edu.rp.client", DISPATCH_QUEUE_SERIAL);
  self.socket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:self.queue];
  //    self.socket.IPv6Enabled = NO;
  //    [self.socket connectToUrl:[NSURL fileURLWithPath:serverURL] withTimeout:5 error:nil];
  NSError *error;
  [self.socket connectToHost:_ip onPort:8999 error:&error];
  [self.socket readDataWithTimeout:-1 tag:0];
  NSLog(@"setupSocket:%@",error);
  if (error == nil)
  {
    NSLog(@"====开启成功");
  }
  else
  {
    NSLog(@"=====开启失败");
  }
}

- (void)socket:(GCDAsyncSocket *)sock didConnectToUrl:(NSURL *)url
{
  [self.socket readDataWithTimeout:-1 tag:0];
}

- (void)socket:(GCDAsyncSocket *)sock didConnectToHost:(NSString *)host port:(uint16_t)port
{
  if (self.connected) {
    NSString * str =@"Start";
    NSData *data =[str dataUsingEncoding:NSUTF8StringEncoding];
    [self.socket writeData:data withTimeout:15 tag:0];
  }
  [self.socket readDataWithTimeout:-1 tag:0];
  self.connected = YES;
}

- (void)socket:(GCDAsyncSocket *)sock didWriteDataWithTag:(long)tag
{
  
}

- (void)socket:(GCDAsyncSocket *)sock didReadData:(NSData *)data withTag:(long)tag
{
  NTESTPCircularBufferProduceBytes(self.recvBuffer, data.bytes, (int32_t)data.length);
  [self handleRecvBuffer];
  [sock readDataWithTimeout:-1 tag:0];
}

- (void)socketDidDisconnect:(GCDAsyncSocket *)sock withError:(NSError *)err
{
  self.connected = NO;
  [self.socket disconnect];
  self.socket = nil;
  [self setupSocket];
  [self.socket readDataWithTimeout:-1 tag:0];
}

- (void)handleRecvBuffer {
  if (!self.socket)
  {
    return;
  }
  
  int32_t availableBytes = 0;
  void * buffer = NTESTPCircularBufferTail(self.recvBuffer, &availableBytes);
  int32_t headSize = sizeof(NTESPacketHead);
  
  if (availableBytes <= headSize)
  {
    return;
  }
  
  NTESPacketHead head;
  memset(&head, 0, sizeof(head));
  memcpy(&head, buffer, headSize);
  uint64_t dataLen = head.data_len;
  
  if(dataLen > availableBytes - headSize && dataLen >0) {
    return;
  }
  
  void *data = malloc(dataLen);
  memset(data, 0, dataLen);
  memcpy(data, buffer + headSize, dataLen);
  NTESTPCircularBufferConsume(self.recvBuffer, (int32_t)(headSize+dataLen));
  
  
  if([self respondsToSelector:@selector(onRecvData:head:)]) {
    @autoreleasepool {
      [self onRecvData:[NSData dataWithBytes:data length:dataLen] head:&head];
    };
  }
  
  free(data);
  
  if (availableBytes - headSize - dataLen >= headSize)
  {
    [self handleRecvBuffer];
  }
}
@end
      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19
      • 20
      • 21
      • 22
      • 23
      • 24
      • 25
      • 26
      • 27
      • 28
      • 29
      • 30
      • 31
      • 32
      • 33
      • 34
      • 35
      • 36
      • 37
      • 38
      • 39
      • 40
      • 41
      • 42
      • 43
      • 44
      • 45
      • 46
      • 47
      • 48
      • 49
      • 50
      • 51
      • 52
      • 53
      • 54
      • 55
      • 56
      • 57
      • 58
      • 59
      • 60
      • 61
      • 62
      • 63
      • 64
      • 65
      • 66
      • 67
      • 68
      • 69
      • 70
      • 71
      • 72
      • 73
      • 74
      • 75
      • 76
      • 77
      • 78
      • 79
      • 80
      • 81
      • 82
      • 83
      • 84
      • 85
      • 86
      • 87
      • 88
      • 89
      • 90
      • 91
      • 92
      • 93
      • 94
      • 95
      • 96
      • 97
      • 98
      • 99
      • 100
      • 101
      • 102
      • 103
      • 104
      • 105
      • 106
      • 107
      • 108
      • 109
      • 110
      • 111
      • 112
      • 113
      • 114
      • 115
      • 116
      • 117
      • 118
      • 119
      • 120
      • 121
      • 122
      • 123
      • 124
      • 125
      • 126
      • 127
      • 128
      • 129
      • 130
      • 131
      • 132
      • 133
      • 134
      • 135
      • 136
      • 137
      • 138
      • 139
      • 140
      • 141
      • 142
      • 143
      • 144
      • 145
      • 146
      • 147
      • 148
      • 149
      • 150
      • 151
      • 152
      • 153
      • 154
      • 155
      • 156
      • 157
      • 158
      • 159
      • 160
      • 161
      • 162
      • 163
      • 164
      • 165
      • 166
      • 167
      • 168
      • 169
      • 170
      • 171
      • 172
      • 173
      • 174
      • 175
      • 176
      • 177
      • 178
      • 179
      • 180
      • 181
      • 182
      • 183
      • 184
      • 185
      • 186
      • 187
      • 188
      • 189
      • 190
      • 191
      • 192
      • 193
      • 194
      • 195
      • 196
      • 197
      • 198
      • 199
      • 200
      • 201
      • 202
      • 203
      • 204
      • 205
      • 206
      • 207
      • 208
      • 209
      • 210
      • 211
      • 212
      • 213
      • 214
      • 215
      • 216
      • 217
      • 218
      • 219
      • 220
      • 221
      • 222
      • 223
      • 224
      • 225
      • 226
      • 227
      • 228
      • 229
      • 230
      • 231
      • 232
      • 233
      • 234
      • 235
      • 236
      • 237
      • 238
      • 239
      • 240
      • 241
      • 242
      • 243
      • 244
      • 245
      • 246
      • 247
      • 248
      • 249
      • 250
      • 251
      • 252
      • 253
      • 254
      • 255
      • 256
      • 257
      • 258
      • 259
      • 260
      • 261
      • 262
      • 263
      • 264
      • 265
      • 266
      • 267
      • 268
      • 269
      • 270
      • 271
      • 272
      • 273
      • 274
      • 275
      • 276
      • 277
      • 278
      • 279
      • 280
      • 281
      • 282
      • 283
      • 284
      • 285
      • 286
      • 287
      • 288
      • 289
      • 290
      • 291
      • 292
      • 293
      • 294
      • 295
      • 296
      • 297
      • 298
      • 299
      • 300
      • 301
      • 302
      • 303
      • 304
      • 305
      • 306
      • 307
      • 308
      • 309
      • 310
      • 311
      • 312
      • 313
      • 314
      • 315
      • 316
      • 317
      • 318
      • 319
      • 320
      • 321
      • 322
      • 323
      • 324
      • 325
      • 326
      • 327
      • 328
      • 329
      • 330
      • 331
      • 332
      • 333
      • 334
      • 335
      • 336
      • 337
      • 338
      • 339
      • 340
      • 341
      • 342
      • 343
      • 344
      • 345
      • 346
      • 347
      • 348
      • 349
      • 350
      • 351
      • 352
      • 353
      • 354
      • 355
      • 356
      • 357
      • 358
      • 359
      • 360
      • 361
      • 362
      • 363
      • 364
      • 365
      • 366
      • 367
      • 368
      • 369
      • 370
      • 371
      • 372
      • 373
      • 374
      • 375
      • 376
      • 377
      • 378
      • 379
      • 380
      • 381
      • 382
      • 383
      • 384
      • 385
      • 386
      • 387
      • 388
      • 389
      • 390
      • 391
      • 392
      • 393
      • 394
      • 395
      • 396
      • 397
      • 398
      • 399
      • 400
      • 401
      • 402
      • 403
      • 404
      • 405
      • 406
      • 407
      • 408
      • 409
      • 410
      • 411
      • 412
      • 413
      • 414
      • 415
      • 416
      • 417
      • 418
      • 419
      • 420
      • 421
      • 422
      • 423
      • 424
      • 425
      • 426
      • 427
      • 428
      • 429
      • 430
      • 431
      • 432
      • 433
      • 434
      • 435
      • 436
      • 437
      • 438
      • 439
      • 440
      • 441
      • 442
      • 443
      • 444
      • 445
      • 446
      • 447
      • 448
      • 449
      • 450
      • 451
      • 452
      • 453
      • 454
      • 455
      • 456
      • 457
      • 458
      • 459
      • 460
      • 461
      • 462
      • 463
      • 464
      • 465
      • 466
      • 467
      • 468
      • 469
      • 470
      • 471
      • 472
      • 473
      • 474
      • 475
      • 476
      • 477
      • 478
      • 479
      • 480
      • 481

      在接收处理的类中，写下如下代码

      - (void)setupSocket
{
  
  self.sockets = [NSMutableArray array];
  self.recvBuffer = (NTESTPCircularBuffer *)malloc(sizeof(NTESTPCircularBuffer)); // 需要释放
  NTESTPCircularBufferInit(self.recvBuffer, kRecvBufferMaxSize);
  //    self.queue = dispatch_queue_create("com.netease.edu.rp.server", DISPATCH_QUEUE_SERIAL);
  self.queue = dispatch_get_main_queue();
  self.socket = [[GCDAsyncSocket alloc] initWithDelegate:self delegateQueue:self.queue];
  self.socket.IPv6Enabled = NO;
  NSError *error;
  //    [self.socket acceptOnUrl:[NSURL fileURLWithPath:serverURL] error:&error];
  [self.socket acceptOnPort:8999 error:&error];
  [self.socket readDataWithTimeout:-1 tag:0];
  if (error == nil)
  {
    NSLog(@"开启成功");
     [[NSRunLoop mainRunLoop]run];//目的让服务器不停止
    [self setTimer];
  }
  else
  {
    NSLog(@"开启失败");
    [self setupSocket];
    
  }


- (void)defaultsChanged:(NSNotification *)notification
{
  GCDAsyncSocket *socket = self.sockets.count ? self.sockets[0] : nil;
  
  NSUserDefaults *defaults = (NSUserDefaults*)[notification object];
  id setting = nil;
  // 分辨率
  static NSInteger quality;
  setting = [defaults objectForKey:@"videochat_preferred_video_quality"];
  if (quality != [setting integerValue] && setting)
  {
    quality = [setting integerValue];
    NTESPacketHead head;
    head.service_id = 0;
    head.command_id = 1; // 1：分辨率 2：裁剪比例 3：视频方向
    head.data_len = 0;
    head.version = 0;
    NSString *str = [NSString stringWithFormat:@"%d", [setting intValue]];
    [socket writeData:[NTESSocketPacket packetWithBuffer:[str dataUsingEncoding:NSUTF8StringEncoding] head:&head] withTimeout:-1 tag:0];
  }
  
  // 视频方向
  static NSInteger orientation;
  setting = [defaults objectForKey:@"videochat_preferred_video_orientation"];
  if (orientation != [setting integerValue] && setting)
  {
    orientation = [setting integerValue];
    self.rotation = orientation;
    NTESPacketHead head;
    head.service_id = 0;
    head.command_id = 3; // 1：分辨率 2：裁剪比例 3：视频方向
    head.data_len = 0;
    head.version = 0;
    head.serial_id = 0;
    NSString *str = [NSString stringWithFormat:@"%@", setting];
    [socket writeData:[NTESSocketPacket packetWithBuffer:[str dataUsingEncoding:NSUTF8StringEncoding] head:&head] withTimeout:-1 tag:0];
    
  }
}

- (void)stopSocket
{
  if (self.socket)
  {
    [self.socket disconnect];
    self.socket = nil;
    [self.sockets removeAllObjects];
    NTESTPCircularBufferCleanup(self.recvBuffer);
  }
  [[NSNotificationCenter defaultCenter] removeObserver:self name:NSUserDefaultsDidChangeNotification object:nil];
  
}

      • 1
      • 2
      • 3
      • 4
      • 5
      • 6
      • 7
      • 8
      • 9
      • 10
      • 11
      • 12
      • 13
      • 14
      • 15
      • 16
      • 17
      • 18
      • 19
      • 20
      • 21
      • 22
      • 23
      • 24
      • 25
      • 26
      • 27
      • 28
      • 29
      • 30
      • 31
      • 32
      • 33
      • 34
      • 35
      • 36
      • 37
      • 38
      • 39
      • 40
      • 41
      • 42
      • 43
      • 44
      • 45
      • 46
      • 47
      • 48
      • 49
      • 50
      • 51
      • 52
      • 53
      • 54
      • 55
      • 56
      • 57
      • 58
      • 59
      • 60
      • 61
      • 62
      • 63
      • 64
      • 65
      • 66
      • 67
      • 68
      • 69
      • 70
      • 71
      • 72
      • 73
      • 74
      • 75
      • 76
      • 77
      • 78
      • 79
      • 80
      本文内容由网友自发贡献，转载请注明出处：https://www.wpsshop.cn/w/小丑西瓜9/article/detail/260736
      推荐阅读
      相关标签

      Copyright © 2003-2013 www.wpsshop.cn 版权所有，并保留所有权利。

        

      闽ICP备14008679号