mojito: 麻烦给我的爱人来一份 RxSwift

WechatIMG6.jpeg

序

学过 Swift 的 同学都知道， RxSwift 宛如 周董的 mojito

开始微醺

再者上头

为什么要学习 RxSwift ？

卡蜜尔说过

优雅，永不过时


麻烦给我的爱人来一份 RxSwift

RxSwift 是 Rx 系列的 Swift 版本，相较于 OC 版的 ReactiveCocoa

它们有着异曲同工之妙 函数响应式编程(FRP)

什么是 函数响应式编程 ？


函数式:

函数式编程的核心思想是 stateless，无状态。函数本身并不关心外界输入的值

它只是在函数内部，将输入的值 和 输出的值 完成一种映射，即 input => output

比如:

func changeNum(input: Int) -> Int {
    return input * 3
}

// changeNum 并不会对input 产生改变，只是将运算之后的值 输出

无状态 意味着函数本身，不会改变外部的状态，也不会改变输入的值的状态



再比如

Q:将数组 [1,2,3,4] 里的元素 都乘以2，返回新的数组

那么一般的做法可能是:

命令式编程

let array = [1,2,3,4]
var newArray: [Int] = []

for item in array {
    var num = item
    num *= 2
    newArray.append(num)
} 
// [2,4,6,8]

命令式编程倾向于怎么做，具体是怎么把每个数都 * 2 的，那么这里 涉及到了 可变数组 newArray

如果某一个时刻，newArray 被某个地方改变了，都会达到 非预期的效果


那么函数式编程会怎么做呢？

let array = [1,2,3,4]

let newArray = array.compactMap {
    return $0 * 2
}
// [2,4,6,8]

函数式编程 和 申明式编程的 思想大体一致

它们都只关注 做什么，而不是上面的 怎么做？


函数式编程：倾向于做什么，省去其繁琐的过程，一种更为 安全，直观，易懂的编程方式


响应式:

一种抽象的事件流的异步编程方法

比如：用户点击一个按钮，发送网络请求，并将结果展示在label 上

这里网络请求是异步的

想要展示在label 上，就要拿到 网络请求的回调，进一步展示

形成事件流写法就是


button.rx.tap.subscribe(onNext: {              // 点击按钮
    HomeApi.getTitle().asObservable() // 发起网络请求
    .map { (title) -> String in       // 拿到回调进行 map
    ("我是 \(title)")
    } 
    .bind(to: (titleLabel?.rx.text)!) // 绑定给 label
    .disposed(by: rx.disposeBag)      // 管理生命周期
})


这么一个较为复杂的操作，且包含异步操作的流程

在 RxSwift 的 调整之后，是不是更为 简单易懂 ？ 事件的分发以及维护，可以在一个地方完成

大大提高了 代码的可读性，以及维护成本

整个事件流的过程 如下：

image

我们不用去关心 序列中的 每一个元素，是异步的 还是同步的，线程是否安全

只有当我们点击按钮，发送信号 之后 ，代码块内的函数体才会执行，整个一系列的事件流才会产生

这使得我们更加面向业务逻辑

而不是每一步的具体操作


那么具体 RxSwift 是怎么做到的呢？

喝完 mojito 你就知道了


我喜欢阅读它时紧皱的眉头

对于初学者来说

RxSwift 的学习曲线确实很陡，它诠释了什么是面向协议编程

过程虽然晦涩

但道阻且长

真正的大师永远怀着一颗学徒的心


rx

在RxSwift 的世界里，万物皆 rx，到处是 序列(sequence)

听着像不像 iOS 的万物皆对象

是的没错，我们来看一下rx Reactive 的定义，首先引入眼帘的是 一个 叫 ReactiveCompatible 的协议

public protocol ReactiveCompatible {
    # 关联协议
    associatedtype ReactiveBase 

    # rx 是  Reactive 类型，并将 ReactiveBase 传入
    static var rx: Reactive<ReactiveBase>.Type { get set }

    var rx: Reactive<ReactiveBase> { get set }
}


Reactive 中 还对 ReactiveCompatible进行了 协议的拓展，在这个扩展中，通过调用rx，返回的是

Reactive 类型 或者Reactive实例

extension ReactiveCompatible {
    # Reactive 类型
    public static var rx: Reactive<Self>.Type {
        get {  return Reactive<Self>.self }
    }
    # Reactive 实例
    public var rx: Reactive<Self> {
        get {  return Reactive(self) }
    }
}


在看一下 Reactive 的 实现，是一个 包含参数泛型 Base 的结构体

public struct Reactive<Base> {
    public let base: Base
    # 将 Reactive 的初始化调用者 设置为 base
    public init(_ base: Base) {
        self.base = base
    }
}


如上文中 点击按钮的 tap，即 button.rx.tap, 类型就是 UIButton 类型，将 UIButton 的实例 设置为 base

那么想 实现 万物皆rx，只需要简单的一步

extension NSObject: ReactiveCompatible { }

这样就可以让所有继承于 NSObjce 的对象，都遵循 ReactiveCompatible 协议，即 万物皆rx


Observable

Observable 意味着，可被观察的，也就是可观察序列,什么是序列呢？

我理解的就是 具备 发出事件能力的 的一种信号



比如:

肚子饿了 -> 吃饭

肚子饿了 可以作为一个 可观察序列，当我们大脑感知到 肚子饿了，就可以执行 去吃饭的操作


TextField 输入 -> 显示

TextField 输入操作可以作为一个序列，可以监听到 输入的内容


接下来

就开始调试 mojito 了

看一个订阅过程:

# 创建
let observable = Observable<String>.create { (observe) -> Disposable in
    # 发送
    observe.onNext("mojito")
    return Disposables.create()
}
# 订阅
observable.subscribe(onNext: { text in
    print(text)
}).disposed(by: rx.disposeBag)

// print "mojito"




调试开始

Observable 可观察序列

  • step1
# Observable 继承于  ObservableType
public class Observable<Element> : ObservableType {
    # 资源的引用计数 +1
    init() {
        _ = Resources.incrementTotal()
    }
     # 提供被订阅的能力，由子类实现
    public func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
        rxAbstractMethod()
    }
     # 将 Observable 类转为 Observable 实例
    public func asObservable() -> Observable<Element> {
        return self
    }
     # 资源的引用计数 -1
    deinit {
        _ = Resources.decrementTotal()
    }
}


可是这里并没有看到序列的创建，但是可以看到一个 继承关系: Observable<Element> : ObservableType

进入 ObservableType

  • step2
# 协议  ObservableType，继承于 ObservableConvertibleType
public protocol ObservableType: ObservableConvertibleType {
    func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element
}

# ObservableType 扩展
extension ObservableType {
    # 提供了一个方法，将遵守 ObservableType 协议的对象 转为 Observable 实体
    public func asObservable() -> Observable<Element> {
        return Observable.create { o in
            return self.subscribe(o)
        }
    }
}

这里还是 没有看到 订阅的方法

还发现了 自己的爸爸是个协议， 还有爷爷 ObservableConvertibleType


持着怀疑的态度，你又点进了 ObservableConvertibleType

  • step3
# 也是个协议
public protocol ObservableConvertibleType {

    associatedtype Element
    typealias E = Element
    
    # 定义了一个方法，返回类型 Observable 可观察序列
    func asObservable() -> Observable<Element>
}
image


可恶

既然这条路走不通，只能先不走了

哪里跌倒

我就躺在哪里

为了达到万物皆序列，我们就要想办法把所有事件转化为序列，asObservable() 即为 RxSwift 的精髓


Observable.create()

点击 creat ，豁然开朗，原来创建是通过 ObservableType 扩展，这也同时证明了 OOP 的好处，可扩展性强

ObservableType 像是一家名叫 ObservableType 的连锁公司

它可以在任何地方开个分店

实现自己公司的业务

  • step4
#  ObservableType 的扩展
extension ObservableType {
    public static func create(_ subscribe: @escaping (AnyObserver<Element>) -> Disposable) -> Observable<Element> {
        # 返回一个 匿名观察序列，将 subscribe 逃逸闭包传入
        return AnonymousObservable(subscribe)
    }
}

点击 AnonymousObservable 进入

  • step5
# 私有方法，外界无法共享
# AnonymousObservable 继承于  Producer
final private class AnonymousObservable<Element>: Producer<Element> {
    typealias SubscribeHandler = (AnyObserver<Element>) -> Disposable
    # 定义 闭包属性
    let _subscribeHandler: SubscribeHandler
    # 将外界传入的 闭包 保存
    init(_ subscribeHandler: @escaping SubscribeHandler) {
        self._subscribeHandler = subscribeHandler
    }
    # 重写 父类 Producer 提供的 run 方法
    override func run<Observer: ObserverType>(_ observer: Observer, cancel: Cancelable) -> (sink: Disposable, subscription: Disposable) where Observer.Element == Element {
        # 初始化匿名管道，传入一个订阅者
        let sink = AnonymousObservableSink(observer: observer, cancel: cancel)
        let subscription = sink.run(self)
        return (sink: sink, subscription: subscription)
    }
}


这里又来了个 Producer，点击 Producer

  • step6
# Producer 同样继承于 Observable
class Producer<Element> : Observable<Element> {
    override init() {
        super.init()
    }

# 这里涉及到了线程，如果  CurrentThreadScheduler 指定了某个线程，那么就会在指定线程中 执行 run
# 否则 就会在当前线程中 执行 run
# SinkDisposer实例 disposer,用来管理资源释放
override func subscribe<Observer: ObserverType>(_ observer: Observer) -> Disposable where Observer.Element == Element {
         if !CurrentThreadScheduler.isScheduleRequired {
            // The returned disposable needs to release all references once it was disposed.
            let disposer = SinkDisposer()
            let sinkAndSubscription = self.run(observer, cancel: disposer)
            disposer.setSinkAndSubscription(sink: sinkAndSubscription.sink, subscription: sinkAndSubscription.subscription)
            return disposer
        }
        else {
            return CurrentThreadScheduler.instance.schedule(()) { _ in
                let disposer = SinkDisposer()
                let sinkAndSubscription = self.run(observer, cancel: disposer)
                disposer.setSinkAndSubscription(sink: sinkAndSubscription.sink, subscription: sinkAndSubscription.subscription)
                return disposer
            }
        }
  }
# 抽象方法，子类去实现，也就是匿名序列 AnonymousObservable
func run<Observer: ObserverType>(_ observer: Observer, cancel: Cancelable) -> (sink: Disposable, subscription: Disposable) where Observer.Element == Element {
    rxAbstractMethod()
    }
}

相信到此，你我都已经微醺了

你问我什么是 序列 ？

我 指 着 大 海 的 方 向


目前也只能先画个图，继续观望

image


小结

  • 小结

    • 我们调用父类协议的 creat 方法 ，生成 匿名观察序列，即Producer 的子类AnonymousObservable
    • AnonymousObservable 保存外界传入的 闭包
    • 负责资源管理，引用计数的 是 Observable 抽象类，不实现方法
    • Producer 类 实现 外界 subscribe 方法，并安排线程调度
    • 具体的 run，由 AnonymousObservable 实现，父类 Producer不负责


ok ，继续往下走

subscribe(onNext:) 订阅

点击 subscribe 进入，可以看到 ObservableType 的扩展,提供了 subscribe.on 和 subscribe.onNext 2个方法

此处省略了 subscribe.on

  • step7
extension ObservableType {
    ...
    
    public func subscribe(onNext: ((Element) -> Void)? = nil, onError: ((Swift.Error) -> Void)? = nil, onCompleted: (() -> Void)? = nil, onDisposed: (() -> Void)? = nil)
        -> Disposable {
            ....
            # 创建一个 匿名订阅者  AnonymousObserver
            # 对外界传入的执行闭包 进行保存
            let observer = AnonymousObserver<Element> { event in
                switch event {
                case .next(let value):
                    onNext?(value)
                case .error(let error):
                    if let onError = onError {
                        onError(error)
                    } else { Hooks.defaultErrorHandler(callStack, error) }
                    disposable.dispose()
                case .completed:
                    onCompleted?()
                    disposable.dispose()
                }
            }
            return Disposables.create(
                self.asObservable().subscribe(observer),
                disposable
            )
    }
}

这里将 外界需要执行的 闭包，即本例中的 print(text)，生成 AnonymousObserver 实例，传入

self.asObservable().subscribe(observer)

也就是说，这个 AnonymousObserver实例，会通过 Producer 调用 subscribe

然后由 子类 AnonymousObservable，序列实例去调用 run方法


来到文中，step 5 的 run 方法，如下

# 将外界 需要执行的闭包 ，以及 资源销毁实例 生成的 元祖 传入  AnonymousObservableSink
# 生成 sink 管道实例，并执行 run 
# 将run 之后生成的实例，赋值给  subscription，并返回 subscription 和  sink

override func run<Observer: ObserverType>(_ observer: Observer, cancel: Cancelable) -> (sink: Disposable, subscription: Disposable) where Observer.Element == Element {
    let sink = AnonymousObservableSink(observer: observer, cancel: cancel)
    let subscription = sink.run(self)
    return (sink: sink, subscription: subscription)
}


进入 AnonymousObservableSink

  • step8
final private class AnonymousObservableSink<Observer: ObserverType>: Sink<Observer>, ObserverType {
    typealias Element = Observer.Element 
    typealias Parent = AnonymousObservable<Element>
    
    # 调用父类 Sink 的初始化方法，传入  observer 和 cancel，即 管道 AnonymousObservableSink 持有 这2个属性
    override init(observer: Observer, cancel: Cancelable) {
        super.init(observer: observer, cancel: cancel)
    }

    func on(_ event: Event<Element>) {
        switch event {
        case .next:
            if load(self._isStopped) == 1 {
                return
            }
            self.forwardOn(event)
        case .error, .completed:
            if fetchOr(self._isStopped, 1) == 0 {
                self.forwardOn(event)
                self.dispose()
            }
        }
    }
    ### 熟悉的东西有没有
    # 这里看到了  _subscribeHandler，也就是 发出的信号，保存的闭包
    
    func run(_ parent: Parent) -> Disposable {
        return parent._subscribeHandler(AnyObserver(self))
    }
}

到这里，我们就会发现 sink 管道 它很重要

它持有了

要销毁的实例，发出序列的闭包，执行序列的闭包

image
这里的  AnyObserver(self) 是为了 兼容传入 闭包的类型， 本文对应的 是 String



也就是说，一旦外界开始订阅序列

那么 火车序列 就开始发动了，但是 怎么响应？ 下一步往哪开？

这就要看 AnyObserver(self)，做了什么，进入 AnyObserver， 查看init


 public init<Observer: ObserverType>(_ observer: Observer) where Observer.Element == Element {
    self.observer = observer.on
}

你会发现这里的 self.observer 保存了 自己的 on 方法

也就是保存的了一个 function

即 会调用 step8 中 的 on, 然后 去调用 父类Sink 的 forwardOn


  • step9
# 父类 Sink
class Sink<Observer: ObserverType> : Disposable {
    final func forwardOn(_ event: Event<Observer.Element>) {
        #if DEBUG
            self._synchronizationTracker.register(synchronizationErrorMessage: .default)
            defer { self._synchronizationTracker.unregister() }
        #endif
        if isFlagSet(self._disposed, 1) {
            return
        }
        # 订阅者
        self._observer.on(event)
    }
}


在父类 forwardOn中， 由订阅者执行 on 事件

可是 订阅者 AnonymousObserver 类有没有 on 方法，只有 onCore

所以去 AnonymousObserver 的 父类中 ObserverBase 寻找

class ObserverBase<Element> : Disposable, ObserverType {
    private let _isStopped = AtomicInt(0)

    func on(_ event: Event<Element>) {
        switch event {
        case .next:
            if load(self._isStopped) == 0 {
                self.onCore(event)
            }
        case .error, .completed:
            if fetchOr(self._isStopped, 1) == 0 {
                self.onCore(event)
            }
        }
    }
    # 子类实现
    func onCore(_ event: Event<Element>) {
        rxAbstractMethod()
    }
}

最后 AnonymousObserver 调用自己的 onCore 执行 eventHandler 闭包

到此

整个执行的过程算是走完了

关于资源回收的内容，后续文章会写到



到此

mojito 初体验 结束

image

小结

  • 小结
    • 通过 AnonymousObservable 保存 可观察序列
    • 通过 AnonymousObserve 保存 执行闭包
    • 外界开始订阅，由 Producer 调度线程，执行 subscribe
    • 生成 SinkDisposer 以及 observer 实例 元祖
    • 将 元祖 注入 Sink 管道
    • Sink 处理事件，发出信号，响应序列
    • 资源回收


简单的流程图如下

image


而我的写法，轻松像魔法

有了RxSwift ，日常开发就变得酣畅淋漓了，比如

  • 监听 tableView 的滚动:
 tableView.rx.contentOffset.subscribe(onNext: { contentOffset in
    /// 修改透明度
 })
.disposed(by: rx.disposeBag)


  • 监听textField 输入
 textField.rx.text.skip(1).subscribe(onNext: { (text) in
    print("输入的是 : \(text!)")
 })
 .disposed(by: rx.disposeBag)


  • 按钮点击
 self.messageBtn.rx.tap.subscribe(onNext: { in
    Navigator.push("")
 })
 .disposed(by: rx.disposeBag)


  • tableView 绑定数据源 代理
  # 这里需要导入 RxDataSources
  dataSource = RxTableViewSectionedReloadDataSource(configureCell: { (_, tab, indexPath, item) -> UITableViewCell in
    let cell = tab.dequeue(Reusable.settingCell, for: indexPath)
    cell.bind(to: item)
    return cell
  })
  
  # 或者
  let items = Observable.just([
    "Just",
    "Relay",
    "From",
    "Driver",
    "merge"
  ])
  
 items.bind(to: tableView.rx.items) { (tableView,_,element) in
    let cell = self.tableView.dequeue(TestV.normalCell)
    cell?.textLabel?.text = element
    return cell!
  }
  .disposed(by: rx.disposeBag)


  • tableView 点击代理
 tableView.rx.itemSelected.subscribe(onNext: { indexPath in
   /// doSomething
 })
 .disposed(by: rx.disposeBag)


  • 配合 HandyJSON 转model
extension Response {
    func mapHandyJsonModel<T: HandyJSON>(_ type: T.Type) -> T {
        let jsonString = String.init(data: data, encoding: .utf8)
        if let modelT = JSONDeserializer<T>.deserializeFrom(json: jsonString) {
            return modelT
        }
        return JSONDeserializer<T>.deserializeFrom(json: "{\"msg\":\"解析有误\"}")!
    }
}

extension ObservableType where Element == Response {
    /// 注释
    public func mapHandyJsonModel<T: HandyJSON>(_ type: T.Type) -> Observable<T> {
        return flatMap { response -> Observable<T> in
            return Observable.just(response.mapHandyJsonModel(T.self))
        }
    }
}

# 配合 Moya 
static func getTopList() -> Observable<HomeResponseModel> {
    return HomeApiProvider.rx.request(.Top).asObservable().mapHandyJsonModel(HomeResponseModel.self)
}


  • 多个请求合并
 Observable.zip(HomeApi.getTopList(), HomeApi.getRecommondList()).subscribe(onNext: { topResponse, recommodResponse in
    /// 数据处理
  }).disposed(by: self.rx.disposeBag)



等等....

先介绍一点简单的用法

后续会慢慢更新

image


这世界因我让你不再受折磨

RxSwift 熟悉了之后，会让我们的代码变得 简洁且优雅

它面向协议编程，我们面向业务编程

RxSwift 需要慢慢品味

听一遍 mojito 肯定是不够的

不说了

听歌去了~



对了

RxSwift 中文网

没喝过 mojito 的 就从这里开始吧~

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
  • 人面猴
    序言：七十年代末，一起剥皮案震惊了整个滨河市，随后出现的几起案子，更是在滨河造成了极大的恐慌，老刑警刘岩，带你破解...
    沈念sama阅读 204,684评论 6赞 478
  • 死咒
    序言：滨河连续发生了三起死亡事件，死亡现场离奇诡异，居然都是意外死亡，警方通过查阅死者的电脑和手机，发现死者居然都...
    沈念sama阅读 87,143评论 2赞 381
  • 救了他两次的神仙让他今天三更去死
    文/潘晓璐 我一进店门，熙熙楼的掌柜王于贵愁眉苦脸地迎上来，“玉大人，你说我怎么就摊上这事。” “怎么了？”我有些...
    开封第一讲书人阅读 151,214评论 0赞 337
  • 道士缉凶录：失踪的卖姜人
    文/不坏的土叔 我叫张陵，是天一观的道长。 经常有香客问我，道长，这世上最难降的妖魔是什么？ 我笑而不...
    开封第一讲书人阅读 54,788评论 1赞 277
  • 港岛之恋（遗憾婚礼）
    正文 为了忘掉前任，我火速办了婚礼，结果婚礼上，老公的妹妹穿的比我还像新娘。我一直安慰自己，他们只是感情好，可当我...
    茶点故事阅读 63,796评论 5赞 368
  • 恶毒庶女顶嫁案：这布局不是一般人想出来的
    文/花漫 我一把揭开白布。 她就那样静静地躺着，像睡着了一般。 火红的嫁衣衬着肌肤如雪。 梳的纹丝不乱的头发上，一...
    开封第一讲书人阅读 48,665评论 1赞 281
  • 城市分裂传说
    那天，我揣着相机与录音，去河边找鬼。 笑死，一个胖子当着我的面吹牛，可吹牛的内容都是我干的。 我是一名探鬼主播，决...
    沈念sama阅读 38,027评论 3赞 399
  • 双鸳鸯连环套：你想象不到人心有多黑
    文/苍兰香墨 我猛地睁开眼，长吁一口气：“原来是场噩梦啊……” “哼！你这毒妇竟也来了？” 一声冷哼从身侧响起，我...
    开封第一讲书人阅读 36,679评论 0赞 258
  • 万荣杀人案实录
    序言：老挝万荣一对情侣失踪，失踪者是张志新（化名）和其女友刘颖，没想到半个月后，有当地人在树林里发现了一具尸体，经...
    沈念sama阅读 41,346评论 1赞 299
  • 护林员之死
    正文 独居荒郊野岭守林人离奇死亡，尸身上长有42处带血的脓包…… 初始之章·张勋 以下内容为张勋视角 年9月15日...
    茶点故事阅读 35,664评论 2赞 321
  • 白月光启示录
    正文 我和宋清朗相恋三年，在试婚纱的时候发现自己被绿了。 大学时的朋友给我发了我未婚夫和他白月光在一起吃饭的照片。...
    茶点故事阅读 37,766评论 1赞 331
  • 活死人
    序言：一个原本活蹦乱跳的男人离奇死亡，死状恐怖，灵堂内的尸体忽然破棺而出，到底是诈尸还是另有隐情，我是刑警宁泽，带...
    沈念sama阅读 33,412评论 4赞 321
  • 日本核电站爆炸内幕
    正文 年R本政府宣布，位于F岛的核电站，受9级特大地震影响，放射性物质发生泄漏。R本人自食恶果不足惜，却给世界环境...
    茶点故事阅读 39,015评论 3赞 307
  • 男人毒药：我在死后第九天来索命
    文/蒙蒙 一、第九天 我趴在偏房一处隐蔽的房顶上张望。 院中可真热闹，春花似锦、人声如沸。这庄子的主人今日做“春日...
    开封第一讲书人阅读 29,974评论 0赞 19
  • 一桩弑父案，背后竟有这般阴谋
    文/苍兰香墨 我抬头看了看天上的太阳。三九已至，却和暖如春，着一层夹袄步出监牢的瞬间，已是汗流浃背。 一阵脚步声响...
    开封第一讲书人阅读 31,203评论 1赞 260
  • 情欲美人皮
    我被黑心中介骗来泰国打工， 没想到刚下飞机就差点儿被人妖公主榨干…… 1. 我叫王不留，地道东北人。 一个月前我还...
    沈念sama阅读 45,073评论 2赞 350
  • 代替公主和亲
    正文 我出身青楼，却偏偏与公主长得像，于是被迫代替她去往敌国和亲。 传闻我的和亲对象是个残疾皇子，可洞房花烛夜当晚...
    茶点故事阅读 42,501评论 2赞 343