就问此时此刻还有谁？45度仰望天空，该死！我这无处安放的魅力！
- RxSwift（1）—— 初探
- RxSwift（2）—— 核心逻辑源码分析
- RxSwift（3）—— Observable序列的创建方式
- RxSwift（4）—— 高阶函数（上）
- RxSwift（5）—— 高阶函数（下）
- RxSwift（6）—— scheduler源码解析（上）
- RxSwift（7）—— scheduler源码解析（下）
- RxSwift（8）—— KVO底层探索（上）
- RxSwift（9）—— KVO底层探索（下）
- RxSwift（10）—— 场景序列总结
- RxSwift（11）—— 销毁者-dispose源码解析
- RxSwift（12）—— Subject即攻也守
- RxSwift（13）—— 爬过的坑
- RxSwift（14）—— MVVM双向绑定
RxSwift目录直通车--- 和谐学习，不急不躁！
RxSwift是一个非常好用的框架，如果你喜欢用Swift开发，那么RxSwift是你不二的选择，函数响应式的结果，让你的代码飞起来！在上瘾RxSwift给我们带来的便捷的同时，经常也会出现一些致命的坑，让你怎么也爬不出去，难受的一匹....归其本质：你还是对RxSwift不够了解，如果你想玩好RxSwift，不妨花点时间静下心来研究一下底层！这一篇文章给大家介绍几点，平时在使用RxSwift经常会遇到的坑
RxSwift计数问题
首先有两个页面LGHomeViewController 首页和LGDetialViewController 详情,详情页面给首页进行传值，我们可以通过序列传递，达到你意想不到的快感，看代码
LGDetialViewController 中
// 内部序列响应，不被外界影响
fileprivate var mySubject = PublishSubject<Any>()
var publicOB : Observable<Any>{
return mySubject.asObservable()
}
- 对外暴露
publicOB,以便订阅信息 -
mySubject序列响应，内部事件发送 - 内外区分，达到干净的效果
LGHomeViewController 中
override func touchesBegan(_ touches: Set<UITouch>, with event: UIEvent?) {
let vc = LGDetialViewController()
vc.publicOB
.subscribe(onNext: { (item) in
print("订阅到 \(item)")
})
.disposed(by: disposeBag)
self.navigationController?.pushViewController(vc, animated: true)
}
- 首页响应
push到详情页面去 - 订阅内部响应事件，以便处理事务
上面的代码乍一看没有什么问题，其实不然，这个过程不断往首页disposeBag添加订阅事件，会导致计数不断增加，就是性能消耗
*****LGDetialViewController出现了:RxSwift的引用计数: 37
****************************************
<_01_RxSwift-内存管理.LGDetialViewController: 0x7fa966414de0>走了
销毁了
<_01_RxSwift-内存管理.LGPerson: 0x600001c8c6c0>销毁释放
text = Optional("Cooci")
*****LGDetialViewController出现了:RxSwift的引用计数: 38
****************************************
<_01_RxSwift-内存管理.LGDetialViewController: 0x7fa96665d280>走了
销毁了
<_01_RxSwift-内存管理.LGPerson: 0x600001c93780>销毁释放
text = Optional("Cooci")
*****LGDetialViewController出现了:RxSwift的引用计数: 39
****************************************
- 可以清晰的看到：计数由37-38-39
解决办法
- 思路一：最直接不加入垃圾销毁袋
-
思路二：我们分析因为，当前首页没有释放导致首页的销毁垃圾袋不断增多！
换一个垃圾销毁袋
-
思路三： 我们通过前面的销毁流程，可以直接调用
complete或者error信号达到 ：及时回收,这样就不至于一直存在首页的垃圾袋中
override func viewWillDisappear(_ animated: Bool) {
super.viewWillDisappear(animated)
// 页面要退出，及时完成以便调用dispose
mySubject.onCompleted()
}
因为调用序列的完成函数，就会导致我们的序列一次性，下次就无法响应
解决办法：重新激活
fileprivate var mySubject = PublishSubject<Any>()
var publicOB : Observable<Any>{
// 重置激活
mySubject = PublishSubject<Any>()
return mySubject.asObservable()
}
cell复用导致序列重复订阅响应
我们实际开发中避免不了使用tableView,那么在使用过程中，经常会有一个坑：cell复用
override func tableView(_ tableView: UITableView, cellForRowAt indexPath: IndexPath) -> UITableViewCell {
let cell = tableView.dequeueReusableCell(withIdentifier: "reuseIdentifier", for: indexPath) as! LGTableViewCell
cell.button.rx.tap
.subscribe(onNext: { () in
print("点击了 \(indexPath)")
})
.disposed(by: bag)
return cell
}
- 这一段代码乍一看也是没有什么问题的，包括你不滑动屏幕也不会产生问题
- 只要你一划动屏幕，因为我们的
cell的重用机制，会导致cell.button.rx.tap的订阅也会重复订阅响应，显然不是我们正常开发中想见到的样子
点击了 [0, 0]
********************
点击了 [0, 1]
********************
点击了 [0, 2]
********************
点击了 [0, 1]
点击了 [0, 21]
********************
点击了 [0, 3]
点击了 [0, 23]
********************
点击了 [0, 29]
点击了 [0, 49]
点击了 [0, 69]
********************
解决思路
-
思路一： 把主动销毁的能力收回，销毁垃圾袋交给我们的
cell.disposeBag,在我们重用响应的时候，及时销毁，重置！
// 外界订阅处理
cell.button.rx.tap
.subscribe(onNext: { () in
print("点击了 \(indexPath)")
})
.disposed(by: cell.disposeBag)
// cell内部处理
override func prepareForReuse() {
super.prepareForReuse()
// 销毁垃圾袋重置
disposeBag = DisposeBag()
}
销毁垃圾袋交给
cell自身在
prepareForReuse响应的时候，销毁垃圾袋重置效果很明显，问题得到了解决！
思路二：基类封装
class LGCustomCell: UITableViewCell{
var disposeBag = DisposeBag()
override func prepareForReuse() {
super.prepareForReuse()
disposeBag = DisposeBag()
}
}
- 把相关重用方法和我们垃圾袋封装在基类，这样就大大节省人力咯！
作为一个牛逼的开发人员，每每想到在
tableView中处理响应都需要重写prepareForReuse,我就觉得难受，此刻我要勇敢的说：RxSwift其实你可以更好
于是我带着不将就的心态构建我们的思路三和思路四
extension Reactive where Base: UITableViewCell {
// 提供给外界重用序列
public var prepareForReuse: RxSwift.Observable<Void> {
var prepareForReuseKey: Int8 = 0
if let prepareForReuseOB = objc_getAssociatedObject(base, &prepareForReuseKey) as? Observable<Void> {
return prepareForReuseOB
}
let prepareForReuseOB = Observable.of(
sentMessage(#selector(Base.prepareForReuse)).map { _ in }
, deallocated)
.merge()
objc_setAssociatedObject(base, &prepareForReuseKey, prepareForReuseOB, objc_AssociationPolicy.OBJC_ASSOCIATION_RETAIN)
return prepareForReuseOB
}
// 提供一个重用垃圾回收袋
public var reuseBag: DisposeBag {
MainScheduler.ensureExecutingOnScheduler()
var prepareForReuseBag: Int8 = 0
if let bag = objc_getAssociatedObject(base, &prepareForReuseBag) as? DisposeBag {
return bag
}
let bag = DisposeBag()
objc_setAssociatedObject(base, &prepareForReuseBag, bag, objc_AssociationPolicy.OBJC_ASSOCIATION_RETAIN)
_ = sentMessage(#selector(Base.prepareForReuse))
.subscribe(onNext: { [weak base] _ in
let newBag = DisposeBag()
guard let base = base else {return}
objc_setAssociatedObject(base, &prepareForReuseBag, newBag, objc_AssociationPolicy.OBJC_ASSOCIATION_RETAIN)
})
return bag
}
}
- 重用响应
prepareForReuse,只要发现我们的cell已发生重用，通过RxSwift就会接受到一个重用序列的响应，起到绑定效果 - 这里还合并了
cell的销毁序列，毕竟cell都销毁了也就没有任何响应的意义
cell.button.rx.tap.takeUntil(cell.rx.prepareForReuse)
.subscribe(onNext: { () in
print("点击了 \(indexPath)")
})
- 通过
takeUntil限定了button的点击响应能力
cell.button.rx.tap
.subscribe(onNext: { () in
print("点击了 \(indexPath)")
})
.disposed(by: cell.rx.reuseBag)
-
思路四：就是通过把此次响应加入到特定的销毁袋，这个销毁袋通过关联属性的方式保证了一定的性能，同时这个销毁袋是观察了
cell的重写响应，一旦有重写那么就直接销毁重置，达到自动重置效果 - 思路三&思路四都是基于最初的思路不够构建，目的也是为了：Write once, run anywhere
2019年08月10日 01：33还在坚持把博客写完，这一年一直在不断更新博客内容（因为之前一直忙还有自己惰性都没有好好更新）看到很多博主都是粉丝几千，内心也难免失落。悟已往之不谏，知来者之可追！ 接下来会持续努力和大家一起共建iOS生态强盛。我还是我，颜色不一样的烟火，我是Cooci,我为自己带盐！就问此时此刻还有谁？45度仰望天空，该死！我这无处安放的魅力！
