返回 导航

Swift

hangge.com

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

作者:hangge | 2018-04-09 08:10

三、将结果转为 JSON 对象

1,实现方法

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

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

(2)当然我们在订阅前就进行转换也是可以的:
//创建URL对象
let urlString = "https://www.douban.com/j/app/radio/channels"
let url = URL(string:urlString)
//创建请求对象
let request = URLRequest(url: url!)

//创建并发起请求
URLSession.shared.rx.data(request: request)
    .map {
        try JSONSerialization.jsonObject(with: $0, options: .allowFragments)
            as! [String: Any]
    }
    .subscribe(onNext: {
        data in
        print("--- 请求成功!返回的如下数据 ---")
        print(data)
    }).disposed(by: disposeBag)

(3)还有更简单的方法,就是直接使用 RxSwift 提供的 rx.json 方法去获取数据,它会直接将结果转成 JSON 对象。
//创建URL对象
let urlString = "https://www.douban.com/j/app/radio/channels"
let url = URL(string:urlString)
//创建请求对象
let request = URLRequest(url: url!)

//创建并发起请求
URLSession.shared.rx.json(request: request).subscribe(onNext: {
    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 request = URLRequest(url: url!)
        
        //获取列表数据
        let data = URLSession.shared.rx.json(request: request)
            .map{ result -> [[String: Any]] in
                if let data = result as? [String: Any],
                    let channels = data["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)
//创建请求对象
let request = URLRequest(url: url!)

//创建并发起请求
URLSession.shared.rx.json(request: request)
    .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 request = URLRequest(url: url!)
        
        //获取列表数据
        let data = URLSession.shared.rx.json(request: request)
            .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)

回到顶部