通过Moya+RxSwift+Argo完成网络请求

首页 > 娱乐前沿 > 热点

2016-01-16 19:20:29 | 来源：玩转帮会 | 投稿：佚名 | 编辑：小柯

原标题：通过Moya+RxSwift+Argo完成网络请求

作者：@请叫我汪二授权本站转载。

最近在新项目中尝试使用 Moya+RxSwift+Argo 进行网络请求和解析，感觉还阔以，再来给大家安利一波。

Moya

Moya 是一个基于 Alamofire 的更高层网络请求封装，深入学习请参见官方文档：Moya/Docs。

使用 Moya 之后网络请求一般长了这样：

provider.request(.UserProfile("ashfurrow")){(data,statusCode,response,error)in
ifletdata=data{
//dosomethingwiththedata
}
}

Moya 提供了很多不错的特性，其中我感觉最棒的是 stub ，配合 sampleData 分分钟就完成了单元测试：

privateletprovider=MoyaProvider(stubClosure:MoyaProvider.ImmediatelyStub)

注意这里的 MoyaProvider.ImmediatelyStub ，我原以为它是个枚举类型，看了 MoyaProvider 定义发现这里应该传个 closure ，看了 ImmediatelyStub 的定义发现原来它是个类方法：

publictypealiasStubClosure=Target->Moya.StubBehavior
overridepublicinit(stubClosure:StubClosure=MoyaProvider.NeverStub,...){
}
publicfinalclassfuncImmediatelyStub(_:Target)->Moya.StubBehavior{
return.Immediate
}

如果想打印每次请求的参数，在组装 endpoint 的时候打印即可：

privatefuncendpointMapping(target:Target)->Endpoint{
ifletparameters=target.parameters{
log.verbose("\(parameters)")
}
returnMoyaProvider.DefaultEndpointMapping(target)
}
privateletprovider=RxMoyaProvider(endpointClosure:endpointMapping)

RxSwift

RxSwift 前面强行安利过两波，在此不再赘述啦，Moya 本身提供了 RxSwift 扩展，可以无缝衔接 RxSwift 和 ReactiveCocoa ，于是打开方式变成了这样：

privateletprovider=RxMoyaProvider()
privatevardisposeBag=DisposeBag()
extensionItemAPI{
staticfuncgetNewItems(completion:[Item]->Void){
disposeBag=DisposeBag()
provider
.request(.GetItems())
.subscribe(
onNext:{itemsin
completion(items)
}
)
.addDisposableTo(disposeBag)
}
}

Moya 的核心开发者、同时也是 Artsy 的成员：Ash Furrow，在 AltConf 做过一次《Functional Reactive Awesomeness With Swift》的分享，推荐大家看一下，很可爱的！

Argo

Argo 是 thoughtbot 开源的函数式 JSON 解析转换库。说到 thoughtbot 就不得不提他司关于 JSON 解析质量很高的一系列文章：

Efficient JSON in Swift with Functional Concepts and Generics
Real World JSON Parsing with Swift
Parsing Embedded JSON and Arrays in Swift
Functional Swift for Dealing with Optional Values

Argo 基本上就是沿着这些文章的思路写出来的，相关的库还有 Runes 和 Curry。

使用 Argo 做 JSON 解析很有意思，大致长这样：

structItem{
letid:String
leturl:String
}
extensionItem:Decodable{
staticfuncdecode(j:JSON)->Decoded{
returncurry(Item.init)
j<|"id"
j<|"url"
}
}

至于这其中各种符号的缘由，在几篇博客中都有讲解，还是挺有意思滴。

All

说完这三者，如何把它们串起来呢？Emergence 中的 Observable/Networking 给了我们答案。稍微整理后如下：

enumORMError:ErrorType{
caseORMNoRepresentor
caseORMNotSuccessfulHTTP
caseORMNoData
caseORMCouldNotMakeObjectError
}
extensionObservable{
privatefuncresultFromJSON(object:[String:AnyObject],classType:T.Type)->T?{
letdecoded=classType.decode(JSON.parse(object))
switchdecoded{
case.Success(letresult):
returnresultas?T
case.Failure(leterror):
log.error("\(error)")
returnnil
}
}
funcmapSuccessfulHTTPToObject(type:T.Type)->Observable{
returnmap{representorin
guardletresponse=representoras?MoyaResponseelse{
throwORMError.ORMNoRepresentor
}
guard((200...209)~=response.statusCode)else{
ifletjson=try?NSJSONSerialization.JSONObjectWithData(response.data,options:.AllowFragments)as?[String:AnyObject]{
log.error("Goterrormessage:\(json)")
}
throwORMError.ORMNotSuccessfulHTTP
}
do{
guardletjson=tryNSJSONSerialization.JSONObjectWithData(response.data,options:.AllowFragments)as?[String:AnyObject]else{
throwORMError.ORMCouldNotMakeObjectError
}
returnself.resultFromJSON(json,classType:type)!
}catch{
throwORMError.ORMCouldNotMakeObjectError
}
}
}
funcmapSuccessfulHTTPToObjectArray(type:T.Type)->Observable{
returnmap{responsein
guardletresponse=responseas?MoyaResponseelse{
throwORMError.ORMNoRepresentor
}
//AllowsuccessfulHTTPcodes
guard((200...209)~=response.statusCode)else{
ifletjson=try?NSJSONSerialization.JSONObjectWithData(response.data,options:.AllowFragments)as?[String:AnyObject]{
log.error("Goterrormessage:\(json)")
}
throwORMError.ORMNotSuccessfulHTTP
}
do{
guardletjson=tryNSJSONSerialization.JSONObjectWithData(response.data,options:.AllowFragments)as?[[String:AnyObject]]else{
throwORMError.ORMCouldNotMakeObjectError
}
//Objectsarenotguaranteed,thuscannotdirectlymap.
varobjects=[T]()
fordictinjson{
ifletobj=self.resultFromJSON(dict,classType:type){
objects.append(obj)
}
}
returnobjects
}catch{
throwORMError.ORMCouldNotMakeObjectError
}
}
}
}

这样在调用的时候就很舒服了，以前面的 Item 为例：

privateletprovider=RxMoyaProvider()
privatevardisposeBag=DisposeBag()
extensionItemAPI{
staticfuncgetNewItems(records:[Record]=[],needCount:Int,completion:[Item]->Void){
disposeBag=DisposeBag()
provider
.request(.AddRecords(records,needCount))
.mapSuccessfulHTTPToObjectArray(Item)
.subscribe(
onNext:{itemsin
completion(items)
}
)
.addDisposableTo(disposeBag)
}
}

一个 mapSuccessfulHTTPToObjectArray 方法，直接将 JSON 字符串转换成了 Item 对象，并且传入了后面的数据流中，所以在 onNext 订阅的时候传入的就是 [Item] 数据，并且这个转换过程还是可以复用的，且适用于所有网络请求中 JSON 和 Model 的转换。爽就一个字，我只说一次。

爽！

匆匆读了一点 Emergence 和 Eidolon 的项目源码，没有深入不过已经受益匪浅。通过 bundle 管理 id 和 key 直接解决了我当初纠结已久的『完整项目开源如何优雅地保留 git 记录且保护项目隐私』的问题，还有 Moya/RxSwift 和 Moya/ReactiveCocoa 这图片模块化处理也在共有模块管理这个问题上给了我一些启发。

真是很喜欢 Artsy 这样的团队，大家都一起做着自己喜欢的事情，还能站着把钱赚了。

所幸的是我也可以这样做自己喜欢的事情了，不过不赚钱。具体状况后面单独开一篇闲扯扯。

碎告。

参考资料：