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,我为自己带盐！