浅谈RxSwift 网络请求

· 教程大全 · 232631

一、说明

入坑RxSwift 有段时间了，之前在项目中只是小范围的使用RxSwift，为了更好的使用响应式编程，决定在项目中更广范围的使用RxSwift，然后研究了一下RxSwift的网络请求，现在有关网络请求的案例大多是基于RXSwift(4.0.0)或者更早的库来写的，本篇文章是基于目前最新的版本（4.2.0）版本来写的，由于RxSwift 版本的更新，里面的使用语法，发生了变化，在整理的过程中遇到了一些问题，为了让后来学习的小伙伴，节约时间，决定记录下来

二、网络请求

1.使用RxSwift相关库的版本

  • ObjectMapper (3.2.0)
  • HandyJSON (4.1.1)
  • Moya (11.0.2)
  • RxCocoa (4.2.0)
  • RxSwift (4.2.0)

2.在Swift语言中，我们使用Alamofire 作为网络库，moya 是对Alamofire 更抽象一层的封装，RxSwift把Moya封装后作为网络请求的接口，我们在使用的时候只需要实现 TargetType 协议就好，用一个例子来看下怎么使用： 

import Foundation
import Moya
enum APIService{
  case mainClassList
}

extension APIService:TargetType{

  var baseURL: URL {
    return URL(string:"http://cmsadmin.fotoable.net")!
  }
  
  var path: String {
    switch self {
    case .mainClassList:
       return "/sandboxColor/category"
    }
  }
  
  var method: Moya.Method {
    switch self {
    case .mainClassList:
       return .get
    }
  }
  
  var parameters: [String : Any]? {
    
    switch self {
    case .mainClassList:
      return nil
    }
  }
  
  var parameterEncoding: ParameterEncoding {
    
    return URLEncoding.default
  }
  
  var sampleData: Data {
    return "{}".data(using: String.Encoding.utf8)!
  }
  
  var task: Task {
    return .requestPlain
  }
  
  var headers: [String : String]? {
    return nil
  }
}

首先，我们定义了一个 枚举 APIService ，作用主要是在内部定义网络请求的接口，然后，就是对协议 TargetType进行扩展，我们一一解读下里面的参数

  • baseURL：网络请求的基本URL
  • path：用于匹配具体网络请求接口
  • method：网络请求方式，常用就是 get/post 两种
  • parameters：接口请求时要带的参数
  • parameterEncoding：参数编码方式(这里使用URL的默认方式)
  • sampleData：这里用于单元测试
  • task：执行网络请求的任务
  • validationType：是否执行Alamofire验证，默认值为false
  • headers：网络请求时需要的header，如果和后台没有特殊的验证处理，默认传nil 就可以
  • APIService 作为网络请求的统一接口,里面封装了网络请求所需的一些基本数据

3.在进行网络请求之前，需要做一些准备工作，把网络请求回的数据通过JSON 转化成 Model , 这里我们使用了两种方式进行转换（根据项目的情况，灵活选择使用），一种通过 ObjectMapper库进行转换，一种是通过 HandyJSON 库 进行转换 ，分别通过对 Response 类 扩展 ，以下是对这两种方式的封装

其一：使用 ObjectMapper库 把JSON 转换成 Model

import Foundation
import RxSwift
import Moya
import ObjectMapper

// MARK: - Json -> Model
extension Response {
  
  func mapObjectModel<T: BaseMappable>(_ type: T.Type, context: MapContext? = nil) throws -> T {
    guard let object = Mapper<T>(context: context).map(JSONObject: try mapJSON()) else {
      throw MoyaError.jsonMapping(self)
    }
    return object
  }
  
  func mapObjectArray<T: BaseMappable>(_ type: T.Type, context: MapContext? = nil) throws -> [T] {
    guard let array = try mapJSON() as? [[String : Any]] else {
      throw MoyaError.jsonMapping(self)
    }
    return Mapper<T>(context: context).mapArray(JSONArray: array)
  }
}

// MARK: - Json -> Observable<Model>

extension ObservableType where E == Response {
  // 将Json解析为Observable<Model>
  public func mapObjectModel<T: BaseMappable>(_ type: T.Type) -> Observable<T> {
    return flatMap { response -> Observable<T> in
      return Observable.just(try response.mapObjectModel(T.self))
    }
  }
  // 将Json解析为Observable<[Model]>
  public func mapObjectArray<T: BaseMappable>(_ type: T.Type) -> Observable<[T]> {
    return flatMap { response -> Observable<[T]> in
      return Observable.just(try response.mapObjectArray(T.self))
    }
  }
}

其二 : 使用 HandyJSON 库 把JSON 转化成 Model

import Foundation
import RxSwift
import Moya
import HandyJSON

extension ObservableType where E == Response {
  public func mapHandyJsonModel<T: HandyJSON>(_ type: T.Type) -> Observable<T> {
    return flatMap { response -> Observable<T> in
      return Observable.just(response.mapHandyJsonModel(T.self))
    }
  }
}

extension Response {
  func mapHandyJsonModel<T: HandyJSON>(_ type: T.Type) -> T {
    let jsonString = String.init(data: data, encoding: .utf8)
    if let modelT = JSONDeserializer<T>.deserializeFrom(json: jsonString) {
      return modelT
    }
    return JSONDeserializer<T>.deserializeFrom(json: "{\"msg\":\"请求有误\"}")!
  }
}

4.在MainClassViewModel中，使用已经封装好的接口进行网络请求，代码如下: 

import RxSwift
import Moya
import ObjectMapper
import HandyJSON
import RxCocoa

class MainClassViewModel {

  private let provider = MoyaProvider<APIService>()
  let disposeBag = DisposeBag()
  var dataSource = BehaviorRelay<[MainClassModelMapObject_sub]>(value:[])
  var networkError = BehaviorRelay(value: Error.self)
}


//MARK: -- 网络
extension MainClassViewModel {
  
  //网络请求-- ObjectMapper
  func getClassListWithMapObject(){
    provider.rx.request(.mainClassList).asObservable().mapObjectModel(MainClassModelMapObject.self).subscribe({ [unowned self] (event) in
      
      switch event {
      case let .next(classModel):
        print("ObjectMapper -- 加载网络成功")
        self.dataSource.accept(classModel.data)
        
      case let .error( error):
        print("error:", error)
        self.networkError.accept(error as! Error.Protocol)
      case .completed: break
      }
    }).disposed(by: self.disposeBag)
  }
  
  
  //网络请求-- HandyJSON
  func getClassListWithMapHandyJson(){
    provider.rx.request(.mainClassList).asObservable().mapHandyJsonModel(MainClassModel.self).subscribe({ [unowned self] (event) in
      
      switch event {
      case let .next(classModel):
        
        print("HandyJSON -- 加载网络成功")
        
      case let .error( error):
        print("error:", error)
        self.networkError.accept(error as! Error.Protocol)
      case .completed: break
      }
    }).disposed(by: self.disposeBag)
  }
  
}

这里用了两种方式，分别对 mainClassList API 接口进行了网络请求，唯一不同的是，在得到到网络请求回来数据的时候，一个是使用 mapObjectModel 把JSON 转化成 Model ，一个是使用 mapHandyJsonModel 把 JSON转化成Model ，由于我们使用的是不同的库，把JSON 转化成 Model，这两种实现的方式还是有一些差别，下面是这两种 Model 的具体实现方式：

其一、实现协议 Mappable

import UIKit
import ObjectMapper

class MainClassModelMapObject: Mappable {
  
  var code:NSInteger?
  var data:[MainClassModelMapObject_sub]!
  
  required init?(map: Map) {}
  
  func mapping(map: Map) {
    code <- map["code"]
    data <- map["data"]
  }
}

class MainClassModelMapObject_sub: Mappable {
  
  var ID:String?
  var name:String?
  var desc:String?
  var imgUrl:String?
  var gifUrl:String?
  var isUpdate:Bool?
  var backgroundGroup:NSInteger?
  
  required init?(map: Map) {}
  
  func mapping(map: Map) {
    
    ID <- map["ID"]
    name <- map["name"]
    desc <- map["desc"]
    imgUrl <- map["imgUrl"]
    gifUrl <- map["gifUrl"]
    isUpdate <- map["isUpdate"]
    backgroundGroup <- map["backgroundGroup"]
  }
}

其二、实现协议 HandyJSON

import UIKit
import HandyJSON

struct MainClassModel: HandyJSON {

  var code:NSInteger?
  var data:[MainClassModel_sub]!
}

struct MainClassModel_sub: HandyJSON {
  
  var ID:String?
  var name:String?
  var desc:String?
  var imgUrl:String?
  var gifUrl:String?
  var isUpdate:Bool?
  var backgroundGroup:NSInteger?
}

5、以上是使用 RxSwift 进行网络请求的分析，接下来看一个示例如何使用，在MainClassViewModel 中我们使用 dataSource 保存了网络请求回来的数据，我们要在 ViewController里 用tableview 把这个数据展示出来，需要提前把数据源和TableView进行绑定，以下是示例代码： 

 //cell
   viewModel.dataSource.bind(to: tableView.rx.items) { (tableView, row, element) in
      let cell = tableView.dequeueReusableCell(withIdentifier: "MainClassTableViewCell", for: IndexPath(row: row, section: 0)) as! MainClassTableViewCell
      
      cell.setModel(model: element)
      // configure cell
      return cell
      }
      .disposed(by: disposeBag)

在需要使用的地方，调用 方法 getClassListWithMapObject() 或者 getClassListWithMapHandyJson()

三、总结

这部分的内容，适合对RxSwift 有一定了解的小伙伴学习, 文章重点是 帮助大家学习和了解 RxSwift 网络请求的相关知识,下面是一个写好的demo

demo

以上就是本文的全部内容，希望对大家的学习有所帮助，也希望大家多多支持。

相关推荐：

Python定时任务教程_APScheduler使用详解

APScheduler是Python中功能强大且灵活的定时任务调度库，支持内存级或持久化级任务管理，提供BlockingScheduler、BackgroundScheduler和AsyncIOScheduler三种常用调度器，以及date、interval、cron四种触发器，并建议生产环境使用S...

iOS中Safari点击事件失效怎么办

小编给大家分享一下iOS中Safari点击事件失效怎么办，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！问题描述当使用委托给一个元素添加click事件时，如果事件是委托到document或body上，并且委托的元素是默认不可...

开发者必备实用工具

工欲善其事必先利其器，今天给大家推荐一些程序员（开发者）用得上的实用开发工具，部分下载地址已经在链接中，需要的话可以自取。 1、文本编辑器——Notepad++ 相信绝大部分程序员用上它都会爱得死去活来。Notepad++是一套非常有特色的自由软件的纯文字编辑器。支持27种编程语言，通吃C,C++,...

如何使用iOS开发实现翻转扑克牌动画

这篇文章主要介绍了如何使用iOS开发实现翻转扑克牌动画，具有一定借鉴价值，感兴趣的朋友可以参考下，希望大家阅读完这篇文章之后大有收获，下面让小编带着大家一起了解一下。动画效果实现原理实现原理就是创建三个扑克牌pockerView,先在扑克牌上添加一个imageview，作为牌的背面。然后实现翻转动画...

iOS浮点类型精度问题的原因与解决办法是什么

这篇文章主要为大家分析了iOS浮点类型精度问题的原因与解决办法是什么的相关知识点，内容详细易懂，操作细节合理，具有一定参考价值。如果感兴趣的话，不妨跟着跟随小编一起来看看，下面跟着小编一起深入学习“iOS浮点类型精度问题的原因与解决办法是什么”的知识吧。前言相信不少人（其实我觉得应该是每个人）都遇到...

微信小程序使用request网络请求操作实例

本文实例讲述了微信小程序使用request网络请求操作。分享给大家供大家参考，具体如下： 小程序提供了很多api，极大的方便了开发者，其中网络请求api是wx.request(object)，这是小程序与开发者的服务器实现数据交互的一个很重要的api。 官方参数说明如下 OBJECT参数说明： 参数...

IOS如何实现三数之和

小编给大家分享一下IOS如何实现三数之和，相信大部分人都还不怎么了解，因此分享这篇文章给大家参考一下，希望大家阅读完这篇文章后大有收获，下面让我们一起去了解一下吧！1、三数求和简单介绍对于一个整数的数组,是否存在a,b,c使得a+b+c=0,返回abc数组，相同数组只返回一个,:例如:[-1,-2,...

利用python怎么在ios中模拟一个点击事件

利用python怎么在ios中模拟一个点击事件？针对这个问题，这篇文章详细介绍了相对应的分析和解答，希望可以帮助更多想解决这个问题的小伙伴找到更简单易行的方法。代码示例Python Version import socket import time # eve...