三、将结果转为 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。关于它的安装配置，以及相关说明可以参考航ge之前写的文章：
（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)
}
}
网友评论