我经常有这样的代码,当我有一个处理与REST API通信的类时,里面有很多方法使用NSURLSession任务,闭包作为回调.我还给出了一些这些方法的回调闭包,所以我可以一个接一个地链接不同的API调用.我经常将这些方法称为View Controller,例如在按下按钮或viewDidLoad后作为操作.
让我们看一个示例类,它使用一个方法与假想的API进行对话,该方法发送POST请求以使用API注册新用户:
class ApiConnection { var session: NSURLSession! init() { let config = NSURLSessionConfiguration.defaultSessionConfiguration() config.URLCache = NSURLCache.sharedURLCache() self.session = NSURLSession(configuration: config) } func registerNewUser(user user: String,password: String,callback: (() -> Void)? ) { let data = ["email": user,"password": password] let url = NSURL(string: "https://backend.myapp.com/auth/register/") let request = NSMutableuRLRequest(URL: url!) request.setValue("application/json; charset=utf-8",forHTTPHeaderField: "Content-Type") try! request.HTTPBody = NSJSONSerialization.dataWithJSONObject(data,options: NSJSONWritingOptions()) let task = session.dataTaskWithRequest(request) { data,response,error in if (error != nil) { print("Todo do the right thing here for error: \(error!.localizedDescription)") return } if let httpResponse = response as? NSHTTPURLResponse { do { let result = try NSJSONSerialization.JSONObjectWithData(data!,options: NSJSONReadingOptions()) as? NSDictionary if httpResponse.statusCode == 201 { print("registration went successfully") callback?() } else { print("registration went wrong,not registered new user: \(result)") } } catch { print("Todo something went wrong decoding the JSON response") } } } task.resume() } }
let myAPI = ApiConnection() myAPI.registerNewUser(user: "email@foo.bar",password: "testing") { // continue here,probably doing the next call print("user is registered") }
到目前为止一切都那么好,但这个例子完全没有正确的错误处理(上面的代码中的“Todo”,以显示警告标签或其他.我想知道如何改进我的代码以优雅的方式做到这一点.
当然,我可以在我创建的完成闭包中给出一个错误对象,并在视图控制器中执行一些错误!= nil magic,但这对于连续调用来说会很难看并且变得很麻烦.
我认为新的do-try-catch习惯用法可能是完美的:拥有一个只在成功案例中执行的完成闭包,并且除非在出现任何错误时捕获异常,即使格式错误也是如此我可以在APIConnection类中编写的消息.但经过一些阅读后我发现不可能抛出一个闭包,因为这个闭包可以在任何时候被调用,即使在方法本身已经执行之后,对我来说也是有意义但我不知道如何很好地处理这种情况.
你是如何经验丰富的程序员处理这个的?我的整个方法和我的APIConnection类的架构是愚蠢的,整个事情可以做得更优雅吗? Plaese,任何评论都表示赞赏.
解决方法
什么最适合这类问题,是承诺的概念.您在代码中执行的操作可以轻松地视为管道操作:get_server_respose | parse_json | execute_callback.在同步方法中,这将非常简单,并且将提供干净/可读的代码.在异步世界中,事情变得复杂,你很容易迷失在
callback hell中.
使用promises,您可以以非常类似于管道同步版本的方式链接异步操作,并且在链的末尾只能有一个故障点.
以下是您的问题的promise-d版本的外观:
let task = session.dataTaskWithRequest(request) task.promisify.then({response,data in guard let httpResponse = response as? NSHTTPURLResponse else { return FailedPromise(Error(...)} } guard response.statusCode == 201 else { return FailedPromise(Error(...)} } return jsonParsePromise(data); }).then({ parsedDict in print("Registration went successfully") callback?() }).then(nil,{ error in print("An error occured: \(error)") }) task.resume()
更清洁,json在单独的(可测试的)单元中解析,只有一个故障点.
附:你可以更进一步,宣传registerNewUser函数本身:
func registerNewUser(user user: String,password: String) -> Promise { //... task setup return task.promisify.then({response,data in guard let httpResponse = response as? NSHTTPURLResponse else { return FailedPromise(Error(...)} } guard response.statusCode == 201 else { return FailedPromise(Error(...)} } return jsonParsePromise(data); }) task.resume() }
,该功能的客户可以很容易地使用:
registerNewUser(usernameTextfield.text,passwordTextfied.text).then({user in print("Registration succeeded with user \(user)") },{error in print("Registration Failed with error \(error)") })