RXSwift-初体验(随想)

为什么要学RXSwift?

有产生这个疑问的同学，请先看下图

🐂

试问，这么牛逼的框架不值得去研究一番嘛？？？

(贴心奉上)点了我，爱上我

决定要去做一件事，至少要知道原因，或者是需要一份动力。RXSwift官网上列举了一些例子简单告诉了我们RXSwift具备了哪些能力，比如说：

• 它可以统一处理 Delegate, KVO,Notification
• 它可以绑定UI
• 方便网络请求的处理

等等一系列能力......

但这些也只是描述了可以用RXSwift可以来做什么，而我们更关注的是为什么要选择RXSwift?

关于这一点我们需要分析下GUI 编程的本质

GUI可以抽象为视图和数据的结合

视图负责两件事：展示和交互，而展示什么由数据决定！

上图可以看到RxSwift可以在UniDirectional Data Flow的各个阶段都发挥作用，从而让Data 的处理和流动更加简洁和清晰！

具体解释如下：

• 通过对RxCocoa的各种回调进行统一处理，方便了「Interact」的处理。
• 通过对Observable的transform和composite，方便了 「Action」的生成（比如使用throttle来压缩Action）。
• 通过对网络请求以及其他异步数据的获取进行Observable封装，方便了异步数据的处理。
• 通过RxCocoa的binding，方便了数据的渲染。

综上我们能看到

RxCocoa规范了数据流，RxSwift为数据的处理提供了方便，这两个类库的结合，可以产生清晰的架构和易维护的代码

RXSwift所为何物？

在说RxSwift之前，先来说下Rx， ReactiveX 是一种编程模型，最初由微软开发，结合了观察者模式、迭代器模式和函数式编程的精华，来更方便地处理异步数据流。其中最重要的一个概念是 Observable。

在这里有个比较好的例子帮助理解这个Observable

“举个简单的例子，当别人在跟你说话时，你就是那个观察者，别人就是那个 Observable，它有几个特点：

• 可能会不断地跟你说话。（onNext:）
• 可能会说错话。（onError:）
• 结束会说话。（onCompleted）

你在听到对方说的话后，也可以有几种反应：

• 根据说的话，做相应的事，比如对方让你借本书给他。（subscribe）
• 把对方说的话，加工下再传达给其他人，比如对方说小张好像不太舒服，你传达给其他人时就变成了小张失恋了。（map:）
• 参考其他人说的话再做处理，比如 A 说某家店很好吃，B 说某家店一般般，你需要结合两个人的意见再做定夺。（zip:）”

在这里核心是当数据有变化时，能够立刻知晓，并且通过组合和转换后，可以即时作出响应。

RXSwift工作流？

在了解了RXSwift后，我们自然而然的就会想它具体的工作流程是什么呢？

其实大致可以分为这么几个阶段：

• 先把 Native Object 变成Observable
  |
• 通过 Observable 内置的各种强大的转换和组合能力变成新的 Observable
  |
• 最后消费新的 Observable 的数据

可以参考下图来理解：

RXSwift工作流

Native Object -> Observable

• rx extension
  可以说“万物皆可RX”，直接上图

万物皆可RX 万物皆可RX

看到这里，无需多言了吧。。

Observable.create

通过这个方法，可以将 Native object 包装成 Observable

  public static func create(_ subscribe: @escaping (AnyObserver<E>) -> Disposable) -> Observable<E> {
        return AnonymousObservable(subscribe)
    }

• Variable()
  Variable(value)可以把 value 变成一个 Observable

我们可以点击到它里面看一下

public final class Variable<Element> {

    public typealias E = Element

    private let _subject: BehaviorSubject<Element>

    private var _lock = SpinLock()

    // state
    private var _value: E

    #if DEBUG
    fileprivate let _synchronizationTracker = SynchronizationTracker()
    #endif

    /// Gets or sets current value of variable.
    ///
    /// Whenever a new value is set, all the observers are notified of the change.
    ///
    /// Even if the newly set value is same as the old value, observers are still notified for change.
    public var value: E {
        get {
            self._lock.lock(); defer { self._lock.unlock() }
            return self._value
        }
        set(newValue) {
            #if DEBUG
                self._synchronizationTracker.register(synchronizationErrorMessage: .variable)
                defer { self._synchronizationTracker.unregister() }
            #endif
            self._lock.lock()
            self._value = newValue
            self._lock.unlock()

            self._subject.on(.next(newValue))
        }
    }

    /// Initializes variable with initial value.
    ///
    /// - parameter value: Initial variable value.
    public init(_ value: Element) {
        #if DEBUG
            DeprecationWarner.warnIfNeeded(.variable)
        #endif

        self._value = value
        self._subject = BehaviorSubject(value: value)
    }

    /// - returns: Canonical interface for push style sequence
    public func asObservable() -> Observable<E> {
        return self._subject
    }

    deinit {
        self._subject.on(.completed)
    }
}

就会发现是它通过 subject来做的，大意是把 value存到一个内部变量_value 里，当调用 value方法时，先更新_value值，然后调用内部的_subject.on(.next(newValue))方法告知 subscriber

• Subject

Subject简单说是一个可以主动发射数据的Observable，多了 onNext(value), onError(error), ‘onCompleted’方法!

let disposeBag = DisposeBag()
let subject = PublishSubject<String>()
    
subject.addObserver("1").addDisposableTo(disposeBag)
subject.onNext("AAA")
subject.onNext("BBB")
    
subject.addObserver("2").addDisposableTo(disposeBag)
subject.onNext("😁😁😁")
subject.onNext("😝😝😝")

Subject还是建议少用，虽然官方并没有提及，但因为在以前使用RAC的时候，Subject 因其本身功能太过强大，不好控制，成了一个不太推荐使用的功能，

• Observable -> New Observable

Observable ----(修改／过滤／组合等操作)----> New Observable

换言之，Observable可以随心所欲构造自己想要的数据~！

• Combine
  Combine 就是把多个 Observable组合起来使用

• Transform
  对一个 Observable 的数值做一些小改动，产出新的值，依是 Observable

let disposeBag = DisposeBag()
Observable.of(1, 2, 3)
    .map { $0 * $0 }
    .subscribe(onNext: { print($0) })
    .addDisposableTo(disposeBag)

• Filter
  Filter的作用是对 Observable 传过来的数据进行过滤，只有符合条件的才有资格被subscribe

结语

上面只是简单介绍了RXSwift相关的一些基本概念，其实这些如果理清楚了，你会发现RXSwift并不难（尤其是具备RAC开发经验的），要习惯多去从Observable的角度分析思考问题，慢慢的就会领略到函数响应式编程的真正魅力了，同时自身的抽象能力和代码可读性都会有提升。

学习技术我个人觉得掌握其核心思想最重要，因为它是可以提升你个人认知能力的~！

这不仅仅可以帮助你解决技术问题，也可以在你生活中遇到问题时，提供解决思路~！