Swift - RxSwift的使用详解50（结合Moya使用2：结果处理、模型转换）

作者：hangge | 2018-04-19 08:10

三、将结果转为 JSON 对象

1，实现方法

（1）如果服务器返回的数据是 json 格式的话，直接通过 Moya 提供的 mapJSON 方法即可将其转成 JSON 对象。

注意：关于 DouBanProvider 里的具体内容，可以参考上文（点击查看）。

//获取数据
DouBanProvider.rx.request(.channels)
    .subscribe(onSuccess: { response in
        //数据处理
        let json = try? response.mapJSON() as! [String: Any]
        print("--- 请求成功！返回的如下数据 ---")
        print(json!)
    },onError: { error in
        print("数据请求失败!错误原因：", error)
        
    }).disposed(by: disposeBag)

（2）或者使用下面这种写法也是可以的。

//获取数据
DouBanProvider.rx.request(.channels)
    .mapJSON()
    .subscribe(onSuccess: { data in
        //数据处理
        let json = data as! [String: Any]
        print("--- 请求成功！返回的如下数据 ---")
        print(json)
    },onError: { error in
        print("数据请求失败!错误原因：", error)
        
    }).disposed(by: disposeBag)

（3）运行结果如下：

2，使用样例

（1）效果图

我们使用 Moya 调用豆瓣 FM 的 API 接口，获取所有的频道列表并显示在表格中。
点击任意一个频道，调用另一个接口随机获取该频道下的一首歌曲，并弹出显示。

（2）样例代码

import UIKit
import RxSwift
import RxCocoa

class ViewController: UIViewController {
    
    //显示频道列表的tableView
    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!)
        
        //获取列表数据
        let data = DouBanProvider.rx.request(.channels)
            .mapJSON()
            .map{ data -> [[String: Any]] in
                if let json = data as? [String: Any],
                    let channels = json["channels"] as? [[String: Any]] {
                    return channels
                }else{
                    return []
                }
            }.asObservable()
        
        //将数据绑定到表格
        data.bind(to: tableView.rx.items) { (tableView, row, element) in
            let cell = tableView.dequeueReusableCell(withIdentifier: "Cell")!
            cell.textLabel?.text = "\(element["name"]!)"
            cell.accessoryType = .disclosureIndicator
            return cell
            }.disposed(by: disposeBag)
        
        //单元格点击
        tableView.rx.modelSelected([String: Any].self)
            .map{ $0["channel_id"] as! String }
            .flatMap{ DouBanProvider.rx.request(.playlist($0)) }
            .mapJSON()
            .subscribe(onNext: {[weak self] data in
                //解析数据，获取歌曲信息
                if let json = data as? [String: Any],
                    let musics = json["song"] as? [[String: Any]]{
                    let artist = musics[0]["artist"]!
                    let title = musics[0]["title"]!
                    let message = "歌手：\(artist)\n歌曲：\(title)"
                    //将歌曲信息弹出显示
                    self?.showAlert(title: "歌曲信息", message: message)
                }                
            }).disposed(by: disposeBag)
    }
    
    //显示消息
    func showAlert(title:String, message:String){
        let alertController = UIAlertController(title: title,
                                                message: message, preferredStyle: .alert)
        let cancelAction = UIAlertAction(title: "确定", style: .cancel, handler: nil)
        alertController.addAction(cancelAction)
        self.present(alertController, animated: true, completion: nil)
    }
    
    override func didReceiveMemoryWarning() {
        super.didReceiveMemoryWarning()
    }
}

四，将结果映射成自定义对象

1，准备工作

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

Swift - 使用ObjectMapper实现模型转换1（JSON与Model的相互转换）

（2）为了让 ObjectMapper 能够更好地与 Moya 配合使用，我们需要使用 Moya-ObjectMapper 这个 Observable 扩展库。它的作用是增加数据转模型对象、以及数据转模型对象数组这两个方法。我们现将其下载到本地。

GitHub 主页：https://github.com/ivanbruel/Moya-ObjectMapper

（3）Moya-ObjectMapper 配置很简单只需把 sourcs 文件夹中的如下 3 个文件添加到项目中来即可。

Response+ObjectMapper.swift
ObservableType+ObjectMapper.swift
Single+ObjectMapper.swift

2，使用样例

（1）我们还是以前面的豆瓣音乐频道数据为例。首先我定义好相关模型（需要实现 ObjectMapper 的 Mappable 协议，并设置好成员对象与 JSON 属性的相互映射关系。）

//豆瓣接口模型
struct Douban: Mappable {
    //频道列表
    var channels: [Channel]?
    
    init?(map: Map) { }
    
    // Mappable
    mutating func mapping(map: Map) {
        channels <- map["channels"]
    }
}

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

//歌曲列表模型
struct Playlist: Mappable {
    var r: Int!
    var isShowQuickStart: Int!
    var song:[Song]!
    
    init?(map: Map) { }
    
    // Mappable
    mutating func mapping(map: Map) {
        r <- map["r"]
        isShowQuickStart <- map["is_show_quick_start"]
        song <- map["song"]
    }
}

//歌曲模型
struct Song: Mappable {
    var title: String!
    var artist: String!
    
    init?(map: Map) { }
    
    // Mappable
    mutating func mapping(map: Map) {
        title <- map["title"]
        artist <- map["artist"]
    }
}

（2）下面样例演示如何获取数据，并转换成对应的模型。

//获取数据
DouBanProvider.rx.request(.channels)
    .mapObject(Douban.self)
    .subscribe(onSuccess: { 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)）")
                }
            }
        }
    }, onError: { error in
        print("数据请求失败!错误原因：", error)
    })
    .disposed(by: disposeBag)

（3）下面样例演示将数据换成模型，并绑定到表格上显示。

import UIKit
import RxSwift
import RxCocoa
import ObjectMapper

class ViewController: UIViewController {
    
    //显示频道列表的tableView
    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!)
        
        //获取列表数据
        let data = DouBanProvider.rx.request(.channels)
            .mapObject(Douban.self)
            .map{ $0.channels ?? [] }
            .asObservable()
        
        //将数据绑定到表格
        data.bind(to: tableView.rx.items) { (tableView, row, element) in
            let cell = tableView.dequeueReusableCell(withIdentifier: "Cell")!
            cell.textLabel?.text = "\(element.name!)"
            cell.accessoryType = .disclosureIndicator
            return cell
            }.disposed(by: disposeBag)
        
        //单元格点击
        tableView.rx.modelSelected(Channel.self)
            .map{ $0.channelId! }
            .flatMap{ DouBanProvider.rx.request(.playlist($0)) }
            .mapObject(Playlist.self)
            .subscribe(onNext: {[weak self] playlist in
                //解析数据，获取歌曲信息
                if playlist.song.count > 0 {
                    let artist = playlist.song[0].artist!
                    let title = playlist.song[0].title!
                    let message = "歌手：\(artist)\n歌曲：\(title)"
                    //将歌曲信息弹出显示
                    self?.showAlert(title: "歌曲信息", message: message)
                }
            }).disposed(by: disposeBag)
    }
    
    //显示消息
    func showAlert(title:String, message:String){
        let alertController = UIAlertController(title: title,
                                                message: message, preferredStyle: .alert)
        let cancelAction = UIAlertAction(title: "确定", style: .cancel, handler: nil)
        alertController.addAction(cancelAction)
        self.present(alertController, animated: true, completion: nil)
    }
}

功能改进：将网络请求服务提取出来

（1）上面的样例中我们是在 VC 里是直接调用 Moya 的 Provider 进行数据请求，并进行模型转换。

（2）我们也可以把网络请求和数据转换相关代码提取出来，作为一个专门的 Service。比如 DouBanNetworkService，内容如下：

import RxSwift
import RxCocoa
import ObjectMapper

class DouBanNetworkService {
    
    //获取频道数据
    func loadChannels() -> Observable<[Channel]> {
        return DouBanProvider.rx.request(.channels)
            .mapObject(Douban.self)
            .map{ $0.channels ?? [] }
            .asObservable()
    }
    
    //获取歌曲列表数据
    func loadPlaylist(channelId:String) -> Observable<Playlist> {
        return DouBanProvider.rx.request(.playlist(channelId))
            .mapObject(Playlist.self)
            .asObservable()
    }
    
    //获取频道下第一首歌曲
    func loadFirstSong(channelId:String) -> Observable<Song> {
        return loadPlaylist(channelId: channelId)
            .filter{ $0.song.count > 0}
            .map{ $0.song[0] }
    }
}

（3）VC 这边不再直接调用 provider，而是通过这个 Service 就获取需要的数据。可以看到代码简洁许多：

import UIKit
import RxSwift
import RxCocoa
import ObjectMapper

class ViewController: UIViewController {
    
    //显示频道列表的tableView
    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!)
        
        //豆瓣网络请求服务
        let networkService = DouBanNetworkService()
        
        //获取列表数据
        let data = networkService.loadChannels()
        
        //将数据绑定到表格
        data.bind(to: tableView.rx.items) { (tableView, row, element) in
            let cell = tableView.dequeueReusableCell(withIdentifier: "Cell")!
            cell.textLabel?.text = "\(element.name!)"
            cell.accessoryType = .disclosureIndicator
            return cell
            }.disposed(by: disposeBag)
        
        //单元格点击
        tableView.rx.modelSelected(Channel.self)
            .map{ $0.channelId! }
            .flatMap(networkService.loadFirstSong)
            .subscribe(onNext: {[weak self] song in
                //将歌曲信息弹出显示
                let message = "歌手：\(song.artist!)\n歌曲：\(song.title!)"
                self?.showAlert(title: "歌曲信息", message: message)
            }).disposed(by: disposeBag)
    }
    
    //显示消息
    func showAlert(title:String, message:String){
        let alertController = UIAlertController(title: title,
                                                message: message, preferredStyle: .alert)
        let cancelAction = UIAlertAction(title: "确定", style: .cancel, handler: nil)
        alertController.addAction(cancelAction)
        self.present(alertController, animated: true, completion: nil)
    }
}

全部评论（4）

豆花2018-09-27 20:02

楼主您好，感谢您分享的博客，看完这篇后，我有一个疑问
我想知道最后的封装请求失败的时候想做其他的事该怎么做，因为没有留请求失败时返回的方法呀
1. 站长回复：有的啊，文章最上面一段代码例里 onError 回调就是请求失败时的响应，你可以在这里面做一些请求失败后的事情。
choosingsl2018-09-18 21:05

tableview的高度如何设置呢
1. 站长回复：指的是tableview表格整体的高度吗？和以前一样，在初始化tableview时设置，或者使用约束设置。
素素2018-08-29 11:52

楼主您好，一直在看您的博客学习RXSwift . 实在有些不开窍的地方，麻烦指导一下。问：如果不同的cell 对应不同的model 用RXSourcedata + moya + ObjectMapper 应该怎么结合去写呢。
1. 站长回复：你可参考我之前写的这篇文章：Swift - RxSwift的使用详解35（UITableView的使用6：不同类型的单元格混用），你稍做修改即可。
梦子2018-08-24 11:15

航哥我经常看你的文章这个文章我有点疑惑就是我如何获取这个数据的数量呢？
1. 站长回复：不知你指的是哪个数据的数量?

Swift - RxSwift的使用详解50（结合Moya使用2：结果处理、模型转换）

三、将结果转为 JSON 对象

1，实现方法

2，使用样例

四，将结果映射成自定义对象

1，准备工作

2，使用样例

功能改进：将网络请求服务提取出来

全部评论（4）

楼主您好，感谢您分享的博客，看完这篇后，我有一个疑问 我想知道最后的封装请求失败的时候想做其他的事该怎么做，因为没有留请求失败时返回的方法呀

tableview的高度如何设置呢

楼主您好，一直在看您的博客学习RXSwift . 实在有些不开窍的地方，麻烦指导一下 。 问：如果不同的cell 对应不同的model 用RXSourcedata + moya + ObjectMapper 应该怎么结合去写呢。

航哥 我经常看你的文章 这个文章我有点疑惑 就是我如何获取这个 数据的数量呢？

楼主您好，感谢您分享的博客，看完这篇后，我有一个疑问
我想知道最后的封装请求失败的时候想做其他的事该怎么做，因为没有留请求失败时返回的方法呀

楼主您好，一直在看您的博客学习RXSwift . 实在有些不开窍的地方，麻烦指导一下。问：如果不同的cell 对应不同的model 用RXSourcedata + moya + ObjectMapper 应该怎么结合去写呢。

航哥我经常看你的文章这个文章我有点疑惑就是我如何获取这个数据的数量呢？