前提:近期做的项目中,用到了七牛云上传图片,七牛云的介绍就不多说了,安全,低成本(具体的集成查看七牛官网)。移动端的图片上传到七牛,服务器再去七牛拽取图片,拽取的时候可以设置参数以便拽下来的图片就是裁剪(等操作)好的。
与服务器定的流程:
第一步:客户端请求服务器,拿到服务器生成的七牛token
第二步:客户端上传图片到七牛,成功后拿到七牛返回的图片地址
第三步:将图片地址再次上传到服务器
先得到token,再上传七牛,最后上传服务器图片地址,顺序不可乱。
引入问题:
以上三步网络请求为异步,回调的时机不一样,你发了3个请求,有可能回来的时候是2请求先完成了,但是这三个步骤需要依次执行。
- 存在多个请求,需要依次执行
通过NSOperationQueue进行实现(GCD提供的dispatch_group_t group也可实现,因人而异吧)
//第一步:获取token
NSBlockOperation *operation1 = [NSBlockOperation blockOperationWithBlock:^{
[self task_1];
}];
//第二步:上传七牛
NSBlockOperation *operation2 = [NSBlockOperation blockOperationWithBlock:^{
[self task_2];
}];
//第三步:图片地址上传服务器
NSBlockOperation *operation3 = [NSBlockOperation blockOperationWithBlock:^{
[self task_3];
}];
//设置依赖
[operation2 addDependency:operation1]; //任务二依赖任务一
[operation3 addDependency:operation2]; //任务三依赖任务二
//创建队列
NSOperationQueue *queue = [[NSOperationQueue alloc] init];
[queue addOperations:@[operation3, operation2, operation1] waitUntilFinished:NO];
这里需要注意:上面的情况只实用于普通情况,即单个线程任务,同步 。可实际项目中,任务为网络请求。而网络请求通常为异步回调,这样就不适用了。举个例子,A、B,两个人是按顺序排队点餐的(发网络请求),A点了牛排,B点了煎蛋,很可能就是B的煎蛋先上菜了(回调)。
- 这里我们就要借助GCD
GCD中的信号量dispatch_semaphore进行实现,即营造线程同步情况。
dispatch_semaphore信号量为基于计数器的一种多线程同步机制。用于解决在多个线程访问共有资源时候,会因为多线程的特性而引发数据出错的问题。
如果semaphore计数大于等于1,计数-1,返回,程序继续运行。如果计数为0,则等待。
dispatch_semaphore_signal(semaphore)为计数+1操作。dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER)为设置等待时间,这里设置的等待时间是一直等待。
我们可以通俗的理解为,单柜台排队点餐(计数默认为0),每当有顾客点餐(计数+1),点餐结束(-1归零),继续等待下一位顾客。
//AFN网络请求
// task_2,task_3,任务也是这样的
//创建信号量并设置计数默认为0
- (void)task_1
{
//创建信号量并设置计数默认为0
dispatch_semaphore_t sema = dispatch_semaphore_create(0);
[self.entityRequest postGetQiNiuTokenSuccess:^(NS_M_RequestOutput *json) {
//请求成功 计数+1操作
dispatch_semaphore_signal(sema);
} failure:^(NSString *msg) {
//请求失败 计数+1操作
dispatch_semaphore_signal(sema);
} error:^(NSError *error) {
//请求异常 计数+1操作
dispatch_semaphore_signal(sema);
}];
//若计数为0则一直等待
dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
}
在dispatch_semaphore_wait位置打个断点
通过信号量dispatch_semaphore完美的解决了此问题,并且网络请求仍为异步,不会堵塞当前主线程。
再次引入问题:
上文说了,task_2为发送图片到七牛,修改头像这种一张图片上传没问题。
但是项目需求,需要一次上传很多张图片。七牛并没有提供多图片上传,最后希望达到效果,task_2任务包含大量的图片的并发上传。
希望实现:
1、2、3...10张图片同时上传,回调肯定不是依次回来的,使用NSOperationQueue依次添加任务? 这不太可能。由于我们的服务器小哥要求我们上传图片地址的时候,数组中的顺序要正确,服务器不进行排序操作。
对于这问题,可以上传服务器的时候每张图片带个顺序标记,让服务器进行排序,但是我们这边种种原因没这么做,需要客户端自己进行排序。
即:
//这里 content 中的对象是顺序的,对应用户添加照片的顺序
{
"system":"ios",
"content":[
Object{...},
Object{...},
Object{...},
Object{...}
],
"uid":"123456789"
}
准备实现:
1、大量请求并发执行
2、回调同时,顺便搞下顺序
3、等这些请求都回调了,再执行任务三。
下面说下我的做法 (for循环中存在block回调):
for (int i = 0; i < images.count; i++) {
//七牛 发送图片请求 10张图片 上传成功block回调均为异步
^() {
// KVC 操作 key == i | value == 图片名字
}
}
那么问题来了,for循环中发了很多请求,但是kvc赋值的时候,回调还没回来,此时i++操作已经完了,结果就是,第一张照片对应的i 不是0 ,而是非0的某个数字,那顺序就乱了。该方式放弃。
- 这里引入enumerateObjectsWithOptions遍历
上面的截图大概知道了,并发执行,顺序无所谓 ,最后都执行完了,才输出Done。
// NSEnumerationConcurrent
// 枚举过程中,各个Block是同时开始执行的。这样枚举的完成顺序是不确定的。
// NSEnumerationReverse
// 以反序方式枚举。
[images enumerateObjectsWithOptions:NSEnumerationConcurrent usingBlock:^(id _Nonnull obj, NSUInteger idx, BOOL * _Nonnull stop) {
// idx 在代码块中不会改变
}];
这样就感觉,在这里添加网络请求 ,再kvc, key : value 就是一一对应的,而且,等Done完成了,我们再进行任务三。
思考:
enumerateObjectsWithOptions里面是网络请求的话,问题还是一样,请求并发执行了,输出Done了,此时回调才来。那么这里也用信号量呢?
//开始上传图片 要按顺序添加 进新数组
[upDataImages enumerateObjectsWithOptions:NSEnumerationConcurrent usingBlock:^(id _Nonnull obj, NSUInteger idx, BOOL * _Nonnull stop) {
dispatch_semaphore_t sema = dispatch_semaphore_create(0);
[网络请求:{
成功:dispatch_semaphore_signal(sema);
失败:dispatch_semaphore_signal(sema);
}];
dispatch_semaphore_wait(sema, DISPATCH_TIME_FOREVER);
}];
NSLog(@"Done...........");
结果:
很显然, dispatch_semaphore_wait等待回调完成,才算这次任务完成,也就是说,最终enumerateObjectsWithOptions中任务全部执行完成,并且回调了,才输出Done。
最后还剩下排序,方法很多,这里说下我的。
1、先将图片data添加进数组(upDataImages),然后上传
2、回调后,再使用idx进行替换数组中的元素,因为idx在代码块中不会改变,所以上传第一张照片时,idx就是0。[imagesArr replaceObjectAtIndex:idx withObject:resp[@"key"]];
注意:这里upDataImages数组遍历时,不要再去进行操作(删除,添加,替换),由于upDataImages(NSMutableArray)为线程不安全,会造成不同的线程同时操作了某块内存,导致崩溃。
以上就是这些...实现方法因人而异,项目急,暂时就这样算是解决了,收工~