概述:
ReactiveCocoa是github开源的一个函数式响应式编程框架,是在iOS平台上对FRP的实现。FRP的核心是信号,信号在ReactiveCocoa(以下简称RAC)中是通过RACSignal来表示的,信号是数据流,可以被绑定和传递。
ReactiveCocoa比较复杂,在正式开始介绍它的核心组件前,我们先来看看它的类图,以便从宏观上了解它的层次结构:
ReactiveCocoa主要包含四个组件:
- 信号源:RACStream 及其子类;
- 订阅者:RACSubscriber 的实现类及其子类;
- 调度器:RACScheduler 及其子类;
- 清洁工:RACDisposable 及其子类。
而信号源是最核心的部分,其它所有组件都是围绕它运作的。
ReactiveCocoa最简单的工作过程就是
创建信号——订阅信号——发送信号。
所以首先我们就来介绍一下信号。
一、信号源
冷信号与热信号:
信号分为冷信号与热信号,理解冷信号与热信号的区别,对于RAC的理解有非常大的帮助,所以我们这篇文章也重点讲解这里。
- Hot Observable是主动的,尽管你并没有订阅事件,但是它会时刻推送,就像鼠标移动;而Cold Observable是被动的,只有当你订阅的时候,它才会发布消息。
- Hot Observable可以有多个订阅者,是一对多,集合可以与订阅者共享信息;而Cold Observable只能一对一,当有不同的订阅者,消息是重新完整发送。
而在RAC中除了RACSubject及其子类是热信号外,其它都是冷信号。subject类似“直播”,错过了就不再处理。而signal类似“点播”,每次订阅都会从头开始。所以我们有理由认定subject天然就是热信号。
Subject具备如下三个特点:
- Subject是“可变”的。
- Subject是非RAC到RAC的一个桥梁。
- Subject可以附加行为,例如RACReplaySubject具备为未来订阅者缓冲事件的能力。
我们平常使用RACSignal最简单的步骤如下:
两段代码很简单,我也做了注释,就不再多做解释,从输出中我们可以发现:
- 0.1秒后订阅的subject1接收到了0.5秒后2秒后发送的信号,没有接收到之前发送的新号。
- 1秒后订阅的subject2接收到了2秒后发送的信号,也没有接收到之前发送的新号。
- signal1和signal2都接收到了所有信号。
从中我们可以得出结论:
- 热信号是主动的,即使你没有订阅事件,它仍然会时刻推送。如上面没有接收到的信号都是因为在没有订阅者的时候,它也会推送出去。而冷信号是被动的,只有当你订阅的时候,它才会发送消息。如第二段代码,订阅后才把信号推送出去。
- 热信号可以有多个订阅者,是一对多,信号可以与订阅者共享信息。如第一段代码,订阅者1和订阅者2是共享的,他们都能在同一时间接收到3这个值。而冷信号只能一对一,当有不同的订阅者,消息会从新完整发送。如第一个例子,我们可以观察到两个订阅者没有联系,都是基于各自的订阅时间开始接收消息的。
将冷信号转变为热信号
RAC库中对于冷信号转化成热信号有如下标准的封装:
可以看到,现在已经是热信号了,和前面的RACSubject相同。
感兴趣的同学可以去看看- (RACMulticastConnection *)multicast:(RACSubject *)subject这个方法的实现,它是将冷信号转换为热信号的核心。其实它的本质就是使用一个Subject来订阅原始信号,并让其他订阅者订阅这个Subject,这个Subject就是热信号。
使用信号中常见的问题:1、多次订阅
对RAC的信号进行转换的时候,其实就是对原有的信号进行订阅从而产生新的信号。如下代码所示:
上面分别对model进行了map,也就是产生了两个新的信号,然后再对两个信号进行订阅,对这两个信号订阅的时候,也会对间接对原信号进行订阅,从而造成对原信号的多次订阅,如上所示来了就输出了三次,如果是网络请求的话,也会输出三次,所以一定在信号转换的时候一定要注意这些情况。
要解决也很简单,把signal转换成热信号就行了
登录 | 立即注册