iOS RAC 基本使用

RAC使用函数响应式编程的思想，将我们平时用到的按钮点击事件、KVO、代理、通知等等封装起来，处理业务逻辑的代码放到一起，使代码更加的简洁、高内聚、低耦合，那么我们来看看它的具体使用。

一、RAC的基本使用

RAC和KVO

//使用RAC来监听字符串myString的变化
[RACObserve(self, myString) subscribeNext:^(id  _Nullable x) {
    
    NSLog(@"myString值发生变化后的新值：%@",x);
}];

一句代码就可以代替KVO ,代码和功能在一起，写起来方便，简单易读。

• RACObserve(TARGET, KEYPATH): RAC提供的宏定义，用来监听值的变化，返回RACSignal类型的信号，有了这个宏定义返回的信号，就可以订阅该信号，变化后的值。
• subscribeNext:订阅信号，只有订阅了信号才可以收到值的变化。

RAC和通知

//自定义通知  只需把通知名称 替换成自己的即可
[[[NSNotificationCenter defaultCenter] rac_addObserverForName:@"NotificationName" object:nil] subscribeNext:^(NSNotification * _Nullable x) {
    //处理接收到的通知
    NSLog(@"%@",x);
}];
//发送通知
[[NSNotificationCenter defaultCenter] postNotificationName:@"NotificationName" object:@"999" userInfo:@{@"key":@"6666"}];

RAC和代理

self.textField = [[UITextField alloc] initWithFrame:CGRectMake(100, 100, 200, 50)];
self.textField.placeholder = @"RAC_Test";
self.textField.delegate = self;
[self.view addSubview:_textField];
// 添加UITextFieldDelegate代理方法textFieldDidBeginEditing:信号
[[self rac_signalForSelector:@selector(textFieldDidBeginEditing:) fromProtocol:@protocol(UITextFieldDelegate)] subscribeNext:^(RACTuple * _Nullable x) {
    //RACTuple：元组类型
    UITextField *field  = [x first];
    //[field resignFirstResponder];
    NSLog(@"---%@",field.text);
}];

rac_signalForSelector:fromProtocol:添加代理方法信号。

• 值得注意的是，接收订阅信号的参数是RACTuple元组类型，熟悉swift语法的话对元组类型一定不陌生，元组是把多个值组合成一个复合值。元组内的值可以是任意类型，并不要求是相同类型

UIButton

// rac_signalForControlEvents：用于监听某个事件。
// 把按钮点击事件转换为信号，点击按钮，就会发送信号
UIButton *button =[[UIButton alloc] initWithFrame:CGRectMake(300, 300, 50, 50)];
[self.view addSubview:button];
button.backgroundColor = [UIColor orangeColor];
//按钮点击信号需要 防止循环引用
@weakify(self);//防止循环引用的问题
[[button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(id x) {
    @strongify(self);//暂时强引用
    NSLog(@"按钮被点击了");
}];

rac_signalForControlEvents ::UIButton的分类方法，产生点击信号。

• 在订阅信号中进行UI的绑定，这种思想在 MVVM+RAC的架构中非常重要，MVVM中通过block回调可以完成ViewModel向UI层数据传递，使用rac进行UI绑定，就可以完成UI层向ViewModel层的数据传输，从而实现双向绑定。

UITextField

//输入框文字改变信号
[self.textField.rac_textSignal subscribeNext:^(NSString * _Nullable x) {
    //打印当前textField的text
    NSLog(@"%@",x);
}];

rac_textSignal:输入框输入的文字发生改变的信号，订阅这个信号可以处理文字长度，输入格式等。

UITapGestureRecognizer(手势)

//给Lable或者View添加监听
UILabel *textLab = [[UILabel alloc] initWithFrame:CGRectMake(100, 100, 200, 30)];
textLab.backgroundColor = [UIColor greenColor];
textLab.text = @"********************";
textLab.userInteractionEnabled = YES;
[self.view addSubview:textLab];
//手势
UITapGestureRecognizer *tap = [[UITapGestureRecognizer alloc] init];
[textLab addGestureRecognizer:tap];
[[tap rac_gestureSignal] subscribeNext:^(id x) {
    NSLog(@"点击Lab");
}];

rac_gestureSignal：手势触发信号。

序列 sequence

数组遍历

NSArray *nameArray = @[@"Niki",@"Pan",@"Ding",@"Jiao"];
//数组遍历
[nameArray.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);//依次打印数组元素
}];

字典遍历

NSDictionary *dict = @{@"name":@"Niki",@"age":@"18",@"number":@"999"};
//遍历字典
[dict.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
   //元组类型
    NSLog(@"%@",x);
    //RACTwoTuple继承自RACTuple，表示有两个值的元组
    RACTwoTuple *tuple = (RACTwoTuple *)x;
    
    NSLog(@"key == %@ , value = %@",tuple[0],tuple[1]);
    
}];

集合类型在RAC中都封装成了序列，通过访问rac_sequence属性得到序列。

二、RAC中的高阶函数

信号映射：map和flattenMap

• map和flattenMap,把原有信号中的值映射成新的值。
• map:方法返回依旧是一个信号RACSignal类型，如下代码，将rac_textSignal信号中的字符串经过map映射处理成字符串的长度。注意：map的block中必须要返回对象类型的数据。

// 修改数据类型格式 ，转换为自己想要的数据 然后返回
[[self.textField.rac_textSignal map:^id _Nullable(NSString * _Nullable value) {
    // 对原数据进行处理
    // 可在这里面对输入框内容进行转换 ，返回自己想要类型的数据
    return @(value.length);
}] subscribeNext:^(id _Nullable x) {
    // 处理后的新值
    NSLog(@"映射后的新值：%@",x);//输出字符串长度
}];

• flattenMap:把源信号的内容映射成一个新的信号，信号可以是任意类型。

[[self.textField.rac_textSignal flattenMap:^__kindof RACSignal * _Nullable(NSString * _Nullable value) {
    //返回RACSignal类型
    return [RACReturnSignal return:@(value.length)];
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"映射后的新值：%@",x);

}];

信号过滤：filter,ignore,distinctUntilChanged

• filter：获取满足条件的信号

• ignore：内部调用了filter，忽略掉ignore传入的参数。

• distinctUntilChanged：跟函数名字面意思一样，直到值和上一次有区别才会发出信号，忽略的是和上一次值一样的信号。经常用于UI的刷新，值发生变化的时候才刷新。

  下面依次来看代码示例：

// filter
[[self.textField.rac_textSignal filter:^BOOL(NSString * _Nullable value) {
    //输入字符串长度大于3
    return value.length > 3;
}] subscribeNext:^(id _Nullable x) {
    //获取到输入字符串长度大于3的信号
    //当输入字符串长度大于3才会在这里打印
    NSLog(@"%@",x);
}];

// ignore
[[self.textField.rac_textSignal ignore:@"n"] subscribeNext:^(NSString * _Nullable x) {
    NSLog(@"这里收不到信号 %@",x);//输入n，这里收不到信号
    
}];

// distinctUntilChanged
RACSubject *subject = [RACSubject subject];
[[subject distinctUntilChanged] subscribeNext:^(id x) {
    //收到的信号依次是a b c,第三次发送的b被忽略了
    NSLog(@"第三次发送的b被忽略了 sendNext -- %@", x);
}];
// 发送信号
[subject sendNext:@"a"];
[subject sendNext:@"b"];
[subject sendNext:@"b"];
[subject sendNext:@"c"];

信号合并：combineLatest,reduce,merge,zip

• combineLatest：将多个信号合并起来，并且拿到各个信号的最新值,必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。
• reduce：把combineLatest的元组聚合成一个值发送出去，相当于对combineLatest的进一步加工，必须每个合并的signal至少都有过一次sendNext，才会触发合并的信号。
• merge：把多个信号合并成一个信号，任何一个信号发送数据，都能监听到。
• zip：把最近发出的信号包装成元组发出。当每个信号同事发出信号内容，才会发出信号。

• combineLatest

//创建三个信号
RACSubject *s1 = [RACSubject subject];
RACSubject *s2 = [RACSubject subject];
RACSubject *s3 = [RACSubject subject];
//合并三个信号
RACSignal *combineSg = [RACSignal combineLatest:@[s1,s2,s3]];
//订阅合并信号
[combineSg subscribeNext:^(id  _Nullable x) {
    //当三个信号都有一次发送的时候才能收到聚合信号
    //这里收到是一个元组类型，三个元素分别为三个信号的最新值
    NSLog(@"%@",x);
}];

//发送信号
[s1 sendNext:@"a"];
[s2 sendNext:@"1"];
[s3 sendNext:@"!"];

[s1 sendNext:@"b"];
[s2 sendNext:@"2"];
[s3 sendNext:@"@"];

[s1 sendNext:@"c"];
[s2 sendNext:@"3"];
[s3 sendNext:@"#"];

• reduce

RACSubject *s1 = [RACSubject subject];
RACSubject *s2 = [RACSubject subject];
RACSubject *s3 = [RACSubject subject];

RACSignal *reduceSg = [RACSignal combineLatest:@[s1,s2,s3] reduce:^(id value1,id value2,id value3){
    //value1 value2 value3为三个信号的最新值
    return [NSString stringWithFormat:@"%@,%@,%@",value1,value2,value3];
}];
//订阅聚合信号
[reduceSg subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@",x);
}];
//发送信号
[s1 sendNext:@"a"];
[s2 sendNext:@"1"];
[s3 sendNext:@"!"];

[s1 sendNext:@"b"];
[s2 sendNext:@"2"];
[s3 sendNext:@"@"];

[s1 sendNext:@"c"];
[s2 sendNext:@"3"];
[s3 sendNext:@"#"];
/*打印输出结果,三个信号都发送一次sendNext之后才会收到第一次聚合信号
a,1,!
b,1,!
b,2,!
b,2,@
c,2,@
c,3,@
c,3,#
*/

• merge

RACSubject *s1 = [RACSubject subject];
RACSubject *s2 = [RACSubject subject];
RACSubject *s3 = [RACSubject subject];
//合并三个信号
RACSignal *mergeSg = [RACSignal merge:@[s1,s2,s3]];

[mergeSg subscribeNext:^(id  _Nullable x) {
    //收到九次信号，每次打印当前信号最新值
    NSLog(@"%@",x);
}];

[s1 sendNext:@"a"];
[s2 sendNext:@"1"];
[s3 sendNext:@"!"];

[s1 sendNext:@"b"];
[s2 sendNext:@"2"];
[s3 sendNext:@"@"];

[s1 sendNext:@"c"];
[s2 sendNext:@"3"];
[s3 sendNext:@"#"];

• zip

RACSubject *s1 = [RACSubject subject];
RACSubject *s2 = [RACSubject subject];
RACSubject *s3 = [RACSubject subject];

RACSignal *zipSg = [RACSignal zip:@[s1,s2,s3]];

[zipSg subscribeNext:^(id  _Nullable x) {
    /*收到两次信号
        (  a,  1,  !,  ) (b, 3, @, )
      */
        NSLog(@"%@",x);
}];

[s1 sendNext:@"a"];
[s2 sendNext:@"1"];
[s3 sendNext:@"!"];

[s1 sendNext:@"b"];
//  [s2 sendNext:@"2"];
[s3 sendNext:@"@"];

[s1 sendNext:@"c"];
[s2 sendNext:@"3"];
[s3 sendNext:@"#"];

信号连接：concat,then

• concat:信号连接起来，按顺序响应信号。

• then:只收到then返回的信号，之前的信号会被忽略

• concat

RACSignal *s1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    
    [subscriber sendNext:@"信号1"];
    [subscriber sendCompleted];
    return nil;
}];

RACSignal *s2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    
    [subscriber sendNext:@"信号2"];
    [subscriber sendCompleted];
    return nil;
}];

RACSignal *contactSg = [s1 concat:s2];

[contactSg subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@", x);//依次打印 信号1 信号2
}];

• then

RACSignal *s1 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {
    
    [subscriber sendNext:@"信号1"];
    [subscriber sendCompleted];
    return nil;
}];

RACSignal *s2 = [RACSignal createSignal:^RACDisposable * _Nullable(id<RACSubscriber>  _Nonnull subscriber) {

    [subscriber sendNext:@"信号2"];
    [subscriber sendCompleted];
    return nil;
}];

[[s2 then:^RACSignal * _Nonnull{
    return s1;
}] subscribeNext:^(id  _Nullable x) {
    NSLog(@"%@", x);//只收到信号1，第一个信号会被忽略
}];

信号操作时间：timeout,interval,dely

• timeout:超时信号，超过设定时间后会收到错误信号

• dely:延时发送信号

  //设置signal的超时时间是2秒
  RACSignal *signal = [[RACSignal createSignal:^RACDisposable *(id<RACSubscriber> subscriber) {
  //延时三秒发送信号
   [[RACScheduler mainThreadScheduler] afterDelay:3 schedule:^{
         [subscriber sendNext:@"delay"];
         [subscriber sendCompleted];
   }];
      return nil;
  }] timeout:2 onScheduler:[RACScheduler mainThreadScheduler]];
  
  [signal subscribeNext:^(id x) {
      NSLog(@"%@", x);
  } error:^(NSError *error) {
      NSLog(@"%@", error);//2秒后打印信息，因为发送信号延时了3秒
  }];
  

参考链接：https://www.jianshu.com/p/58a1214fc6d8（文章介绍详细基本是完全Copy）

---

文章持续更新中、希望对各位有所帮助、有问题可留言 大家共同学习.