使用ReactiveCocoa实现iOS平台响应式编程

ReactiveCocoa和响应式编程

在说ReactiveCocoa之前，先要介绍一下FRP（Functional Reactive Programming，响应式编程），在维基百科中有这样一个例子介绍：

在命令式编程环境中，a = b + c 表示将表达式的结果赋给a，而之后改变b或c的值不会影响a。但在响应式编程中，a的值会随着b或c的更新而更新。

Excel就是响应式编程的一个例子。单元格可以包含字面值或类似”=B1+C1″的公式，而包含公式的单元格的值会依据其他单元格的值的变化而变化 。

而ReactiveCocoa简称RAC，就是基于响应式编程思想的Objective-C实践，它是Github的一个开源项目，你可以在这里找到它。

关于FRP和ReactiveCocoa可以去看leezhong的这篇blog，图文并茂，讲的很好。

ReactiveCocoa框架概览

先来看一下leezhong再博文中提到的比喻，让你对有个ReactiveCocoa很好的理解：

可以把信号想象成水龙头，只不过里面不是水，而是玻璃球(value)，直径跟水管的内径一样，这样就能保证玻璃球是依次排列，不会出现并排的情况(数据都是线性处理的，不会出现并发情况)。水龙头的开关默认是关的，除非有了接收方(subscriber)，才会打开。这样只要有新的玻璃球进来，就会自动传送给接收方。可以在水龙头上加一个过滤嘴(filter)，不符合的不让通过，也可以加一个改动装置，把球改变成符合自己的需求(map)。也可以把多个水龙头合并成一个新的水龙头(combineLatest:reduce:)，这样只要其中的一个水龙头有玻璃球出来，这个新合并的水龙头就会得到这个球。

下面我来逐一介绍ReactiveCocoa框架的每个组件

Streams

Streams 表现为RACStream类，可以看做是水管里面流动的一系列玻璃球，它们有顺序的依次通过，在第一个玻璃球没有到达之前，你没法获得第二个玻璃球。

RACStream描述的就是这种线性流动玻璃球的形态，比较抽象，它本身的使用意义并不很大，一般会以signals或者sequences等这些更高层次的表现形态代替。

Signals

Signals 表现为RACSignal类，就是前面提到水龙头，ReactiveCocoa的核心概念就是Signal，它一般表示未来要到达的值，想象玻璃球一个个从水龙头里出来，只有了接收方（subscriber）才能获取到这些玻璃球（value）。

Signal会发送下面三种事件给它的接受方（subscriber)，想象成水龙头有个指示灯来汇报它的工作状态，接受方通过

-subscribeNext:error:completed:

对不同事件作出相应反应

• next 从水龙头里流出的新玻璃球（value）
• error 获取新的玻璃球发生了错误，一般要发送一个NSError对象，表明哪里错了
• completed 全部玻璃球已经顺利抵达，没有更多的玻璃球加入了

一个生命周期的Signal可以发送任意多个“next”事件，和一个“error”或者“completed”事件（当然“error”和“completed”只可能出现一种）

Subjects

subjects 表现为RACSubject类，可以认为是“可变的（mutable）”信号/自定义信号，它是嫁接非RAC代码到Signals世界的桥梁，很有用。嗯。。。 这样讲还是很抽象，举个例子吧：

1 2 3

RACSubject *letters = [RACSubject subject]; RACSignal *signal = [letters sendNext:@"a"];

可以看到

@"a"

只是一个NSString对象，要想在水管里顺利流动，就要借RACSubject的力。

Commands

command 表现为RACCommand类，偷个懒直接举个例子吧，比如一个简单的注册界面：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21

RACSignal *formValid=[RACSignal         combineLatest:@[             self.userNameField.rac_textSignal,             self.emailField.rac_textSignal,         ]         reduce:^(NSString *userName,NSString *email){             return@(userName.length>0                     &&email.length>0);         }];     RACCommand *createAccountCommand=[RACCommandcommandWithCanExecuteSignal:formValid];   RACSignal *networkResults=[[[createAccountCommand       addSignalBlock:^RACSignal *(idvalue){           //... 网络交互代码       }]       switchToLatest]       deliverOn:[RACSchedulermainThreadScheduler]];     // 绑定创建按钮的 UI state 和点击事件     [[self.createButtonrac_signalForControlEvents:UIControlEventTouchUpInside]executeCommand:createAccountCommand];

Sequences

sequence 表现为RACSequence类，可以简单看做是RAC世界的NSArray，RAC增加了

-rac_sequence

方法，可以使诸如NSArray这些集合类（collection classes）直接转换为RACSequence来使用。

Schedulers

scheduler 表现为RACScheduler类，类似于GCD，but schedulers support cancellationbut schedulers support cancellation, and always execute serially.

ReactiveCocoa的简单使用

实践出真知，下面就举一些简单的例子，一起看看RAC的使用

Subscription

接收 

-subscribeNext:

-subscribeError:

-subscribeCompleted:

1 2 3 4 5 6 7

RACSignal *letters = [@"A B C D E F G H I" componentsSeparatedByString:@" "].rac_sequence.signal;   // 依次输出 A B C D… [letters subscribeNext:^(NSString *x) {     NSLog(@"%@", x); }];

Injecting effects

注入效果 

-doNext:

-doError:

-doCompleted:

，看下面注释应该就明白了：

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20

__blockunsignedsubscriptions=0;   RACSignal *loggingSignal=[RACSignalcreateSignal:^RACDisposable *(id<RACSubscriber>subscriber){     subscriptions++;     [subscribersendCompleted];     returnnil; }];   // 不会输出任何东西 loggingSignal=[loggingSignaldoCompleted:^{     NSLog(@"about to complete subscription %u",subscriptions); }];   // 输出: // about to complete subscription 1 // subscription 1 [loggingSignalsubscribeCompleted:^{     NSLog(@"subscription %u",subscriptions); }];

Mapping

-map:

 映射，可以看做对玻璃球的变换、重新组装

1 2 3 4 5 6 7

RACSequence *letters = [@"A B C D E F G H I" componentsSeparatedByString:@" "].rac_sequence;   // Contains: AA BB CC DD EE FF GG HH II RACSequence *mapped = [letters map:^(NSString *value) {     return [value stringByAppendingString:value]; }];

Filtering

-filter:

 过滤，不符合要求的玻璃球不允许通过

1 2 3 4 5 6 7

RACSequence *numbers=[@"1 2 3 4 5 6 7 8 9"componentsSeparatedByString:@" "].rac_sequence;   // Contains: 2 4 6 8 RACSequence *filtered=[numbersfilter:^BOOL(NSString *value){     return(value.intValue%2)==0; }];

Concatenating

-concat:

 把一个水管拼接到另一个水管之后

1 2 3 4 5 6

RACSequence *letters = [@"A B C D E F G H I" componentsSeparatedByString:@" "].rac_sequence; RACSequence *numbers = [@"1 2 3 4 5 6 7 8 9" componentsSeparatedByString:@" "].rac_sequence;   // Contains: A B C D E F G H I 1 2 3 4 5 6 7 8 9 RACSequence *concatenated = [letters concat:numbers];

Flattening

-flatten:

Sequences are concatenated

1 2 3 4 5 6 7

RACSequence *letters=[@"A B C D E F G H I"componentsSeparatedByString:@" "].rac_sequence; RACSequence *numbers=[@"1 2 3 4 5 6 7 8 9"componentsSeparatedByString:@" "].rac_sequence; RACSequence *sequenceOfSequences=@[letters,numbers].rac_sequence;   // Contains: A B C D E F G H I 1 2 3 4 5 6 7 8 9 RACSequence *flattened=[sequenceOfSequencesflatten];

Signals are merged （merge可以理解成把几个水管的龙头合并成一个，哪个水管中的玻璃球哪个先到先吐哪个玻璃球）

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22

RACSubject *letters = [RACSubject subject]; RACSubject *numbers = [RACSubject subject]; RACSignal *signalOfSignals = [RACSignal createSignal:^ RACDisposable * (id<RACSubscriber> subscriber) {     [subscriber sendNext:letters];     [subscriber sendNext:numbers];     [subscriber sendCompleted];     return nil; }];   RACSignal *flattened = [signalOfSignals flatten];   // Outputs: A 1 B C 2 [flattened subscribeNext:^(NSString *x) {     NSLog(@"%@", x); }];   [letters sendNext:@"A"]; [numbers sendNext:@"1"]; [letters sendNext:@"B"]; [letters sendNext:@"C"]; [numbers sendNext:@"2"];

Mapping and flattening

-flattenMap:

 先 map 再 flatten

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23 24 25 26 27 28 29 30

RACSequence *numbers=[@"1 2 3 4 5 6 7 8 9"componentsSeparatedByString:@" "].rac_sequence;   // Contains: 1 1 2 2 3 3 4 4 5 5 6 6 7 7 8 8 9 9 RACSequence *extended=[numbersflattenMap:^(NSString *num){     return@[num,num].rac_sequence; }];   // Contains: 1_ 3_ 5_ 7_ 9_ RACSequence *edited=[numbersflattenMap:^(NSString *num){     if(num.intValue%2==0){         return[RACSequenceempty];     }else{         NSString *newNum=[numstringByAppendingString:@"_"];         return[RACSequencereturn:newNum];     } }];         RACSignal *letters=[@"A B C D E F G H I"componentsSeparatedByString:@" "].rac_sequence.signal;   [[letters     flattenMap:^(NSString *letter){         return[databasesaveEntriesForLetter:letter];     }]     subscribeCompleted:^{         NSLog(@"All database entries saved successfully.");     }];

Sequencing

-then:

1 2 3 4 5 6 7 8 9 10 11 12 13

RACSignal *letters = [@"A B C D E F G H I" componentsSeparatedByString:@" "].rac_sequence.signal;   // 新水龙头只包含: 1 2 3 4 5 6 7 8 9 // // 但当有接收时，仍会执行旧水龙头doNext的内容，所以也会输出 A B C D E F G H I RACSignal *sequenced = [[letters     doNext:^(NSString *letter) {         NSLog(@"%@", letter);     }]     then:^{         return [@"1 2 3 4 5 6 7 8 9" componentsSeparatedByString:@" "].rac_sequence.signal;     }];

Merging

+merge:

 前面在flatten中提到的水龙头的合并

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15

RACSubject *letters=[RACSubjectsubject]; RACSubject *numbers=[RACSubjectsubject]; RACSignal *merged=[RACSignalmerge:@[letters,numbers]];   // Outputs: A 1 B C 2 [mergedsubscribeNext:^(NSString *x){     NSLog(@"%@",x); }];   [letterssendNext:@"A"]; [numberssendNext:@"1"]; [letterssendNext:@"B"]; [letterssendNext:@"C"]; [numberssendNext:@"2"];

Combining latest values

+combineLatest:

 任何时刻取每个水龙头吐出的最新的那个玻璃球

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20

RACSubject *letters = [RACSubject subject]; RACSubject *numbers = [RACSubject subject]; RACSignal *combined = [RACSignal     combineLatest:@[ letters, numbers ]     reduce:^(NSString *letter, NSString *number) {         return [letter stringByAppendingString:number];     }];   // Outputs: B1 B2 C2 C3 [combined subscribeNext:^(id x) {     NSLog(@"%@", x); }];   [letters sendNext:@"A"]; [letters sendNext:@"B"]; [numbers sendNext:@"1"]; [numbers sendNext:@"2"]; [letters sendNext:@"C"]; [numbers sendNext:@"3"];

Switching

-switchToLatest:

 取指定的那个水龙头的吐出的最新玻璃球

1 2 3 4 5 6 7 8 9 10 11 12 13 14 15 16 17 18 19 20 21 22 23

RACSubject *letters=[RACSubjectsubject]; RACSubject *numbers=[RACSubjectsubject]; RACSubject *signalOfSignals=[RACSubjectsubject];   RACSignal *switched=[signalOfSignalsswitchToLatest];   // Outputs: A B 1 D [switchedsubscribeNext:^(NSString *x){     NSLog(@"%@",x); }];   [signalOfSignalssendNext:letters]; [letterssendNext:@"A"]; [letterssendNext:@"B"];   [signalOfSignalssendNext:numbers]; [letterssendNext:@"C"]; [numberssendNext:@"1"];   [signalOfSignalssendNext:letters]; [numberssendNext:@"2"]; [letterssendNext:@"D"];

常用宏

RAC 可以看作某个属性的值与一些信号的联动

1 2 3 4

RAC(self.submitButton.enabled) = [RACSignal combineLatest:@[self.usernameField.rac_textSignal, self.passwordField.rac_textSignal]reduce:^id(NSString *userName, NSString *password) {     return @(userName.length >= 6 && password.length >= 6); }];

RACObserve 监听属性的改变，使用block的KVO

1 2 3 4

[RACObserve(self.textField,text)subscribeNext:^(NSString *newName){     NSLog(@"%@",newName); }];

UI Event

RAC为系统UI提供了很多category，非常棒，比如UITextView、UITextField文本框的改动

rac_textSignal

，UIButton的的按下

rac_command

等等。

最后

有了RAC，可以不用去操心值什么时候到达什么时候改变，只需要简单的进行数据来了之后的步骤就可以了。

说了这么多，在回过头去看leezhong的比喻和该文最后总结的关系图，再好好梳理一下吧。我也是初学者，诚惶诚恐的呈上这篇博文，欢迎讨论，如有不正之处欢迎批评指正。

参考

https://github.com/ReactiveCocoa/ReactiveCocoa

https://github.com/ReactiveCocoa/ReactiveCocoa/blob/master/Documentation/FrameworkOverview.md

https://github.com/ReactiveCocoa/ReactiveCocoa/blob/master/Documentation/BasicOperators.md

http://vimeo.com/65637501

http://iiiyu.com/2013/09/11/learning-ios-notes-twenty-eight/

http://blog.leezhong.com/ios/2013/06/19/frp-reactivecocoa.htmlhttp://nshipster.com/reactivecocoa/