*网上看了很多关于断点续传的文章,但是发现各个项目的需求可能有所差异,最近做了一个关于上传视频的,这里分享一下我的处理方式,处理不好的地方请谅解。*
这里我先说一下我们处理的逻辑:由于上传一个较大的视频文件失败的几率较高,所以打算把每个视频文件分割成多个小的块,然后一块一块的上传,这样就提高的上传的成功率,而且上传的部分会被保存到服务器,中途失败,再继续上传就会接着上次未完成的上传。这个功能需要后台同事的配合,制定一套属于自己的逻辑。上传分为两部分部分:查询 和 上传。
-查询
1.加密字符串(具体后台可以定义):首先和后端约定了需要传的参数(此处我用的是“md5value”)。每次上传之前先调用一次查询接口,然后保留md5value的值存到本地,下次调用查询接口的时候获取到的md5value与本地相对比,如果是一样的就保留本地值,不同就替换。此外接口还会返回当前上传到第几块,和每块定义的大小(此处定义为separatedSize)。
2.接下来是计算需要把视频文件分为多少块上传,首先需要通过本地路径获取视频data,用data的长度除以每块的大小(separatedSize),得到块数;
//视频总大小
NSData *video_total = [NSData dataWithContentsOfURL:filePath];
//视频总块数
int video_num = ceil(video_total.length/[separatedSize intValue]);
3.确定了块数,这里就需要分割文件,直接用NSFileHandle就可以。这里我用到了for循环,seekToFileOffset方法,移动文件指针到目标位置(比如第2块:** [handle seekToFileOffset:[separatedSize intValue] * (2-1)];)“i”是for循环,默认从1开始,查询接口返回当前传到第几块,如果有值,i就从接口返回的值开始循环。因为之前都是均分大小,当传到最后一块,无法确定大小,所以直接用readDataToEndOfFile**
NSFileHandle *handle = [NSFileHandle fileHandleForReadingAtPath:filePath.path];
// 移动文件指针
[handle seekToFileOffset:[separatedSize intValue] * (i-1)];
//读取数据指定大小的数据
NSData *blockData = nil;
if (i ==“最后一块”) {
blockData = [handle readDataToEndOfFile];
}else{
blockData = [handle readDataOfLength:[separatedSize intValue]];
}
4.接下来就是上传了,直接用for循环调用AFNetWorking的上传方法就可以了
[manager POST:@"" parameters:parameters constructingBodyWithBlock:^(id<AFMultipartFormData> _Nonnull formData) {
[formData appendPartWithFileData:fileData name:@"mfile" fileName:@"ios.mp4" mimeType:@"video/quicktime"];
} progress:^(NSProgress * _Nonnull uploadProgress) {
} success:^(NSURLSessionDataTask * _Nonnull task, id _Nullable responseObject) {
} failure:^(NSURLSessionDataTask * _Nullable task, NSError * _Nonnull error) {
}];
注意的是需要确定每块上传成功后再执行for循环,如果中途失败了直接return,否则和后台的对接会出错。
这里我是创建了一个串行队列
// 1.创建一个串行队列,保证for循环依次执行
dispatch_queue_t serialQueue = dispatch_queue_create("serialQueue", DISPATCH_QUEUE_SERIAL);
dispatch_async(serialQueue, ^{
// 3.创建一个数目为1的信号量,用于“卡”for循环,等上次循环结束在执行下一次的for循环
dispatch_semaphore_t sema = dispatch_semaphore_create(1);
for (int i = chunkValue; i <= video_num; i++) {
// 开始执行for循环,让信号量-1,这样下次操作须等信号量>=0才会继续,否则下次操作将永久停止
[self requestUploadVideo_new:item dic:[dict mj_JSONString] fileData:blockData name:item.fileName fileName:item.fileName progress:^(NSProgress *progress) {
} success:^(id object) {
//block成功再执行
dispatch_semaphore_signal(sema);