在之前的两篇文章中，我介绍了 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)
}
}
