响应式编程(Reactive Programming,简称RP)也是一种编程范式,于1997年提出,可以简化异步编程,提供更优雅的数据绑定。
一、初始响应式编程
响应式编程一般与函数式融合在一起,所以也会叫做:函数响应式编程(Functional Reactive Programming,简称FRP)。
比较著名的,成熟的响应式框架:
ReactiveCocoa
- 简称RAC,有OC、Swift版本
- 官网:http://reactivecocoa.io/
- github:https://github.com/ReactiveCocoa
ReactiveX
- 简称Rx,有众多编程语言的版本,比如RxJava、RxKotlin、RxJS、RxCpp、RxPHP、RxGo、RxDart、RxSwift等等
- 官网:http://reactivex.io
- github:https://github.com/ReactiveX
Swift响应式编程一般使用RxSwift框架。
二、RxSwift
2.1. 安装RxSwift
源码:https://github.com/ReactiveX/RxSwift
中文文档(非官方):https://beethOven.github.io/RxSwift-Chinese-Documentation
RxSwift的github上已经有详细的安装教程,这里只演示CocoaPods方式的安装。
第一步:创建Podfile
(可以直接在项目根目录执行pod init
)
1 | Podfile |
第二步:命令行安装
注意把YOUR_TARGET_NAME
替换为自己的工程名。然后在Podfile
所在文件夹执行pod install
。
第三步:导入模块
1 | import RxSwift |
模块说明:
- RxSwift:Rx标准API的Swift实现,不包括任何iOS相关的内容
- RxCocoa:基于RxSwift,给iOS的UI控件扩展了很多Rx特性
2.2. RxSwift的核心角色
- Observable:负责发送事件(Event)
- Observer:负责订阅
Observable
,监听Observable
发送的事件(Event)
每次发送的事件是枚举类型:
1 | public enum Event<Element> { |
next
:携带具体数据error
:携带错误信息,表明Observable
终止,不会再发出事件completed
:表明Observable
终止,不会再发出事件
2.2.1. 创建、订阅Observable
示例代码:
1 | // 创建Observable第一种写法 |
只要有订阅Observable
的地方,subscribe
都会收到消息。
2.2.2. Disposable取消订阅
每当Observable
被订阅时,都会返回一个Disposable
实例,当调用Disposable
的dispose
,就相当于取消订阅。
在不需要再接收事件时,建议取消订阅,释放资源。有3种常见方式取消订阅:
第一种:立即取消订阅(一次性订阅)
1 | observable.subscribe { event in |
第二种:当bag销毁(deinit
)时,会自动调用Disposable
实例的dispose
1 | let bag = DisposeBag() |
第三种:self
销毁(deinit
)时,会自动调用Disposable
实例的dispose
1 | let _ = observable.takeUntil(self.rx.deallocated).subscribe { event in |
2.2.3. 创建Observer
第一种:AnyObserver
1 | let observer = AnyObserver<Int>.init { event in |
第二种:Binder
1 | let label = UILabel.init() |
2.3. 状态监听
2.3.1. 传统的状态监听
在开发中经常要对各种状态进行监听,传统的常见监听方案有:
- KVO
- Target-Action
- Notification
- Delegate
- Block Callback
传统方案经常会出现错综复杂的依赖关系、耦合性高,还需要编写重复的非业务代码。
2.3.2. RxSwift的状态监听
示例代码一(Target-Action):
1 | let buttton = UIButton.init(type: .custom) |
示例代码二(KVO):
1 | class Dog: NSObject { |
使用KVO的本质是调用了addObserver:forKeyPath:
,所以要使用runtime
。并且初始化实例时对属性进行了赋值,因此也会监听到初始化值。
示例代码三(Notification):
1 | NotificationCenter.default.rx |
示例代码四(既是Observable,又是Observer):
1 | let slider = UISlider() |
label.rx.text
返回的是Binder
类型,而Binder
本质是ObserverType
,所以label
只能作为Observer
。
slider.rx.value
返回的是ControlProperty
类型,ControlProperty
遵守了ControlPropertyType
协议,ControlPropertyType
协议遵守了ObservableType, ObserverType
协议,所以既可以作为Observable
,又可以作为Observer
。
示例代码五(UITableView):
1 | let tableView = UITableView.init(frame: .zero, style: .plain) |
注意:如果使用
RxSwift
,就不要遵守代理和数据源协议,否则RxSwift
就会失效。