Stream Obtenir des Données - NSInputStream

Tous,

J'ai un serveur qui a un socket tcp stream pour la communication. J'ai besoin d'obtenir à ce flux et de lire les données initiales qu'il doit m'envoyer.

Mon code est comme suit. Pour être honnête, je vais à présent complètement aveugle. Je ne sais pas si cela est correct sans parler de la bonne chose pour l'emploi.

-(void) initNetworkCommunication
{
    //input stream
    NSInputStream *iStream;
    NSURL *url = [url initWithString:@"192.168.17.1:2004"];

    [iStream initWithURL:url];
    [iStream setDelegate:self];
    [iStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
    [iStream open];

}

Donc, à partir de la façon dont je le vois, ce code initialise le flux, mais comment puis-je lire le stream?

Grâce

Le codeblock ne semble pas bien attribuer les NSInputStream objet (c'est à dire il y a un init mais pas alloc).

InformationsquelleAutor Baub | 2011-07-13

23

Il y a deux façons d'obtenir des données à partir d'un flux: l'interrogation et à l'aide de flux d'événements.

Interrogation est plus simple, mais va bloquer le thread qu'il est en cours d'exécution. Si vous utilisez cette méthode, vous n'avez pas besoin d'effectuer la setDelegate: ou scheduleInRunLoop:forMode: appels. Bureau de vote est effectué à plusieurs reprises d'appeler read:maxLength:.
```
NSInteger result;
uint8_t buffer[BUFFER_LEN]; //BUFFER_LEN can be any positive integer
while((result = [iStream read:buffer maxLength:BUFFER_LEN]) != 0) {
    if(result > 0) {
        //buffer contains result bytes of data to be handled
    } else {
        //The stream had an error. You can get an NSError object using [iStream streamError]
    }
}
//Either the stream ran out of data or there was an error
```
À l'aide de flux d'événements nécessite la définition d'un délégué et d'ajouter le flux à une course en boucle. Au lieu de bloquer le thread, le flux envoyer un stream:handleEvent: message à son délégué lorsque certains événements se produisent, y compris lorsqu'il reçoit des données. Le délégué peut ensuite récupérer les données dans le flux. Voici un exemple stream:handleEvent: méthode:
```
- (void)stream:(NSInputStream *)iStream handleEvent:(NSStreamEvent)event {
    BOOL shouldClose = NO;
    switch(event) {
        case  NSStreamEventEndEncountered:
            shouldClose = YES;
            //If all data hasn't been read, fall through to the "has bytes" event
            if(![iStream hasBytesAvailable]) break;
        case NSStreamEventHasBytesAvailable: ; //We need a semicolon here before we can declare local variables
            uint8_t *buffer;
            NSUInteger length;
            BOOL freeBuffer = NO;
            //The stream has data. Try to get its internal buffer instead of creating one
            if(![iStream getBuffer:&buffer length:&length]) {
                //The stream couldn't provide its internal buffer. We have to make one ourselves
                buffer = malloc(BUFFER_LEN * sizeof(uint8_t));
                freeBuffer = YES;
                NSInteger result = [iStream read:buffer maxLength:BUFFER_LEN];
                if(result < 0) {
                    //error copying to buffer
                    break;
                }
                length = result;
            }
            //length bytes of data in buffer
            if(freeBuffer) free(buffer);
            break;
        case NSStreamEventErrorOccurred:
            //some other error
            shouldClose = YES;
            break;
    }
    if(shouldClose) [iStream close];
}
```
- C'est un précieux résumé de la réponse pour nous les débutants, et il vaut la peine d'édition: Comme il est aujourd'hui, avec l'appel à NSInputStream de read:maxLength: à l'intérieur la si-stmt, vous n'aurez plus jamais rien lu de si vous réussissez à obtenir le flux de la mémoire tampon interne. Mais je ne suis pas assez solide sur le sujet pour le modifier moi-pouvez-vous le corriger, s'il vous plaît?
- P. S. je me demande pourquoi NSOutputStream n'a pas d'équivalent getBuffer méthode?
- Dans cet exemple, l'appel à read:maxLength: consiste à copier les données dans une mémoire tampon temporaire créé à l'intérieur de l'instruction if. Vous avez seulement besoin de faire cela si vous n'en avez pas déjà un tampon avec les données qu'il contient. Immédiatement après l'instruction if, vous devez ajouter le code pour faire quelque chose avec les données dans la mémoire tampon, parce que la mémoire tampon n'est que temporaire. NSOutputStream n'a probablement pas fournir l'accès à une mémoire tampon interne car elle ne permet pas l'accès aux données que vous avez déjà écrit, et si vous avez écrit directement dans la mémoire tampon, il n'aurait aucun moyen de savoir qu'il doit envoyer les données.
- Merci, je comprends maintenant. (Je pensais à la mémoire tampon interne était juste un autre vide titulaire, et que vous avez toujours besoin d'appeler read:maxlength à mettre les données en elle.)
- Ne devriez-vous pas aussi appel removeFromRunLoop en outre à close dans le if (shouldClose) bloc?
- Il pourrait être une bonne pratique, mais n'est pas nécessaire. La fermeture du flux implicitement retire de la course de la boucle si nécessaire.
InformationsquelleAutor ughoavgfhw

Je suis venu avec ce, sur la base d'autres réponses.

public enum StreamError: Error {
    case Error(error: Error?, partialData: [UInt8])
}

extension InputStream {

    public func readData(bufferSize: Int = 1024) throws -> Data {
        var buffer = [UInt8](repeating: 0, count: bufferSize)
        var data: [UInt8] = []

        open()

        while true {
            let count = read(&buffer, maxLength: buffer.capacity)

            guard count >= 0 else {
                close()
                throw StreamError.Error(error: streamError, partialData: data)
            }

            guard count != 0 else {
                close()
                return Data(bytes: data)
            }

            data.append(contentsOf: (buffer.prefix(count)))
        }

    }
}

InformationsquelleAutor Mark Bridges

Vous devez vous connecter pour publier un commentaire.