0

我有一个程序在一些初始处理后通过 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 库。

4

1 回答 1

0

万一有人偶然发现了这个并且碰巧看到了我看到的同样的东西（并认为同样的事情是问题所在）：

问题不在于线程导致问题 - 只是写那篇文章让我意识到我是多么荒谬。问题似乎是底层 TCP 套接字在等待这么长时间接收数据后超时。我通过每秒发送一次心跳消息解决了这个问题，这使套接字保持活动状态，直到我准备好实际开始发送数据。

于 2016-07-20T17:10:32.957 回答