【发布时间】:2016-07-19 16:11:24
【问题描述】:
我有一个程序在经过一些初始处理后通过 NSStreams 发送大文件。申请流程是这样的:
1) 两个设备相互连接,打开它们的输入和输出流,并安排它们的运行循环:
[self.inputStream setDelegate:self];
[self.outputStream setDelegate:self];
[self.inputStream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
[self.outputStream scheduleInRunLoop:[NSRunLoop mainRunLoop] forMode:NSDefaultRunLoopMode];
[self.inputStream open];
[self.outputStream open];
2) 服务器设备向客户端发送一条消息,表明一切顺利,我们都准备好了。客户端收到这个消息就好了。
3) 客户端然后选择它想要发送到服务器的文件列表并点击“发送”。然后客户端启动一个后台线程来抓取一堆文件并将它们全部压缩。这可能需要一分钟左右的时间。
- (void) sendFilesAtPaths: (NSArray *) paths
{
self.paths = [paths copy];
__weak FileSharingClient *weakSelf = self;
dispatch_async(dispatch_get_global_queue(DISPATCH_QUEUE_PRIORITY_DEFAULT, 0), ^{
for(Item *item in weakSelf.paths)
{
//Zip files up, this can take some time but we're on a background thread so it won't lock up the UI
[weakSelf.connection zipFilesAssociatedWithItem:item];
}
//Now that we've done all the heavy work, bounce back to the main thread to actually start sending the data
dispatch_async(dispatch_get_main_queue(), ^{
//Start by sending only the first file, the server will let us know when they are ready for the next one
[weakSelf.connection sendFileWithItem:weakSelf.paths.firstObject];
});
});
}
4) 对“sendFileWithItem:”的调用通过以下调用传递第一个信息突发:
if([_outputStream hasSpaceAvailable])
{
NSInteger written = [self.outputStream write:buffer maxLength:self.outputHeaderSize];
}
以下所有数据都是通过调用- (void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)streamEvent发送数据来传输的
问题
我在这里看到的问题是,如果压缩这些文件的后台线程需要更长的时间,写入数据的初始调用确实表明字节已写入流,但我从未收到任何调用进入- (void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)streamEvent。服务器从不接收信息。大约 30 秒后,写入命令(我假设?)超时,客户端收到一个空字符串(不是我从服务器显式发送的),客户端的连接关闭。
如果我发送一个压缩时间不长的文件,我看不到这个问题。
在主线程上运行所有内容 - 包括压缩过程 - 并不能解决问题(即使忽略它锁定 UI 的事实)。这似乎可以排除线程是一个问题,但这是我现在要做的全部。
我完全没有想法,希望有人能帮助我。
注意:鉴于此建议,我无法使用 CocoaAsyncSockets 库。
【问题讨论】:
标签: ios cocoa-touch nsstream nsinputstream nsoutputstream