AFNetworking同步操作在NSOperationQueue iPhone上

Question

我的应用程序以这种方式工作： - 创建相册和拍照 - 送他们我的服务器上 - 让图片分析后的答案/补充信息。

我有一些问题与发送部分。下面是代码

@interface SyncAgent : NSObject <SyncTaskDelegate> 

@property NSOperationQueue* _queue; 
-(void)launchTasks; 

@end 


@implementation SyncAgent 

@synthesize _queue; 

- (id)init 
{ 
    self = [super init]; 
    if (self) { 
     self._queue = [[NSOperationQueue alloc] init]; 
     [self._queue setMaxConcurrentOperationCount:1]; 
    } 
    return self; 
} 

-(void) launchTasks { 

    NSMutableArray *tasks = [DataBase getPendingTasks]; 

    for(Task *t in tasks) { 
     [self._queue addOperation:[[SyncTask alloc] initWithTask:t]]; 
    } 
} 
@end 

和SyncTask：

@interface SyncTask : NSOperation 

@property (strong, atomic) Task *_task; 
-(id)initWithTask:(Task *)task; 
-(void)mainNewID; 
-(void)mainUploadNextPhoto:(NSNumber*)photoSetID; 

@end 

@implementation SyncTask 

@synthesize _task; 

-(id)initWithTask:(Task *)task { 
    if(self = [super init]) { 
     self._task = task; 
    } 
    return self; 
} 

-(void)main { 

    NSLog(@"Starting task : %@", [self._task description]); 
    // checking if everything is ready, sending delegates a message etc 

    [self mainNewID]; 
} 

-(void)mainNewID { 

    __block SyncTask *safeSelf = self; 

    [[WebAPI sharedClient] createNewPhotoSet withErrorBlock:^{ 
     NSLog(@"PhotoSet creation : error") 
    } andSuccessBlock:^(NSNumber *photoSetID) { 
     NSLog(@"Photoset creation : id is %d", [photoSetID intValue]); 
     [safeSelf mainUploadNextPhoto:photoSetID]; 
    }]; 
} 

-(void)mainUploadNextPhoto:(NSNumber*) photoSetID { 

    //just admit we have it. won't explain here how it's done 
    NSString *photoPath; 

    __block SyncTask *safeSelf = self; 

    [[WebAPI sharedClient] uploadToPhotosetID:photoSetID withPhotoPath:photoPath andErrorBlock:^(NSString *photoPath) { 
     NSLog(@"Photo upload error : %@", photoPath); 

    } andSuccessBlock:^(NSString *photoPath) { 

     NSLog(@"Photo upload ok : %@", photoPath); 
     //then we delete the file 
     [safeSelf mainUploadNextPhoto:photoSetID]; 
    }]; 
} 
@end 

每个网络操作使用AFNetworking这样做的话：

-(void)myDummyDownload:(void (^)(NSData * data))successBlock 
{ 
    AFHTTPClient* _httpClient = [[AFHTTPClient alloc] initWithBaseURL:[NSURL URLWithString:@"http://www.google.com/"]]; 
    [_httpClient registerHTTPOperationClass:[AFHTTPRequestOperation class]]; 

    NSMutableURLRequest *request = [_httpClient requestWithMethod:@"GET" path:@"/" nil]; 
    [request setValue:@"application/x-www-form-urlencoded" forHTTPHeaderField:@"Content-Type"]; 

    AFHTTPRequestOperation *operation = [_httpClient HTTPRequestOperationWithRequest:(NSURLRequest *)request 
     success:^(AFHTTPRequestOperation *operation, id data) { 
      if(dataBlock) 
       dataBlock(data); 
     } failure:^(AFHTTPRequestOperation *operation, NSError *error) { 
      NSLog(@"Cannot download : %@", error); 
    }]; 

    [operation setShouldExecuteAsBackgroundTaskWithExpirationHandler:^{ 
     NSLog(@"Request time out"); 
    }]; 

    [_httpClient enqueueHTTPRequestOperation:operation]; 
} 

我的问题是：我的连接是异步的，所以每个任务都会一起启动，无需等到[self._queue setMaxConcurrentOperationCount:1]在SyncAgent即可完成。

我是否需要同步执行每个连接？我不认为这是一个好主意，因为连接永远不应该这样做，也因为我可能会在别处使用这些方法，并且需要它们在后台执行，但是我找不到更好的方法。任何想法 ？

哦，如果在我的代码中有任何错误/拼写错误，我可以向你保证，当我在粘贴它之前总结它时，它现在没有任何问题。

谢谢！

PS：很抱歉，我找不到更好的解决问题的方法。

编辑：我发现，使用信号量更容易建立和理解：How do I wait for an asynchronously dispatched block to finish?

Answer 1

以下代码适用于我，但我不确定是否有缺点。拿一点盐就可以了。

- (void) main { 

    NSCondition* condition = [[NSCondition alloc] init]; 
    __block bool hasData = false; 
    [condition lock]; 

    [[WebAPI sharedClient] postPath:@"url" 
         parameters:queryParams 
          success:^(AFHTTPRequestOperation *operation, id JSON) { 
          //success code 
          [condition lock]; 
          hasData = true; 
          [condition signal]; 
          [condition unlock]; 

          } 
          failure:^(AFHTTPRequestOperation *operation, NSError *error) { 

          //failure code 

          [condition lock]; 
          hasData = true; 
          [condition signal]; 
          [condition unlock]; 
          }]; 

    while (!hasData) { 
    [condition wait]; 
    } 
    [condition unlock]; 

} 

Answer 2

如果你有对服务器的任何控制可言，你真的应该考虑创建一个API，允许你上传照片以任意的顺序，以支持多个同时上传（对于大批量，这可以相当快）。

但是，如果你必须做同步的事情，最简单的方法可能是排队在请求的完成块的新请求。即

// If [operations length] == 1, just enqueue it and skip all of this 
NSEnumerator *enumerator = [operations reverseObjectEnumerator]; 
AFHTTPRequestOperation *currentOperation = nil; 
AFHTTPRequestOperation *nextOperation = [enumerator nextObject]; 
while (nextOperation != nil && (currentOperation = [enumerator nextObject])) { 
    currentOperation.completionBlock = ^{ 
    [client enqueueHTTPRequestOperation:nextOperation]; 
    } 
    nextOperation = currentOperation; 
} 
[client enqueueHTTPRequestOperation:currentOperation];