Swift - RxSwift的使用详解45(结合RxAlamofire使用1:数据请求)
在之前的两篇文章中,我介绍了 RxSwift 对 URLSession 的扩展以及使用。当然除了可以使用 URLSession 进行网络请求外,网上还有许多优秀的第三方网络库也可以与 RxSwift 结合使用的,比如:RxAlamofire 和 Moya。这次我先介绍下前者。
一 、安装配置
1,引入 Alamofire
由于 RxAlamofire 是对 Alamofire 的封装,所以我们项目中先要把 Alamofire 库给引入进来。关于 Alamofire 的安装配置可以参考我之前的文章:
2,添加 RxAlamofire
(1)这里我使用手动配置的方式,先把 RxAlamofire 库下载到本地。
(2)接着把里面的 RxAlamofire.swift 文件添加到我们的项目中即可。

二、基本用法
1,使用 request 请求数据
(1)下面代码我们通过豆瓣提供的频道列表接口获取数据,并将返回结果输出到控制台中。

//创建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 str = String(data: data, encoding: String.Encoding.utf8) print("返回的数据是:", str ?? "") }).disposed(by: disposeBag)
(2)如果还要处理失败的情况,可以在 onError 回调中操作。我们把 url 改成一个错误的地址,运行结果如下:

//创建URL对象 let urlString = "https://www.douban.com/jxxxxxxxx/app/radio/channels" let url = URL(string:urlString)! //创建并发起请求 request(.get, url) .data() .subscribe(onNext: { data in //数据处理 let str = String(data: data, encoding: String.Encoding.utf8) print("返回的数据是:", str ?? "") }, onError: { error in print("请求失败!错误原因:", error) }).disposed(by: disposeBag)
2,使用 requestData 请求数据
(1)下面代码同样是获取豆瓣频道数据,并将返回结果输出到控制台中。
//创建URL对象 let urlString = "https://www.douban.com/j/app/radio/channels" let url = URL(string:urlString)! //创建并发起请求 requestData(.get, url).subscribe(onNext: { response, data in //数据处理 let str = String(data: data, encoding: String.Encoding.utf8) print("返回的数据是:", str ?? "") }).disposed(by: disposeBag)
(2)使用 requestData 的话,不管请求成功与否都会进入到 onNext 这个回调中。如果我们想要根据响应状态进行一些相应操作,通过 response 参数即可实现。
//创建URL对象 let urlString = "https://www.douban.com/jxxxxxxx/app/radio/channels" let url = URL(string:urlString)! //创建并发起请求 requestData(.get, url).subscribe(onNext: { response, data in //判断响应结果状态码 if 200 ..< 300 ~= response.statusCode { let str = String(data: data, encoding: String.Encoding.utf8) print("请求成功!返回的数据是:", str ?? "") }else{ print("请求失败!") } }).disposed(by: disposeBag)
3,获取 String 类型数据
(1)如果请求的数据是字符串类型的,我们可以在 request 请求时直接通过 responseString() 方法实现自动转换,省的在回调中还要手动将 data 转为 string。

//创建URL对象 let urlString = "https://www.douban.com/j/app/radio/channels" let url = URL(string:urlString)! //创建并发起请求 request(.get, url) .responseString() .subscribe(onNext: { response, data in //数据处理 print("返回的数据是:", data) }).disposed(by: disposeBag)
(2)当然更简单的方法就是直接使用 requestString 去获取数据。
//创建URL对象 let urlString = "https://www.douban.com/j/app/radio/channels" let url = URL(string:urlString)! //创建并发起请求 requestString(.get, url) .subscribe(onNext: { response, data in //数据处理 print("返回的数据是:", data) }).disposed(by: disposeBag)
三、手动发起请求、取消请求
在很多情况下,网络请求并不是由程序自动发起的。可能需要我们点击个按钮,或者切换个标签时才去请求数据。而且除了可以手动发起请求外,同样可能还需要能手动取消上一次的网络请求(如果未完成)。下面通过样例演示这个功能如何实现。
1,效果图
(1)每次点击“发起请求”按钮则去请求一次数据。
(2)如果请求没返回时,点击“取消请求”则可将其取消(取消后即使返回数据也不处理了)。

2,样例代码
import UIKit import RxSwift import RxCocoa import Alamofire class ViewController: UIViewController { //“发起请求”按钮 @IBOutlet weak var startBtn: UIButton! //“取消请求”按钮 @IBOutlet weak var cancelBtn: UIButton! let disposeBag = DisposeBag() override func viewDidLoad() { super.viewDidLoad() //创建URL对象 let urlString = "https://www.douban.com/j/app/radio/channels" let url = URL(string:urlString)! //发起请求按钮点击 startBtn.rx.tap.asObservable() .flatMap { request(.get, url).responseString() .takeUntil(self.cancelBtn.rx.tap) //如果“取消按钮”点击则停止请求 } .subscribe(onNext: { response, data in print("请求成功!返回的数据是:", data) }, onError: { error in print("请求失败!错误原因:", error) }).disposed(by: disposeBag) } }