來源：朱凱奇
鏈接：http://www.jianshu.com/p/5d966074741a
1.ReactiveCocoa簡介
ReactiveCocoa（簡稱為RAC）,是由Github開源的一個應用於iOS和OS開發的新框架,Cocoa是蘋果整套框架的簡稱，因此很多蘋果框架喜歡以Cocoa結尾。
2.ReactiveCocoa作用
-
在我們iOS開發過程中，當某些事件響應的時候，需要處理某些業務邏輯,這些事件都用不同的方式來處理。
-
比如按鈕的點擊使用action，使用delegate，屬性值改變使用KVO,通知等系統提供的方式。都可以通過RAC處理
-
ReactiveCocoa為事件提供了很多處理方法，而且利用RAC處理事件很方便，可以把要處理的事情，和監聽的事情的代碼放在一起，這樣非常方便我們管理，就不需要跳到對應的方法里。非常符合我們開發中高內聚，低耦合的思想。
3.ReactiveCocoa編程思想
ReactiveCocoa結合了幾種編程風格：
函數式編程（Functional Programming）
響應式編程（Reactive Programming）
所以，ReactiveCocoa被描述為函數響應式編程（FRP）框架。
以后使用RAC解決問題，就不需要考慮調用順序，直接考慮結果，把每一次操作都寫成一系列嵌套的方法中，使代碼高聚合，方便管理。
4.編程思想
編程思想：通過開發需求,逐漸形成快速完成這些需求的思想。
目前已知的編程思想。
4.1 面向過程：處理事情以過程為核心，一步一步的實現。
4.2 面向對象：萬物皆對象。
4.3 鏈式編程思想：是將多個操作（多行代碼）通過點號(.)鏈接在一起成為一句代碼,使代碼可讀性好。a(1).b(2).c(3)
-
鏈式編程特點：方法的返回值是block,block必須有返回值（本身對象），block參數（需要操作的值）
-
代表：masonry框架。
4.4 響應式編程思想：不需要考慮調用順序，只需要知道考慮結果，類似於蝴蝶效應，產生一個事件，會影響很多東西，這些事件像流一樣的傳播出去，然后影響結果，借用面向對象的一句話，萬物皆是流。
-
代表：KVO運用。
4.5 函數式編程思想：是把操作盡量寫成一系列嵌套的函數或者方法調用。
-
函數式編程本質:就是往方法中傳入Block,方法中嵌套Block調用，把代碼聚合起來管理
-
函數式編程特點：每個方法必須有返回值（本身對象）,把函數或者Block當做參數,block參數（需要操作的值）block返回值（操作結果）
-
代表：ReactiveCocoa。
5.如何導入ReactiveCocoa框架
通常都會使用CocoaPods（用於管理第三方框架的插件）幫助我們導入。
注意：
-
podfile如果只描述pod ‘ReactiveCocoa’，會導入不成功
-
需要在podfile加上use_frameworks，重新pod install 才能導入成功。
6.ReactiveCocoa常見類。
學習框架首要之處:先要搞清楚框架中常用的類，在RAC中最核心的類RACSiganl,會用這個類就能用ReactiveCocoa開發了。
RACSiganl:信號類,表示將來有數據傳遞，只要有數據改變，信號內部接收到數據，就會馬上發出數據。
信號類(RACSiganl)，只是表示當數據改變時，信號內部會發出數據，它本身不具備發送信號的能力，而是交給內部一個訂閱者去發出。
默認一個信號都是冷信號，也就是值改變了，也不會觸發，只有訂閱了這個信號，這個信號才會變為熱信號，值改變了才會觸發。
如何訂閱信號：調用信號RACSignal的subscribeNext就能訂閱。
-
RACSiganl簡單使用:
// RACSignal使用步驟：
// 1.創建信號 + (RACSignal *)createSignal:(RACDisposable * (^)(id subscriber))didSubscribe
// 2.訂閱信號,才會激活信號. - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock
// 3.發送信號 - (void)sendNext:(id)value
- (void)signal{
//三步驟:創建信號,訂閱信號,發送信號
//1.創建信號
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
//保存起來 就不會被取消訂閱
_subscriber = subscriber;
//3.發送信號
[subscriber sendNext:@1];
return [RACDisposable disposableWithBlock:^{
NSLog(@"默認信號發送完畢被取消");
}];
}];
//如果要取消就拿到 RACDisposable
//2.訂閱信號
RACDisposable *disposable = [signal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
//取消訂閱
[disposable dispose];
}
結果如下:
-
RACSubscriber:表示訂閱者的意思，用於發送信號，這是一個協議，不是一個類，只要遵守這個協議，並且實現方法才能成為訂閱者。通過create創建的信號，都有一個訂閱者，幫助他發送數據。
-
RACDisposable:用於取消訂閱或者清理資源，當信號發送完成或者發送錯誤的時候，就會自動觸發它。
使用場景:不想監聽某個信號時，可以通過它主動取消訂閱信號。
-
RACSubject:RACSubject:信號提供者，自己可以充當信號，又能發送信號。
使用場景:通常用來代替代理，有了它，就不必要定義代理了。
-
RACReplaySubject:重復提供信號類，RACSubject的子類。
RACReplaySubject與RACSubject區別:
RACReplaySubject可以先發送信號，再訂閱信號，RACSubject就不可以。
使用場景一:如果一個信號每被訂閱一次，就需要把之前的值重復發送一遍，使用重復提供信號類。
使用場景二:可以設置capacity數量來限制緩存的value的數量,即只緩充最新的幾個值。
-
RACSubject簡單使用:
// RACSubject使用步驟
// 1.創建信號 [RACSubject subject]，跟RACSiganl不一樣，創建信號時沒有block。
// 2.訂閱信號 - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock
// 3.發送信號 sendNext:(id)value
//:RACSubject:信號提供者，自己可以充當信號，又能發送信號。
- (void)subject {
//創建信號
RACSubject *subject = [RACSubject subject];
//訂閱信號
[subject subscribeNext:^(id x) {
NSLog(@"訂閱者一%@",x);
}];
[subject subscribeNext:^(id x) {
NSLog(@"訂閱者二%@",x);
}];
//發送信號
[subject sendNext:@"111"];
}
結果如下:
-
RACReplaySubject的簡單使用
// RACReplaySubject使用步驟:
// 1.創建信號 [RACSubject subject]，跟RACSiganl不一樣，創建信號時沒有block。
// 2.可以先訂閱信號，也可以先發送信號。
// 2.1 訂閱信號 - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock
// 2.2 發送信號 sendNext:(id)value
- (void)replaySubject{
//創建信號
RACReplaySubject *replaySubject = [RACReplaySubject subject];
//發送信號
[replaySubject sendNext:@"222"];
[replaySubject sendNext:@"333"];
//訂閱信號
[replaySubject subscribeNext:^(id x) {
NSLog(@"第一個訂閱者%@",x);
}];
//如果想一個信號被訂閱，就重復播放之前所有值，需要先發送信號，在訂閱信號。
[replaySubject subscribeNext:^(id x) {
NSLog(@"第二個訂閱者%@",x);
}];
}
結果如下:
RACTuple:元組類,類似NSArray,用來包裝值.
RACSequence:RAC中的集合類，用於代替NSArray,NSDictionary,可以使用它來快速遍歷數組和字典。
使用場景：1.字典轉模型
RACSequence和RACTuple簡單使用
- (void)arrayTuple{
NSArray *array = @[@1,@2,@3];
[array.rac_sequence.signal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
}
結果如下:
- (void)dictTuple {
NSDictionary *dict = @{@"name":@"張三",@"age":@"20",@"sex":@"男"};
[dict.rac_sequence.signal subscribeNext:^(id x) {
// 解包元組，會把元組的值，按順序給參數里面的變量賦值
// RACTupleUnpack這是個宏,后面會介紹
RACTupleUnpack(NSString *key,NSString *value) = x;
NSLog(@"%@---%@",key,value);
//相當與
// NSString *key = x[0];
// NSString *value = x[1];
}];
}
結果如下:
字典轉模型
- (void)dicToModel {
// RAC高級寫法:
[AFNHelper get:kUrl parameter:nil success:^(id responseObject) {
NSArray *array = responseObject;
// map:映射的意思，目的：把原始值value映射成一個新值
// array: 把集合轉換成數組
// 底層實現：當信號被訂閱，會遍歷集合中的原始值，映射成新值，並且保存到新的數組里。
NSArray *musicArray =[[array.rac_sequence map:^id(id value) {
Music *music = [Music fetchMusicModelWithDict:value ];
return music;
}] array];
NSLog(@"--------%@",musicArray);
} faliure:^(id error) {
NSLog(@"%@",error);
}];
}
-
RACMulticastConnection:用於當一個信號，被多次訂閱時，為了保證創建信號時，避免多次調用創建信號中的block，造成副作用，可以使用這個類處理。
-
使用注意:RACMulticastConnection通過RACSignal的-publish或者-muticast:方法創建.
RACMulticastConnection簡單使用
// RACMulticastConnection使用步驟:
// 1.創建信號 + (RACSignal *)createSignal:(RACDisposable * (^)(id subscriber))didSubscribe
// 2.創建連接 RACMulticastConnection *connect = [signal publish];
// 3.訂閱信號,注意：訂閱的不在是之前的信號，而是連接的信號。 [connect.signal subscribeNext:nextBlock]
// 4.連接 [connect connect]
// 5.發送信號
// 需求：假設在一個信號中發送請求，每次訂閱一次都會發送請求，這樣就會導致多次請求。
// 解決：使用RACMulticastConnection就能解決.
- (void)multicastConnection {
//1.創建信號
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id subscriber) {
NSLog(@"請求一次");
//5.發送信號
[subscriber sendNext:@"2"];
return nil;
}];
//2.把信號轉化為連接類
RACMulticastConnection *connection = [signal publish];
//3.訂閱連接類信號
[connection.signal subscribeNext:^(id x) {
NSLog(@"第一個訂閱者%@",x);
}];
[connection.signal subscribeNext:^(id x) {
NSLog(@"第二個訂閱者%@",x);
}];
[connection.signal subscribeNext:^(id x) {
NSLog(@"第三個訂閱者%@",x);
}];
//4.鏈接信號
[connection connect];
}
結果如下:
RACCommand:RAC中用於處理事件的類，可以把事件如何處理,事件中的數據如何傳遞，包裝到這個類中，他可以很方便的監控事件的執行過程。
使用場景:監聽按鈕點擊，網絡請求
RACCommand簡單使用
// 一、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]，這時命令才會執行完畢，否則永遠處於執行中。
// 三、RACCommand設計思想：內部signalBlock為什么要返回一個信號，這個信號有什么用。
// 1.在RAC開發中，通常會把網絡請求封裝到RACCommand，直接執行某個RACCommand就能發送請求。
// 2.當RACCommand內部請求到數據的時候，需要把請求的數據傳遞給外界，這時候就需要通過signalBlock返回的信號傳遞了。
// 四、如何拿到RACCommand中返回信號發出的數據。
// 1.RACCommand有個執行信號源executionSignals，這個是signal of signals(信號的信號),意思是信號發出的數據是信號，不是普通的類型。
// 2.訂閱executionSignals就能拿到RACCommand中返回的信號，然后訂閱signalBlock返回的信號，就能獲取發出的值。
- (void)command {
//1創建命令
RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) {
//命令內部傳遞的參數
NSLog(@"input===%@",input);
//2.返回一個信號,可以返回一個空信號 [RACSignal empty];
return [RACSignal createSignal:^RACDisposable *(id subscriber) {
NSLog(@"發送數據");
//發送信號
[subscriber sendNext:@"22"];
// 注意：數據傳遞完，最好調用sendCompleted，這時命令才執行完畢。
[subscriber sendCompleted];
return nil;
}];
}];
//強引用
__command = command;
//拿到返回信號方式二:
//command.executionSignals信號中的信號 switchToLatest轉化為信號
[command.executionSignals.switchToLatest subscribeNext:^(id x) {
NSLog(@"拿到信號的方式二%@",x);
}];
//拿到返回信號方式一:
RACSignal *signal = [command execute:@"11"];
[signal subscribeNext:^(id x) {
NSLog(@"拿到信號的方式一%@",x);
}];
//3.執行命令
[command execute:@"11"];
//監聽命令是否執行完畢
[command.executing subscribeNext:^(id x) {
if ([x boolValue] == YES) {
NSLog(@"命令正在執行");
}
else {
NSLog(@"命令完成/沒有執行");
}
}];
}
結果如下:
7.ReactiveCocoa常見宏。
RAC(TARGET, [KEYPATH, [NIL_VALUE]]):用於給某個對象的某個屬性綁定。
基本用法
// 只要文本框文字改變，就會修改label的文字
RAC(self.labelView,text) = _textField.rac_textSignal;
結果如下:
RACObserve(self, name):監聽某個對象的某個屬性,返回的是信號。
基本用法
[RACObserve(self.view, center) subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
結果如下:
@weakify(Obj)和@strongify(Obj),一般兩個都是配套使用,解決循環引用問題.
RACTuplePack：把數據包裝成RACTuple（元組類）
基本用法
// 把參數中的數據包裝成元組
RACTuple *tuple = RACTuplePack(@10,@20);
NSLog(@"tuple =%@",tuple);
結果如下:
RACTupleUnpack：把RACTuple（元組類）解包成對應的數據。
基本用法
// 把參數中的數據包裝成元組
RACTuple *tuple = RACTuplePack(@"ZKQ",@25);
// 解包元組，會把元組的值，按順序給參數里面的變量賦值
// name = @"ZKQ" age = <a href='http://www.jobbole.com/members/Laidong1306992'>@25</a>
RACTupleUnpack(NSString *name,NSNumber *age) = tuple;
結果如下:
8.ReactiveCocoa開發中常見用法。
代替代理:
rac_signalForSelector：用於替代代理。
RACSubject:也用於代理.
// 需求：自定義BlueView,監聽BlueView中按鈕點擊
// 之前都是需要通過代理監聽，點擊按鈕的時候，通知代理做事情
// rac_signalForSelector:把調用某個對象的方法的信息轉換成信號，就要調用這個方法，就會發送信號。
// 這里表示只要blueView調用clickBlueViewButton,就會發出信號，訂閱就好了。
[[self.blueView rac_signalForSelector:@selector(clickBlueViewButton)] subscribeNext:^(id x) {
NSLog(@"點擊了藍色視圖上的按扭");
}];
結果如下:
代替KVO :
rac_valuesAndChangesForKeyPath：用於監聽某個對象的屬性改變。
[[self.blueView rac_valuesAndChangesForKeyPath:@"frame" options:NSKeyValueObservingOptionNew observer:nil] subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
結果如下:
監聽事件:
rac_signalForControlEvents：用於監聽某個事件。
// 把按鈕點擊事件轉換為信號，點擊按鈕，就會發送信號
//監聽事件
[[self.bt rac_signalForControlEvents:UIControlEventTouchUpInside ] subscribeNext:^(id x) {
NSLog(@"點擊了按扭");
}];
結果如下:
代替通知:
rac_addObserverForName:用於監聽某個通知。
// 把監聽到的通知轉換信號
[[[NSNotificationCenter defaultCenter] rac_addObserverForName:UIKeyboardWillChangeFrameNotification object:nil] subscribeNext:^(id x) {
NSLog(@"鍵盤frame發生改變%@",x);
}];
結果如下:
監聽文本框文字改變:
rac_textSignal:只要文本框發出改變就會發出這個信號。
// 5.監聽文本框的文字改變
[self.textfield.rac_textSignal subscribeNext:^(id x) {
NSLog(@"%@",x);
}];
結果如下:
9總結
ReactiveCocoa 是一個很強大的框架,還有很多東西沒有講到,我講的這些只是最基本的使用,講的有不到位的地方,請大家見諒.如有問題請留言!!!