当前位置: > > > Swift - RxSwift的使用详解46(结合RxAlamofire使用2:结果处理、模型转换)

Swift - RxSwift的使用详解46(结合RxAlamofire使用2:结果处理、模型转换)

四、将结果转为 JSON 对象

1,实现方法

(1)如果服务器返回的数据是 json 格式的话,我们可以使用 iOS 内置的 JSONSerialization 将其转成 JSON 对象,方便我们使用。
//创建URL对象
let urlString = "https://www.douban.com/j/app/radio/channels"
let url = URL(string:urlString)!

//创建并发起请求
request(.get, url)
    .data()
    .subscribe(onNext: {
        data in
        let json = try? JSONSerialization.jsonObject(with: data, options: .allowFragments)
            as! [String: Any]
        print("--- 请求成功!返回的如下数据 ---")
        print(json!)
    }).disposed(by: disposeBag)

(2)我们换种方式,在订阅前使用 responseJSON() 进行转换也是可以的:
//创建URL对象
let urlString = "https://www.douban.com/j/app/radio/channels"
let url = URL(string:urlString)!

//创建并发起请求
request(.get, url)
    .responseJSON()
    .subscribe(onNext: {
        dataResponse in
        let json = dataResponse.value as! [String: Any]
        print("--- 请求成功!返回的如下数据 ---")
        print(json)
    }).disposed(by: disposeBag)

(3)当然最简单的还是直接使用 requestJSON 方法去获取 JSON 数据。
//创建URL对象
let urlString = "https://www.douban.com/j/app/radio/channels"
let url = URL(string:urlString)!

//创建并发起请求
requestJSON(.get, url)
    .subscribe(onNext: {
        response, data in
        let json = data as! [String: Any]
        print("--- 请求成功!返回的如下数据 ---")
        print(json)
    }).disposed(by: disposeBag)

2,使用样例

(1)效果图
我们将获取到的豆瓣频道列表数据转换成 JSON 对象,并绑定到表格上显示。

(2)样例代码
import UIKit
import RxSwift
import RxCocoa

class ViewController: UIViewController {
    
    var tableView:UITableView!
    
    let disposeBag = DisposeBag()
    
    override func viewDidLoad() {
        super.viewDidLoad()
        
        //创建表格视图
        self.tableView = UITableView(frame: self.view.frame, style:.plain)
        //创建一个重用的单元格
        self.tableView!.register(UITableViewCell.self, forCellReuseIdentifier: "Cell")
        self.view.addSubview(self.tableView!)
        
        //创建URL对象
        let urlString = "https://www.douban.com/j/app/radio/channels"
        let url = URL(string:urlString)!
        
        //获取列表数据
        let data = requestJSON(.get, url)
            .map{ response, data -> [[String: Any]] in
                if let json = data as? [String: Any],
                    let channels = json["channels"] as? [[String: Any]] {
                    return channels
                }else{
                    return []
                }
        }
        
        //将数据绑定到表格
        data.bind(to: tableView.rx.items) { (tableView, row, element) in
            let cell = tableView.dequeueReusableCell(withIdentifier: "Cell")!
            cell.textLabel?.text = "\(row):\(element["name"]!)"
            return cell
            }.disposed(by: disposeBag)
    }
}

五,将结果映射成自定义对象

1,准备工作

(1)要实现数据转模型(model),我们这里还要先引入一个第三方的数据模型转换框架:ObjectMapper。关于它的安装配置,以及相关说明可以参考我之前写的文章:

(2)为了让 ObjectMapper 能够更好地与 RxSwift 配合使用,我们对 Observable 进行扩展(RxObjectMapper.swift),增加数据转模型对象、以及数据转模型对象数组这两个方法。
import ObjectMapper
import RxSwift

//数据映射错误
public enum RxObjectMapperError: Error {
    case parsingError
}

//扩展Observable:增加模型映射方法
public extension Observable where Element:Any {
    
    //将JSON数据转成对象
    public func mapObject< T>(type:T.Type) -> Observable<T> where T:Mappable {
        let mapper = Mapper<T>()
        
        return self.map { (element) -> T in
            guard let parsedElement = mapper.map(JSONObject: element) else {
                throw RxObjectMapperError.parsingError
            }
            
            return parsedElement
        }
    }
    
    //将JSON数据转成数组
    public func mapArray< T>(type:T.Type) -> Observable<[T]> where T:Mappable {
        let mapper = Mapper<T>()
        
        return self.map { (element) -> [T] in
            guard let parsedArray = mapper.mapArray(JSONObject: element) else {
                throw RxObjectMapperError.parsingError
            }
            
            return parsedArray
        }
    }
}

2,使用样例

(1)我们还是以前面的豆瓣音乐频道数据为例。首先我定义好相关模型(需要实现 ObjectMapper Mappable 协议,并设置好成员对象与 JSON 属性的相互映射关系。)
//豆瓣接口模型
class Douban: Mappable {
    //频道列表
    var channels: [Channel]?
    
    init(){
    }
    
    required init?(map: Map) {
    }
    
    // Mappable
    func mapping(map: Map) {
        channels <- map["channels"]
    }
}

//频道模型
class Channel: Mappable {
    var name: String?
    var nameEn:String?
    var channelId: String?
    var seqId: Int?
    var abbrEn: String?
    
    init(){
    }
    
    required init?(map: Map) {
    }
    
    // Mappable
    func mapping(map: Map) {
        name <- map["name"]
        nameEn <- map["name_en"]
        channelId <- map["channel_id"]
        seqId <- map["seq_id"]
        abbrEn <- map["abbr_en"]
    }
}

(2)下面样例演示如何获取数据,并转换成对应的模型。
//创建URL对象
let urlString = "https://www.douban.com/j/app/radio/channels"
let url = URL(string:urlString)!

//创建并发起请求
requestJSON(.get, url)
    .map{$1}
    .mapObject(type: Douban.self)
    .subscribe(onNext: { (douban: Douban) in
        if let channels = douban.channels {
            print("--- 共\(channels.count)个频道 ---")
            for channel in channels {
                if let name = channel.name, let channelId = channel.channelId {
                    print("\(name) (id:\(channelId))")
                }
            }
        }
    }).disposed(by: disposeBag)

(3)下面样例演示将数据换成模型,并绑定到表格上显示。
import UIKit
import RxSwift
import RxCocoa
import ObjectMapper

class ViewController: UIViewController {
    
    var tableView:UITableView!
    
    let disposeBag = DisposeBag()
    
    override func viewDidLoad() {
        super.viewDidLoad()
       
        //创建表格视图
        self.tableView = UITableView(frame: self.view.frame, style:.plain)
        //创建一个重用的单元格
        self.tableView!.register(UITableViewCell.self, forCellReuseIdentifier: "Cell")
        self.view.addSubview(self.tableView!)
        
        //创建URL对象
        let urlString = "https://www.douban.com/j/app/radio/channels"
        let url = URL(string:urlString)!
        
        //获取列表数据
        let data = requestJSON(.get, url)
            .map{$1}
            .mapObject(type: Douban.self)
            .map{ $0.channels ?? []}
        
        //将数据绑定到表格
        data.bind(to: tableView.rx.items) { (tableView, row, element) in
            let cell = tableView.dequeueReusableCell(withIdentifier: "Cell")!
            cell.textLabel?.text = "\(row):\(element.name!)"
            return cell
            }.disposed(by: disposeBag)
    }
}
评论0