- (void)startSocket:(NSString *)address andPort:(int)port{    CFReadStreamRef readRef;    CFWriteStreamRef writeRef;        CFStreamCreatePairWithSocketToHost(NULL, (__bridge CFStringRef)address, port, &readRef, &writeRef);        _inputStream = (__bridge NSInputStream *)readRef;    _outputStream = (__bridge NSOutputStream *)writeRef;        // 设置流属性    [_inputStream setProperty:NSStreamNetworkServiceTypeVoIP forKey:NSStreamNetworkServiceType];    [_outputStream setProperty:NSStreamNetworkServiceTypeVoIP forKey:NSStreamNetworkServiceType];        // 设置代理    _inputStream.delegate = self;    _outputStream.delegate = self;        // 放到runloop中    [_inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];    [_outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];        [_inputStream open];    [_outputStream open];}// 断开 scoket 连接- (void)closeSocket {    if(_inputStream){        _inputStream.delegate = nil;        [_inputStream close];        [_inputStream removeFromRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];        _inputStream = nil;    }    if(_outputStream){        _outputStream.delegate = nil;        [_outputStream close];        [_outputStream removeFromRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];        _outputStream = nil;        [SVProgressHUD showSuccessWithStatus:@"断开连接成功"];    }    // 通知给界面    [[NSNotificationCenter defaultCenter] postNotificationName:@"closeSocket" object:nil userInfo:nil];}// 代理的回调是在主线程#pragma mark - <NSStreamDelegate>代理方法- (void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode{    switch (eventCode) {        case NSStreamEventNone:            break;        case NSStreamEventOpenCompleted:            [SVProgressHUD showSuccessWithStatus:@"连接成功"];            NSLog(@"成功建立连接, 形成输入输出管道");            break;        case NSStreamEventHasBytesAvailable:            NSLog(@"有数据可读");        {            uint8_t buf[3072];            NSInteger len = 0;            NSInputStream *inputStream = (NSInputStream *)aStream;            len = [inputStream read:buf maxLength:3072];                        if (len) {                _tempString = [NSMutableString string];                // 将16进制字符拼接起来                for (int i = 0; i < len; i++) {                    NSMutableString *str = [NSMutableString stringWithFormat:@"%x", buf[i]];                    if (str.length < 2) {                        [str insertString:@"0" atIndex:0];                    }                    [_tempString appendString:str];                }                // 进行分包丶 粘包处理, 同时进行KVO监听可用的包                                    [_stick_Subcontract_Package HandleResultOnReceiveData:_tempString];                           }            break;        }        case NSStreamEventHasSpaceAvailable:            NSLog(@"可以发送数据");            break;        case NSStreamEventErrorOccurred:            NSLog(@"有错误发生, 连接失败");            [SVProgressHUD showErrorWithStatus:@"连接错误"];        {            [aStream close];            break;        }        case NSStreamEventEndEncountered:            [SVProgressHUD showErrorWithStatus:@"正常断开连接"];            NSLog(@"正常断开连接");                    {            [aStream close];            [aStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];            aStream = nil;            break;        }                    default:            break;    }}