序言
首先先介绍两个概念, Reactive Extensions 和Functional Reactive Programming(FRP)。
Reactive Extensions
Reactive Extensions原来是由微软提出的一个综合了异步和基于事件驱动编程的库包,使用可观察序列和LINQ-style查询操作。
事件驱动编程
事件,事件代表过去发生的事件,事件既是技术架构方面的概念,也是业务概念。以事件为驱动的编程模型称为事件驱动架构EDA
。
EDA
是一种以事件为媒介,实现组件或服务之间最大松耦合的方式。传统面向接口编程是以接口为媒介,实现调用接口者和实现接口者之间的解耦,就是我们平常开发中的请求网络数据,解析数据,但是这种解耦程度不是很高,如果接口发生变化,双方的代码都需要变动,而事件驱动则是调用者和被调用者互相不知道对方,两者只和中间消息队列耦合。就像古人结婚一样,男女双方不见面,需要了解什么对方的情况只能通过媒人来了解,当然这个例子举的不太合适。下面用个图直接明了的表明一下这种方式。
事件驱动有以下特征:
1.生产者producer发生实时事件
2.推送通知
3.生产者发送消息面
4.消费者consumer立即响应
5.事件和命令是有区别的
事件驱动还有异步特征,传统方法就像我们iOS中调用什么什么method(),是一种同步模型,必须等待调用者执行完这段代码后才可以执行其他代码。而对于异步模型来说,事件生产者发出事件后,不必等待回应,可以继续执行下面的代码。
当然,还有一个重要的概念就是不代表使用了消息系统架构的都叫做EDA,还有面向服务驱动架构的SOA里面也使用了消息系统作为ESB,服务端的东西我不了解,我们做前端的也不需要过多的了解。
Functional Reactive Programming(FRP)
Functional Reactive Programming(FRP)叫做函数式反应式编程,是一种和事件流有关的编程方式,关注导致状态值改变的行为事件,一系列事件组成了事件流。
FRP是更加有效率的处理事件流,而无需显式去管理状态。
具体来说,FRP包括两个核心观点:
1.事件流,离散事件序列
2.属性,代表模型连续的值
一系列事件是导致值发生变化的原因。
总述
Rx是Reactive Extensions 的一部分,其他的开发语言比如C#,Java,JS等也有Rx。
RAC是 受 Functional Reactive Programming(FRP) 启发,但是在最近一段时间里,他们提到也受到Reactive Extensions 的启发。最终结果就是一个从Rx借鉴了一些东西,但是有着源自FRP名声的一个框架。
无论是Rx还是RAC,都不是真正意义上的FRP。
RAC是一个有着三年历史的项目了,从最初的OC开始,到3.0开始支持swift,现在直接停止了对OC的维护和更新。
Rx是严格按照ReactiveX这个组织的规定开发的,所以如果真正学会了RxSwift,再去学习什么Rx.net,Rx.js,Rx.java,都是洒洒水了,只是语法上的差异而已。
分析
RAC3.0主要有两个实体,signal
和 SignalProducer
。
signal
无论是否绑定了订阅者都可以发布事件。
SignalProducer
要有一个信号或者事件产生才会触发。
这两个区别是为了区分冷信号和热信号。what?你说你不知道什么是热信号,什么是冷信号。好吧
热信号是主动的,即使你没有订阅事件,它仍然会时刻推送。而冷信号是被动的,只有当你订阅的时候,它才会发送消息。
热信号可以有多个订阅者,是一对多,信号可以与订阅者共享信息。而冷信号只能一对一,当有不同的订阅者,消息会从新完整发送。
在RxSwift中,signal
和 SignalProducer
变成了Observable
,这两个实体在Rx中是一个东西。在RxSwift里创建Observables不需要考虑是冷信号还是热信号。冷/热信号是当你subscribing/observing产生的副作用。
对于订阅的概念两者基本是一样的。在RAC里有一点小的区别,RAC可以中断一个事件,当信号被disposed
,即使在事件发送完成信号之前。
下面说一下两者订阅时共有的吧
Next
处理新收到的值
Error
处理一个错误,结束整个流,对所有的观察者取消订阅
Complete
标记整个流已经完成,取消所有观察者的订阅
另外RAC会在收到一个disposed Signal 后中断,即使没有收到complete或者error。
在RAC中,Signal/SignalProducer都只是只读的实体,他们不能从外部被改变,RxSwift中的Observable也是如此。如果要把Signal/SignalProducer改变成可以手动改写的实体的话,你只能通过调用管道pipe()
函数返回一个可以改动的对象。在Rx中,这是一个不同的类型叫做Subject
。
RAC是连续的,串行,而Rx可以支持并发。
在Rx中所有的observable的实体的类型都是ObservableType
,所以我们可以轻松的用同一个操作符将Subject和Observable的实例组合起来。
在RAC中,Signal和SignalProducer是两种不同的对象。我们必须把SignalProducer转换成Signal后才能compose由Signal实例产生的信号。这两个对象拥有各自的操作符。所以当你需要混合使用它们时,你必须考虑到某种操作符是否是两者通用,这个时候你也不必关心冷/热的处理了。
现在signal的API主要关注在处理next
上,让你可以改变值,skip
,delay
,combineLatest
并且在不同的线程里观察值。signal producer的API主要处理信号的生命周期事件(completed,error),和一些这样的操作:then
,flatMap
,takeUntil
和catch
。
skip
跳过几个信号,不接受
delay
延迟发送next
combineLatest
将多个信号合并起来,并且拿到各个信号的最新的值,必须每个合并的signal至少都有过一次sendNext,才会触发合并的信号。
then
用于连接两个信号,当第一个信号完成,才会连接then返回的信号
flatMap
用于把源信号内容映射成一个新的内容
takeUntil
获取信号直到某个信号执行完成
catch
用于封装一个错误处理机制的signal,也就是当signal1出现了错误,将创建一个新的错误处理signal2,完成后并处理订阅者的流程,举个例子,如果要为服务器上的某个商品点赞+1,但是出现了网络不通,这个时候就要把UserDefault里的值减1
在RAC中还有Action
和Property
的概念。Action是一种处理副作用的类型,主要和用户交互相关。Property用于观察当执行一个任务后值改变了的情况。
在Rx中Action
也会转变成一个Observable
类型。RAC中的Property
对应于Rx中的Variable
或者BehaviourSubject
结论
通过本文大家可以自己抉择是用Rx呢还是RAC,个人意见是如果你的项目是主OC,不妨使用RAC,因为RAC在cocoa领域是很成熟的,如果项目是主Swift,不如尝试下Rx,一劳永逸。