我在网上搜索了很长时间...我没有找到问题的答案,所以我决定在这里发布。我尝试使用 NSStream 建立与 NNTP 服务器的连接。
在测试程序中,我打开流并发送消息。委托方法(stream:handleEvent:
)对于输出流(NSStreamEventOpenCompleted
,NSStreamEventHasSpaceAvailable
)被调用两次,但对于输入流从不调用!
为什么输入流从不调用委托?有什么想法吗?
基本上,代码如下所示:
初始化和打开流:
CFReadStreamRef tmpiStream;
CFWriteStreamRef tmpoStream;
CFStreamCreatePairWithSocketToHost(NULL, (__bridge CFStringRef)SERVER, PORT, &tmpiStream, &tmpoStream);
iStream = (__bridge NSInputStream *) tmpiStream;
oStream = (__bridge NSOutputStream *)tmpoStream;
[iStream setDelegate:self];
[oStream setDelegate:self];
[iStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[oStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[iStream open];
[oStream open];
发送消息:
NSData *data = [[NSData alloc] initWithData:[messageString dataUsingEncoding:NSASCIIStringEncoding]];
[oStream write:[data bytes] maxLength:[data length]];
接收消息:
-(void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode
{
NSLog(@"EventCode: %i", eventCode);
//switch-case-statement...(using constants - NSStreamEventOpenCompleted...)
}
包含该代码的类继承自 NSObject 并实现NSStreamDelegate
。(带 ARC 的 iOS5)
感谢任何帮助!
编辑:我刚刚在打开这样的流后尝试了"轮询" - 它正在工作:
while (![iStream hasBytesAvailable])
{}
uint8_t buffer[1024];
int len;
NSString *str = @"";
while ([iStream hasBytesAvailable])
{
len = [iStream read:buffer maxLength:sizeof(buffer)];
if (len > 0)
{
NSString *output = [[NSString alloc] initWithBytes:buffer length:len encoding:NSISOLatin1StringEncoding];
if (output != nil)
{
str = [str stringByAppendingString:output];
}
}
}
NSLog(@"Response: %@", str);
但是,可以肯定的是,我仍然需要一个更好的(异步)解决方案;)
我在这里找到了你的答案,我有同样的问题。 你的回答对我有用,但我认为这更好:
如何在 NSStream 中使用委托?
引用他的话:
运行循环运行的时间不够长,无法使委托方法运行 叫。
加:
[[NSRunLoop currentRunLoop] runUntilDate:[NSDate dateWithTimeIntervalSinceNow:2.0]];
打开流后。这仅在程序中是必需的 没有 GUI - 否则运行循环将为您旋转。
所以我看起来像这样:
[self.inputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
[self.inputStream open];
[[NSRunLoop currentRunLoop] runUntilDate:[NSDate dateWithTimeIntervalSinceNow:30.0]];
编辑:然后,当您拥有数据时,例如,当 NSStreamEventEndMet 发生在委托方法流:handleEvent 中时,我完成了所有数据,我把这个:
[theStream removeFromRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode];
CFRunLoopStop(CFRunLoopGetCurrent());
[theStream close];
这会在 30.0s 之前或您设置的长度之前关闭运行循环。 如果你的代码在NSStreamHasBytesAvailable中,你的答案是一样的。
这使我仍然可以使用委托方法并保持运行循环打开,直到下载完成,而无需一起跳过委托方法。
你是否让运行循环在默认模式下运行?
尝试检查输入流状态 ( -streamStatus
)。
控制台上是否记录了任何内容?
您声称为输出流调用了委托方法,但您的NSLog()
调用不会记录流。是否确定?
最后,这是无关的,但如果您打算将拥有的核心基础流对象的所有权转移到 ARC,则应使用 __bridge_transfer
强制转换。更好的是,使用 CFBridgingRelease()
因为它与函数名称中的 Create 有明显的对称性。除非有您没有显示CFRelease()
调用,否则现有代码会泄漏这些流。
我遇到了同样的问题,然后我意识到我不小心打电话
[iStream setDelegate:self]
在我创建iStream之前。