iOS Le client du serveur tcp NSStream ne peut pas communiquer

Question

J'ai un problème avec le développement d'un serveur/client tcp dans l'objectif c avec Bonjour.

Côté serveur, j'ouvre correctement les flux et j'utilise la fonction handleEvent pour envoyer et recevoir des données. Mais je ne sais pas quel est le bon moyen d'envoyer et de recevoir des données. J'ai lu cet excellent message: Correct way to send data through a socket with NSOutputStream J'utiliser un système mis en attente de paquets pour envoyer des données:

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

}

. Donc, fondamentalement, je viens d'envoyer séparément mes données sur de nombreux paquets. Mais je ne vois pas comment reconstruire les données du côté client. Et je pense que je n'ai pas correctement compris l'événement NSStreamEventHasBytesAvailable. Parce que ici j'envoie beaucoup de paquets mais cet évènement côté client n'est appelé qu'une seule fois. Et quand je reconstitue les données du tampon les données semblent être corrompues. J'apprécierais vraiment si quelqu'un peut clarifier tout cela, la documentation n'est pas vraiment claire sur ce point (ou peut-être que je manque un point ..).

 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

Il semble que vous utilisez deux variables currentDataOffset - une variable d'instance et une propriété - pour le même but. Si vous avez besoin des deux, vous devez également définir 0 sur currentDataOffset. Mais je pense que le fragment devrait ressembler à:

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