RxSwift（或者说 RxCocoa）除了对系统原生的 UI 控件提供了 rx 扩展外，对 URLSession 也进行了扩展，从而让我们可以很方便地发送 HTTP 请求。
一、请求网络数据
1，通过 rx.response 请求数据
（1）下面代码我们通过豆瓣提供的音乐频道列表接口获取数据，并将返回结果输出到控制台中。
//创建URL对象
let urlString = "https://www.douban.com/j/app/radio/channels"
let url = URL(string:urlString)
//创建请求对象
let request = URLRequest(url: url!)
//创建并发起请求
URLSession.shared.rx.response(request: request).subscribe(onNext: {
(response, data) in
//数据处理
let str = String(data: data, encoding: String.Encoding.utf8)
print("返回的数据是：", str ?? "")
}).disposed(by: disposeBag)
（2）从上面样例可以发现，不管请求成功与否都会进入到 onNext 这个回调中。如果我们需要根据响应状态进行一些相应操作，比如：
- 状态码在 200 ~ 300 则正常显示数据。
- 如果是异常状态码（比如：404）则弹出告警提示框。
这个借助 response 参数进行判断即可。我们把 url 改成一个错误的地址，运行结果如下：
//创建URL对象
let urlString = "https://www.douban.com/xxxxxxxxxx/app/radio/channels"
let url = URL(string:urlString)
//创建请求对象
let request = URLRequest(url: url!)
//创建并发起请求
URLSession.shared.rx.response(request: request).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)
2，通过 rx.data 请求数据
rx.data与rx.response的区别：
- 如果不需要获取底层的
response，只需知道请求是否成功，以及成功时返回的结果，那么建议使用rx.data。- 因为
rx.data会自动对响应状态码进行判断，只有成功的响应（状态码为 200~300）才会进入到onNext这个回调，否则进入onError这个回调。
（1）如果不需要考虑请求失败的情况，只对成功返回的结果做处理可以在 onNext 回调中进行相关操作。
//创建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 str = String(data: data, encoding: String.Encoding.utf8)
print("请求成功！返回的数据是：", str ?? "")
}).disposed(by: disposeBag)
（2）如果还要处理失败的情况，可以在 onError 回调中操作。
//创建URL对象
let urlString = "https://www.douban.com/xxxxxx/app/radio/channels"
let url = URL(string:urlString)
//创建请求对象
let request = URLRequest(url: url!)
//创建并发起请求
URLSession.shared.rx.data(request: request).subscribe(onNext: {
data in
let str = String(data: data, encoding: String.Encoding.utf8)
print("请求成功！返回的数据是：", str ?? "")
}, onError: { error in
print("请求失败！错误原因：", error)
}).disposed(by: disposeBag)
二、手动发起请求、取消请求
在很多情况下，网络请求并不是由程序自动发起的。可能需要我们点击个按钮，或者切换个标签时才去请求数据。除了手动发起请求外，同样的可能还需要手动取消上一次的网络请求（如果未完成）。下面通过样例演示这个如何实现。
1，效果图
（1）每次点击“发起请求”按钮则去请求一次数据。
（2）如果请求没返回时，点击“取消请求”则可将其取消（取消后即使返回数据也不处理了）。
2，样例代码
import UIKit
import RxSwift
import RxCocoa
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)
//创建请求对象
let request = URLRequest(url: url!)
//发起请求按钮点击
startBtn.rx.tap.asObservable()
.flatMap {
URLSession.shared.rx.data(request: request)
.takeUntil(self.cancelBtn.rx.tap) //如果“取消按钮”点击则停止请求
}
.subscribe(onNext: {
data in
let str = String(data: data, encoding: String.Encoding.utf8)
print("请求成功！返回的数据是：", str ?? "")
}, onError: { error in
print("请求失败！错误原因：", error)
}).disposed(by: disposeBag)
}
}
