此文章主要总结一下Moya+RxSwift网络请求中一些常见的情况。如有不足欢迎来访交流。话不多说直接上干货。
1.开始前的准备工作
- 导入用到的第三方库
pod 'RxSwift'
pod 'RxCocoa'
pod 'Alamofire'
pod 'Moya/RxSwift'
pod 'SwiftyJSON'
pod 'ObjectMapper'
- 配置ObjectMapper的通用类
请参照我的另一篇文章Swift ObjectMapper 通用类配置
至此所有的前置准备工作完成
2.创建网络请求的公共类(我创建好的公共请求类的文件放在后面)
1.先创建一个公共类的文件 我的文件名是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>{
//此处可以自定义一个检测网络状态的东西
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
//此处的返回信息依据自己的情况去定义 例如添加上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>{
//检测网络状态
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))//数据转化为字典然后返回
case let .error(error)://网络请求失败
signal(.error(error))
case .completed: break//完成
}
}.disposed(by: BaseTool.disposeBag)
return Disposables.create()
}
}
}
extension BaseTool{
//MARK:检测网络状态
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参数实现多网络请求
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
//此处设置了参数
//而func mapping(map: Map) 方法中没有设置的话
//则数据不会保存进来 需要自己手动保存
func mapping(map: Map) {
id <- map["id"]
}
init() {}
required init?(map: Map) {}
}
完
网友评论