iOS：NSOperationQueue：辅助队列

Question

我想以异步方式接收一些数据到服务器，并避免App UI performance 过载。因此希望将任务发送到辅助队列而不是主队列。

这是我目前使用 “主队列” 的解决方案（我理解 [NSOperationQueue mainQueue] 会降低性能）：

-(NSDictionary*) fetchURL:(NSString*)url
{
    NSURLRequest *request = [[NSURLRequest alloc] initWithURL:[NSURL URLWithString:kCONTACTSINFOURL]];

    __block BOOL hasError = FALSE;
    __block NSDictionary *json;

    [NSURLConnection sendAsynchronousRequest:request
                                       queue:[NSOperationQueue mainQueue] 
                           completionHandler:^(NSURLResponse *response, NSData *data, NSError *connectionError)
                           {
                               //Verify type of connection error

                               json = [NSJSONSerialization JSONObjectWithData:data
                                                                      options:0
                                                                        error:nil];
                               NSLog(@"Async JSON: %@", json);



                           }];

    if (hasError) {
        [[NSOperationQueue mainQueue] suspend];
        return nil;
    }
    return json;
}

为了使用二级队列，避免UI和App性能超载，可以分配一个共享的NSOperationQueue并引用它吗？或者还有其他一些“更好”的类或者实现这一点的方法？

这将是我使用辅助 NSOperationQueue 改进的解决方案：

创建辅助队列：

    NSOperationQueue* otherQueue = [NSOperationQueue init];

使用另一个（辅助）队列：

....
[NSURLConnection sendAsynchronousRequest:request
                                       queue:otherQueue
                           completionHandler:^(NSURLResponse *response, NSData *data, NSError *connectionError)
....

}

这是正确的吗？或者有没有其他方法可以解决这个问题？

Answer 1

... 继 cmets...

NSURLConnection 方法

[NSURLConnection sendAsynchronousRequest:queue:completionHandler:]

允许您指定在连接完成时将调用完成处理程序的队列。如果您暂停此队列，您将不会停止发送请求，您只会在完成后停止接收回调。您可能想考虑稍微不同地执行此操作...

NSOperation 很棒，但我更喜欢直接使用 GCD（NSOperation 只是顶部的一个很好的 obj-c 包装器），如果你很难使用 NSOperation，请告诉我，我会添加一些建议那个。

我假设您有某种管理器类来处理您的所有服务器通信？如果没有，我建议您这样做，并将其作为单例。

@ interface ChatManager : NSObject
    + (ChatManager *)sharedManager;
@end

@implementation ChatManager {
    dispatch_queue_t fetchQueue;
    dispatch_queue_t postQueue;
}
+ (ChatManager *)sharedManager {
    // This is just the standard apple pattern for creating a singleton
    static SCAddressBookManager *sharedManager = nil;
    static dispatch_once_t onceToken;
    dispatch_once(&onceToken, ^{
        sharedManager = [[SCAddressBookManager alloc] init];
    });
    return sharedManager;
}

- (id)init {
    self = [super init];
    if (self) {
        // Create a dispatch queue that will run requests one after another, you could make this concurrent but that may cause messages to be lost when you suspend
        fetchQueue = dispatch_queue_create("fetch_queue", DISPATCH_QUEUE_SERIAL);
        postQueue = dispatch_queue_create("post_queue", DISPATCH_QUEUE_SERIAL);
    }
}

- (NSDictionary *)fetchURL:(NSURL *)url {
    // In here we will dispatch to our queue and so that the 
    dispatch_async(fetchQueue, ^{
        NSURLRequest = // create your request
        NSURLResponse *response = nil;
        NSError *error = nil;
        NSData *data = [NSURLConnection sendSynchronousRequest:request returningResponse:&response error:&error];
        // Check for error
        if (error) dispatch_suspend(fetchQueue); // this suspends the queue that is making the calls to the server, so will stop attempting to send messages when you have an error - you should start pinging to see when you come back online here too, and then use dispatch_resume(fetchQueue) to get it going again!
        else {
            json = [NSJSONSerialization JSONObjectWithData:data options:0 error:nil];
            NSLog(@"Async JSON: %@", json);
            return json; // ??
        }
    });
}

- (NSDictionary *)postURL:(NSURL *)url data:(NSData *)bodyData {
    // In here we will dispatch to our queue and so that the 
    dispatch_async(postQueue, ^{
        /*
          Make your post request.
        */
        // Check for error
        if (error) dispatch_suspend(postQueue);
        else {
            json = [NSJSONSerialization JSONObjectWithData:data options:0 error:nil];
            NSLog(@"Async JSON: %@", json);
            return json; // ??
        }
    });
}

@end

您可能还需要使用

dispatch_sync(dispatch_get_main_queue(), ^{
    // Do stuff on the main thread here
};

如果您需要对主线程进行委托样式回调！

这是关于我将如何进行设置以尝试实现您的目标的基本想法...如果您觉得其中任何一个没有意义，请随时告诉我..？

作为旁注，我假设无论出于何种原因，您的服务器都需要一个简单的 http 接口。更好的方法是在应用程序和您的服务器之间打开一个持久套接字，然后您可以随意上下推送数据。带有心跳的套接字也会让您知道您的连接何时断开。不确定您是否希望我进一步详细说明此选项...