reactiveCocoa学习之路（二）

1.今天继续学习reactiveCocoa的用法，昨天只是了解了一下链式编程思想。

2.RACSiganl的介绍及简单使用：
2.1RACSiganl:信号类,一般表示将来有数据传递，只要有数据改变，信号内部接收到数据，就会发出数据。只是表示当数据改变时，信号内部会发出数据，它自身并不能发送信号，而是交给内部的订阅者发出。

2.2默认一个信号都是冷信号，也就是值改变了，也不会触发，只有订阅了这个信号，这个信号才会变为热信号，值改变了才会触发。

2.3如何订阅信号：调用信号RACSignal的subscribeNext就能订阅。

2.4使用步骤：

// 1.创建信号 
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe 
// 2.订阅信号,订阅之后才会激活信号. 
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock 
// 3.发送信号 
- (void)sendNext:(id)value

2.5RACSignal底层实现：

1.创建信号，首先把didSubscribe保存到信号中，还不会触发。
2.当信号被订阅，也就是调用signal的subscribeNext:nextBlock 
2.2 subscribeNext内部会创建订阅者subscriber，并且把nextBlock保存到subscriber中。
2.1 subscribeNext内部会调用siganl的didSubscribe 
3.siganl的didSubscribe中调用[subscriber sendNext:@1]; 
3.1 sendNext底层其实就是执行subscriber的nextBlock

2.6简单的调用：

调用过程.png

2.7RACSubscriber：表示订阅者的意思，用于发送信号，这是一个协议，不是类，只有遵守这个协议，并且实现方法才能成为订阅者。通过create创建的信号，都有一个订阅者，帮助它发送数据。

2.8RACDisposeable:用于取消订阅或者清理资源，当信号发送完成或者发送错误的时候，就会自动触发。

2.9RACSubject:信号提供者，自己可以充当信号，也能发送信号。通常用来代替代理，有了它就不必定义代理了。
RACReplaySubject:重复提供信号类，RACSubject的子类。他们的区别是前者可以先发送信号，再订阅信号，后者不行。如果一个信号每被订阅一次，就需要把之前的值重复发送一遍，使用RACReplaySubject。可以设置capacity的数量来限制缓存的value的数量，即只缓冲最新分几个值。

3.0RACSubject使用步骤

1.创建信号 [RACSubject subject]，跟RACSiganl不一样，创建信号时没有block。 
2.订阅信号 - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock 
3.发送信号 sendNext:(id)value

3.1RACSubject底层实现和RACSignal不一样。

1.调用subscribeNext订阅信号，只是把订阅者保存起来，并且订阅者的nextBlock已经赋值了。 
2.调用sendNext发送信号，遍历刚刚保存的所有订阅者，一个一个调用订阅者的nextBlock。

3.2RACReplaySubject使用步骤:

1.创建信号 [RACSubject subject]，跟RACSiganl不一样，创建信号时没有block。 
2.可以先订阅信号，也可以先发送信号。 
2.1 订阅信号 - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock 
2.2 发送信号 sendNext:(id)value

3.3RACReplaySubject:底层实现和RACSubject不一样。

1.调用sendNext发送信号，把值保存起来，然后遍历刚刚保存的所有订阅者，一个一个调用订阅者的nextBlock。 
2.调用subscribeNext订阅信号，遍历保存的所有值，一个一个调用订阅者的nextBlock 
3.如果想当一个信号被订阅，就重复播放之前所有值，需要先发送信号，在订阅信号。 
4.也就是先保存值，在订阅值。

3.2RACReplaySubject和RACSubject的简单使用：

调用过程.png

3.3RACSubject作为代理使用：

处理点击后的变化.png
声明代理.png
实现代理.png

3.4RACTuple:元组类，类似NSArray，用来包装值。

3.5RACSequence:RAC中的集合类，用于代替NSArray，NSDictionary，可以使用它来快速遍历数组和字典。多用于字典转模型

3.6RACSequence和RACTuple简单使用:

第一步: 把数组转换成集合RACSequence numbers.rac_sequence 
第二步: 把集合RACSequence转换RACSignal信号类,numbers.rac_sequence.signal 
第三步: 订阅信号，激活信号，会自动把集合中的所有值，遍历出来。
实现.png

3.7字典转模型

//1.OC写法 
NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil]; 
NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath];      
NSMutableArray *items = [NSMutableArray array]; 
for (NSDictionary *dict in dictArr) { 
    FlagItem *item = [FlagItem flagWithDict:dict];
     [items addObject:item]; 
    } 

//2.RAC写法 
NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil]; 
NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath]; 
NSMutableArray *flags = [NSMutableArray array]; 
_flags = flags;
// rac_sequence注意点：调用subscribeNext，并不会马上执行nextBlock，而是会等一会。 
[dictArr.rac_sequence.signal subscribeNext:^(id x) { 
    // 运用RAC遍历字典，x：字典 
    FlagItem *item = [FlagItem flagWithDict:x];
    [flags addObject:item]; 
}]; 
NSLog(@"%@", NSStringFromCGRect([UIScreen mainScreen].bounds)); 

//3.RAC高级写法: 
NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil]; 
NSArray *dictArr = [NSArray arrayWithContentsOfFile:filePath]; 
// map:映射的意思，目的：把原始值value映射成一个新值 
// array: 把集合转换成数组 
// 底层实现：当信号被订阅，会遍历集合中的原始值，映射成新值，并且保存到新的数组里。 
NSArray *flags = [[dictArr.rac_sequence map:^id(id value) { 
    return [FlagItem flagWithDict:value];
 }] array];

3.8RACCommand:RAC中用于处理事件的类，可以把事件如何处理，事件中的数据如何传递，包装到这个类中，他可以很方便的监控事件的执行过程，用于监听按钮点击，网络请求。

3.9RACCommand的简单使用

 一、RACCommand使用步骤: 
1.创建命令 initWithSignalBlock:(RACSignal * (^)(id input))signalBlock 
2.在signalBlock中，创建RACSignal，并且作为signalBlock的返回值
3.执行命令 - (RACSignal *)execute:(id)input 

二、RACCommand使用注意: 
1.signalBlock必须要返回一个信号，不能传nil. 
2.如果不想要传递信号，直接创建空的信号[RACSignal empty]; 
3.RACCommand中信号如果数据传递完，必须调用[subscriber sendCompleted]，这时命令才会执行完毕，否则永远处于执行中。
4.RACCommand需要被强引用，否则接收不到RACCommand中的信号，因此RACCommand中的信号是延迟发送的。 

三、RACCommand设计思想：内部signalBlock为什么要返回一个信号，这个信号有什么用。 
1.在RAC开发中，通常会把网络请求封装到RACCommand，直接执行某个RACCommand就能发送请求。
2.当RACCommand内部请求到数据的时候，需要把请求的数据传递给外界，这时候就需要通过signalBlock返回的信号传递了。 

四、如何拿到RACCommand中返回信号发出的数据。
1.RACCommand有个执行信号源executionSignals，这个是signal of signals(信号的信号),意思是信号发出的数据是信号，不是普通的类型。
2.订阅executionSignals就能拿到RACCommand中返回的信号，然后订阅signalBlock返回的信号，就能获取发出的值。

五、监听当前命令是否正在执行executing 

六、使用场景：监听按钮点击，网络请求

4.0RACMulticastConnection：用于当一个信号被多次订阅是，为了保证创建信号是，避免多次调用穿件信号中的block，造成副作用，可以使用这个类处理。RACMulticastConnection是通过RACSignal的-publish或者-muticast方法创建的。

4.1RACMulticastConnection的简单使用

RACMulticastConnection使用步骤: 
1.创建信号 + (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe 
2.创建连接 RACMulticastConnection *connect = [signal publish]; 
3.订阅信号,注意：订阅的不在是之前的信号，而是连接的信号。   
[connect.signal subscribeNext:nextBlock] 
4.连接 [connect connect] 
 
RACMulticastConnection底层原理: 
1.创建connect，connect.sourceSignal -> RACSignal(原始信号) connect.signal -> RACSubject 
2.订阅connect.signal，会调用RACSubject的subscribeNext，创建订阅者，而且把订阅者保存起来，不会执行block。 
3.[connect connect]内部会订阅RACSignal(原始信号)，并且订阅者是RACSubject 
3.1.订阅原始信号，就会调用原始信号中的didSubscribe 
3.2 didSubscribe，拿到订阅者调用sendNext，其实是调用RACSubject的sendNext 
4.RACSubject的sendNext,会遍历RACSubject所有订阅者发送信号。
4.1 因为刚刚第二步，都是在订阅RACSubject，因此会拿到第二步所有的订阅者，调用他们的nextBlock 

需求：假设在一个信号中发送请求，每次订阅一次都会发送请求，这样就会导致多次请求。 
解决：使用RACMulticastConnection就能解决.

4.2RACScheduler:RAC中的对列，用GCD封装的。

4.3RACUnit:表示stream不包含有意义的值，也就是看到这个没直接理解为nil。

4.4RACEvent：把数据包装成信号事件(signal event)。它主要通过RACSignal的-materialize来使用。

4.5ReactiveCocoa开发中常见用法

`rac_signalForSelector`:用来替代代理。
`rac_valuesAndChangeForKeyPath`:用来监听某个对象属性改变。
`rac_signalForControlEvents`:用于监听某个事件。
`rac_addObserverForName`:用于监听某个通知。
`rac_textSignal`:用于监听文本框文字改变，只要文本框发生改变就会发出这个信号。
`rac_liftSelector:withSignalsFromArray:Signals`:用于处理当界面有多长请求时，需要都获取到数据时，才能展示界面。当传人的signals(信号数组)，每一个signal都至少sendNext过一次，就会去触发第一个selector参数的方法。使用注意：几个信号，参数一的方法就几个参数，每个参数对应的信号发出的数据。

4.6ReactiveCocoa常见宏

`RAC(TARGET, [KEYPATH, [NIL_VALUE]])` : 用于给某个对象的某个属性绑定。
//只要文本框文字改变，就会修改label的文字
RAC(self.labelView.text) = _textF.rac_textSignal;

RACObserve(self, name):监听某个对象的某个属性，返回的是信号
[RACObserve(self.view, center) subscribeNext:^(id x){
    NSLog(@"--%@--", x);
}];

@weakify(Obj)和@strongify(Obj),一般两个都是配套使用,在主头文件(ReactiveCocoa.h)中并没有导入，需要自己手动导入，RACEXTScope.h才可以使用。但是每次导入都非常麻烦，只需要在主头文件自己导入就好了。

`RACTuplePack`：把数据包装成RACTuple（元组类）
//把参数中的数据包装成元组
RACTuple *tuple = RACTuplePack(@10, @20);

`RACTupleUnpack`:把RACTulpe（元组类）解包成对应数据
// 把参数中的数据包装成元组 
RACTuple *tuple = RACTuplePack(@"xmg",@20); 
// 解包元组，会把元组的值，按顺序给参数里面的变量赋值 
// name = @"xmg" age = @20 
RACTupleUnpack(NSString *name,NSNumber *age) = tuple;

共勉！一步一个巴掌印。。。。。

最后编辑于 ：
©著作权归作者所有,转载或内容合作请联系作者
平台声明：文章内容（如有图片或视频亦包括在内）由作者上传并发布，文章内容仅代表作者本人观点，简书系信息发布平台，仅提供信息存储服务。

推荐阅读更多精彩内容