本文轉載自最快讓你上手ReactiveCocoa之基礎篇,在此基礎上稍做修改,歡迎交流。javascript
有關對 ReactiveCocoa 的見解能夠看一下唐巧的這篇ReactiveCocoa 討論會css
ReactiveCocoa(簡稱爲RAC),是由Github開源的一個應用於iOS和OS開發的新框架,Cocoa是蘋果整套框架的簡稱,所以不少蘋果框架喜歡以Cocoa結尾。java
在咱們iOS開發過程當中,當某些事件響應的時候,須要處理某些業務邏輯,這些事件都用不一樣的方式來處理。ios
好比按鈕的點擊使用action,ScrollView滾動使用delegate,屬性值改變使用KVO等系統提供的方式。其實這些事件,均可以經過RAC處理git
ReactiveCocoa爲事件提供了不少處理方法,並且利用RAC處理事件很方便,能夠把要處理的事情,和監聽的事情的代碼放在一塊兒,這樣很是方便咱們管理,就不須要跳到對應的方法裏。github
很是符合咱們開發中高聚合,低耦合的思想。編程
在開發中咱們也不能太依賴於某個框架,不然這個框架不更新了,致使項目後期沒辦法維護,好比以前Facebook提供的 Three20
框架,在當時也是神器,可是後來不更新了,也就沒什麼人用了。所以我感受學習一個框架,仍是有必要了解它的編程思想。數組
先簡單介紹下目前我們已知的編程思想:緩存
響應式編程思想:不須要考慮調用順序,只須要知道考慮結果,相似於蝴蝶效應,產生一個事件,會影響不少東西,這些事件像流同樣的傳播出去,而後影響結果,借用面向對象的一句話,萬物皆是流。ruby
表明
:KVO
鏈式編程 是將多個操做(多行代碼)經過點號(.)連接在一塊兒成爲一句代碼,使代碼可讀性好。如:
make.add(1).add(2).sub(5).muilt(-4).divide(4);
特色
:方法的返回值是block,block必須有返回值(自己對象),block參數(須要操做的值)
表明
:masonry框架。
實現
:模仿masonry,寫一個加法計算器,練習鏈式編程思想。
NSObject+Caculator.h
# import <Foundation/Foundation.h> @class CaculatorMaker; @interface NSObject (Caculator) // 計算 + (int)makeCaculators:(void (^)(CaculatorMaker *))block; @end
NSObject+Caculator.m
@implementation NSObject (Caculator) + (int)makeCaculators:(void (^)(CaculatorMaker *))block { CaculatorMaker *mgr = [[CaculatorMaker alloc] init]; block(mgr); return (mgr.result); } @end
CaculatorMaker.h
# import <Foundation/Foundation.h> @class CaculatorMaker; typedef CaculatorMaker *(^CasulatorBlock)(int); @interface CaculatorMaker : NSObject @property (nonatomic, assign) int result; // 算數方法 - (CaculatorMaker *(^)(int))add; - (CasulatorBlock)sub; - (CasulatorBlock)muilt; - (CasulatorBlock)divide; @end
CaculatorMaker.m
# import "CaculatorMaker.h" @implementation CaculatorMaker - (CaculatorMaker *(^)(int))add { return ^CaculatorMaker *(int value) { _result += value; return self; }; } - (CasulatorBlock)sub { return ^CaculatorMaker *(int value) { _result -= value; return self; }; } - (CasulatorBlock)muilt { return ^CaculatorMaker *(int value) { _result *= value; return self; }; } - (CasulatorBlock)divide { return ^CaculatorMaker *(int value) { _result /= value; return self; }; } @end
使用:
int result = [NSObject makeCaculators:^(CaculatorMaker *make) { // ( 1 + 2 - 5 ) * (-4) / 4 make.add(1).add(2).sub(5).muilt(-4).divide(4); }]; NSLog(@"%d", result);
函數式編程思想:是把操做盡可能寫成一系列嵌套的函數或者方法調用。
特色
:每一個方法必須有返回值(自己對象),把函數或者Block當作參數,block參數(須要操做的值)block返回值(操做結果)
表明
:ReactiveCocoa
實現
:用函數式編程實現,寫一個加法計算器,而且加法計算器自帶判斷是否等於某個值.
Calculator *caculator = [[Calculator alloc] init];
BOOL isqule = [[[caculator caculator:^int(int result) { result += 2; result *= 5; return result; }] equle:^BOOL(int result) { return result == 10; }] isEqule]; NSLog(@"%d", isqule);
Calculator.h
#import <Foundation/Foundation.h> @interface Calculator : NSObject @property (nonatomic, assign) BOOL isEqule; @property (nonatomic, assign) int result; - (Calculator *)caculator:(int (^)(int result))caculator; - (Calculator *)equle:(BOOL (^)(int result))operation; @end
Calculator.m
#import "Calculator.h" @implementation Calculator - (Calculator *)caculator:(int (^)(int))caculator { _result = caculator(_result); return self; } - (Calculator *)equle:(BOOL (^)(int))operation { _isEqule = operation(_result); return self; } @end
ReactiveCocoa 結合了這兩種種編程風格:
函數式編程(Functional Programming)
響應式編程(Reactive Programming)
因此,你可能據說過 ReactiveCocoa 被描述爲函數響應式編程(FRP)框架。
之後使用RAC解決問題,就不須要考慮調用順序,直接考慮結果,把每一次操做都寫成一系列嵌套的方法中,使代碼高聚合,方便管理。
ReactiveCocoa的GitHub地址
ReactiveCocoa 2.5版本之後改用了Swift,因此Objective-C項目須要導入2.5版本
CocoaPods
集成:
platform :ios, '8.0' target 'YouProjectName' do use_frameworks! pod 'ReactiveCocoa', '~> 2.5' end
PS:新版本的CocoaPods
須要加入
target 'YouProjectName' do ... end
這句話來限定項目,不然導入失敗。
Swift項目導入2.5後的版本
platform :ios, '8.0' target 'YouProjectName' do use_frameworks! pod 'ReactiveCocoa' end
使用時在全局頭文件導入頭文件便可
PrefixHeader.pch
#ifndef PrefixHeader_pch #define PrefixHeader_pch #import <ReactiveCocoa/ReactiveCocoa.h> #endif
信號類,通常表示未來有數據傳遞,只要有數據改變,信號內部接收到數據,就會立刻發出數據。
注意:
使用:
// RACSignal使用步驟: // 1.建立信號 + (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe // 2.訂閱信號,纔會激活信號. - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock // 3.發送信號 - (void)sendNext:(id)value // RACSignal底層實現: // 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 // 1.建立信號 RACSignal *siganl = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { // block調用時刻:每當有訂閱者訂閱信號,就會調用block。 // 2.發送信號 [subscriber sendNext:@1]; // 若是不在發送數據,最好發送信號完成,內部會自動調用[RACDisposable disposable]取消訂閱信號。 [subscriber sendCompleted]; return [RACDisposable disposableWithBlock:^{ // block調用時刻:當信號發送完成或者發送錯誤,就會自動執行這個block,取消訂閱信號。 // 執行完Block後,當前信號就不在被訂閱了。 NSLog(@"信號被銷燬"); }]; }]; // 3.訂閱信號,纔會激活信號. [siganl subscribeNext:^(id x) { // block調用時刻:每當有信號發出數據,就會調用block. NSLog(@"接收到數據:%@",x); }];
表示訂閱者的意思,用於發送信號,這是一個協議,不是一個類,只要遵照這個協議,而且實現方法才能成爲訂閱者。經過create建立的信號,都有一個訂閱者,幫助他發送數據。
用於取消訂閱或者清理資源,當信號發送完成或者發送錯誤的時候,就會自動觸發它。
使用場景:不想監聽某個信號時,能夠經過它主動取消訂閱信號。
RACSubject:信號提供者,本身能夠充當信號,又能發送信號。
使用場景:一般用來代替代理,有了它,就沒必要要定義代理了。
重複提供信號類,RACSubject的子類。
RACReplaySubject
與RACSubject
區別:
RACReplaySubject
能夠先發送信號,在訂閱信號,RACSubject
就不能夠。
使用場景一:若是一個信號每被訂閱一次,就須要把以前的值重複發送一遍,使用重複提供信號類。
使用場景二:能夠設置capacity數量來限制緩存的value的數量,即只緩充最新的幾個值。
ACSubject 和 RACReplaySubject 簡單使用:
ACSubject
// RACSubject使用步驟 // 1.建立信號 [RACSubject subject],跟RACSiganl不同,建立信號時沒有block。 // 2.訂閱信號 - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock // 3.發送信號 sendNext:(id)value // RACSubject:底層實現和RACSignal不同。 // 1.調用subscribeNext訂閱信號,只是把訂閱者保存起來,而且訂閱者的nextBlock已經賦值了。 // 2.調用sendNext發送信號,遍歷剛剛保存的全部訂閱者,一個一個調用訂閱者的nextBlock。 // 1. 建立信號 RACSubject *subject = [RACSubject subject]; // 2.訂閱信號 [subject subscribeNext:^(id x) { // block調用時機:當信號發出新值,就會調用 NSLog(@"收到信號"); }]; // 3.發送信號 NSLog(@"發送信號"); [subject sendNext:@"1"];
// RACReplaySubject使用步驟: // 1.建立信號 [RACSubject subject],跟RACSiganl不同,建立信號時沒有block。 // 2.能夠先訂閱信號,也能夠先發送信號。 // 2.1 訂閱信號 - (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock // 2.2 發送信號 sendNext:(id)value // RACReplaySubject:底層實現和RACSubject不同。 // 1.調用sendNext發送信號,把值保存起來,而後遍歷剛剛保存的全部訂閱者,一個一個調用訂閱者的nextBlock。 // 2.調用subscribeNext訂閱信號,遍歷保存的全部值,一個一個調用訂閱者的nextBlock // 若是想當一個信號被訂閱,就重複播放以前全部值,須要先發送信號,在訂閱信號。 // 也就是先保存值,在訂閱值。 // 1.建立信號 RACReplaySubject *replaySubject = [RACReplaySubject subject]; // 3.先訂閱信號 [replaySubject subscribeNext:^(id x) { NSLog(@"第一個訂閱者接受到的數據%@", x); }]; // 2.發送信號 [replaySubject sendNext:@1]; [replaySubject sendNext:@2]; // 後訂閱信號 [replaySubject subscribeNext:^(id x) { NSLog(@"第二個訂閱者接收到的數據%@",x); }];
RACSubject替換代理(與block相似)
// 需求: // 1.給當前控制器添加一個按鈕,modal到另外一個控制器界面 // 2.另外一個控制器view中有個按鈕,點擊按鈕,通知當前控制器 步驟一:在第二個控制器.h,添加一個RACSubject代替代理。 @interface TwoViewController : UIViewController @property (nonatomic, strong) RACSubject *delegateSignal; @end 步驟二:監聽第二個控制器按鈕點擊 @implementation TwoViewController - (IBAction)notice:(id)sender { // 通知第一個控制器,告訴它,按鈕被點了 // 通知代理 // 判斷代理信號是否有值 if (self.delegateSignal) { // 有值,才須要通知 [self.delegateSignal sendNext:nil]; } } @end 步驟三:在第一個控制器中,監聽跳轉按鈕,給第二個控制器的代理信號賦值,而且監聽. @implementation OneViewController - (IBAction)btnClick:(id)sender { // 建立第二個控制器 TwoViewController *twoVc = [[TwoViewController alloc] init]; // 設置代理信號 twoVc.delegateSignal = [RACSubject subject]; // 訂閱代理信號 [twoVc.delegateSignal subscribeNext:^(id x) { NSLog(@"點擊了通知按鈕 %@", x); }]; // 跳轉到第二個控制器 [self presentViewController:twoVc animated:YES completion:@"hi"]; } @end
元組類,相似NSArray,用來包裝值.(
@[key, value]
)
RAC中的集合類,用於代替NSArray,NSDictionary,可使用它來快速遍歷數組和字典。
使用場景:字典轉模型
// 1.遍歷數組 NSArray *numbers = @[@1,@2,@3,@4]; // 這裏實際上是三步 // 第一步: 把數組轉換成集合RACSequence numbers.rac_sequence // 第二步: 把集合RACSequence轉換RACSignal信號類,numbers.rac_sequence.signal // 第三步: 訂閱信號,激活信號,會自動把集合中的全部值,遍歷出來。 [numbers.rac_sequence.signal subscribeNext:^(id x) { NSLog(@"%@", x); }]; // 2.遍歷字典,遍歷出來的鍵值對 都會包裝成 RACTuple(元組對象) @[key, value] NSDictionary *dic = @{@"name": @"BYqiu", @"age": @18}; [dic.rac_sequence.signal subscribeNext:^(RACTuple *x) { // 解元組包,會把元組的值,按順序給參數裏的變量賦值 // 寫法至關與 // NSString *key = x[0]; // NSString *value = x[1]; RACTupleUnpack(NSString *key, NSString *value) = x; NSLog(@"key:%@, value:%@", key, value); }]; // 3.字典轉模型 NSString *filePath = [[NSBundle mainBundle] pathForResource:@"flags.plist" ofType:nil]; NSArray *dicArray = [NSArray arrayWithContentsOfFile:filePath]; NSMutableArray *items = [NSMutableArray array]; // OC寫法 for (NSDictionary *dic in dicArray) { //FlagItem *item = [FlagItem flagWithDict:dict]; //[items addObject:item]; } // RAC寫法 [dicArray.rac_sequence.signal subscribeNext:^(id x) { // 利用RAC遍歷, x:字典 //FlagItem *item = [FlagItem flagWithDict:x]; //[items addObject:item]; }]; // RAC高級用法(函數式編程) NSArray *flags = [[dicArray.rac_sequence map:^id(id value) { return [FlagItem flagWithDict:value]; }] array];
RAC中用於處理事件的類,能夠把事件如何處理,事件中的數據如何傳遞,包裝到這個類中,他能夠很方便的監控事件的執行過程。
1、RACCommand使用步驟:
initWithSignalBlock:(RACSignal * (^)(id input))signalBlock
- (RACSignal *)execute:(id)input
2、RACCommand使用注意:
nil
.[RACSignal empty]
;[subscriber sendCompleted]
,這時命令纔會執行完畢,不然永遠處於執行中。3、RACCommand設計思想:
內部signalBlock爲何要返回一個信號,這個信號有什麼用。
4、如何拿到RACCommand中返回信號發出的數據。
executionSignals
,這個是 signal of signals
(信號的信號),意思是信號發出的數據是信號,不是普通的類型。5、監聽當前命令是否正在執行 executing
6、使用場景,監聽按鈕點擊,網絡請求
使用:
// 1.建立命令 RACCommand *command = [[RACCommand alloc] initWithSignalBlock:^RACSignal *(id input) { NSLog(@"執行命令"); // 返回空信號 //return [RACSignal empty]; // 2.建立信號 傳遞數據 return [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { [subscriber sendNext:@"請求數據"]; // 注意:數據傳遞完,最好調用sendCompleted,這時命令才執行完畢 [subscriber sendCompleted]; return nil; }]; }]; // 強引用命令,不要被銷燬,不然接收不到數據 _command = command; // 3.訂閱RACCommand的信號 [command.executionSignals subscribeNext:^(id x) { [x subscribeNext:^(id x) { NSLog(@"訂閱RACCommand的信號: %@", x); }]; }]; // RAC高級用法 // switchToLatest:用於signal of signals,獲取signal of signals發出的最新信號,也就是能夠直接拿到RACCommand中的信號 [command.executionSignals.switchToLatest subscribeNext:^(id x) { NSLog(@"RAC高級用法: %@", x); }]; // 4.監聽命令是否執行完畢,默認會來一次,能夠直接跳過,skip表示跳過第一次信號。 [[command.executing skip:1] subscribeNext:^(id x) { if ([x boolValue] == YES) { // 正在執行 NSLog(@"正在執行"); } else { // 執行完畢 NSLog(@"執行完成"); } }]; // 5.執行命名 [self.command execute:@1];
用於當一個信號,被屢次訂閱時,爲了保證建立信號時,避免屢次調用建立信號中的block,形成反作用,可使用這個類處理。
注意:RACMulticastConnection經過RACSignal的 -publish
或者 -muticast:
方法建立.
RACMulticastConnection使用步驟:
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe
RACMulticastConnection *connect = [signal publish]
[connect.signal subscribeNext:nextBlock]
[connect connect]
RACMulticastConnection底層原理:
connect
,connect.sourceSignal -> RACSignal(原始信號) connect.signal -> RACSubject
connect.signal
,會調用RACSubject的 subscribeNext
,建立訂閱者,並且把訂閱者保存起來,不會執行block。[connect connect]
內部會訂閱 RACSignal(原始信號),而且訂閱者是RACSubject
didSubscribe
didSubscribe
,拿到訂閱者調用 sendNext
,實際上是調用RACSubject的 sendNext
sendNext
,會遍歷 RACSubject 全部訂閱者發送信號。
nextBlock
需求:假設在一個信號中發送請求,每次訂閱一次都會發送請求,這樣就會致使屢次請求。
解決:使用 RACMulticastConnection 就能解決.
問題:每次訂閱一次都會發送請求
// 建立請求信號 RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { NSLog(@"發送請求"); [subscriber sendNext:@1]; return nil; }]; // 訂閱信號 [signal subscribeNext:^(id x) { NSLog(@"接受數據: %@", x); }]; // 再次訂閱信號,會再次執行發送請求,也就是每次訂閱都會發送一次請求 [signal subscribeNext:^(id x) { NSLog(@"接受數據: %@", x); }];
輸出:
2016-12-28 11:37:04.397 ReactiveCacoa[1505:340573] 發送請求 2016-12-28 11:37:04.398 ReactiveCacoa[1505:340573] 接受數據: 1 2016-12-28 11:37:04.398 ReactiveCacoa[1505:340573] 發送請求 2016-12-28 11:37:04.398 ReactiveCacoa[1505:340573] 接受數據: 1
能夠發現每次訂閱都會從新發送請求.
下面咱們使用RACMulticastConnection:
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { NSLog(@"發送請求"); [subscriber sendNext:@1]; return nil; }]; // 建立鏈接 RACMulticastConnection *connect = [signal publish]; // 訂閱信號 // 注意:訂閱信號,也不能激活信號,只是保存訂閱者到數組,必須經過鏈接,當調用鏈接,就會一次性調用全部訂閱者的SendNext [connect.signal subscribeNext:^(id x) { NSLog(@"訂閱者1信號: %@", x); }]; [connect.signal subscribeNext:^(id x) { NSLog(@"訂閱者2信號: %@", x); }]; // 鏈接、激活信號 [connect connect];
輸出:
2016-12-28 11:37:04.399 ReactiveCacoa[1505:340573] 發送請求 2016-12-28 11:37:04.399 ReactiveCacoa[1505:340573] 訂閱者1信號: 1 2016-12-28 11:37:04.399 ReactiveCacoa[1505:340573] 訂閱者2信號: 1
RAC中的隊列,用GCD封裝的。
表⽰stream不包含有意義的值,也就是看到這個,能夠直接理解爲nil.
把數據包裝成信號事件(signal event)。它主要經過RACSignal的-materialize來使用,然並卵。
rac_signalForSelector:
rac_signalForSelector:
直接監聽 Selector
事件的調用
應用場景:監聽 RedViewController
中按鈕的點擊事件 btnTap:
跳轉到RedViewController
前,先使用rac_signalForSelector
訂閱rvc中的 btnTap: 點擊事件
// 使用segue跳轉 - (void)prepareForSegue:(UIStoryboardSegue *)segue sender:(id)sender { - if ([segue.identifier isEqualToString:@"goRedVC"]) { RedViewController *rvc = segue.destinationViewController; // 訂閱rvc中的 btnTap: 點擊事件 [[rvc rac_signalForSelector:@selector(btnTap:)] subscribeNext:^(id x) { NSLog(@"RedVC btnTap!"); }]; } }
RedViewController.m
中的按鈕事件
- (IBAction)btnTap:(id)sender { NSLog(@"!"); }
rac_valuesForKeyPath:
// KVO // 監聽 slider 的 value 變化 [[self.slider rac_valuesForKeyPath:@"value" observer:nil] subscribeNext:^(id x) { NSLog(@"slider value Change:%@", x); }];
rac_signalForControlEvents:
// 監聽 btn 的 UIControlEventTouchUpInside 點擊事件 [[self.btn rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(id x) { NSLog(@"btnTap"); }];
rac_textSignal
[[self.textField rac_textSignal] subscribeNext:^(id x) { NSLog(@"textField change: %@", x); }];
rac_liftSelector:
- (void)viewDidLoad { [super viewDidLoad]; // 處理多個請求都返回結果的時候,統一處理 // 如同時進行多個網絡請求,每一個請求都正確返回時,再去刷新頁面 RACSignal *signalOne = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { // 網絡請求1 // ... // 返回成功 [subscriber sendNext:@"網絡請求1 data"]; return nil; }]; RACSignal *signalTwo = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { // 網絡請求2 // ... // 返回成功 [subscriber sendNext:@"網絡請求2 data"]; return nil; }]; [self rac_liftSelector:@selector(updateWithR1:R2:) withSignalsFromArray:@[signalOne, signalTwo]]; } // 更新界面 - (void)updateWithR1:(id)r1 R2:(id)r2 { NSLog(@"R1:%@, R2:%@ 完成!", r1, r2); }
替換KVO
和 監聽文本框文字改變
方法在建立監聽方法時就會執行一次。
2016-12-28 16:53:50.746 ReactiveCacoa[4956:1246592] slider value Change:0.5
2016-12-28 16:53:50.748 ReactiveCacoa[4956:1246592] textField change:
- 使用`rac_liftSelector`時 `@selector(updateWithR1:R2:) `中的方 **參數個數** 要與 **signal個數** 相同,不然會被斷言Crash! >下一篇:[《ReactiveCocoa進階》](http://www.jianshu.com/p/e0b0afd0519f)