iOS -RAC使用

玉兰 • 2023-04-21 01:05 • 杂文

一、简介

ReactiveCocoa 可以说是结合了函数式编程和响应式编程的框架，也可称其为函数响应式编程（FRP）框架，强调一点，RAC 最大的优点是提供了一个单一的、统一的方法去处理异步的行为，包括 delegate 方法， blocks 回调，target-action 机制，notifications 和 KVO。

导入

在项目的 podfile 文件中添加

# RAC
  pod 'ReactiveObjC'

在使用时导入

#import

二、基本使用

1.button 添加点击事件

    [[button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
        //button点击
    }];

2.代替 KVO 监听

#import "ViewController.h"
#import 
@interface ViewController ()

@property(nonatomic,assign)NSInteger num;

@end

@implementation ViewController

- (void)viewDidLoad {
    [super viewDidLoad];
    self.view.backgroundColor = [UIColor whiteColor];
    UIButton *button = [[UIButton alloc]initWithFrame:CGRectMake(50, 100, 100, 100)];
    button.backgroundColor = [UIColor orangeColor];
    @weakify(self);
    //subscribeNext 收到信号
    [[button rac_signalForControlEvents:UIControlEventTouchUpInside] subscribeNext:^(__kindof UIControl * _Nullable x) {
        @strongify(self);
        //button点击
        self.num++;
    }];
    [self.view addSubview:button];

    //RACObserve(TARGET, KEYPATH):监听某个对象的某个属性，返回的是一个信号
    [RACObserve(self,num) subscribeNext:^(id  _Nullable x) {
        //
        NSLog(@"%@",x);
    }];

    //忽略值为 1 的情况，不执行回调
    [[RACObserve(self, num) ignore:@1]subscribeNext:^(id  _Nullable x) {
        NSLog(@"忽略%@",x);
    }];
 
}
@end

3.监听输入变化

    self.textField = [[UITextField alloc]initWithFrame:CGRectMake(100, 100, 100, 100)];
    [self.view addSubview:self.textField];
    [[self.textField rac_textSignal] subscribeNext:^(NSString * _Nullable x) {
        NSLog(@"%@",x);
    }];

4.通知回调

    //RAC监听回调
    [[[NSNotificationCenter defaultCenter] rac_addObserverForName:@"DJTESTNOTI" object:nil] subscribeNext:^(NSNotification * _Nullable x) {
            NSLog(@"x===%@",x);
    }];
    
    //发送通知
    [[NSNotificationCenter defaultCenter] postNotificationName:@"DJTESTNOTI" object:@"444"];

5.手势回调

    UITapGestureRecognizer *tap = [[UITapGestureRecognizer alloc] init];
    [self.view addGestureRecognizer:tap];
    [[tap rac_gestureSignal] subscribeNext:^(__kindof UIGestureRecognizer * _Nullable x) {
        NSLog(@"点击");
    }];

6.数组和字典遍历

    //数组遍历
    NSArray *array = @[@"111",@"222",@"333",@"444"];
    [array.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"数组%@",x);
    }];
    //字典遍历
    NSDictionary *dict = @{@"111":@"-111",@"222":@"-222",@"333":@"-333",@"444":@"-444"};
    [dict.rac_sequence.signal subscribeNext:^(id  _Nullable x) {
        NSLog(@"字典%@",x);
    }];

二、宏

1. `RAC`

RAC(TARGET, [KEYPATH, [NIL_VALUE]])用于给某个对象的某个属性绑定

 // 给某个对象的某个属性绑定一个信号，只要产生信号，就会把信号的内容给对象的属性进行赋值
 // 给label的text属性绑定一个输入值的信号
 RAC(self.titleLabel,text) = RACObserve(self, inputContentText);

2.`RACObserve`

RACObserve(TARGET, KEYPATH)监听某个对象的某个属性，返回的是一个信号

3.`RACTuplePack`和`RACTupleUnpack`

RACTuplePack把数据包装成 RACTuple（元组类），被包装的数据必须是 object 类数据

   // RACTuplePack:把一些数据包装成元组类，可用于信号间的数据传输
   // 注意：被包装的数据必须是 object类数据
   RACTuple *tuple = RACTuplePack(@"数据1",@1,@[@"1",@"2",@"3",@"4"]);

RACTupleUnpack把 RACTuple（元组类）解包成对应的数据，解包参数的顺序及数据类型要和包装数据时的顺序及类型保持一致

  // 参数：需要解析数据生成出来对应的变量名
  // 注意：解包参数的顺序及数据类型要和包装数据时的顺序及类型保持一致
  RACTupleUnpack(NSString  *str,NSNumber  *num, NSArray *arr) = tuple;

三、信号组合

1. `concat`

concat按一定顺序拼接信号，当多个信号发出的时候，有顺序的接收信号，依赖关系把一组信号串联起来，前面一个信号 complete，后面一个信号才开始发挥作用。

    //比如A请求依赖B请求，只有B请求完成之后才能执行A请求或操作
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"signalA"];
        return nil;
    }];
    
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"signalB"];
        //因为A依赖B，所以只需要在B里面声明发送完成
        [subscriber sendCompleted];
        return nil;
    }];
    
    //注意点：如果一个操作后面还被其他操作依赖，比如signalB，需要在其内部发送完数据后声明发送完成，[subscriber sendCompleted];
    RACSignal *contatSignal = [signalB concat:signalA];
    
    [contatSignal subscribeNext:^(id x) {
        NSLog(@"（concat）结果：%@",x);
        //输出结果
        
    }];

2.`then`

then用于连接两个信号，当第一个信号完成，才会连接 then 返回的信号。

    //A请求依赖B请求，只有B请求完成之后才能执行A的请求或操作,需要注意：这个方法最后只能拿到A的值，如果B不需要传值，只需要先进行某些操作的时候可以用then
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"signalA"];
        return nil;
    }];
    
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"signalB"];
        [subscriber sendCompleted];
        return nil;
    }];
    
    RACSignal *thenSignal = [signalB then:^RACSignal *{
        return signalA;
    }];
    
    [thenSignal subscribeNext:^(id x) {
        NSLog(@"（then）结果：%@",x);
        //输出结果

    }];

then 与 concat 区别：then 监听不到第一个信号的值，共同点都是必须第一个信号完成，第二个信号才会激活

3. `merge`

merge 把多个信号合并为一个信号，任何一个信号有新值的时候就会调用。

    RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
            [subscriber sendNext:@"signalA"];
            return nil;
        }];
        
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"signalB"];
        [subscriber sendCompleted];
        return nil;
    }];
    
    RACSignal *mergeSignal = [signalA merge:signalB];
    
    [mergeSignal subscribeNext:^(id x) {
        NSLog(@"（merge）结果：%@",x);
    }];

4. `zipWith`

zipWith 把两个信号压缩成一个信号，只有当两个信号同时发出信号内容时，并且把两个信号的内容合并成一个元组，才会触发压缩流的 next 事件。

    //信号压缩，这个方法其实和rac_liftSelector本质时一样的，把多个信号压缩成一个信号，只有被压缩的信号全部发出消息时才能调用
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"signalA"];
        return nil;
    }];
    
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"signalB"];
        return nil;
    }];
    
    //zipSignal是有顺序的
    RACSignal *zipSignal = [signalB zipWith:signalA];
    
    [zipSignal subscribeNext:^(id x) {
        //x是接受到的所有数据包装成的元组
        NSLog(@"（zipWith）结果：%@",x);
        //输出结果
        /*--TIME：14:53:55.966000+0800
        （zipWith）结果： (
            signalB,
            signalA
        )*/
    }];

5. `reduce`

reduce信号聚合，参数需要自己添加

    //多用于登录逻辑
    RACSignal *signalA = [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"signalA"];
        return nil;
    }];
    RACSignal *signalB = [RACSignal createSignal:^RACDisposable *(id subscriber) {
        [subscriber sendNext:@"signalB"];
        return nil;
    }];
    
    // 聚合
    // reduce：信号聚合，参数需要自己添加
    // 常见的用法，（先组合再聚合）。combineLatest:(id)signals reduce:(id (^)())reduceBlock
    // reduce中的block简介:
    // reduceblcok中的参数，有多少信号组合，reduceblcok就有多少参数，每个参数就是之前信号发出的内容
    // reduceblcok的返回值：聚合信号之后的内容。
    RACSignal *combineSignal = [RACSignal combineLatest:@[signalA, signalB] reduce:^id(NSString *signalA, NSString *signalB){
        NSLog(@"%@----%@", signalA, signalB);
        //block:只要任意一个信号发出内容,就会调用
        //block参数个数:由信号决定
        //block参数类型:block的参数就是信号发出值
        //把两个信号中的值聚合成哪个值
        return @(signalA.length && signalB.length);
    }];
    
    [combineSignal subscribeNext:^(id x) {
        NSLog(@"（combineLatest）结果：%@",x);
        //输出结果
        //--TIME：14:53:55.966000+0800 （combineLatest）结果：1
    }];
    
    [[signalA combineLatestWith:signalB] subscribeNext:^(id  _Nullable x) {
            //x是接收两个信号合并后的数据包装成的元组（RACTuple）
        NSLog(@"（combineLatestWith）结果：%@",x);
        //输出结果
       /*--TIME：14:53:55.966000+0800
        （combineLatestWith）结果： (
            signalA,
            signalB
        )
        */
    }];

6.其他

combineLatest将多个信号合并起来，并且拿到各个信号的最新的值,必须每个合并的 signal 至少都有过一次 sendNext，才会触发合并的信号。
combineLatestWith 合并两个信号，当两个信号都有 sendNext 才会触发合并的信号。

四、MVVM+RAC

示例如下：

DJViewController


#import 

@interface DJViewController : UIViewController

@end

#import "DJViewController.h"
#import "DJViewModel.h"
#import "DJTableViewCell.h"

@interface DJViewController ()
@property (strong, nonatomic)  UITableView *tableView;
@property (strong, nonatomic) DJViewModel *reqVM;
@end

@implementation DJViewController

- (void)viewDidLoad {
   [super viewDidLoad];
    self.view.backgroundColor = [UIColor whiteColor];
   [self setUI];
   [self ViewModelEvent];
}
#pragma mark - 界面设置
- (void)setUI {
    self.tableView = [[UITableView alloc]initWithFrame:CGRectMake(0, 100, [UIScreen mainScreen].bounds.size.width, [UIScreen mainScreen].bounds.size.height - 100)];
   self.tableView.dataSource = self;
   self.tableView.delegate = self;
    [self.view addSubview:self.tableView];
}
#pragma mark - ViewModel事件
- (void)ViewModelEvent {
   [self.reqVM.reqCommand execute:nil];
   @weakify(self);
   [self.reqVM.refreshUISubject subscribeNext:^(id x) {
      @strongify(self);
      [self.tableView reloadData];
   }];
}
#pragma mark - UITableView配置
- (NSInteger)tableView:(UITableView *)tableView numberOfRowsInSection:(NSInteger)section
{
   return self.reqVM.dataArray.count;
}
- (UITableViewCell *)tableView:(UITableView *)tableView cellForRowAtIndexPath:(NSIndexPath *)indexPath
{
   DJTableViewCell *cell = [tableView dequeueReusableCellWithIdentifier:@"OrderCell"];
    if (!cell) {
        cell = [[DJTableViewCell alloc]initWithStyle:UITableViewCellStyleDefault reuseIdentifier:@"OrderCell"];
    }
   cell.model = self.reqVM.dataArray[indexPath.row];
   return cell;
}
-(CGFloat)tableView:(UITableView *)tableView heightForRowAtIndexPath:(NSIndexPath *)indexPath{
    return 80;
}
#pragma mark - 懒加载
- (DJViewModel *)reqVM {
   if (!_reqVM) {
      _reqVM = [[DJViewModel alloc] init];
   }
   return _reqVM;
}

@end

[self.reqVM.reqCommand execute:nil]; 方法为执行 reqCommand 事件命令，reqCommand 是 DJViewModel 中网络请求事件。
[self.reqVM.refreshUISubject subscribeNext:^(id x) { @strongify(self); [self.tableView reloadData]; }];
此方法为订阅 DJViewModel 中网络请求完成时发送的信号（refreshUISubject），也就是说当网络请求完成之后会执行 block 中的刷新 tableView 方法。

DJViewModel


#import 

#import 

@interface DJViewModel : NSObject

@property (nonatomic, strong) RACSubject *refreshUISubject;
@property (strong, nonatomic) RACCommand *reqCommand;
@property (nonatomic, strong) NSArray *dataArray;

@end

#import "DJViewModel.h"
#import "DJModel.h"

@interface DJViewModel ()

@end

@implementation DJViewModel

- (instancetype)init {
    if (self = [super init]) {
        [self or_initialize];
    }
    return self;
}
- (void)or_initialize {
    //网络请求信号
    [self.reqCommand.executionSignals.switchToLatest subscribeNext:^(NSDictionary *dic) {
        NSArray *items = dic[@"items"];
        NSMutableArray *arr = [NSMutableArray array];
        for (NSDictionary * dict in items) {
            DJModel *model = [[DJModel alloc]init];
            model.name = dict[@"name"];
            [arr addObject:model];
        }
        self.dataArray = [arr copy];
        [self.refreshUISubject sendNext:nil];
    }];
    [[self.reqCommand.executing skip:1] subscribeNext:^(id x) {
        if ([x isEqualToNumber:@(YES)]) {
//            [MBProgressHUD showCircleHud:nil];
        }else {
//            [MBProgressHUD closeHud:nil];
        }
    }];
}
#pragma mark - 懒加载
- (RACCommand *)reqCommand {
    if (!_reqCommand) {
        _reqCommand = [[RACCommand alloc] initWithSignalBlock:^RACSignal * _Nonnull(id  _Nullable input) {
            //因为要把请求的数据传出去，所以要把网络请求包装在信号里
            RACSignal *signal = [RACSignal createSignal:^RACDisposable * _Nullable(id  _Nonnull subscriber) {
                //网络请求
                NSDictionary *dic = @{@"items":@[@{@"name":@"hhhh"}]};
                [subscriber sendNext:dic];
                [subscriber sendCompleted];
                return nil;
            }];
            //返回网络请求信号
            return signal;
        }];
    }
    return _reqCommand;
}
- (RACSubject *)refreshUISubject {
    if (!_refreshUISubject) {
        _refreshUISubject = [RACSubject subject];
    }
    return _refreshUISubject;
}
- (NSArray *)dataArray {
    if (!_dataArray) {
        _dataArray = [[NSArray alloc] init];
    }
    return _dataArray;
}

@end

refreshUISubject 属性是通知控制器刷新 UI 的信号,其功能类似于代理。reqCommand 属性是网络请求事件，暴露在 .h 文件的原因是让控制器来决定什么时候发起事件，也就是说什么时候发起网络请求。
or_initialize 中第一个方法是订阅 reqCommand（网络请求）事件中的信号发出的值，也就是网络请求成功后发送的数据。第二个方法的功能是监听 reqCommand 事件过程，其 block 中的值返回 YES 是，代表事件正在执行，所以在这里面可以加一个正在加载的菊花，当返回值为 NO 时，代表事件执行完成，把正在加载菊花去掉。
懒加载 - (RACCommand *)reqCommand 方法中就是网络请求事件，block 里面的 signal 信号作用是把网络请求的数据发送给 or_initialize 中第一个方法的订阅者。订阅者拿到数据后执行字典转模型操作，然后发送暴露在 .h 文件中的 refreshUISubject 信号给订阅此信号的控制器，通知他刷新 tableView。

DJViewModel、DJTableViewCell

#import 
@interface DJModel : NSObject
@property(nonatomic,assign)NSInteger num;
@end

#import "DJModel.h"
@implementation DJModel
@end

#import 
#import "DJModel.h"

@interface DJTableViewCell : UITableViewCell

@property (nonatomic, strong) DJModel *model;

@end

#import "DJTableViewCell.h"

@interface DJTableViewCell ()

@end

@implementation DJTableViewCell

- (void)setModel:(DJModel *)model {
    self.textLabel.text = model.name;
}

@end

版权声明：
作者：玉兰
链接：https://www.techfm.club/p/41916.html
来源：TechFM
文章版权归作者所有，未经允许请勿转载。

THE END

二维码

关于咖啡（12）咖啡机趋势

< <上一篇

《道德经》

下一篇>>

搜索内容

iOS -RAC使用

一、简介

导入

二、基本使用

1.button 添加点击事件

2.代替 KVO 监听

3.监听输入变化

4.通知回调

5.手势回调

6.数组和字典遍历

二、宏

1. `RAC`

2.`RACObserve`

3.`RACTuplePack`和`RACTupleUnpack`

三、信号组合

1. `concat`

2.`then`

3. `merge`

4. `zipWith`

5. `reduce`

6.其他

四、MVVM+RAC

DJViewController

DJViewModel

DJViewModel、DJTableViewCell

取消回复

共有 0 条评论

Ads

iOS -RAC使用

一、简介

导入

二、基本使用

1.button 添加点击事件

2.代替 KVO 监听

3.监听输入变化

4.通知回调

5.手势回调

6.数组和字典遍历

二、宏

1. RAC

2.RACObserve

3.RACTuplePack和RACTupleUnpack

三、信号组合

1. concat

2.then

3. merge

4. zipWith

5. reduce

6.其他

四、MVVM+RAC

DJViewController

DJViewModel

DJViewModel、DJTableViewCell

取消回复

共有 0 条评论

Ads

1. `RAC`

2.`RACObserve`

3.`RACTuplePack`和`RACTupleUnpack`

1. `concat`

2.`then`

3. `merge`

4. `zipWith`

5. `reduce`