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

Server在末尾发送一个终止符序列。当客户端检测到此终止符时，它开始处理。。。。