使用事例
私はソケットを使用してデータを送受信し、複数のデータセット（つまり、1つのリクエストCFStreamCreatePairWithSocketToHost()だけでなく）を送信するときにこれがどのように行われるかについて頭を悩ませようとしています。
問題
現在、データを送信して応答を受信できます（つまり、1往復）。ただし、ストリーム内のすべてのデータを送信するとoutputStream、ストリームは閉じられます（つまり、受信しますNSStreamEventEndEncountered）。
質問
したがって、問題は、複数のデータ要求を送信したい場合はどうなるかということです。
- 送信する新しいデータオブジェクトがあるたびに新しいソケットを設定しますか？
- リセット
outputStreamしてさらにデータを送信する必要がありますか？
コード
このコードのほとんどは、CocoaStreamsのドキュメントからのものです。
- (void)viewDidLoad {
[super viewDidLoad];
// Do any additional setup after loading the view, typically from a nib.
_data = [[NSMutableData alloc] init];
[self initNetworkCommunication];
[self sendString:@"Hello World!"];
}
- (void)initNetworkCommunication {
CFReadStreamRef readStream;
CFWriteStreamRef writeStream;
CFStreamCreatePairWithSocketToHost(NULL, (CFStringRef)@"123.456.0.0", 1234, &readStream, &writeStream);
inputStream = (NSInputStream *)readStream; // ivar
[inputStream setDelegate:self];
[inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[inputStream open];
outputStream = (NSOutputStream *)writeStream; // ivar
[outputStream setDelegate:self];
[outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[outputStream open];
}
- (void)sendString:(NSString *)string {
NSData *data = [[NSData alloc] initWithData:[string dataUsingEncoding:NSASCIIStringEncoding]];
[_data appendData:data];
[data release];
}
- (void)stream:(NSStream *)theStream handleEvent:(NSStreamEvent)streamEvent {
NSLog(@"stream event %u", streamEvent);
switch (streamEvent) {
case NSStreamEventOpenCompleted:
NSLog(@"Stream opened");
break;
case NSStreamEventHasSpaceAvailable: {
uint8_t *readBytes = (uint8_t *)[_data mutableBytes];
readBytes += byteIndex; // ivar
int data_len = [_data length];
unsigned int len = ((data_len - byteIndex >= 1024) ? 1024 : (data_len - byteIndex));
uint8_t buf[len];
(void)memcpy(buf, readBytes, len);
len = [(NSOutputStream *)theStream write:(const uint8_t *)buf maxLength:len];
NSLog(@"Sending buffer of len: %d", len);
byteIndex += len;
break;
}
case NSStreamEventHasBytesAvailable:
if (theStream == inputStream) {
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:NSASCIIStringEncoding];
if (nil != output) {
NSLog(@"server said: %@", output);
}
}
}
[self sendString:@"Another Test"];
}
break;
case NSStreamEventErrorOccurred:
NSLog(@"Can not connect to the host!");
break;
case NSStreamEventEndEncountered:
NSLog(@"Closing stream...");
[theStream close];
[theStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[theStream release];
theStream = nil;
break;
default:
NSLog(@"Unknown event");
}
}
応答：
2012-08-15 08:16:30.896 Sockets[34836:f803] Opened input stream.
2012-08-15 08:16:30.898 Sockets[34836:f803] Opened output stream.
2012-08-15 08:16:30.899 Sockets[34836:f803] Sending buffer of len: 12
2012-08-15 08:16:30.900 Sockets[34836:f803] Sending buffer of len: 0
2012-08-15 08:16:30.901 Sockets[34836:f803] Closing output stream.
2012-08-15 08:16:30.939 Sockets[34836:f803] server said: Hello World!
データを送信した後、outputStreamストリームが閉じることに注意してください。outputStream前に再開してみ[self sendString:@"Another Test"];ます。idzの答えも試してみました。
ドキュメントによると、len：0の送信バッファが私の問題だと思います。
デリゲートがNSStreamEventHasSpaceAvailableイベントを受信し、ストリームに何も書き込まない場合、NSOutputStreamオブジェクトがさらにバイトを受信するまで、実行ループからそれ以上のスペース使用可能イベントを受信しません。これが発生すると、空き領域のイベントに対して実行ループが再開されます。
ただし、ドキュメントには、ストリームの終わりに達したときにストリームを閉じることについては何も記載されていません。だから私は混乱しています…</p>