此文章主要總結一下Moya+RxSwift網絡請求中一些常見的情況。如有不足歡迎來訪交流。話不多說直接上干貨。

1.開始前的準備工作

• 導入用到的第三方庫

  pod 'RxSwift'
  pod 'RxCocoa'
  pod 'Alamofire'
  pod 'Moya/RxSwift'
  pod 'SwiftyJSON'
  pod 'ObjectMapper'

• 配置ObjectMapper的通用類
  請參照我的另一篇文章Swift ObjectMapper 通用類配置

至此所有的前置準備工作完成

2.創(chuàng)建網絡請求的公共類(我創(chuàng)建好的公共請求類的文件放在后面)

1.先創(chuàng)建一個公共類的文件 我的文件名是BaseTool，

 此處存放了一些網絡請求用的到的公共類  如url地址  header請求頭等信息
class BaseTool {   //
    static var disposeBag = DisposeBag()
    //URL地址
    static var baseUrl : URL{
        get{
            return URL(string: "https://xxxxxxx")
        }
    }
    //header  
    static var headers: [String: String] {
        get {
            xxxxxxx   此處自定義添加你的header信息
            return headers
        }
    }

}
2.擴展一下BaseTool  存放網絡請求的公共類
extension BaseTool{
    // 最最核心的地方
    static func request<T : TargetType>(target: T) -> Single<Any>{
        //此處可以自定義一個檢測網絡狀態(tài)的東西
        let provider = MoyaProvider<T>()
        return Single<Any>.create {signal -> Disposable in
            //網絡請求模塊
            provider.rx.request(target).asObservable().subscribe { (event) in
                switch event{
                    case let .next(response)://網絡請求成功
                        let responseDic = JSON(response.data).dictionaryObject
                        
                        
                       //此處的返回信息依據(jù)自己的情況去定義  例如添加上400錯

                        signal(.success(response.data))//
                    case let .error(error)://網絡請求失敗
                        signal(.error(error))
                    case .completed: break//完成
                }
            }.disposed(by: BaseTool.disposeBag)
            
            return Disposables.create()
        }
        
    }
}

BaseTool完整的代碼

import Foundation
import Moya
import RxSwift
import SwiftyJSON
import SwiftyUserDefaults
import ObjectMapper


class BaseTool {
    static var disposeBag = DisposeBag()
    static var netWorkStatus = Reachability.Connection.unavailable
    //URL地址
    static var baseUrl : URL{
        get{
            return URL(string: "https://xxxxxxxxxxx")!
        }
    }
    //header
    static var headers: [String: String] {
        get {
            var headers = [String : String]()
            return headers
        }
    }

}

extension BaseTool{
    
    static func request<T : TargetType>(target: T) -> Single<Any>{
        //檢測網絡狀態(tài)
        let netWorkStatus = BaseTool.checkNetWorkStatus()
        if !netWorkStatus {
            return Single<Any>.create{signal -> Disposable in
                signal(.success(NOTNETWORKSTRING))
                return Disposables.create()
            }
            
        }
    
        let provider = MoyaProvider<T>()
        return Single<Any>.create {signal -> Disposable in
            //網絡請求模塊
            provider.rx.request(target).asObservable().subscribe { (event) in
                switch event{
                    case let .next(response)://網絡請求成功
                        let responseDic = JSON(response.data).dictionaryObject
                        signal(.success(response.data))//數(shù)據(jù)轉化為字典然后返回
                    case let .error(error)://網絡請求失敗
                        signal(.error(error))
                    case .completed: break//完成
                }
            }.disposed(by: BaseTool.disposeBag)
            
            return Disposables.create()
        }
        
    }
}

extension BaseTool{
    //MARK:檢測網絡狀態(tài)
    static func checkNetWorkStatus() -> Bool{
        do{
            let reach = try Reachability.init(hostname: "https://www.baidu.com")
            BaseTool.netWorkStatus = reach.connection
        }catch{}
        if netWorkStatus == .unavailable{
            return false
        }
        return true
    }
}

3.配置一個網絡請求的類 繼承自TargetType

import UIKit
import Moya
enum CommenTool {
    case systemArea//獲取集團架構
}

extension CommenTool : TargetType{
    var baseURL: URL {
        return BaseTool.baseUrl  //返回URL  url已經保存在了BaseTool里面了
    }
    
    var path: String {
        switch self {
            case .systemArea:
                return "system/area" 
              //返回地址鏈接 地址鏈接公共類已經卸載了BaseTool里面 這里是非公共的部分
        }
        
    }
    
    var method: Moya.Method {
        switch self {
            case .systemArea:
                return .get//get還是post請求
        }
    }
    
    var sampleData: Data {
        return "".data(using: String.Encoding.utf8)!//文件格式
    }
    
    var task: Task {
        switch self {
            case .systemArea:
                return .requestParameters(parameters: ["":""], encoding: URLEncoding.default)
        }
    }
    
    var headers: [String : String]? {
        return BaseTool.headers
    }
    
    
}

此處畫重點- 單網絡請求和多網絡請求的使用方法

4.單網絡請求的使用方法

BaseTool.request(target: CommenTool.systemArea).subscribe{event in
            switch event{
                case let .success(response):
                    guard response is Bool else {
                        let responseDic = JSON(response).dictionaryValue
                        let requestArray = responseDic["data"]?.arrayValue.map({ json -> SystemAreaModel in
                            return SystemAreaModel(JSON: json.dictionaryObject!)!
                        })
                        OrderSystemAreaArray = requestArray!
                        break
                    }
                case .error(_):break//請求失敗返回false
            }
        }.disposed(by: disposeBag)

5.多網絡共同請求

使用RxSwift的.zip參數(shù)實現(xiàn)多網絡請求

Observable.zip(BaseTool.request(target: OrderTool.orderDetail(id: self.orderId)).asObservable(), BaseTool.request(target: OrderTool.orderDetailEvaluate(id: self.orderId)).asObservable(), BaseTool.request(target: OrderTool.orderDetailStatus(id: self.orderId)).asObservable()).subscribe(onNext:{[weak self](detailResult , evaluateResult , statusResult) in
           // 這里我用了三個網絡請求     detailResult , evaluateResult , statusResult 
           //分別對用每個網絡請求的返回結果
            
        }).disposed(by: disposeBag)

6.最后一單 model的設計

import UIKit
import ObjectMapper

//MARK: 工單列表model

class OrderListModel: Mappable {
    var id                  : Int = 0
    //此處設置了參數(shù) 
   //而func mapping(map: Map) 方法中沒有設置的話
   //則數(shù)據(jù)不會保存進來 需要自己手動保存

    func mapping(map: Map) {
        id              <- map["id"]

    }
    
    init() {}
    
    required init?(map: Map) {}
}

完