ReactiveCocoa(简称RAC,以下都用RAC)是github团队开源的一套基于Cocoa并且具有FRP(Functional Reactive Programming-响应式编程)特性的框架。RAC本身就是一个第三方类库,使用它可以大大提高开发效率,简化代码,目前在各个公司也在大范围使用。RAC比较复杂,在正式介绍之前,先看一下它的类图,以便大致了解层次结构。

RAC(ReactiveCocoa)概括-LMLPHP

RAC主要包含了四个组件

  • 信号源方面:RACStream及其子类
  • 订阅者方面:RACSubscriber及其子类
  • 调度器方面:RACScheduler及其子类
  • 清洁工方面:RACDisposable及其子类

在RAC中,信号源是最核心的部分,其工作过程是:创建信号--订阅信号--发送信号。

拓展:响应式编程(FRP)

在命令式编程中,a = b + c代表是b与c的加和结果赋值给a,如果之后再改变b或者c的值并不会影响a。但是在响应式编程中,a的值会随着b或者c的变化而变化,也就是a的结果和b与存在绑定关系,b或者c的变化会直接影响a。这就是响应式编程(FRP),举个简单的例子。

信号源

信号分为冷信号和热信号。

理解冷信号和热信号的区别对RAC的理解有非常大的帮助,下面我们重点讲解这:

  • Hot Observable(热信号)是主动的,即使你没有订阅信号,它也会时可推送,例如鼠标移动;而Cold Observable(冷信号)是被动的,也就是只有你订阅信号,它才会发布消息,反之不然。
  • Hot Observable(热信号)可以有多个订阅者,是一对多,整个集合可以与订阅者共享信息;而Cold Observable只能一对一,遇到有不同的订阅者,消息是重新完整发送的。

在RAC中除了RACSubject和其子类是热信号,剩下的就是冷信号。RACSubject和其子类类似直播,错过之后也就不会处理了;而signal类似点播,每次发送订阅,都是从头开始。

Subject具备如下特点:

  • Subject是非RAC到RAC的桥梁
  • Subject可以附加行为:RACReplaySubject具备为订阅者缓冲事件的能力。

为了大家更好理解两者的区别,如下:

//创建热信号
RACSubject *subject = [RACSubject subject];
[subject sendNext:@]; //立即发送1
[[RACScheduler mainThreadScheduler] afterDelay:0.5 schedule:^{
[subject sendNext:@]; //0.5秒后发送2 }]; [[RACScheduler mainThreadScheduler] afterDelay: schedule:^{
[subject sendNext:@]; //2秒后发送3 }];
[[RACScheduler mainThreadScheduler] afterDelay:0.1 schedule:^{
[subject subscribeNext:^(id x) {
NSLog(@"subject1接收到了%@",x); //0.1秒后subject1订阅了 }];
}];
[[RACScheduler mainThreadScheduler] afterDelay: schedule:^{
[subject subscribeNext:^(id x) {
NSLog(@"subject2接收到了%@",x); //1秒后subject2订阅了 }];
}];
//创建冷信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
[subscriber sendNext:@];
[[RACScheduler mainThreadScheduler] afterDelay:0.5 schedule:^{
[subscriber sendNext:@];
}];
[[RACScheduler mainThreadScheduler] afterDelay: schedule:^{
[subscriber sendNext:@];
}]; return nil;
}]; [[RACScheduler mainThreadScheduler] afterDelay:0.1 schedule:^{
[signal subscribeNext:^(id x) { NSLog(@"signal1接收到了%@", x);
}];
}];
[[RACScheduler mainThreadScheduler] afterDelay: schedule:^{
[signal subscribeNext:^(id x) { NSLog(@"signal2接收到了%@", x);
}];
}];

通过运行结果:

RAC(ReactiveCocoa)概括-LMLPHP

从上面运行结果发现:

  • 0.1秒后订阅的subject1接收到了0.5秒后2秒后发送的信号,没有接收到之前发送的新号。

  • 1秒后订阅的subject2接收到了2秒后发送的信号,也没有接收到之前发送的新号。

  • signal1和signal2都接收到了所有信号。

从上面的运行结果总结

热信号是主动的,即使没有订阅事件,仍然会时刻推送;而冷信号是被动的,只有当你订阅的时候,它才会发送消息。

热信号是可以有多个订阅者,一对多,信号是可以与订阅者相互共享信息的。在第一段代码,两个订阅者是共享的,他们在同一时间接收到3个值,而冷信号只能一对一,当有不同的订阅者,消息都会从新完整发送。

使用信号常见的问题:

1.多次订阅

对RAC的信号进行转换的时候,其实就是对原有的信号进行订阅从而产生新的信号。如下代码所示:

RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) { NSLog(@"来了"); //网络请求,产生model [subscriber sendNext:model]; return nil;
}]; RACSignal *name = [signal flattenMap:^RACStream *(Person *model) { return [RACSignal return:model.name];
}];
RACSignal *age = [signal flattenMap:^RACStream *(Person *model) { return [RACSignal return:model.age];
}]; RAC(self.userNameTextFiled,text) = [[name catchTo:[RACSignal return:@"error"]] startWith:@"name:"];
RAC(self.passwordTextField,text) = [[age catchTo:[RACSignal return:@"error"]] startWith:@"age:"];

上面分别对model进行了map,也就是产生了两个新的信号,然后再对两个信号进行订阅,对这两个信号订阅的时候,也会对间接对原信号进行订阅,从而造成对原信号的多次订阅,如上所示来了就输出了三次,如果是网络请求的话,也会输出三次,所以一定在信号转换的时候一定要注意这些情况。

RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id subscriber) { NSLog(@"来了");
[subscriber sendNext:model]; return nil;
}] replayLazily]; //转换为热信号
RACSignal *name = [signal flattenMap:^RACStream *(Person *model) { return [RACSignal return:model.name];
}];
RACSignal *age = [signal flattenMap:^RACStream *(Person *model) { return [RACSignal return:model.age];
}]; RAC(self.userNameTextFiled,text) = [[name catchTo:[RACSignal return:@"error"]] startWith:@"name:"];
RAC(self.passwordTextField,text) = [[age catchTo:[RACSignal return:@"error"]] startWith:@"age:"];

2、内存泄露

RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) { //1 Person *model = [[Person alloc] init];
[subscriber sendNext:model];
[subscriber sendCompleted]; return nil;
}]; self.flattenMapSignal = [signal flattenMap:^RACStream *(Person *model) { //2 return RACObserve(model, name);
}];
[self.flattenMapSignal subscribeNext:^(id x) { //3 NSLog(@"recieve - %@", x);
}];

如上代码,看起来工作正常,但你使用内存检测工具会发现,这里会造成内存泄漏,原因就是

#define RACObserve(TARGET, KEYPATH) \ ({ \
_Pragma("clang diagnostic push") \
_Pragma("clang diagnostic ignored \"-Wreceiver-is-weak\"") \
__weak id target_ = (TARGET); \
[target_ rac_valuesForKeyPath:@keypath(TARGET, KEYPATH) observer:self]; \
_Pragma("clang diagnostic pop") \
})

这段代码,所以这里的Block引用了self,就造成了循环引用。
解决办法也很简单,使用@weakify和@strongify即可:

RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
Person *model = [[Person alloc] init];
[subscriber sendNext:model];
[subscriber sendCompleted]; return nil;
}];
@weakify(self); self.flattenMapSignal = [signal flattenMap:^RACStream *(Person *model) {
@strongify(self); return RACObserve(model, name);
}];
[self.flattenMapSignal subscribeNext:^(id x) { NSLog(@"recieve - %@", x);
}];

调度器:RACScheduler 在 ReactiveCocoa 中就是扮演着调度器的角色,本质上,它就是用 GCD 的串行队列来实现的,并且支持取消操作。是的,在 ReactiveCocoa 中,并没有使用到 NSOperationQueue 和 NSRunloop 等技术,RACScheduler 也只是对 GCD 的简单封装而已。

清洁工:RACDisposable 在 ReactiveCocoa 中就充当着清洁工的角色,它封装了取消和清理一次订阅所必需的工作。它有一个核心的方法 -dispose ,调用这个方法就会执行相应的清理工作,这有点类似于 NSObject 的 -dealloc 方法。

以后博客也将继续介绍RAC的基本框架。

05-07 15:10