最近有幸学习了一下RxSwift框架，突然有了一种发现新大陆的感觉，虽然之前也一直在用OC的RAC框架，但是在Swift开发中RxSwift真的是iOS开发者的利器，后悔没有早点接触，特此记录一下。
官网地址
1、RxSwift导入
话不多说，直接上实操：
使用pods直接install最新的库，cocoapods安装就不说了，参考：cocoapods详解
target 'YOUR_TARGET_NAME' do
pod 'RxSwift', '6.5.0'
pod 'RxCocoa', '6.5.0'
end
2、RxSwift简单使用
import RxSwift
import RxCocoa
KVO使用
正常操作需要三步，1、添加观察者对象 2、实现监听方法 3、销毁观察者
// 添加观察者对象
func setupKVO() {
self.person.addObserver(self, forKeyPath: "name", options: .new, context: nil)
}
// 实现监听方法
override func observeValue(forKeyPath keyPath: String?, of object: Any?, change: [NSKeyValueChangeKey : Any]?, context: UnsafeMutableRawPointer?) {
print("响应")
print(change as Any)
}
// 销毁观察者
deinit {
self.removeObserver(self.person, forKeyPath: "name", context: nil)
}
相对来说，用rxSwift实现，一步到位，代码简洁，模块功能划分清晰，不用这边写一个那边写一个，增加代码可读性和可维护性
func setupKVO() {
self.person.rx.observeWeakly(String.self, "name")
.subscribe { value in
print(value as Any)
}
.disposed(by: disposeBag)
}
UIButton使用
UIButton我们平时使用也是一样，点击事件需要addTarget，然后在某一个地方，实现点击事件函数；
同样的，用RxSwift也是一目了然。
// self.button.addTarget(self, action: #selector(<#T##@objc method#>), for: .touchUpInside)
self.button.rx.controlEvent(.touchUpInside)
.subscribe { _ in
print("点击事件")
}
.disposed(by: disposeBag)
UITextField
func setupTextFiled() {
self.textFiled.rx.text.orEmpty.changed
.subscribe { text in
print(text)
}
.disposed(by: disposeBag)
}
同时textFiled也可以跟button进行双向绑定，输入文字同步修改按钮的值，也可以根据输入文字长度，动态变更按钮状态；
这个bind确实很好用，让我想起之前做前端开发的时候，用的vue框架，v-bind，v-on，无需关心逻辑代码，专心写好业务代码就好，简直不要太爽
self.textFiled.rx.text
.bind(to: self.button.rx.title())
.disposed(by: disposeBag)
// 根据输入文字长度，动态变更按钮状态
let isEnabled = textFiled.rx.text.orEmpty
.map { text in
return text.count >= 6
}
isEnabled.bind(to: button.rx.isEnabled)
.disposed(by: disposeBag)
UIScrollView
UIScrollView的用法同样也可以订阅我们想要的内容，比如监听contentOffset变化，平时我们可能要设置delegate，然后在遵循方法，修改等等，使用rx就是一步到位，比如我们常见的向下滚动，导航栏透明，一行代码就可以搞定；
func setupScrollerView() {
scrollView.rx.contentOffset
.subscribe { [weak self]content in
self?.titleView.alpha = (100-content.y)/(100)
}
.disposed(by: disposeBag)
}
手势
手势用起来同样也很简单，直接rx.event就可以
func setupGestureRecognizer() {
let tap = UITapGestureRecognizer()
self.label.addGestureRecognizer(tap)
self.label.isUserInteractionEnabled = true
tap.rx.event.subscribe { tap in
print(tap.view!)
}
.disposed(by: disposeBag)
}
通知
func setupNotification() {
NotificationCenter.default.rx.notification(UIResponder.keyboardWillShowNotification)
.subscribe { noti in
print(noti)
}
.disposed(by: disposeBag)
}
网络请求
网络请求步骤其实没有比之前简化多少，只是它帮我们做了处理，成功失败都有区分开，无需再判断是否有error，只关心业务实现就可以
func setupNetwork() {
let url = URL(string: "https://www.baidu.com")
// 正常的网络请求步骤
// URLSession.shared.dataTask(with: url!) { data, response, error in
// print(String.init(data: data!, encoding: .utf8)!)
// }.resume()
URLSession.shared.rx.response(request: URLRequest(url: url!))
.subscribe(onNext: { response, data in
print(response)
}, onError: { error in
print(error)
})
.disposed(by: disposeBag)
}
定时器
这个定时器就比较有点不同了，实际上是个可观察序列，给这个序列添加subscribe订阅回调，一秒回调一次
func setupTimer() {
timer = Observable<Int>.interval(.seconds(1), scheduler: MainScheduler.instance)
timer.subscribe { num in
print(num)
}
.disposed(by: disposeBag)
}
有个小细节需要注意一下，DisposeBag翻译过来就是垃圾袋的意思，回收rx开辟的内存的地方，如果使用局部变量DisposeBag()，容易出错，可能函数出栈就被释放掉了，导致rx真正要释放时，没有DisposeBag可以用；建议一个类对象里面共用一个disposeBag全局变量，当前对象被销毁，它也跟着被释放，
let disposeBag = DisposeBag()
// DisposeBag() 容易出问题
URLSession.shared.rx.response(request: URLRequest(url: url!))
.subscribe { response, data in
print(response)
}
.disposed(by: DisposeBag())
3、总结
像RxSwift这种函数响应式框架其实在OC、Swift中都很常见，常见的比如Masonry，这种代码的书写可读性、清晰度、可维护性都很高，当然OC中的RAC跟RxSwift是有异曲同工之妙的，可以理解为RxSwift就是Swift版的RAC；
