Klient serwera tcp NSOS iS NSStream nie może komunikować się

Question

Mam problem z rozwojem serwera/klienta TCP w celu c z Bonjour.

Po stronie serwera poprawnie otwieram strumienie i używam funkcji handleEvent do wysyłania i odbierania danych. Ale nie wiem, jaki jest właściwy sposób wysyłania i odbierania danych. Czytałem ten doskonały wpis: Correct way to send data through a socket with NSOutputStream więc korzystać z systemu pakietów w kolejce do wysyłania danych:

switch(eventCode) { 

    case NSStreamEventOpenCompleted: { 
     NSLog(@"Complete"); 

    } break; 

    case NSStreamEventHasSpaceAvailable: { 
     if (stream == _outputStream) 
      [self _sendData]; 
    } break; 

...

- (void)_sendData { 
flag_canSendDirectly = NO; 
NSData *data = [_dataWriteQueue lastObject]; 
if (data == nil) { 
    flag_canSendDirectly = YES; 
    return; 
} 
uint8_t *readBytes = (uint8_t *)[data bytes]; 
readBytes += currentDataOffset; 
NSUInteger dataLength = [data length]; 
NSUInteger lengthOfDataToWrite = (dataLength - currentDataOffset >= 1024) ? 1024 : (dataLength - currentDataOffset); 
NSInteger bytesWritten = [_outputStream write:readBytes maxLength:lengthOfDataToWrite]; 
currentDataOffset += bytesWritten; 
if (bytesWritten > 0) { 
    self.currentDataOffset += bytesWritten; 
    if (self.currentDataOffset == dataLength) { 
     [self.dataWriteQueue removeLastObject]; 
     self.currentDataOffset = 0; 
    } 
} 

}

. Więc po prostu wysyłam oddzielne moje dane na wiele pakietów. Ale nie widzę sposobu, aby zrekonstruować dane po stronie klienta. I myślę, że nie zrozumiałem poprawnie zdarzenia NSStreamEventHasBytesAvailable. Ponieważ tutaj wysyłam wiele pakietów, ale to zdarzenie po stronie klienta to wywołanie tylko raz. A kiedy odtwarzam dane z bufora, dane wydają się być uszkodzone. Byłbym bardzo wdzięczny, gdyby ktoś mógł to wszystko wyjaśnić, dokumentacja nie jest bardzo jasna w tym punkcie (a może brakuje mi punktu ...).

 case NSStreamEventHasBytesAvailable: { 
     if (stream == _inputStream) 
     { 
      //read data 
      uint8_t buffer[1024]; 
      int len; 
      while ([_inputStream hasBytesAvailable]) 
      { 
       len = [_inputStream read:buffer maxLength:sizeof(buffer)]; 
       if (len > 0) 
       { 
        NSString *output = [[NSString alloc] initWithBytes:buffer length:len encoding:NSUTF8StringEncoding]; 
        //NSData *theData = [[NSData alloc] initWithBytes:buffer length:len]; 
        UnitySendMessage("AppleBonjour_UnityNetworkManager(Clone)", "OnLocalClientReceiveMessageFromServer", [output cStringUsingEncoding:NSUTF8StringEncoding]); 
       } 
      } 
     } 

Answer 1

Wydaje się, że używasz dwóch zmiennych currentDataOffset - zmiennej instancji i majątkowe - w tym samym celu. Jeśli rzeczywiście potrzebujesz ich obu, powinieneś również ustawić 0 na currentDataOffset. Ale myślę, że fragment powinien wyglądać następująco:

readBytes += currentDataOffset; 
NSUInteger dataLength = [data length]; 
NSUInteger lengthOfDataToWrite = MIN(dataLength - currentDataOffset, 1024); 
NSInteger bytesWritten = [_outputStream write:readBytes maxLength:lengthOfDataToWrite]; 
if (bytesWritten > 0) { 
    currentDataOffset += bytesWritten; 
    if (currentDataOffset == dataLength) { 
     [self.dataWriteQueue removeLastObject]; 
     currentDataOffset = 0; 
    } 
}