公司项目中使用到了 RAC 的东西,现在有时间了稍微总结下:
一.什么是 RAC?
- 1.是有 github 开源的一个应用于 iOS 和 OS x 开发的新框架
- 2.RAC 是一个函数响应式编程框架
- 3.RAC 使用 signal 信号 和 signalProducer 信号提供者类型来便是事件流,也就是使用信号代替事件流
- 4.RAC 把所有的事件流统一用一种凡是来处理
- 代理,block,通知,点击事件和响应者链条事件,kvo,属性监听等
- 5.RAC 可以很简单的声明一个链条结合在一起,减少代码的耦合和相互之间的依赖
RAC 解决哪些问题?
- 1.是代码更加直观,减少代码的复杂度
- 2.使开发者专注于数据和界面
- 3.通过 block 减低代码间的耦合
- 4.为 target-action/代理/通知/kvo 统一消息传递机制
二.初识 RAC 的几个类
- 1.RACStream:一系列事件流的抽象类
- 2.RACSignal:具体的事件流对象,继承自 RACStream
- 3.RACDisposable:信号取消订阅对象
其他:RAC 为 UIKit 中的类大部分提供了分类,用来获取对象的信号
三.RAC 的使用思想
- 1.获取或者创建一个信号对象
- 2.调用信号的订阅方法
//监听用户密码文本变化 //RAC吧代理转化为文本信号 RACSignal *textSignal = self.pwdTF.rac_textSignal; [textSignal subscribeNext:^(id x) { NSLog(@"%@",x); }]; //监听按钮的点击事件 RACSignal *clickSignal = [self.loginBtn rac_signalForControlEvents:UIControlEventTouchUpInside]; [clickSignal subscribeNext:^(id x) { NSLog(@"%@",x);//x是btn }];
- (void)viewDidLoad { [super viewDidLoad]; //subscribeNext方法会返回一个取消订阅对象 self.disposable = [[self.loginBtn rac_signalForControlEvents:UIControlEventTouchUpInside]subscribeNext:^(id x) { NSLog(@"%@",x);//x是btn }]; } - (void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event{//点击空白部分后就不再订阅对应的信号 //取消按钮点击信号的订阅 [self.disposable dispose]; }
四.RACSignal 的其他方法
- 1.map:方法更改信号的输出类型,map 方法返回一个信号
//map:更改订阅block输出的id参数的类型 RACSignal *textSignal = self.pwdTF.rac_textSignal; textSignal = [textSignal map:^id(id value) {//这个value就是文本框输入的内容,可以在这个block做一些处理 return @(1); }]; [textSignal subscribeNext:^(id x) { NSLog(@"%@",x);//不管文本框输入什么,都输出1 }];
- 2.filter:过滤,filter 可以决定订阅的 block 是否被调用,方法返回一个信号
//filter可以决定订阅的block是否被调用,做一个过滤 RACSignal *textSignal = self.pwdTF.rac_textSignal; textSignal = [textSignal filter:^BOOL(NSString *value) { //当文字的个数大于6时,能调用订阅的block return value.length > 6; }]; [textSignal subscribeNext:^(id x) { NSLog(@"%@",x);//是否输出由filter返回的bool值决定 }];
- 3.combineLatest:reduce 方法可以组合信号
NSArray *signals = @[self.accountTF.rac_textSignal,self.pwdTF.rac_textSignal]; //第一个参数:信号的数组 第二个参数block //组合信号 RACSignal *combineSignal = [RACSignal combineLatest:signals reduce:^id(NSString *username,NSString *pwd){ //当用户名和密码长度都大于1时,返回yes BOOL btnEnable = (username.length > 0 && pwd.length > 0); return @(btnEnable); }]; [combineSignal subscribeNext:^(id x) { NSLog(@"%@",x);//这里订阅的是组合信号 //设置按钮的可用状态 self.loginBtn.enabled = [x boolValue]; }];
四.自定义信号
自定义一个网络请求信号
//1.创建一个网络信号,把网络请求封装成一个信号,一般封装到viewmodel中 RACSignal *ipSignal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { //subscriber:订阅者 //写网络请求 // 1.创建一个请求对象 NSURLRequest *request = [NSURLRequest requestWithURL:[NSURL URLWithString:@""]]; // 2.通过session对象创建一个任务 NSURLSessionDataTask *dataTask = [[NSURLSession sharedSession]dataTaskWithRequest:request completionHandler:^(NSData * _Nullable data, NSURLResponse * _Nullable response, NSError * _Nullable error) { if (!error) { NSLog(@"%@",response); //网络请求成功,调用订阅者的sendNext方法 [subscriber sendNext:response];//不会终止信号的订阅 [subscriber sendCompleted];//会终止信号的订阅,订阅的block就不会被调用 }else{ NSLog(@"%@",error); [subscriber sendError:error];//会终止信号的订阅,订阅的block就不会被调用 } }]; // 3.执行任务 [dataTask resume]; //返回一个取消订阅对象 return [RACDisposable disposableWithBlock:^{ //取消网络请求 [dataTask cancel]; }]; }]; // 2.订阅信号 [ipSignal subscribeNext:^(id x) { NSLog(@"网络请求成功%@",x); } error:^(NSError *error) { NSLog(@"网络请求失败%@",error); } completed:^{ NSLog(@"终止了信号的订阅"); }];
五.信号的创建和订阅底层剖析
RAC 中是函数响应式编程思想,一般是信号,然后订阅信号,如果不订阅信号,信号就不会被执行,底层是如何实现的呢?下面一步步剖析原码结合图,看看底层到底如何实现的.
1.创建一个信号
RACSignal *signal = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { [subscriber sendNext:@"发出信号"]; return nil; }];
- 1.上面创建了一个信号,跳进
createSignal方法,看里面做了什么,其实就是返回了一个RACDynamicSignal动态的信号,然后将didSubscribe(比如上面的网络请求信号 block)这个 block 在动态信号创建时传了进去
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe { return [RACDynamicSignal createSignal:didSubscribe];//返回动态信号 }
- 2.跳进动态信号的创建方法
createSignal如下,可以看到didSubscribe这个 block 在动态信号创建时copy给了RACDynamicSignal动态信号的一个属性.
+ (RACSignal *)createSignal:(RACDisposable * (^)(id<RACSubscriber> subscriber))didSubscribe { RACDynamicSignal *signal = [[self alloc] init]; signal->_didSubscribe = [didSubscribe copy]; return [signal setNameWithFormat:@"+createSignal:"]; }
2.订阅信号
[signal subscribeNext:^(id x) { NSLog(@"成功接收信号%@",x); } error:^(NSError *error) { NSLog(@"接收信号失败%@",error); } completed:^{ NSLog(@"接收信号完毕"); }];
- 1.上面我们是订阅了这个信号,现在看一下
subscribeNext里面做了什么
- (RACDisposable *)subscribeNext:(void (^)(id x))nextBlock { NSCParameterAssert(nextBlock != NULL); //创建了一个订阅者 RACSubscriber *o = [RACSubscriber subscriberWithNext:nextBlock error:NULL completed:NULL]; return [self subscribe:o]; }
- 2.从上面可以看到,如果订阅了这个信号,内部会创建一个
RACSubscriber对象,然后在创建时将订阅后的 block,就是一开始订阅信号subscribeNext这个 block 传进去,然后再看里面做了什么
+ (instancetype)subscriberWithNext:(void (^)(id x))next error:(void (^)(NSError *error))error completed:(void (^)(void))completed { RACSubscriber *subscriber = [[self alloc] init]; subscriber->_next = [next copy]; subscriber->_error = [error copy]; subscriber->_completed = [completed copy]; return subscriber; }
- 3.可以看到,其实就是将一开始订阅信号
subscribeNext这个 block,赋值给了subscriber订阅者的一个属性,然后接着看 2 中return [self subscribe:o];这里的 self 是那个动态的信号,然后调用了subscribe方法,里面是做了什么如下
- (RACDisposable *)subscribe:(id<RACSubscriber>)subscriber { NSCParameterAssert(subscriber != nil); RACCompoundDisposable *disposable = [RACCompoundDisposable compoundDisposable]; //把订阅者给改了 subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable]; if (self.didSubscribe != NULL) { RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{ RACDisposable *innerDisposable = self.didSubscribe(subscriber); [disposable addDisposable:innerDisposable]; }]; [disposable addDisposable:schedulingDisposable]; } return disposable; }
- 4.上面的方法一步一步来看,首先创建了一个
RACCompoundDisposable跳进去看一下,发现就是创建了一个对象什么也没做,subscriber = [[RACPassthroughSubscriber alloc] initWithSubscriber:subscriber signal:self disposable:disposable];这里创建了一个RACPassthroughSubscriber并且把订阅者subscriber,信号self,取消订阅disposable传了进去,里面做了什么如下
- (instancetype)initWithSubscriber:(id<RACSubscriber>)subscriber signal:(RACSignal *)signal disposable:(RACCompoundDisposable *)disposable { NSCParameterAssert(subscriber != nil); self = [super init]; if (self == nil) return nil; _innerSubscriber = subscriber; _signal = signal; _disposable = disposable; [self.innerSubscriber didSubscribeWithDisposable:self.disposable]; return self; }
- 5.可以看到把订阅者
subscriber,信号self,取消订阅disposable分别传给了对象RACPassthroughSubscriber的 3 个属性,然后再返回到 3 中看创建了RACPassthroughSubscriber后做了什么即 3 中的代码
if (self.didSubscribe != NULL) {//信号里的block不为空 RACDisposable *schedulingDisposable = [RACScheduler.subscriptionScheduler schedule:^{ RACDisposable *innerDisposable = self.didSubscribe(subscriber); [disposable addDisposable:innerDisposable]; }]; [disposable addDisposable:schedulingDisposable]; }
- 6.这里首先
[RACScheduler.subscriptionScheduler调用了RACScheduler的一个方法subscriptionScheduler看里面做了什么如下
+ (instancetype)subscriptionScheduler { static dispatch_once_t onceToken; static RACScheduler *subscriptionScheduler; dispatch_once(&onceToken, ^{ subscriptionScheduler = [[RACSubscriptionScheduler alloc] init]; }); return subscriptionScheduler; }
- 7.创建了一个
RACSubscriptionScheduler对象,然后接着看紧接着用创建出来的对象调用了schedule方法,并且传进去一个 block,看下里面做了什么如下
- (RACDisposable *)schedule:(void (^)(void))block { NSCParameterAssert(block != NULL); if (RACScheduler.currentScheduler == nil) return [self.backgroundScheduler schedule:block]; block();//调用block return nil; }
- 8.我们发现我们的 block 在这里执行,这个 block,是什么就是
RACDisposable *innerDisposable = self.didSubscribe(subscriber); [disposable addDisposable:innerDisposable]; }];
其中 self.didSubscribe(subscriber); 就是执行我们网络请求的那个 block,
- 综述:最终是 RACScheduler 来执行的,所以如果信号不被订阅就不会有
RACScheduler这个类,信号就不会被执行
六.RAC 中常用方法
1.flatternMap:信号嵌套
场景设置:点击按钮后再发送网络请求,要监听这两个信号
[[[self.btn rac_signalForControlEvents:UIControlEventTouchUpInSide] flatterMap:^RACStream *(id value){//返回一个新的信号对象 return [self ipSignal] ;//网络请求的信号 }] subscribeNext:^(id x){ NSLog(@"%@",x); }]
2. doNext:额外再添加一些代码
场景设置:点按钮转菊花
[[[[self.btn rac_signalForControlEvents:UIControlEventTouchUpInSide]doNext:^(id x){ //网络请求之前做事情 [self.indicator startAnimating]; }]flatterMap:^RACStream *(id value){//返回一个新的信号对象 return [self ipSignal] ;//网络请求的信号 }] subscribeNext:^(id x){ NSLog(@"%@",x); [self.indicator stopAnimating]; }]
3.throttle:订阅的 block(subscribeNext)延时被调用
场景设置:点击按钮一段时间后再调用
[[[self.btn rac_signalForControlEvents:UIControlEventTouchUpInside] throttle:5]subscribeNext:^(id x){ NSLog(@"%@",x); }]
4.concat :信号串联,必须是一个信号完成之后,才可以开始另一个信号,所以第一个信号必须执行 sendCompleted 才会执行后面的信号
5. merge: 信号并联,信号可以同时并联执行,必定是多线程执行的,后面的信号不一定等到前面的信号执行完才执行
RACSignal *eat = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { [subscriber sendNext:@"吃饭"]; [subscriber sendNext:@"完毕"]; [subscriber sendCompleted]; return nil; }]; RACSignal *work = [RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) { [subscriber sendNext:@"上班"]; [subscriber sendNext:@"完毕"]; [subscriber sendCompleted]; return nil; }]; [[eat concat:work]subscribeNext:^(id x) { NSLog(@"%@",x);//吃饭 完毕 上班 完毕 eat没有sendCompleted,就输出 吃饭 完毕 }]; [[eat merge:work]subscribeNext:^(id x) { NSLog(@"%@",x); }];
6.then:信号忽略,会忽略调用此方法的信号,内部实现是串联 concat
[[eat then:^RACSignal *{//返回一个信号 return work;//只执行上班, }] subscribeNext:^(id x) { NSLog(@"%@",x);//会忽略吃饭 }];;
7. delay:延迟多久后,订阅 block 才会被调用
[[[self.loginBtn rac_signalForControlEvents:UIControlEventTouchUpInside]delay:5]subscribeNext:^(id x) { NSLog(@"%@",x);//5s后调用 }];
8.timeout:超时
[[self.internationnalSignal timeout:5 onScheduler:[RACScheduler scheduler]]subscribeNext:^(id x) { NSLog(@"%@",x);//如果时间超过5s后就不会调用 }];
七.常用 RAC 中信号分类:
1. UIImagePickerController+RACSignalSupport.h:获取相册图片
- (void)touchesBegan:(NSSet<UITouch *> *)touches withEvent:(UIEvent *)event { UIImagePickerController *picker = [[UIImagePickerController alloc]init]; picker.sourceType = UIImagePickerControllerSourceTypePhotoLibrary; //之前是设置代理 //现在通过信号获取用户选中的图片 穿过来的是一个字典 [picker.rac_imageSelectedSignal subscribeNext:^(NSDictionary * x) { NSLog(@"%@",x); UIImage *selectedImage = x[@"UIImagePickerControllerOriginalImage"]; [self dismissViewControllerAnimated:YES completion:nil]; }]; [self presentViewController:picker animated:YES completion:nil]; }
2. NSNotificationCenter+RACSupport.h:通知
[[[NSNotificationCenter defaultCenter]rac_addObserverForName:UIKeyboardWillShowNotification object:nil]subscribeNext:^(id x) { NSLog(@"%@",x); }];
3. "UIGestureRecognizer+RACSignalSupport.h":添加手势
self.view.userInteractionEnabled = YES; UITapGestureRecognizer *tap = [[UITapGestureRecognizer alloc]init]; [tap.rac_gestureSignal subscribeNext:^(id x) { NSLog(@"view被点击"); }]; [self.view addGestureRecognizer:tap];
八.RAC 中常用宏和循环引用
- 1.RACObserve(TARGET,KEYPATH):KVO 监听
//监听某个对象的属性是否变化 //方法一: [self.pwdTF.rac_textSignal subscribeNext:^(id x) { NSLog(@"%@",x); }]; //方法二:RACObserve(<#TARGET#>, <#KEYPATH#>) [RACObserve(self.pwdTF,text)subscribeNext:^(id x) { NSLog(@"%@",x); }];
- 2.RAC(TARGET, ...):绑定某个对象的属性
RAC(self.loginBtn.titleLabel,text) = self.pwdTF.rac_textSignal;
- 3.@weakify(self) @strongify(self) :解决 block 的循环应用
//解决block的循环应用 //方法一:_weak typeof(self) weakself = self; //方法二:@weakify(self) @strongify(self),必须意义对应的使用,可以批量生产弱引用 @weakify(self) [[RACSignal combineLatest:@[self.accountTF.rac_textSignal,self.pwdTF.rac_textSignal] reduce:^id(NSString *username,NSString *pwd){ return @(username.length > 0 && pwd.length > 0); }]subscribeNext:^(id x) { @strongify(self) self.loginBtn.enabled = [x boolValue]; }];
还有两个重要的类:
1.RACCommand
//监听按钮的点击 //方法一: [[self.loginBtn rac_signalForControlEvents:UIControlEventTouchUpInside]subscribeNext:^(id x) { NSLog(@"点击了按钮%@",x); }]; //方法二: //RACCommand:(命令):点击了按钮,执行RACCommand内部的RACSignal的订阅方法 self.loginBtn.rac_command = [[RACCommand alloc]initWithSignalBlock:^RACSignal *(id input) { return [self ipSignal]; }]; //按钮的可用信号 RACSignal *btnEnableSignal = [RACSignal combineLatest:@[self.accountTF.rac_textSignal,self.pwdTF.rac_textSignal] reduce:^id(NSString *username,NSString *pwd){ return @(username.length>0 && pwd.length>0); }]; //按钮点击后触发信号 self.loginBtn.rac_command = [[RACCommand alloc]initWithEnabled:btnEnableSignal signalBlock:^RACSignal *(id input) { return [self ipSignal]; }];
2.RACSequence:主要用于遍历,继承自 RACStream
// RACSequence:主要用于遍历,继承自RACStream // 获取RACSequence里的信号,然后进行遍历 // 1.数组遍历 NSArray *names = @[@"liu",@"wen",@"xiao",@"li"]; [names.rac_sequence.signal subscribeNext:^(id x) { NSLog(@"%@",x); }]; //2.字符串遍历 NSString *text = @"123456789"; [text.rac_sequence.signal subscribeNext:^(id x) { NSLog(@"%@",x); }]; //3.添加过滤条件 [[text.rac_sequence.signal filter:^BOOL(id value) { return [value integerValue] > 5; }] subscribeNext:^(id x) { NSLog(@"%@",x);//输出6,7,8,9 }];
未完待续
由于时间问题,随后会写一个 MVVM 结合 RAC 的小项目供大家参考
最后:文章推荐
如果想深入学习请看这里
- 美团的技术博客
- ReactiveCocoa 与 Functional Reactive Programming
如果想从入门到进阶看这里 GitHub
如果想了解其他相关基础知识看这里最快让你上手 ReactiveCocoa
欢迎来到这里！
我们正在构建一个小众社区，大家在这里相互信任，以平等 • 自由 • 奔放的价值观进行分享交流。最终，希望大家能够找到与自己志同道合的伙伴，共同成长。
注册 关于