主要流程
- 开始录音,与服务器建立流上传连接
- 录音期间,将分块数据传输到服务器
- 录音结束并且所有数据传输完毕,关闭流连接
- 处理服务器返回的数据
与服务器建立连接
用户开始录音时,建立流上传连接任务.在session调用uploadTaskWithStreamedRequest:后,系统会调用URLSession:task:needNewBodyStream: 代理方法获取输入流(HTTPBodyStream),通过输入流就可以向服务器上传分块数据
NSURLSessionConfiguration *config = [NSURLSessionConfiguration defaultSessionConfiguration];NSURLSession *session = [NSURLSession sessionWithConfiguration:config];// 实例化 requestNSURL *r_url = [NSURL URLWithString:@"http://www.example.com"];NSMutableURLRequest *request = [NSMutableURLRequest requestWithURL:r_url];request.HTTPMethod = @"POST";// 创建上传任务NSURLSessionUploadTask *uploadTask = [session uploadTaskWithStreamedRequest:request]; // 任务执行[uploadTask resume];复制代码
实现代理方法,传入输入流给session 建立输入流的方式有两种:
- 调用
NSStream类方法getBoundStreamsWithBufferSize:inputStream:outputStream:得到两个绑定的流对象输入流(inputStream)和输出流(outputStream),当输出流写入数据的时候系统内部会将数据传递给输入流. - 子类化
NSInputStream(文后链接有介绍这种方法,原文作者推荐第一种方法,本文不重点讲解)
- (void)URLSession:(NSURLSession *)session task:(NSURLSessionTask *)task needNewBodyStream:(void (^)(NSInputStream * _Nullable))completionHandler{ NSInputStream *inputStream = nil; NSOutputStream *outputStream = nil; [NSStream getBoundStreamsWithBufferSize:1024 inputStream:&inputStream outputStream:&outputStream]; self.bodyStream = inputStream; self.outputStream = outputStream; self.outputStream.delegate = self; [self.outputStream scheduleInRunLoop:[NSRunLoop currentRunLoop] forMode:NSDefaultRunLoopMode]; [self.outputStream open]; completionHandler(self.bodyStream);}复制代码 数据分块上传到服务器
传输分块数据,写入分块数据是在stream:handleEvent:方法处理的,上文有设置输出流代理并且开启,每当有数据可以写入的时候,就会代用代理方法.
NSStreamEventHasSpaceAvailable事件表示有新数据可以写入,输入流写入数据方法write:maxLength:- 当用户停止录音并且所有数据写入完成之后,我们需要关闭输出流和将其代理置空.如果不关闭流,可能会出现连接超时,数据传输失败.
- 所有数据是否写入完成需要结合具体场景来判断
- 关于输入流输出流如何使用,请参考苹果给的demo
- 下面是伪代码
- (void)stream:(NSStream *)aStream handleEvent:(NSStreamEvent)eventCode{ switch (eventCode) { case NSStreamEventNone: NSLog(@"NSStreamEventNone"); break; case NSStreamEventOpenCompleted: NSLog(@"NSStreamEventOpenCompleted"); break; case NSStreamEventHasBytesAvailable: { NSLog(@"NSStreamEventHasBytesAvailable"); } break; case NSStreamEventHasSpaceAvailable: { NSLog(@"NSStreamEventHasBytesAvailable"); // 录音中且有新数据需要写入,输入流写入数据 // 录音中没有新数据,等待新数据进入 // 录音停止,数据未写完 // 录音停止,所有数据未写完,关闭输入流,设置输入流代理为nil .... } break; case NSStreamEventErrorOccurred: NSLog(@"NSStreamEventErrorOccurred"); break; case NSStreamEventEndEncountered: NSLog(@"NSStreamEventEndEncountered"); break; default: break; }}复制代码 处理服务器响应数据
要获取服务器返回的数据需要结合下面两个代理方法:
URLSession:dataTask:didReceiveResponse:completionHandler:URLSession:dataTask:didReceiveData:
实现第一个代理方法的completionHandler,才会调用第二个代理拿到服务器数据
- (void)URLSession:(NSURLSession *)session dataTask:(NSURLSessionDataTask *)dataTaskdidReceiveResponse:(NSURLResponse *)response completionHandler:(void (^)(NSURLSessionResponseDisposition disposition))completionHandler{ NSLog(@"Send audio status code：%d", (int)urlResponse.statusCode); if (urlResponse.statusCode >= 200 || urlResponse.statusCode <= 299) { NSHTTPURLResponse *urlResponse = (NSHTTPURLResponse *)response; completionHandler(NSURLSessionResponseAllow); }}复制代码 接收服务器响应数据 如果服务器返回的数据过大,系统会多次调用这个方法,分断返回响应数据,这些数据需要我们自己拼接处理,本人有两种处理方法:
- 保存流上传任务
uploadTask为私有属性,并且用KVO监听其state属性变化,当其状态为完成时就可以处理相应数据了.数据的拼接再代理方法中实现 - 保存流上传任务
uploadTask为私有属性,每次代理方法进来之后拼接响应数据,然后直接处理
- (void)URLSession:(NSURLSession *)session dataTask:(NSURLSessionDataTask *)dataTask didReceiveData:(NSData *)data { NSHTTPURLResponse *res = (NSHTTPURLResponse *)dataTask.response; NSLog(@"Send audio status code：%d", (int)res.statusCode); if (self.streamUploadTask == dataTask) { // 拼接数据 [self.streamReceiveData appendData:data]; // 数据处理 } else { // 其他任务响应数据 } }复制代码