NSStreamDelegate 读取异步数据

Question

好的。因此，对于 NSStreamDelegate 实现，我必须处理一个例外情况。

流程如下：

1-一个COMMAND数据写入输出流触发另一端

2- 另一端，开始为输入流放入数据但异步，这意味着数据的第一部分在开始时被接收，然后几秒钟后，其余数据进入。

3- 收到所有数据后，服务器不会发送任何数据，但连接保持打开状态。 （输入流状态=打开（2））

4- 几分钟后，服务器结束连接（输入流状态 = 5）并触发 NSStreamEventEndEncountered。

SendRequest 类

- (void)sendSecondRequest {
    CFReadStreamRef readStream = nil;
    CFWriteStreamRef writeStream = nil;
    CFStreamCreatePairWithSocketToHost(NULL, (__bridge CFStringRef)self.SOMEServer, self.SOMEPort, &readStream, &writeStream);
    self.inputStream = (__bridge NSInputStream *)readStream;
    self.outputStream = (__bridge NSOutputStream *)writeStream;
    [self.inputStream setDelegate:self];
    [self.outputStream setDelegate:self];
    NSData *data = [NSData dataWithData:[kSecondCall dataUsingEncoding:NSASCIIStringEncoding]];
    [self.inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
    [self.outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
    [self.inputStream open];
    [self.outputStream open];
    [self.outputStream write:[data bytes] maxLength:[data length]];
}

- (void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode {
    switch (eventCode) {
        case NSStreamEventOpenCompleted:
            break;
        case NSStreamEventHasBytesAvailable:
            if (aStream == self.inputStream) {
                uint8_t buffer[1024];
                NSInteger len = [self.inputStream read:buffer maxLength:sizeof(buffer)];
                if (len > 0) {
                    NSString *output = [[NSString alloc] initWithBytes:buffer length:len encoding:NSASCIIStringEncoding];
                    [gOutput appendString:output];
                }
            }
            break;
        case NSStreamEventEndEncountered:
            NSLog(@"Can not connect to the host");
            [aStream close];
            [aStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
            aStream = nil;
            break;
        default:
            break;
    }
}

- (void)disconnectSocket {
    [self.inputStream close];
    [self.inputStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
    [self.outputStream close];
    [self.outputStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
    [self.inputStream setDelegate:nil];
    [self.outputStream setDelegate:nil];
    self.inputStream = nil;
    self.outputStream = nil;
}

gOutput 变量是我用来读取和存储输入流的全局变量。

问题是，由于数据的第一部分立即到来，然后其余部分异步进入，我无法处理没有更多可用数据的时刻。

换句话说，我如何知道服务器是否已完成发送数据，我应该开始处理它？

Answer 1

服务器在最后发送一个终止序列。当客户端检测到这个终止符时，它开始处理......